ADO.NET與LINQ to SQL

它基於由 ADO.NET 提供程式模型提供的服務。

因此,我們可以將 LINQ to SQL 代碼與現有的 ADO.NET 應用程式混合在一起,將當前 ADO.NET 解決方案遷移到 LINQ to SQL。

1.連接:

在創建 LINQ to SQL DataContext 時,可以提供現有 ADO.NET 連接。對 DataContext 的所有操作(包括查詢)都使用所提供的這個連接。如果此連接已經打開,則在您使用完此連接時,LINQ to SQL 會保持它的打開狀態不變。我們始終可以訪問此連接,另外還可以使用 Connection 屬性自行關閉它。

//新建一個標準的ADO.NET連接:
SqlConnection nwindConn = new SqlConnection(connString);
nwindConn.Open();
// ... 其它的ADO.NET資料操作代碼... //
//利用現有的ADO.NET連接來創建一個DataContext:
Northwind interop_db = new Northwind(nwindConn);
var orders = from o in interop_db.Orders
             where o.Freight > 500.00M
             select o;
//返回Freight>500.00M的訂單
nwindConn.Close();

語句描述:這個例子使用預先存在的ADO.NET連接創建Northwind物件,本例中的查詢返回運費至少為500.00 的所有訂單。

2.事務:

當我們已經啟動了自己的資料庫事務並且我們希望DataContext 包含在內時,我們可以向 DataContext 提供此事務。

通過 .NET Framework 創建事務的首選方法是使用 TransactionScope 物件。通過使用此方法,我們可以創建跨資料庫及其他駐留在記憶體中的資源管理器執行的分散式事務。事務範圍幾乎不需要資源就可以啟動。它們僅在事務範圍記憶體在多個連接時才將自身提升為分散式事務。

using (TransactionScope ts = new TransactionScope())
{
    db.SubmitChanges();
    ts.Complete();
}

注意:不能將此方法用於所有資料庫。例如,SqlClient 連接在針對 SQL Server 2000 伺服器使用時無法提升系統事務。它採取的方法是,只要它發現有使用事務範圍的情況,它就會自動向完整的分散式事務登記。

下面用一個例子說明一下事務的使用方法。在這裡,也說明了重用 ADO.NET 命令和 DataContext 之間的同一連接。

//使用LINQ to SQL查詢出來
var q = from p in db.Products
        where p.ProductID == 3
        select p;
//新建一個標準的ADO.NET連接:
SqlConnection nwindConn = new SqlConnection(connString);
nwindConn.Open();
//利用現有的ADO.NET連接來創建一個DataContext:
Northwind interop_db = new Northwind(nwindConn);
SqlTransaction nwindTxn = nwindConn.BeginTransaction();
try
{
  SqlCommand cmd = new SqlCommand( "UPDATE Products SET"
                 + "QuantityPerUnit = 'single item' WHERE ProductID = 3");
  cmd.Connection = nwindConn;
  cmd.Transaction = nwindTxn;
  cmd.ExecuteNonQuery();
  interop_db.Transaction = nwindTxn;
  Product prod1 = interop_db.Products.First(p => p.ProductID == 4);
  Product prod2 = interop_db.Products.First(p => p.ProductID == 5);
  prod1.UnitsInStock -= 3;
  prod2.UnitsInStock -= 5;
  
  //這有一個錯誤,不能為負數
  interop_db.SubmitChanges();
  nwindTxn.Commit();
}
catch (Exception e)
{
  //如果有一個錯誤,所有的操作回滾
  Console.WriteLine(e.Message);
}
nwindConn.Close();

語句描述:這個例子使用預先存在的 ADO.NET 連接創建 Northwind 物件,然後與此物件共用一個 ADO.NET 事務。此事務既用於通過 ADO.NET 連接執行 SQL 命令,又用於通過 Northwind 物件提交更改。當事務因違反 CHECK 約束而中止時,將回滾所有更改,包括通過 SqlCommand 做出的更改,以及通過Northwind 物件做出的更改。

3.直接執行SQL語句:

1.查詢

如果 LINQ to SQL 查詢不足以滿足專門任務的需要,我們可以使用 ExecuteQuery 方法來執行 SQL 查詢,然後將查詢的結果直接轉換成物件。

var products = db.ExecuteQuery<Product>(
             " SELECT [Product List].ProductID,[Product List].ProductName" 
             + " FROM Products AS [Product List] " 
             + " WHERE [Product List].Discontinued = 0 " 
             + " ORDER BY [Product List].ProductName;");

語句描述:這個例子使用ExecuteQuery<T>執行任意 SQL 查詢,並將所得的行映射為 Product 物件的序列。

2.命令

採用DataContext 連接時,可以使用ExecuteCommand來執行不返回物件的 SQL 命令。

db.ExecuteCommand("UPDATE Products SET UnitPrice = UnitPrice + 1.00");

語句描述:使用ExecuteCommand執行任意SQL命令,本例中為將所有產品單價提高 1.00 的批量更新。

arrow
arrow
    文章標籤
    LINQ LINQ to SQL
    全站熱搜

    Jimmy 發表在 痞客邦 留言(0) 人氣()