http://blog.csdn.net/jabby12/archive/2004/08/04/64027.aspxADO.NET提供了Connection來連接數據庫,同時也提供了Command對象來查詢數據庫。同Connection對象一樣,Command也有兩種:OleDbCommand和SqlCommand.其區別同Connection對象。
要操縱數據庫,必須先使用Connection來連接到數據庫,再創建一個Command來查詢。有幾種創建方式,例:
SqlCommand cmd;
string strCon="server=localhost;database=Northwind;Trusted_Connection=Yes;";
string strqry="select * from Categories";
SqlConnection con=new SqlConnection(strCon);
con.Open();
1cmd=con.CreateCommand(); //這里使用用Connection對象的CreateCommand方法來創建一個Command對象。
cmd.CommandText=strqry;
//SqlDataReader reader=cmd.ExecuteReader();
?2cmd=new SqlCommand();?? //直接使用new 關鍵字來創建
cmd.CommandText=strqry;
?cmd.Connection=con;?? //設置與數據庫的連接
3cmd=new SqlCommand(strqry,con); //直接在new的時候帶兩個參數來創建
執行方式:
(主要有這么幾種,cmd.ExecuteReader();cmd.ExecuteNonQuery();cmd.ExecuteScalar();cmd.ExecuteXmlReader();)
1,ExecuteReader();返回一個SqlDataReader對象或OleDbDataReader對象,這個看你的程序的需要去 做。可以通過這個對象來檢查查詢結果,它提供了“游水”式的執行方式,即從結果中讀取一行之后,移動到另一行,則前一行就無法再用。有一點要注意的是執行之后,要等到手動去調用Read()方法之后,DataReader對象才會移動到結果集的第一行,同時此方法也返回一個Bool值,表明下一行是否可用,返回True則可用,返回False則到達結果集末尾。
使用DataReader可以提高執行效率,有兩種方式可以提高代碼的性能:一種是基于序號的查找,一個是使用適當的Get方法來查找。因為查詢出來的結果一般都不會改變,除非再次改動查詢語句,因此可以通過定位列的位置來查找記錄。用這種方法有一個問題,就是可能知道一列的名稱而不知道其所在的位置,這個問題的解決方案是通過調用DataReader 對象的GetOrdinal()方法,此方法接收一個列名并返回此列名所在的列號。例:
int id=reader.GetOrdinal("CategoryName");
while(reader.Read())
{
Response.Write(reader[id]);
reader.Close();
?至于第二種方式很直觀,例:
while(reader.Read())
{
?Response.Write(reader.GetInt32(0).ToString()+" "+reader.GetString(1).ToString()+"
");
}
DataReader的GetInt32()和GetString()通過接收一個列號來返回一個列的值,這兩種是最常用的,其中 還有很多其它的類型。
(注:DataReader對象在調用Close()方法即關閉與數據庫的連接,如果在沒有關閉之前又重新打開第二個連接,則會產生一條異常信息)
2.,ExecuteNonQuery()?這個方法并不返回一個DataReader對象,而是返回一個int類型的值,即在執行之后在數據庫中所影響的行數。
例:
int affectrows=cmd.ExecuteNonQuery();
Response.Write(affectrows +" 條記錄受影響");
?3,ExecuteScalar() 這個方法不接受任何參數,僅僅返回查詢結果集中的第一行第一列,而忽略了其它的行和列,而且返回的是一個object類型,在使用之前必須先將它強制轉換為所需類型。如果返回的僅僅是一個單獨的數據元,則可以使用此方法來提高代碼的性能。例:
string strCon="server=localhost;database=Northwind;Trusted_Connection=Yes;";
string strqry="select count(*) from Categories";
SqlConnection con=new SqlConnection(strCon);
con.Open();
SqlCommand cmd=con.CreateCommand();
int i=Convert.ToInt32(cmd.ExecuteScalar()); //必須強制轉換
4,ExecuteXmlReader() 此方法用于XML操作,返回一個XmlReader對象,由于系統默認沒有引用 System.Xml名空間,因此在使用前必須前引入。例:
string strCon="server=localhost;database=Northwind;Trusted_Connection=Yes;";
SqlConnection con=new SqlConnection(strCon);
con.Open();
SqlCommand cmd = new SqlCommand("select * from Categories FOR XML AUTO, XMLDATA", con);
XmlReader xr=cmd.ExecuteXmlReader();
Response.Write(xr.AttributeCount); //這里獲取當前節點上的屬性個數?
xr.Close();
執行完畢之后,照樣要顯式地調用Close()方法,否則會拋出異常。
使用參數化的查詢
先看一段SQL語句:select CategoryID,Description from Categories where CategoryID=? 其中的問號就是一個參數。但在使用的時候必須是帶有@前綴的命名參數,因為.NET數據提供程序不支持這個通用的參數標記“?”.使用參數化的查詢可以大大地簡化編程,而且執行效率也比直接查詢字符串要高,也更方便,很多情況下都需要更改查詢字符串,這種方式就提供了方便,只需更改參數的值即可。例:
string strCon="server=localhost;database=Northwind;Trusted_Connection=Yes;";
SqlConnection con=new SqlConnection(strCon);
con.Open();
string strqry="select * from Categories where CategoryID=@CategoryID"; //帶參數的查詢
SqlCommand cmd=new SqlCommand(strqry,con);
cmd.Parameters.Add("@CategoryID",SqlDbType.Int,4); //給參數賦于同數據庫中相同的類型
cmd.Parameters["@CategoryID"].Value="3"; //給參數賦值,可靈活改變
SqlDataReader r=cmd.ExecuteReader();
while(r.Read())
{
Response.Write(r.GetString(2)+"
"); //取出指定參數列的值
}
con.Close(); //切記關閉
使用存儲過程進行查詢
先看段存儲過程的形式:create procedure cateproc (@CategoryID int(4)) as select * from Categories where CategoryID=@CategoryID? return。
這個是數據庫中的存儲過程實現方式,要在程序中調用存儲過程,一種方法是使用Command對象的 CommandType屬性來實現。CommandType有三個枚舉值:Text,TableDirect,StoredProcedure。只需將CommandType屬性設為第三個值即可實現調用存儲過程。例:
string strCon="server=localhost;database=Northwind;Trusted_Connection=Yes;";
SqlConnection con=new SqlConnection(strCon);
con.Open();
SqlCommand cmd=con.CreateCommand();
cmd.CommandText="cateproc";
cmd.CommandType=CommandType.StoredProcedure;
cmd.Parameters.Add("@CategoryID",SqlDbType.Int,4);
cmd.Parameters["CategoryID"].Value="2";
SqlDataReader r=cmd.ExecuteReader();
while(r.Read())
{
Response.Write(r.GetString(2)+"
");
}
con.Close();
其實在程序中實現調用存儲過程的方式跟參數化查詢很類似,有點舊鞋翻新的味道。
cmd.CommandType=CommandType.StoredProcedure;這種方式有個缺點,就是當要查詢的表,視圖或存儲過程的名稱中有特殊的字符(如空格)的話,則將無法識別。因此還有一種方式就是:
cmd.CommandText="{Call cateproc(?)}"; //這里是調用存儲過程,問號為參數
cmd.CommandType=CommandType.Text; //關鍵是這里。
設置命令執行超時
命令超時是指Command對象在等待結果的時間,(默認為30秒)如果在30秒內沒執行查詢,則Command拋出一個異常。也可以自己進行設置。例:cmd.CommandTimeout=60;
取消執行查詢
有時因某種原因,需要臨時取消命令的執行,可調用Command對象的Cancel()方法來退出執行,如果在未執行查詢之前,Cancel()將不做任何事。
首先,ADO.NET中使用了DataAdapter 來處理與數據庫的聯機與脫機。當時開發人員設計了DataAdapter是為了能夠處理脫機數據,方便操作,關于這一點,只要調用其Fill()方法即可,這時會在DataSet中創建一個新的名為“Table“的DataTable.要重新指定名可用DataAdapter.Fill(DataSet,“Tabelname“)。此時connection也關閉了。DataAdapter既可以用來提交查詢,并將結果存儲到DataSet中,也可以用來向數據庫傳遞更改。僅僅使用其Update方法即可達到向數據庫提交存儲地DatSet中的更改。
DataAdapter將查詢的結果存儲在DataSet或DataTable對象中,當執行這一過程的時候,DataAdapter使用了一個Command來與數據庫通訊,并在內部使用了DataReader來獲取查詢結果,最后才將結果復制到DataSet新行中去。這也是Fill的過程。如果有兩個DataAdapter對象,都使用相同的Connection對象,在創建的時候就會創建兩個Connection對象,而不是同一個,這種情況的解決方案是:
SqlConnection con=new SqlConnection("server=localhost;database=Northwind;Trusted_Connection=Yes;")
SqlDataAdapter da=new SqlDataAdapter("select CategoryID,Description from Categories",con);
SqlDataAdapter da=new SqlDataAdapter("select CategoryID,Description from Customers",con);
而不是將查詢字符串,單獨寫成一行。
有時候可能并不希望DataSet中的架構與數據庫中的架構相同,這種情況的解決方案之一是可以采用別名的方法,即select id as Product ID,amount as Product Amount from product;另外一種解決方案就是使用DataAdapter提供的TableMappings集合機制,通過它就可以將查詢結果映射到DataSet結構中,這種方法更方便,更靈活。TableMappings屬性返回一個DataTableMappingsCollection對象,其中包含了一組DataTableMappings,只要DataSet中相應的表名稱與數據庫中的表名相同,即可以使用它來創建一個映射(DataSet中可以有多個表)。TableMappings里還有一個ColumnMappings屬性,其用法與TableMappings相似。其原理是DataAdapter從數據庫讀取數據后,利用DataReader從結果集中獲取列名稱,有一點特別要注意,即只能獲取列名稱而無法獲取表名稱,DataAdapter事先假定表名稱為Table,接著遇到映射語句則進行表映射。不說了,看代碼:
DataColumnMapping colMap;
SqlConnection con=new SqlConnection("server=localhost;database=Northwind;Trusted_Connection=Yes;");
SqlDataAdapter da=new SqlDataAdapter("select CategoryID,Description from Categories",con);
DataSet ds=new DataSet();
DataTableMapping tblMap=da.TableMappings.Add("Table","Ca"); //這里Table為關鍵,映射表名為Ca
colMap=tblMap.ColumnMappings.Add("CategoryID","ID"); //映射列表
colMap=tblMap.ColumnMappings.Add("Description","描述");
// Response.Write(tblMap.DataSetTable.ToString());
da.Fill(ds);
DataTable dt=ds.Tables["Ca"]; //這里是映射后的表名,如果仍為數據庫的表名,則無效,特別注意
this.DataGrid1.DataSource=dt;
this.DataGrid1.DataBind();
運行代碼后就會發現DataGrid1上的列名為ID和描述 (^_^)
(注:使用DataTableMapping 之前要前導入名空間System.Data.Common;)
還可以使用AddRange方法來簡化表和列的映射:(一些代碼同上面)
.......
DataTableMapping tblMap=da.TableMappings.Add("Table","Ca"); DataColumnMapping[] colMapArray=new DataColumnMapping[]{new DataColumnMapping("CategoryID","產 品號"),new DataColumnMapping("Description","描述")}; tblMap.ColumnMappings.AddRange(colMapArray);
......
這種映射關系只能從數據庫中讀取展示給用戶,如果要將映射后的Table的更改提交給數據庫,這時庫發現其中列與庫中列不同,便會發生異常,DataAdapter 同時也提供了MissingMappingAction屬性來處理。
DataAdapter1.MissingMappingAction=MissingMappingAction.Passthrough/Ignore/Error
它接受MissingMappingAction的枚舉值,Passthrough這個值表示如果在庫中找不到與DataSet中相同列的話,就將此列映射到庫中,Ignore枚舉值表示忽略示出現的列,Error表示找不到相應的列則拋出異常。
分頁:
分頁在應用中是常有的事,而DataAdapter本身也提供了分頁的簡單功能,如:DataAdapter1.Fill(dataset,startrow,rownum,“tablename“)這種功能用于數據量較小的查詢就可以,但當有大量數據的時候,就會發現這種分頁的問題的存在。它的原理是假如有一百行數據,分成十頁,每頁十行,當獲取每一頁的時候,返回前10行,再接著,第二頁,刪除了前10行而獲取接下的10行,在這一次中,只是為了獲取10行數據,但數據庫卻返回了20行,依此類推,第10頁的時候就會返回100行,而DataAdapter本身就幫我們刪除了90行,因為我們看上去返回的還是10行,這種性能太低。因此本篇繼續介紹另外一種性能較高的分頁方法。實際上這種分頁方法是將上一頁最后一行的鍵值存儲下來,直接在SQL語句中就過濾掉了,不象前面那種到DataAdapter這邊才過濾掉。例:
con=new SqlConnection("server=localhost;database=Northwind;Trusted_Connection=Yes;");
da=new SqlDataAdapter("select top 50 CustomerID,CompanyName from Customers where CustomerID>'BOTTM'",con);
ds=new DataSet();
da.Fill(ds,"Categories");
this.DataGrid1.DataSource=ds.Tables["Categories"]; this.DataGrid1.DataBind();
con.Close();
這里假如上一頁最后一個鍵值為”BOTTM”,可以將它用參數替代掉,這樣就查出了在'BOTTM'之后的50行。這種方法實現簡單效率也高。