using Sqystem.Data;using System.Data.SqlClient;using System.Configuration;//引用一个库Ststem.configuration//修改根目录的web.config文件configuration//最外层节点......connectionStringsadd n...
using Sqystem.Data;
using System.Data.SqlClient;
using System.Configuration;
//引用一个库Ststem.configuration
//修改根目录的web.config文件
<configuration>//最外层节点
......
<connectionStrings>
<add name="connString" connectionString = "Sqerver=.;DataBase=StudentManage;Uid=sa;Pwd=scale2018@">
</connectionStrings>
......
</configuration>
//数据库通用访问类
class SQLHelper
{
//数据库连接字符串
private static string connString = ConfigurationManager.ConnectionStrings["connString"].ToString();
//写入日志文件
public void WriteLog(string msg)
{
FileStream fs = FileStream("1.log",fileMode.Append);
StreamWriter sw = new StreamWriter(fs);
sw.writeLine(DateTime.Now.ToString()+" "+ msg);
sw.Close();
fs.Close();
}
//数据库更新
public static int Update(string sql)
{
SqlConnection conn = new SqlConnection(connString);
SqlConnection cmd = new SqlCommand(sql,conn);
try
{
conn.Open();
return cmd.ExecuteNoQuery();
}
catch(Exception ex)
{
WriteLog("执行更新时发生异常"+ex.Message);
throw ex;
}
finally
{
conn.Close();
}
}
public static object GetSingleResult(string sql)
{
Sqlconnection conn = new SqlConnection(connString);
SqlCommand cmd = new SqlCommand(sql,conn);
try
{
conn.Open();
return cmd.ExecuteScalar();
}
catch(Exception ex)
{
WriteLog("执行单一结果查询"+ex.message);
throw ex;
}
finally
{
conn.Close();
}
}
//返回结果集
public static SqlDataReader GetReader(string sql)
{
SqlConnection conn = new SqlConnection(connString);
SqlCommand cmd = new SqlCommand(sql,conn);
try
{
conn.Open();
retrun cmd.ExecuteReader(CommandBehavior.CloseConnection);//不能在此关闭连接
}
catch(Exception ex)
{
WriteLog("读取结果集发生异常"+ex.message);
throw ex;
}
}
//带参数的存储过程
public static int Update(string sqlOrProcedureName,SqlParameter[]param,bool isProcedure)
{
SqlConnection conn = new SqlConnection(connString);
SqlConnection cmd = new SqlCommand(sqlOrProcedureName,conn);
if(isProcedure)
{
cmd.CommandType = CommmandType.StoredProcedure;
}
try
{
conn.Open();
cmd.Parameters.AddRang(param);
return cmd.ExecuteNoQuery();
}
catch(Exception ex)
{
WriteLog("执行更新时发生异常"+ex.Message);
throw ex;
}
finally
{
conn.Close();
}
}
}
沃梦达教程
本文标题为:C#数据库操作
猜你喜欢
- C# 崩溃异常中研究页堆布局的详细过程 2023-07-04
- Centos7下Supervisor和Jexus两种方式部署.NETCore3.1项目 2023-09-26
- 使用C#编写自己的区块链挖矿算法 2023-01-27
- Unity Shader实现水波纹效果 2023-02-16
- .NET 平台负责人 Scott Hunter 专访:.NET Core 3 给 .NET Core 2023-09-27
- C#使用BinaryFormatter类、ISerializable接口、XmlSerializer类进行序列化和反序列化 2023-07-04
- C#实现钟表程序设计 2023-06-14
- 详细分析c# 客户端内存优化 2023-03-04
- 通过实例解析c# yield关键字使用方法 2023-03-10
- C#多线程异步执行和跨线程访问控件Helper 2023-06-04
