DataReader
DataReader对象提供了用顺序的,只读的方式读取Command对象获得的数据结果集,正是因为DataReader是以顺序的方式连续的读取数据,所有DataReader会以独占的方式打开数据库的连接
由于DataReader只执行读的操作(只读),并且每次只在内存缓冲区里存储结果集中的一条数据,所有使用DataReader的对象的效率比较高,如果要查询大量数据,同时不需要随机访问和修改数据,DataReader是优先的选择
DataReader 对象的常用属性
FieldCount 属性 表示记录中有多少字段
HasRows 属性 用来表示DataReader是否包含数据
IsClosed 属性 表示DataReader是否关闭
DataReader对象常用方法
Close 方法 将DataReader对象关闭
GetDataTypName 方法 取得指定的字段数据形态(类型)
GetName 方法 取得指定的字段数据名称
GetOrdinal 方法 取得指定字段名称在记录中的顺序
GetValue 方法 取得指定字段的数据
GetValues 方法 取得全部字段的数据
Read 方法 读取下一条记录
实例 :
mytable01表中有Id,姓名(name),年龄(age),性别(gender),部门(department),几个字段,并且有几条语句
using System; using System.Data.SqlClient; namespace DataReaderDemo { class Program { static void Main(string[] args) { string constr = "Server = .; user=name;pwd=mima;database=mysql"; SqlConnection myCon = new SqlConnection(constr); try { myCon.Open(); string sql = "select * from mytable01 "; SqlCommand mycom = new SqlCommand(sql, myCon); //声明DataReader SqlDataReader mydr; mydr = mycom.ExecuteReader(); if (mydr.HasRows) { Console.WriteLine("mytable01中存在数据"); } else { Console.WriteLine("mytable01中不存在任何数据"); } //----------------方法---------------------- Console.WriteLine("第一列的数据类型"+mydr.GetDataTypeName(0)); Console.WriteLine("获取对应列的名称:(第一列)"+mydr.GetName(0)); string mystr = "age"; //直接写会报异常,需要有个转换的过程 Console.WriteLine(mydr.GetOrdinal(mystr)); /* 此时将上面的15行的str,换为 * string sql = "select * from mytable01 where id=1"; if (mydr.Read()) { Console.WriteLine("取得指定字段的数据:" + mydr.GetValue(0)); } */ /*将15行的 str更改为: * string sql = "select * from mytable01 where gender='男'"; object[] myobj = new object[mydr.FieldCount]; while(myde.Read()){ mydr.GetValues(myobj); foreach (object item in myobj) { Console.Write(item + "\t"); Console.WriteLine(); } } */ //访问DataReader 对象时使用索引要比字段名称快很多 while (mydr.Read()) { Console.WriteLine(mydr[0].ToString()+","); Console.WriteLine(mydr[1].ToString() + ","); Console.WriteLine(mydr["gender"].ToString()); } //----------------属性---------------------- Console.WriteLine("表中有几个字段:"+mydr.FieldCount); Console.WriteLine("是否关闭:"+mydr.IsClosed); mydr.Close(); Console.WriteLine("是否关闭:" + mydr.IsClosed); } catch(Exception ex) { Console.WriteLine(ex.Message.ToString()); } finally { myCon.Close(); } Console.Read(); } } }
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对的支持。如果你想了解更多相关内容请查看下面相关链接
声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。
评论(0)