欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

C#使用SQL DataReader访问数据的优点和实例

程序员文章站 2023-12-05 21:35:04
datareader datareader对象提供了用顺序的,只读的方式读取command对象获得的数据结果集,正是因为datareader是以顺序的方式连续的读取数据,...

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();
    }
  }
}

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对的支持。如果你想了解更多相关内容请查看下面相关链接