萬盛學電腦網

 萬盛學電腦網 >> 數據庫 >> mssql數據庫 >> C#中Sql DataAdapter的使用

C#中Sql DataAdapter的使用

   SqlDataAdapter概述

  SqlDataAdapter是 DataSet和 SQL Server之間的橋接器,用於檢索和保存數據。SqlDataAdapter通過對數據源使用適當的Transact-SQL語句映射 Fill(它可更改DataSet中的數據以匹配數據源中的數據)和 Update(它可更改數據源中的數據以匹配 DataSet中的數據)來提供這一橋接。當SqlDataAdapter填充 DataSet時,它為返回的數據創建必需的表和列(如果這些表和列尚不存在)。

  我們可以通過以下三種方法來創建SqlDataAdapter對象:

  使用方法

  1、通過連接字符串和查詢語句

  string strConn="uid=賬號;pwd=密碼;database=數據庫;server=服務器";//SQL Server鏈接字符串

  strSql="SELECT * FROM 表名";

  SqlDataAdapter da=new SqlDataAdapter(strSql,strConn);

  DataSet ds=new DataSet();//創建DataSet實例

  da.Fill(ds,"自定義虛擬表名");//使用DataAdapter的Fill方法(填充),調用SELECT命令

  這種方法有一個潛在的缺陷。假設應用程序中需要多個SqlDataAdapter對象,用這種方式來創建的話,會導致創建每個SqlDataAdapter時,都同時創建一個新的SqlConnection對象,方法二可以解決這個問題

  2、通過查詢語句和SqlConnection對象來創建

  string strConn="uid=賬號;pwd=密碼;database=數據庫;server=服務器";//SQL Server鏈接字符串

  SqlConnection conn=new SqlConnection(strConn);

  string strSql="SELECT * FROM 表名";

  SqlDataAdapter da = new SqlDataAdapter(strSql, conn);

  DataSet ds=new DataSet();//創建DataSet實例

  da.Fill(ds,"自定義虛擬表名");//使用DataAdapter的Fill方法(填充),調用SELECT命令

  3、通過SqlCommand對象來創建

  string strConn="uid=賬號;pwd=密碼;database=數據庫;server=服務器";//SQL Server鏈接字符串

  SqlConnection connSql=new SqlConnection (strConn); //Sql鏈接類的實例化

  connSql.Open ();//打開數據庫

  //使用SqlDataAdapter時沒有必要從Connection.open()打開,

  //SqlDataAdapter會自動打開關閉它。

  string strSql = "SELECT * FROM 表名"; //要執行的SQL語句

  SqlCommand cmd=new SqlCommand(strSql,connsql);

  SqlDataAdapter da=new SqlDataAdapter(cmd); //創建DataAdapter數據適配器實例

  DataSet ds=new DataSet();//創建DataSet實例

  da.Fill(ds,"自定義虛擬表名");//使用DataAdapter的Fill方法(填充),調用SELECT命令

  ConnSql.Close ();//關閉數據庫

  SqlDataAdapter da=new SqlDataAdapter(strSQL,ConnSql); //創建DataAdapter數據適配器實例DataSet ds=new DataSet();//創建DataSet實例da.Fill(ds,"自定義虛擬表名");//使用DataAdapter的Fill方法(填充),調用SELECT命令ConnSql.Close ();//關閉數據庫

  注意

  如果只需要執行SQL語句或SP,就沒必要用到DataAdapter ,直接用SqlCommand的Execute系列方法就可以了。sqlDataadapter的作用是實現Dataset和DB之間的橋梁:比如將對DataSet的修改更新到數據庫。

  SqlDataAdapter的UpdateCommand的執行機制是:當調用SqlDataAdapter.Update()時,檢查DataSet中的所有行,然後對每一個修改過的Row執行SqlDataAdapter.UpdateCommand ,也就是說如果未修改DataSet中的數據,SqlDataAdapter.UpdateCommand不會執行。

  使用要點

  1、SqlDataAdapter內部通過SqlDataReader獲取數據,而默認情況下SqlDataReader不能獲知其查詢語句對應的數據庫表名,

  所以下面的代碼:

  string strConn = "uid=賬號;pwd=密碼;database=數據庫;server=服務器";//SQL Server鏈接字符串

  strSql="SELECT * FROM 表名";

  SqlDataAdapter da = new SqlDataAdapter(strSql,strConn);

  DataSet ds = new DataSet();

  da.Fill(ds);

  會在DataSet中創建一個新的DataTable,這個新的DataTable會擁有名為CustomerID和CompanyName 列,但是DataTable對象的名稱是Table,而不是我們希望的Customers。

  這個問題,可以通過添加TableMapping來解決:

  string strConn="uid=賬號;pwd=密碼;database=數據庫;server=服務器";//SQL Server鏈接字符串

  strSql="SELECT * FROM 表名";

  SqlDataAdapter da=new SqlDataAdapter(strSQL,strConn);

  da.TableMappings.Add("Table","Customers"); // 設置對象名稱

  DataSet ds=new DataSet();

  da.Fill(ds);

  其實最簡潔的方法是通過使用Fill方法的重載,通過指定DataTable,像這樣:

  SqlDataAdapter.Fill(DataSet,"MyTableName");

  這樣就可以不必使用TableMappings集合。

  2、在使用Fill方式時,可以指定DataTable,而不是DataSet:

  string strConn="uid=賬號;pwd=密碼;database=數據庫;server=服務器";//SQL Server鏈接字符串

  strSql="SELECT * FROM 表名";

  SqlDataAdapter da = new SqlDataAdapter(strSql, strConn);

  DataTable tbl=new DataTable( );

  da.Fill(tbl);

  3、注意打開和關閉連接的處理

  在調用SqlCommand對象執行sql命令之前,需要保證與該對象關聯的SqlConnection對象時打開的,否則SqlCommand的方法執行時將引發一個異常,但是我們在上面的代碼中看到,SqlDataAdapter沒有這樣的要求。

  如果調用SqlDataAdapter的Fill方法,並且其SelectCommand屬性的SqlConnection是關閉狀態,則SqlDataAdapter會自動打開它,然後提交查詢,獲取結果,最後關閉連接。如果在調用Fill方法前,SqlConnection是打開的,則查詢執行完畢後,SqlConnection還將是打開的,也就是說SqlDataAdapter會保證SqlConnection的狀態恢復到原來的情形。

  這有時會導致性能問題,需要注意,例如下面的代碼:

  string strConn="uid=賬號;pwd=密碼;database=數據庫;server=服務器";//SQL Server鏈接字符串

  SqlConnection conn=new SqlConnection(strConn);

  SqlDataAdapter daCustomers,daOrders;

  strSql="SELECT * FROM Customers";

  daCustomers = new SqlDataAdapter(strSql, conn);

  strSql="SELECT * FROM Orders";

  daOrders=new SqlDataAdapter(strSql, conn);

  DataSet ds=new DataSet();

  daCustomers.Fill(ds,"Customers");

  daOrders.Fill(ds,"Orders");

  以上代碼會導致連接被打開和關閉兩次,在調用Fill方法時各一次。為了避免打開和關閉SqlConnection對象,在調用SqlDataAdapter對象的Fill方法之前,我們可以先打開SqlConnection對象,如果希望之後關閉連接,我們可以再調用Close方法,就像這樣:

  cn.Open();

  daCustomers.Fill(ds,"Customers");

  daOrders.Fill(ds,"Orders");

  cn.Close();

  4、多次調用Fill方法需要注意數據重復和有效更新數據的問題

  string strConn="uid=賬號;pwd=密碼;database=數據庫;server=服務器";//SQL Server鏈接字符串

  strSql="SELECT * FROM Customers";

  SqlDataAdapter da=new SqlDataAdapter(strSql, strConn);

  DataSet ds=new DataSet();

  da.Fill(ds,"Customers");

  //…….

  da.Fill(ds,"Customers");

  我們分析上面的代碼,通過兩次調用Fill方法,SqlDataAdapter執行兩次查詢,並兩次將查詢結果保存到DataSet中,第一次調用在DataSet中創建了一個名為Customers的新表。第二次調用Fill方法將查詢的結果追加到DataSet中的同一個表中,因此,每個客戶的信息將在DataSet中出現兩次!當然,如果數據庫管理員對Customers表定義了主鍵,則SqlDataAdapter在天成DataTable時,會判斷重復行,並自動丟棄掉舊的值。

  考慮一下,假定一個特定客戶在第一次調用Fill方法時,存儲於數據庫中,那麼SqlDataAdapter會將其添加到新建的DataTable中。如果後來這個客戶被刪除了,那麼第二次調用Fill方法時,SqlDataAdapter將不會在查詢結果中找到該客戶信息,但是它也不會將客戶信息從DataSet中刪除。這就導致了數據更新的問題。

  所以推薦的做法是,在調用Fill方法前,先刪除本地DataSet中緩存的數據!

copyright © 萬盛學電腦網 all rights reserved