ADO.NET および LINQ to SQL

[アーティクル]
04/27/2011

LINQ to SQL は、ADO.NET テクノロジファミリの一部です。 ADO.NET プロバイダーモデルから提供されるサービスに基づいて動作します。したがって、LINQ to SQL コードを既存の ADO.NET アプリケーションに混在させ、現在の ADO.NET ソリューションを LINQ to SQL に統合することができます。次の図は、この関係を高いレベルから見たものです。

LINQ to SQL および ADO.NET

接続

LINQ to SQL DataContext を作成するときには、既存の ADO.NET 接続を指定します。 DataContext に対するすべての操作 (クエリを含む) で、この接続が使用されます。接続が既に開いていた場合、LINQ to SQL では使い終わった後も接続をそのままにします。

Dim conString = "Data Source=.\SQLEXPRESS;AttachDbFilename=c:\northwind.mdf; Integrated Security=True;Connect Timeout=30;User Instance=True"
Dim northwindCon = New SqlConnection(conString)
northwindCon.Open()

Dim db = New Northwnd("...")
Dim northwindTransaction = northwindCon.BeginTransaction()

Try
    Dim cmd = New SqlCommand( _
            "UPDATE Products SET QuantityPerUnit = 'single item' " & _
            "WHERE ProductID = 3")
    cmd.Connection = northwindCon
    cmd.Transaction = northwindTransaction
    cmd.ExecuteNonQuery()

    db.Transaction = northwindTransaction

    Dim prod1 = (From prod In db.Products _
  Where prod.ProductID = 4).First
    Dim prod2 = (From prod In db.Products _
  Where prod.ProductID = 5).First
    prod1.UnitsInStock -= 3
    prod2.UnitsInStock -= 5

    db.SubmitChanges()

    northwindTransaction.Commit()

Catch e As Exception

    Console.WriteLine(e.Message)
    Console.WriteLine("Error submitting changes... " & _
"all changes rolled back.")
End Try

northwindCon.Close()

string connString = @"Data Source=.\SQLEXPRESS;AttachDbFilename=c:\northwind.mdf;
    Integrated Security=True; Connect Timeout=30; User Instance=True";
SqlConnection nwindConn = new SqlConnection(connString);
nwindConn.Open();

Northwnd interop_db = new Northwnd(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);
    Console.WriteLine("Error submitting changes... all changes rolled back.");
}

nwindConn.Close();

次のコードに示すとおり、Connection プロパティを使用して、いつでも接続にアクセスしたり、任意に閉じたりすることができます。

db.Connection.Close()

db.Connection.Close();

トランザクション

既に独自のデータベーストランザクションを初期化していて、DataContext をトランザクションに使用する必要がある場合は、DataContext をトランザクションに渡すことができます。

.NET Framework でトランザクションを実行する場合は、TransactionScope オブジェクトの使用をお勧めします。この方法を使うと、データベースと他のメモリ常駐リソースマネージャー間で動作する分散トランザクションを作成できます。トランザクションスコープは、わずかなリソースで開始されます。トランザクションのスコープ内に複数の接続がある場合のみ、このトランザクションは分散トランザクションに昇格します。

Using ts As New TransactionScope()
    db.SubmitChanges()
    ts.Complete()
End Using

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

この方法は、すべてのデータベースに使用できるわけではありません。たとえば、SqlClient 接続を SQL Server 2000 サーバーに使用する場合、この接続はシステムトランザクションに昇格できません。代わりに、トランザクションスコープが使用されているときは、完全な分散トランザクションに自動的に参加します。

直接 SQL コマンド

ときには、クエリを実行したり変更内容を送信したりする DataContext 機能に不足があり、実行する必要がある特別なタスクを完了できないこともあります。このような場合は、ExecuteQuery メソッドを使用して、SQL コマンドをデータベースに発行し、クエリ結果をオブジェクトに変換することができます。

たとえば、Customer クラスのデータが 2 つのテーブル (customer1 および customer2) に含まれているとします。次のクエリは Customer オブジェクトのシーケンスを返します。

    Dim results As IEnumerable(Of Customer) = _
db.ExecuteQuery(Of Customer)( _
"SELECT [c1].custID as CustomerID," & _
    "[c2].custName as ContactName" & _
    "FROM customer1 AS [c1], customer2 as [c2]" & _
    "WHERE [c1].custid = [c2].custid")

            IEnumerable<Customer> results = db.ExecuteQuery<Customer>(
    @"select c1.custid as CustomerID, c2.custName as ContactName
        from customer1 as c1, customer2 as c2
        where c1.custid = c2.custid"
);

表形式の結果の列名がエンティティクラスの列のプロパティと一致する限り、LINQ to SQL は SQL クエリからオブジェクトを作成します。

パラメーター

ExecuteQuery メソッドは、パラメーターを受け取ります。次のコードでは、パラメーター化されたクエリが実行されます。

    Dim results As IEnumerable(Of Customer) = _
db.ExecuteQuery(Of Customer)( _
    "SELECT contactname FROM customers WHERE city = {0}, 'London'")
End Sub

            IEnumerable<Customer> results = db.ExecuteQuery<Customer>(
    "select contactname from customers where city = {0}",
    "London"
);

メモ
パラメーターは、Console.WriteLine() および String.Format() で使用されるものと同じ中かっこ表記でクエリテキストに表現されます。String.Format() は、指定されたクエリ文字列を受け取り、中かっこで囲まれたパラメーターを、@p0、@p1 …、@p(n) などの、生成されたパラメーター名に置き換えます。

参照

処理手順

方法 : ADO.NET コマンドおよび DataContext 間の接続を再利用する (LINQ to SQL)

その他の技術情報

背景情報 (LINQ to SQL)

次の方法で共有