DataReader相关知识点⭐⭐⭐⭐⭐

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