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