DataReader相关知识点

Posted 2020-10-13 Prozkb

C#中提供的DataReader可以从数据库中每次提取一条数据。

1. 获取数据的方式
[1]DataReader 为在线操作数据， DataReader会一直占用SqlConnection连接，在其获得数据过程中其它操作不可以再使用SqlConnection连接对象。

[2]DataSet为离线操作数据，DataSet会将数据一次性读入内存，然后断开连接，这时其它操作就可以使用SqlConnection连接对象。

由于DataReader一次只读取一行数据，所以占用内存较小。但DataReader为只进且只读的，也就是只能单方向向前读取，如果你想回头去读取上一条数据是不允许的，并且不允许其修改数据。
由于DataSet一次性读取所有数据，所以比较消耗资源，

2．获取数据的机制
　　DataReader是通过SqlCommand.ExecuteReader来读取数据。
　　DataSet则是通过SqlDataAdapter.Fill来填充数据。
　　所以DataReader在获取数据时不能关闭连接。而DataSet则可以，因为DbDataAdapter已经将数据读取到应用程序服务器中，所以在使用DataReader时一定要注意，及时关闭连接。

3．其它区别
　　DataReader读取速度快于DataSet。
　　DataReader是数据提供者类，DataSet是一般性类，借助于SqlDataAdapter来填充数据。
　　因为DataSet是离线操作数据，所以在事务中使用锁时要注意，因为DataSet填充数据后会断开连接，也就会释放锁。

//未式关闭连接
        public SysFunction GetModelById(string id)
        {
            SqlConnection conn = new SqlConnection(ConfigurationManager.ConnectionStrings["sqlConStr"].ToString());
            conn.Open();
            SqlCommand cmd = new SqlCommand("SELECT * FROM SysFunction WHERE FunctionId =" + id, conn);            
            SqlDataReader dataReader = cmd.ExecuteReader();
            SysFunction model = new SysFunction();
            while (dataReader.Read())
            {
                model.FunctionName = dataReader["FunctionName"].ToString();
                model.FunctionCode = dataReader["FunctionCode"].ToString();
            }

            dataReader.Close();
            dataReader.Dispose();
            string drState = dataReader.IsClosed.ToString(); //True
            string connState = conn.State.ToString(); //Open
            return model;
            
        }
        

//调用Command 对象的 ExecuteReader() 方法时传递 CommandBehavior.CloseConnection 参数
        public SysFunction GetModelById(string id)
        {
            SqlConnection conn = new SqlConnection(ConfigurationManager.ConnectionStrings["sqlConStr"].ToString());
            conn.Open();
            SqlCommand cmd = new SqlCommand("SELECT * FROM SysFunction WHERE FunctionId =" + id, conn);
            
            //执行该cmd时，如果关闭关联的 DataReader 对象，则关联的 Connection 对象也将关闭
            SqlDataReader dataReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
            SysFunction model = new SysFunction();
            while (dataReader.Read())
            {
                model.FunctionName = dataReader["FunctionName"].ToString();
                model.FunctionCode = dataReader["FunctionCode"].ToString();
            }
            dataReader.Close();
            dataReader.Dispose();
            string drState = dataReader.IsClosed.ToString(); //True
            string connState = conn.State.ToString(); //Close
            return model;            
        }

 

 

DataReader对象概述

        DataReader对象提供了顺序的，只读的方式读取Command对象获得的数据结果集。正是因为DataReader是以顺序的方式连续地读取数据，所以DataReader会以独占的方式打开数据库连接。

        由于DataReader只执行读操作，并且每次只在内存缓冲区里存储结果集的一条数据，所以使用Datareader对象的效率比较高，如果要查询大量数据，同事不需要随机访问和修改数据，DataReader是优先的选择。

判断查询结果中是否有数据

 想要判断查询结果中是否有数据只需要判断DataReader对象的HasRows属性即可。

namespace ConsoleApplication1

{
class Program
{
static void Main(string[] args)
{
string conStr = "server=.;user=sa;pwd=123456;database=CustomerManagement";//连接字符串
SqlConnection conText = new SqlConnection(conStr);//创建Connection对象

try
{
conText.Open();//打开数据库
string sql = "select * from manager";//创建统计语句
SqlCommand comText = new SqlCommand(sql, conText);//创建Command对象
SqlDataReader dr;//创建DataReader对象
dr=comText.ExecuteReader();//执行查询
if (dr.HasRows)//判断数据表中是否含有数据
{
Console.WriteLine("manager数据表中含有数据");
}
else
{
Console.WriteLine("manager数据表中没有数据");
}
}
catch (Exception ex)//创建检查Exception对象
{
Console.WriteLine(ex.Message.ToString());//输出错误信息
}
finally
{
conText.Close();//关闭连接
}
Console.ReadLine();
}
}
}

读取数据

        要想读取DataReader对象中的数据，就要用到DataReader对象的Read方法，由于DataReader对象每次只在内存缓冲区里存储结果集中的一条数据，所以要读取DataReader对象中的多条数据，就要用到迭代语句

namespace ConsoleApplication1
{
class Program
{
static void Main(string[] args)
{
string conStr = "server=.;user=sa;pwd=123456;database=CustomerManagement";//连接字符串
SqlConnection conText = new SqlConnection(conStr);//创建Connection对象

try
{
conText.Open();//打开数据库
string sql = "select * from manager";//创建统计语句
SqlCommand comText = new SqlCommand(sql, conText);//创建Command对象
SqlDataReader dr;//创建DataReader对象
dr=comText.ExecuteReader();//执行查询
while(dr.Read())//判断数据表中是否含有数据
{
Console.Write(dr[0].ToString()+",");//输出用户标识
Console.Write(dr["userName"].ToString()+",");//输出用户名
Console.WriteLine(dr[2].ToString());//输出用户密码
}
dr.Close();//关闭DataReader对象
}
catch (Exception ex)//创建检查Exception对象
{
Console.WriteLine(ex.Message.ToString());//输出错误信息
}
finally
{
conText.Close();//关闭连接
}
Console.ReadLine();
}
}
}