C#编写SqlHelper类
无聊的周末,学习、编码无力。想找点事干但又不知道干点什么,猛然发现自己学过的sqlhelper快忘记了。于是乎虎躯一震心想怎能如此堕落下去,立马打开电脑,双手摸上键盘。写下此文作为学习过程中的复习,并分享出知识(顺便打发时间-^.^-)。
下面开始正文
这里以控制台程序为案例。首先我们需要先配置一下连接字符串,我们需要在app.config文件中增加如下节点:
<connectionstrings> <add name="sql" connectionstring="server=数据库地址;uid=用户名;pwd=密码;database=数据库名"/> </connectionstrings>
1.接着需要创建一个名为sqlhepler类,然后创建一个方法来获取app.config文件中配置的连接字符串。
public static string getsqlconnectionstring() { return configurationmanager. connectionstrings["sql"].connectionstring; }
2.下面来封装第一个sqlhepler方法,封装一个执行的sql 返回受影响的行数。
public static int executenonquery(string sqltext,params sqlparameter[] parameters) { using (sqlconnection conn = new sqlconnection(getsqlconnectionstring())) { using (sqlcommand cmd=conn.createcommand()) { conn.open(); //打开数据库 cmd.commandtext = sqltext; //对commandtext进行赋值 cmd.parameters.addrange(parameters); //对数据库使用参数进行赋值 return cmd.executenonquery(); } } }
参数说明:sqltext:需要执行的sql脚本,parameters:需要的参数集合
该方法主要是用于执行,删除、更新和插入操作,返回受影响的行数。
3.继续封装一个查询操作,返回查询结果中的第一行第一列的值
public static object executescalar(string sqltext, params sqlparameter[] parameters) { using (sqlconnection conn=new sqlconnection(getsqlconnectionstring())) { using (sqlcommand cmd=conn.createcommand()) { conn.open(); cmd.commandtext = sqltext; cmd.parameters.addrange(parameters); return cmd.executescalar(); } } }
参数说明:如上。
该方法的返回值第object,所以当我们查询的数据不知道是什么类型的时候可以使用该类。
4.在封装个常用的查询方法,返回一个datatable
public static datatable executedatatable(string sqltext, params sqlparameter[] parameters) { using (sqldataadapter adapter =new sqldataadapter(sqltext,getsqlconnectionstring())) { datatable dt = new datatable(); adapter.selectcommand.parameters.addrange(parameters); adapter.fill(dt); return dt; } }
参数说明:如上。
该方法主要用于一些查询数据,dt将被填充查询出来的数据,然后返回数据。
5.最后在写封装一个查询方法,该方法返回的是一个sqldatareader类型
public static sqldatareader executereader(string sqltext, params sqlparameter[] parameters) { //sqldatareader要求,它读取数据的时候有,它独占它的sqlconnection对象,而且sqlconnection必须是open状态 sqlconnection conn = new sqlconnection(getsqlconnectionstring());//不要释放连接,因为后面还需要连接打开状态 sqlcommand cmd = conn.createcommand(); conn.open(); cmd.commandtext = sqltext; cmd.parameters.addrange(parameters); //commandbehavior.closeconnection当sqldatareader释放的时候,顺便把sqlconnection对象也释放掉 return cmd.executereader(commandbehavior.closeconnection); }
参数说明:依旧如上。
该方法返回的sqldatareader 类型对象需要一直使用sqlconnection对象,所以不能释放。该类型读取数据是一行一行的读取。读取使用的是该类的read()方法,返回值为bool判断数据是否为空(也就是是否读取到最后一行),该方法将自动读取下到下一条记录。
作为一个初学者,本次只是简单的介绍,并复习了一下sqlhepler类。
附上全部代码:
using system.configuration; using system.data; using system.data.sqlclient; namespace userinfomgr { class sqlhelper { /// <summary> /// 获取连接字符串 /// </summary> /// <returns>连接字符串</returns> public static string getsqlconnectionstring() { return configurationmanager.connectionstrings["sql"].connectionstring; } /// <summary> /// 封装一个执行的sql 返回受影响的行数 /// </summary> /// <param name="sqltext">执行的sql脚本</param> /// <param name="parameters">参数集合</param> /// <returns>受影响的行数</returns> public static int executenonquery(string sqltext,params sqlparameter[] parameters) { using (sqlconnection conn = new sqlconnection(getsqlconnectionstring())) { using (sqlcommand cmd=conn.createcommand()) { conn.open(); cmd.commandtext = sqltext; cmd.parameters.addrange(parameters); return cmd.executenonquery(); } } } /// <summary> /// 执行sql,返回查询结果中的第一行第一列的值 /// </summary> /// <param name="sqltext">执行的sql脚本</param> /// <param name="parameters">参数集合</param> /// <returns>查询结果中的第一行第一列的值</returns> public static object executescalar(string sqltext, params sqlparameter[] parameters) { using (sqlconnection conn=new sqlconnection(getsqlconnectionstring())) { using (sqlcommand cmd=conn.createcommand()) { conn.open(); cmd.commandtext = sqltext; cmd.parameters.addrange(parameters); return cmd.executescalar(); } } } /// <summary> /// 执行sql 返回一个datatable /// </summary> /// <param name="sqltext">执行的sql脚本</param> /// <param name="parameters">参数集合</param> /// <returns>返回一个datatable</returns> public static datatable executedatatable(string sqltext, params sqlparameter[] parameters) { using (sqldataadapter adapter =new sqldataadapter(sqltext,getsqlconnectionstring())) { datatable dt = new datatable(); adapter.selectcommand.parameters.addrange(parameters); adapter.fill(dt); return dt; } } /// <summary> /// 执行sql脚本 /// </summary> /// <param name="sqltext">执行的sql脚本</param> /// <param name="parameters">参数集合</param> /// <returns>返回一个sqldatareader</returns> public static sqldatareader executereader(string sqltext, params sqlparameter[] parameters) { //sqldatareader要求,它读取数据的时候有,它独占它的sqlconnection对象,而且sqlconnection必须是open状态 sqlconnection conn = new sqlconnection(getsqlconnectionstring());//不要释放连接,因为后面还需要连接打开状态 sqlcommand cmd = conn.createcommand(); conn.open(); cmd.commandtext = sqltext; cmd.parameters.addrange(parameters); //commandbehavior.closeconnection当sqldatareader释放的时候,顺便把sqlconnection对象也释放掉 return cmd.executereader(commandbehavior.closeconnection); } } }
再给大家分享一个sqlhelper类
using system; using system.collections.generic; using system.configuration; using system.linq; using system.text; using system.threading.tasks; using system.data.sqlclient; using system.data; namespace adonet2 { class sqlhelper { //封装方法的原则,把不变的放在方法中,把变化的放在参数中传进来 private static string connstr = configurationmanager.connectionstrings["dbconn"].connectionstring; //public static int executenonquery(string sql) //{ // using (sqlconnection conn = new sqlconnection(connstr)) // { // conn.open(); // using (sqlcommand cmd = conn.createcommand()) // { // cmd.commandtext = sql; // return cmd.executenonquery(); // } // } //} //public static object executescalar(string sql) //{ // using (sqlconnection conn = new sqlconnection(connstr)) // { // conn.open(); // using (sqlcommand cmd = conn.createcommand()) // { // cmd.commandtext = sql; // return cmd.executescalar(); // } // } //} //public static datatable executedatatable(string sql) //{ // using (sqlconnection conn = new sqlconnection(connstr)) // { // conn.open(); // using (sqlcommand cmd = conn.createcommand()) // { // cmd.commandtext = sql; // sqldataadapter adapter = new sqldataadapter(cmd); // dataset dataset = new dataset(); // adapter.fill(dataset); // return dataset.tables[0]; // } // } //} public static int executenonquery(string sql,params sqlparameter[] parameters) { using (sqlconnection conn = new sqlconnection(connstr)) { conn.open(); using (sqlcommand cmd = conn.createcommand()) { cmd.commandtext = sql; //foreach (sqlparameter param in parameters) //{ // cmd.parameters.add(param); //} cmd.parameters.addrange(parameters); return cmd.executenonquery(); } } } public static object executescalar(string sql,sqlparameter[] parameters) { using (sqlconnection conn = new sqlconnection(connstr)) { conn.open(); using (sqlcommand cmd = conn.createcommand()) { cmd.commandtext = sql; cmd.parameters.addrange(parameters); return cmd.executescalar(); } } } //public static datatable executedatatable(string sql,sqlparameter[] parameters) //{ // using (sqlconnection conn = new sqlconnection(connstr)) // { // conn.open(); // using (sqlcommand cmd = conn.createcommand()) // { // cmd.commandtext = sql; // cmd.parameters.addrange(parameters); // sqldataadapter adapter = new sqldataadapter(cmd); // dataset dataset = new dataset(); // adapter.fill(dataset); // return dataset.tables[0]; // } // } //} //使用可变参数 public static datatable executedatatable(string sql, params sqlparameter[] parameters) { using (sqlconnection conn = new sqlconnection(connstr)) { conn.open(); using (sqlcommand cmd = conn.createcommand()) { cmd.commandtext = sql; cmd.parameters.addrange(parameters); sqldataadapter adapter = new sqldataadapter(cmd); dataset dataset = new dataset(); adapter.fill(dataset); return dataset.tables[0]; } } } } }