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