返回C# 之 Da......登陆

C# 之 DataReader 和 DataSet 的区别

高洛峰2016-11-02 16:31:10691

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

代码如下:

1

2

3

4

5

6

while(datareader.read())

{

..............

}

dataview.datasource=datareader;

dataview.databind();

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

1

2

3

4

5

6

7

8

9

10

11

public string test = "";

  protected void Page_Load(object sender, EventArgs e)

  {

    DataSet ds=new DataSet();//这里是你的数据,我就不写了

    test = "<table>";

    for (int i = 0; i < ds.Tables[0].Rows; i++)

    {

      test+="<tr><td>"+ds.Tables[0].Rows[i]["你要的字段"].ToString()+"</td></tr>"

    }

    test+="</table>";

  }

1

2

3

4

5

6

7

8

9

10

11

public string test = "";

  protected void Page_Load(object sender, EventArgs e)

  {

    DataSet ds=new DataSet();//这里是你的数据,我就不写了

    test = "<table>";

    for (int i = 0; i < ds.Tables[0].Rows; i++)

    {

      test+="<tr><td>"+ds.Tables[0].Rows[i]["你要的字段"].ToString()+"</td></tr>"

    }

    test+="</table>";

  }

页面代码如下:

1

2

3

<form id="form1" runat="server">

    <%=test %>

</form>

  由于DataReader一次只读取一行数据,所以占用内存较小。但DataReader为只进且只读的,也就是只能单方向向前读取,如果你想回头去读取上一条数据是不允许的,并且不允许其修改数据。
  由于DataSet一次性读取所有数据,所以比较消耗资源,但也提高了灵活性,在断开数据库连接情况下你可以对数据进行任何增删改查,按照任意的顺序读取数据,并可以将其写回到数据库。
    有一点需要注意,DataReader一次读取一行并不意味着这时在数据库中的数据被修改,可以读到新的数据,这是数据库层面的保护.

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

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

4.使用DataReader可以提高执行效率,有两种方式可以提高代码的性能:一种是基于序号的查找,一个是使用适当的Get方法来查找。

  因为查询出来的结果一般都不会改变,除非再次改动查询语句,因此可以通过定位列的位置来查找记录。用这种方法有一个问题,就是可能知道一列的名称而不知道其所在的位置,这个问题的解决方案是通过调用DataReader 对象的GetOrdinal()方法,此方法接收一个列名并返回此列名所在的列号。例:

代码如下:

1

2

3

4

5

6

int id = reader.GetOrdinal("CategoryName");

while (reader.Read())

{

  Response.Write(reader.GetInt32(0).ToString() + " " + reader.GetString(1).ToString() + "<br />");

  reader.Close();

}

  DataReader的GetInt32()和GetString()通过接收一个列号来返回一个列的值,这两种是最常用的,其中还有很多其它的类型。
  

注意:

  DataReader对象在调用其 Close() 方法关闭 DataReader 对象,然后调用 SqlConnection 对象的 Close 方法关闭与数据库的连接,如果在没有关闭之前又重新打开第二个连接,则会产生一条异常信息,如:并发问题。使用完SqlDataReader后,可以在程序中显示的调用 数据库连接对象的 Close() 方法关闭连接,也可以在调用Command对象的ExecuteReader方法时传递 CommandBehavior.CloseConnection 这个枚举变量,这样在调用SqlDataReader的 Close 方法时会自动关闭数据库连接。

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

//未式关闭连接

        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;

             

        }

         

 

     //调用Connection 对象的 Close() 方法显式关闭连接

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

       conn.Close(); //显式关闭连接

 

            string drState = dataReader.IsClosed.ToString(); //True

            string connState = conn.State.ToString(); //Close

            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;

             

        }


最新手记推荐

• 用composer安装thinkphp框架的步骤• 省市区接口说明• 用thinkphp,后台新增栏目• 管理员添加编辑删除• 管理员添加编辑删除

全部回复(0)我要回复

暂无评论~
  • 取消回复发送