SqlDataReader類

可以用SqlDataReader類對象從SQL Server數據庫中讀取行；用OleDbDataReader類對象從支持OLE DB的數據庫中讀行，如Oracle與Access；用OdbcDataReader類對象從支持ODBC的數據庫中讀取行。

DataReader對象允許你以向前的，只讀的方式讀取數據，有時候DataReader對象也稱為消軟管游標。DataReader對象采用了一種簡化的數據讀取方式，但是提高了性能的同時也犧牲了很多特性。例如在DataSet中支持的排序，分頁等功能。這些功能將在以后的章節進行詳細的介紹。

SqlDataReader的屬性

屬性	說明
Depth	其返回類型為int，取得表示當前行嵌入深度的值
FieldCount	其返回類型為int,取得當前行的列數
IsColsed	其返回類型為bool,取得一個布爾值，表示是否關閉數據讀取
RecordsAffected	其返回類型為int, 取得執行SQL語句增加、修改或刪除的行數。

SqlDataReader的方法

方法	說明
Reader()	其返回類型為bool,將數據閱讀器移到結果集的下一行并讀取該行。這個方法返回的布爾值表示結果集中是否有多行
GetValue()	其返回類型為object, 返回指定列的值
GetValues()	其返回類型為int,將當前行中所有列的值復制到指定對象數組。這個方法返回的int是數組元素的個數
NextResult()	其返回類型為bool,將數據閱讀器移到結果集的下一行。這個方法返回的布爾值表示結果集中是否有多行
Close() 關閉	SqlDataReader 對象
GetInt32(),GetChar(), GateDataTime(),Get×××()	返回指定列的值，并且返回的類型為相應的數據類型。例如GetInt32()返回整型的數值。注意，如果你將返回值賦予一個類型不匹配的變量時，將會拋出一個InvalidCastException異常

用ExecuteReader()方法執行查詢

下面是一個用ExecuteReader()方法執行SELECT語句的范例。這個方法用DataReader對象返回結果集，然后可以用此對象讀取數據庫返回的行。

范例程序代碼如下：

01 public partial class _Default : System.Web.UI.Page 02 { 03 protected void Page_Load(object sender, EventArgs e) 04 { 05 string connectionString = 06 ConfigurationManager.ConnectionStrings["Northwind"].ConnectionString; 07 SqlConnection con = new SqlConnection(connectionString); 08 string sql = "SELECT top 5 CustomerID,CompanyName,ContactName,Address 09 FROM Customers"; 10 SqlCommand cmd = new SqlCommand(sql, con); 11 con.Open(); 12 SqlDataReader reader = cmd.ExecuteReader(); 13 StringBuilder htmlStr = new StringBuilder(""); 14 while (reader.Read()) 15 { 16 htmlStr.Append("CustomerID：" + reader["CustomerID"] + "<br>"); 17 htmlStr.Append("CompanyName：" + reader["CompanyName"] + "<br>"); 18 htmlStr.Append("ContactName：" + reader.GetString(2) + "<br>"); 19 htmlStr.Append("Address：" + reader.GetString(3) + "<br>"); 20 htmlStr.Append("<hr>"); 21 } 22 reader.Close(); 23 con.Close(); 24 HtmlContent.Text = htmlStr.ToString(); 25 } 26 }

程序代碼說明：在上述語法范例的程序代碼中，第5到12行代碼生成所要的對象并執行SELECT語句，從Customers表中讀取前5條記錄。cmd返回的結果集存放在reader對象中，然后你可以用Reader()方法讀取reader對象的記錄。這個方法在有另一個可讀的行時返回布爾真值，否則返回布爾假值。可以從reader對象中讀取一個記錄的各個列值，只要在方括號中傳入列名即可。如第16和17行所示，我們用reader[“CustomerID”]讀取CustomerID列的各項內容。你也可以直接在方括號中傳入數字值指定想要列的索引。如第18和19行代碼所顯示，由于我們在用SELECT進行數據查詢的時，ContactName和Address分別位于第3和第4列，而相應的索引值則為2和3，所以我們可以用reader.GetString(2)和reader.GetString(3)讀取ContactName和Address列的數據。如第14行代碼所示，我們可以在While循環中用Reader()方法一一讀取每條記錄。

執行結果：


每次程序執行命令時，都要將相應的命令通過網絡傳遞到數據庫中，并在數據庫進行執行，然后將結果返回到程序中，從而產生大量的網絡通信流。我們可以使用ExecuteReader()方法同時執行多條SELECT語句查詢減少重復的數據傳遞。

下面的實例是使用ExecuteReader()方法同時查詢三個表中的數據，并將返回的三個結果集顯示在頁面上。

范例程序代碼如下：

01 public partial class _Default : System.Web.UI.Page 02 { 03 protected void Page_Load(object sender, EventArgs e) 04 { 05 string connectionString = 06 ConfigurationManager.ConnectionStrings["Northwind"].ConnectionString; 07 SqlConnection con = new SqlConnection(connectionString); 08 SqlCommand cmd = con.CreateCommand(); 09 cmd.CommandText = "SELECT TOP 3 ProductID,ProductName 10 FROM Products ORDER BY ProductID;" + 11 "SELECT TOP 3 CustomerID,CompanyName 12 FROM Customers ORDER BY CustomerID;" + 13 "SELECT TOP 3 OrderID,CustomerID 14 FROM Orders ORDER BY OrderID;"; 15 con.Open(); 16 SqlDataReader reader = cmd.ExecuteReader(); 17 StringBuilder htmStr=new StringBuilder(""); 18 int i = 0; 19 do 20 { 21 htmStr.Append("結果集"); 22 htmStr.Append(i.ToString()); 23 htmStr.Append("<br>"); 24 while (reader.Read()) 25 { 26 htmStr.Append("reader[0]=" + reader[0]); 27 htmStr.Append("<br>"); 28 htmStr.Append("reader[1]=" + reader[1]); 29 htmStr.Append("<br><br>"); 30 } 31 htmStr.Append("<hr>"); 32 i++; 33 } while (reader.NextResult()); 34 reader.Close(); 35 con.Close(); 36 HtmlContent.Text = htmStr.ToString(); 37 } 38 }

程序代碼說明：在上述語法范例的程序代碼中，第9行到第14中定義了3個查詢語句，各語句之間用分號進行間隔。第16行調用ExecuteReader()方法，并返回SqlDataReader對象，并且對三條不同的SELECT語句各返回一個結果集。要讀取第一個結果集的話，可以用SqlDataReader對象的Reader()方法。Reader()方法在沒有其他的可讀行時將返回一個false值。當一個結果集的所有記錄都讀取完畢后，可以調用SqlDataReader對象的NextResult()方法，然后在讀取下一個結果集，在沒有其他的結果集時，也返回一個false值。

提示：外循環do…while測試結尾的reader. NextResult()的返回值。由于do…while循環末尾檢測這個條件，這樣就保證了do…while循環至少執行一次。之所以在末尾才調用NextResult()方法，是因為這樣可以首先把SqlDataReader對象移到下一個結果集，然后才返回表示是否還有下一個結果集的布爾結果。如果使用while循環中，則有可能直接跳過第一個結果集，從而產生錯誤。


用ExecuteScalar()方法執行SELECT語句

用ExecuteScalar()方法執行SELECT語句，返回單個值，并且忽略其他的任何讀取的結果。ExecuteScalar()方法返回的結果是一個object對象。ExecuteScalar()主要是用來執行SELECT語句，或者執行包括聚合函數的SQL語句。

下面我們將使用如下的程序讀取Products表中的記錄條數，并且在相應的查詢語句中使用COUNT()聚合函數。

范例程序代碼如下：

01 public partial class _Default : System.Web.UI.Page 02 { 03 protected void Page_Load(object sender, EventArgs e) 04 { 05 string connectionString = 06 ConfigurationManager.ConnectionStrings["Northwind"].ConnectionString; 07 SqlConnection con = new SqlConnection(connectionString); 08 SqlCommand cmd = con.CreateCommand(); 09 cmd.CommandText = "SELECT COUNT(*) FROM Products"; 10 con.Open(); 11 int returnValue = (int)cmd.ExecuteScalar(); 12 HtmlContent.Text = "Products表中共有" + returnValue.ToString()+"條記錄"; 13 } 14 }

程序代碼說明：在上述語法范例的程序代碼中，第9行即為查詢Products表中的記錄條數的SQL語句。第11行代碼用ExecuteScalar()方法執行SELECT語句。注意，由于ExecuteScalar()方法的結果為object對象，因此我們要將其進行強制類型轉換，再賦予相應的變量。

執行結果：