在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
本文介绍了DataReader不能使用using的详细示例,分享给大家,具有如下: public static MySqlDataReader ExecuteMySqlReader(string sqlStr) { MySqlConnection conn = new MySqlConnection(MyConString); MySqlCommand cmd = new MySqlCommand(sqlStr, conn); try { conn.Open(); //执行CloseConnection命令时,如果关闭关联的DataReader对象,则关联的Connection对象也将关闭 //用using(conn)会报错,因为执行完命令就会关闭连接,其它代码调用DataReader对象时,连接已经关闭。 MySqlDataReader dr = cmd.ExecuteReader(CommandBehavior.CloseConnection); return dr; } catch (Exception exp) { throw new Exception(exp.Message); } } PS:MySqlDataReader在Using中使用 结论:当DataReader放在Using方法中时,会自动释放资源,如果中途出现了异常处理,也同样会释放掉占用的资源。 首先正常的处理流程: MySqlDataReader dr = MySqlHelper.ExecuteReader(MySqlHelper.Conn, CommandType.Text, sqlStr, parameters) while (dr.Read()) { keyWords.Add(dr["KeyWord"].ToString()); } dr.Close() 这样处理貌似是没问题,不过在测试中,如果“keyWords.Add(dr["KeyWord"].ToString());”出现了异常,此时,程序会调到异常处理的模块,这样,就造成了下边的close方法不会被执行到,从而造成了数据库连接数的不断累加,当达到最大值时,问题就显露出来了。 下边第一种处理方式采用异常处理: MySqlDataReader dr = MySqlHelper.ExecuteReader(MySqlHelper.Conn, CommandType.Text, sqlStr, parameters); try{ while (dr.Read()) { keyWords.Add(dr["KeyWord"].ToString()); } } catch(){ } finnally{ dr.Close(); } 毫无疑问,这个方法很容易想到。 第二种处理方式,这里打算使用using方法进行处理。但是根据理论知识,认为这个是可以的。但是真实的程序运行环境,确实有时不能以理论知识来指导。现在程序在这,有一个很合适的测试环境,为什么不自己测试下呢?于是就出现了一下的过程: 首先补充一些基础知识: 1、Using定义范围:即时释放资源,在范围结束时释放资源。当在某个代码段中使用了类得实例,而希望无论什么原因,只要离开了这个代码段就自动调用这个类实例的Dispose方法释放资源。 到达using语句末尾或者中途引发了异常并且控制离开了语句块,即触发实例的Dispose方法释放资源。 然后查看MySqlDataReader的实现: public sealed class MySqlDataReader : DbDataReader, IDataReader, IDisposable, IDataRecord{...} 确实继承了IDisposable方法,理论上应该是正确的。 2、MySql查看连接数: 命令: show processlist; 如果是root帐号,你能看到所有用户的当前连接。如果是其它普通帐号,只能看到自己占用的连接。 有了这两点理论知识,下边的测试就容易多了: 1、不使用using也不关闭连接: MySqlDataReader dr = MySqlHelper.ExecuteReader(MySqlHelper.Conn, CommandType.Text, sqlStr, parameters); while (dr.Read()) { keyWords.Add(dr["KeyWord"].ToString()); } 测试,连接数不断增多。 2、不使用,采用关闭操作: MySqlDataReader dr = MySqlHelper.ExecuteReader(MySqlHelper.Conn, CommandType.Text, sqlStr, parameters); while (dr.Read()) { keyWords.Add(dr["KeyWord"].ToString()); } dr.Close() 测试,连接数不变化。 3、不使用Using,采用关闭操作,中间执行过程制作一个异常: MySqlDataReader dr = MySqlHelper.ExecuteReader(MySqlHelper.Conn, CommandType.Text, sqlStr, parameters); while (dr.Read()) { keyWords.Add(dr["Keyord"].ToString()); } dr.Close() 测试,连接数不断增多。 4、采用Using,无异常的情况: Using(MySqlDataReader dr = MySqlHelper.ExecuteReader(MySqlHelper.Conn, CommandType.Text, sqlStr, parameters)) { while (dr.Read()) { keyWords.Add(dr["KeyWord"].ToString()); } } 测试,连接数未增加。 5、采用Using中间制作一个异常: Using(MySqlDataReader dr = MySqlHelper.ExecuteReader(MySqlHelper.Conn, CommandType.Text, sqlStr, parameters)) { while (dr.Read()) { keyWords.Add(dr["Keyord"].ToString()); } } 测试,连接数未增加。 以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持极客世界。 |
请发表评论