您的位置:首页 > 编程学习 > ASP.NET

DataReader用法

更多 2014/11/30 来源:ASP.NET学习浏览量:6697
学习标签: DataReader
本文导读:DataReader对象只允许以只读、顺向的方式查看其中所存储的数据,提供一个非常有效率的数据查看模式,Datareader对象不能关使用new关键字创建。但可以使用ExecuteReader()方法创建。DataReader是一行一行的读取记录的。当记录中有数据时Read()返回TRUE,当到记录集底部时返回FALSE。

一、DataReader含义

DataReader相比于DataSet,DataReader是一个抽象类,所以不能用DataReader DR = new DataReader(),来构造函数创建对象,如果要创建一个DataReader对象,必须通过command对象的ExecuteReader方法。

DataReader对象访问数据的方式,只能顺序读取数据,而且不能写入数据(这点DataSet占据绝对的优势),所谓的顺序读取数据是将数据表中的行从头至尾一次读出。DataReader被创建时,纪录指针在表的最前端,可以使用Read方法每次从表中读取一条纪录。

DataSet存的是二维数组,而DataReader存的是一维数组。而且DataSet采用的是非连接的传输模式访问数据源,一旦用户所请求的数据读入DataSet,与数据库的连接就关闭,而DataReader则要时刻保持与数据库连接状态。

 

二、重要属性

FieldCount: 只读,表示纪录中有多少字段
HasMoreResults: 表示是否有多个结果,本属性和SQL Script 搭配使用。
HasMoreRows: 只读,表示是否还有资料未读取
IsClosed: 只读,表示DataReader 是否关闭
Item: 只读,本对象是集合对象,以键值(Key)或索引值(Index)的方式取得纪录中某个字段的数据
RowFetchCount: 用来设定一次取回多少笔记录,预设值为1 笔

 

三、常用方法

Close():关闭DataReader对象

GetValue(col):获取序号为col的列的值

GetValues(values)

获取所有字段的值,并将字段值存放到values数组中。

GetValues(values)方法原来我不会用,特别是对于这个values数组是哪里来的,以及如果自定义该定义为什么类型呢,后来百度就知道了,用这个方法之前,Object[] values = new Object[sqlrd.FieldCount];这个是定义values数组的方法前提。

Read()

读取下一条纪录,返回布尔型,返回true,则表示有下一条纪录。一般这个方法与while()循环一起用。是DataReader对象最重要的一个方法。

GetDataTypeName(col) :获取序号为col的列的来源数据类型名

GetFieldType(col) :获取序号为col的列的数据类型,一般显示会是System.**

GetName(col): 获取序号为col的列的字段名

GetOrdinal(name) :获取字段名为name的列的序号

 

三、DataReader实例

 

 
C# 代码   复制

        protected void Page_Load(object sender, EventArgs e)

        {

            string con = ConfigurationManager.ConnectionStrings["con"].ToString();

            SqlConnection sqlcon = new SqlConnection(con);

            string sql = "select * from Cloths";

            sqlcon.Open();

            SqlCommand sqlcom = new SqlCommand(sql, sqlcon);

            SqlDataReader sqlrd;

            sqlrd = sqlcom.ExecuteReader();

            Response.Write("获取DataReader对象包含的记录行数,注意这里DataReader的结构跟数据库的结构是不一样的,它把数据库的一行转换成了一列:" + sqlrd.FieldCount);

            Response.Write("<br>");

            Response.Write("获取序号为0的列的来源数据类型名:" + sqlrd.GetDataTypeName(0));

            Response.Write("<br>");

            Response.Write("获取序号为0的列的数据类型:" + sqlrd.GetFieldType(0));

            Response.Write("<br>");

            Response.Write("获取序列号为0的列的字段名:"+sqlrd.GetName(0));

            Response.Write("<br>");

            Response.Write("获取字段名为品牌的列的序号:"+sqlrd.GetOrdinal("品牌"));

            Response.Write("<br>");

            while (sqlrd.Read())

            {

                Response.Write("<br>");

                Response.Write(sqlrd["id"] + "," + sqlrd["品牌"] + "," + sqlrd["价格"] + "," + sqlrd["数量"]);

                Response.Write("<br>");

                Response.Write("<br>");

                Response.Write("下面的显示要注意,为什么序列号为0的是品牌而不是id,虽然GridViewCommon页面第一列是id,不过这里是要充分尊重数据库的结构,可以看出数据库中第一列是品牌!");

                Response.Write("<br>");

                Response.Write("这里通过GetString函数取出序号为0的列的数据,这里要根据数据的不同类型选用不同的Get函数,可能是GetChar(),GetInt32()等等:"+sqlrd.GetString(0));//这里可以看出GetValue函数可以不需要事先知道每一列的数据类型就可以取出数据,所以尽量用GetValue函数

                Response.Write("<br>");

                Response.Write("这里通过GetValue函数取出序号为0的列的数据,不需要管数据时什么类型,这里注意跟上面的比较:" + sqlrd.GetValue(0));

                Response.Write("<br>");

                Response.Write("<br>");

                Response.Write("这里是运用GetValue()的方法提取显示数据的:");

                for (int i = 0; i < sqlrd.FieldCount;i++ )//这里通过循环取出数据,其实就是循环使用GetValue()方法

                {

                    Response.Write(sqlrd.GetValue(i));//这个是一步一步取数据,用的是GetValue()方法,相比于GetValues,GetValues是一步到位,只要循环数组就好

                    Response.Write("<br>");

                }

                Response.Write("<br>");

                Response.Write("这里是运用GetVales()方法提取显示数据的:");

                Response.Write("<br>");

                Object[] values = new Object[sqlrd.FieldCount];//这一步是很重要的,你要先给定义一个数组

                sqlrd.GetValues(values);//注意这边是用的是GetValues(values)方法

                Response.Write(values[0]+","+values[1]+","+values[2]+","+values[3]+","+values[4]);

                Response.Write("<br>");

                for (int i = 0; i < sqlrd.FieldCount;i++ )//这里是循环的values数组,而不是GetValues(values)方法

                {

                    Response.Write("<br>");

                    Response.Write(values[i]);

                    Response.Write("<br>");

                }

 

            }

            sqlrd.Close();

            Response.Write("<br>");

            Response.Write(sqlrd.RecordsAffected);//获取执行SQL语句所更改,插入或删除的行数

            sqlcon.Close();

        }

 

实例2:

 
C# 代码   复制

using System;
using System.Data;
using System.Data.SqlClient;
using System.Data.OleDb; 

class SqlReader
{
 const string connStr = "data source=table;user id=sa;password=dddd;initial catalog=contract";
 SqlConnection conn; 


 public SqlReader()
 {
  conn = new SqlConnection(connStr);
 }
 
 //**************************************
 //*演示DataReader的两种取值方法
 //**************************************
 public void basicReader()
 {
  string sql="select * from friend";
  SqlCommand cmd; 
  cmd = conn.CreateCommand();
  cmd.CommandText = sql;
  conn.Open();
  SqlDataReader reader = cmd.ExecuteReader();
  while(reader.Read())
  {
   Console.WriteLine("No:{0}\\tName:{1}\\tPhoneNum:{2},\\tAddress:{3}",reader.GetInt32(0).ToString(),reader.GetString(1),reader[2].ToString(),reader["Faddress"].ToString());
  }
  showSplit();
  reader.Close();
  conn.Close();
 }
 
 //**************************************
 //*演示带参数查询的操作,使用SqlCilent
 //**************************************
 public void hasParamReader()
 {
  SqlCommand cmd; 
  cmd = conn.CreateCommand();
  string sql = "select Fname,Fphone,Faddress from friend where Fid > @Fid";
  cmd.CommandText = sql;
  SqlParameter param = new SqlParameter("@Fid",SqlDbType.Int,4);
  param.Value = 15;
  cmd.Parameters.Add(param);
  conn.Open();
  //当关闭reader的时候同时关闭数据库连接
  SqlDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
  while(reader.Read())
  {
   Console.WriteLine("Name:{0}\\tPhoneNum:{1}\\tAddress:{2}",reader.GetString(0),reader.GetString(1),reader.GetString(2));
  }
  showSplit();
  //无需关闭conn,系统会自动调用这个方法来关闭conn的。
  reader.Close(); 
 }
 
 //**************************************
 //*演示存储过程的输出参数
 //**************************************
 public void outParamShow()
 {
  SqlCommand cmd; 
  cmd = conn.CreateCommand();
  cmd.CommandText = "GetInfo";
  cmd.CommandType = CommandType.StoredProcedure;
  SqlParameter param = cmd.Parameters.Add("@Fid",16);
  param = cmd.Parameters.Add("@Fname",SqlDbType.VarChar,8);
  param.Direction = ParameterDirection.Output;
  param = cmd.Parameters.Add("@Fphone",SqlDbType.VarChar,8);
  param.Direction = ParameterDirection.Output;
  conn.Open();
  cmd.ExecuteNonQuery();
  string Fname = cmd.Parameters["@Fname"].Value.ToString();
  string Fphone = cmd.Parameters["@Fphone"].Value.ToString();
  Console.WriteLine(Fname + "  " + Fphone);
  conn.Close();
  showSplit();
 }
 
 //**************************************
 //*演示读取多个无关记录集
 //************************************** 
 public void multiResult()
 {
  SqlCommand cmd; 
  cmd = conn.CreateCommand();
  string sqla = "select Fname from friend";
  string sqlb = "select Fphone from friend";
  cmd.CommandText = sqla + ";" + sqlb;
  conn.Open();
  SqlDataReader reader= cmd.ExecuteReader();
  int i = 1;
  do
  {
   Console.WriteLine("" + i.ToString() + "个记录集内容如下:\\n");
   while(reader.Read())
   {
    Console.WriteLine(reader[0].ToString() + "\\t");
   }
   i++;
  }while(reader.NextResult()); //NextResult()移动到下一个记录集
  reader.Close();
  conn.Close();
  showSplit();
 }
 
 //**************************************
 //*使用DataReader获得数据库模式信息
 //************************************** 
 public void getSchema()
 {
  SqlCommand cmd; 
  cmd = conn.CreateCommand();
  string sql = "select Fid,Fname,Fphone from friend";
     cmd.CommandText = sql;
     conn.Open();
     SqlDataReader reader = cmd.ExecuteReader();
     DataTable SchemaTable = reader.GetSchemaTable();
     
     DataRowCollection SchemaColumns = SchemaTable.Rows;
     DataColumnCollection SchemaProps = SchemaTable.Columns;   
     foreach(DataRow SchemaColumn in SchemaColumns)
     {
      foreach(DataColumn SchemaColumnProp in SchemaProps)
      {
       Console.WriteLine(SchemaColumnProp.ColumnName + "=" + SchemaColumn[SchemaColumnProp.ColumnName].ToString());
      }
     }
     reader.Close();
     conn.Close();
     showSplit();
 }
 
 //**************************************
 //*从数据库读取二进制数据的代码段
 //*该代码段只是读取二进制的片断,不是
 //*整个程序,所以不能执行,你可以把它
 //*集成到你的WinForm项目里面。
 //************************************** 
 public void getBinary()
 {
  /*
  System.IO.MemoryStream stream = new System.IO.MemoryStream();
  System.IO.BinaryWriter writer = new System.IO.BinaryWriter(stream);   
  int BufferSize = 1024;
  byte[] Buffer = new Byte[BufferSize];
  long Offset = 0;
  long BytesRead = 0;
  do
  {
   BytesRead = reader.GetBytes(2,Offset,Buffer,0,BufferSize);
   writer.Writer(Buffer,0,(int)BytesRead);
   writer.Flush();
   Offset += BytesRead;
  }
  while(BytesRead == BufferSize);
  */
 }
 
 //添加输出分隔
 private void showSplit()
 {
  Console.WriteLine("\\n********************************************************************\\n");
 }
 
 public static void Main(string [] args)
 {
  SqlReader sqlreader = new SqlReader();
  
  sqlreader.basicReader();
  
  sqlreader.hasParamReader();
  
  sqlreader.hasOledbParamReader();
  
  sqlreader.outParamShow();
  
  sqlreader.multiResult();
  
  sqlreader.getSchema();
 } 
} 

 

收藏
421
很赞
494
您可能感兴趣