C# と VB.NET の質問掲示板

お世話になっております。
環境：VS2013 VB.NET






Using db = New SomeDataContext(...)

    db.Connection.Open()
    db.Transaction = db.Connection.BeginTransaction()

    ' Insert
    db.Student.InsertOnSubmit(New Student() With {.Id = 1, .Name = "a"})
    db.SubmitChanges()

    ' Delete
    db.ExecuteCommand("delete from Student where Id = 1")
    db.SubmitChanges()

    '' Delete
    'db.Student.DeleteOnSubmit(db.Student.Single(Function(m) m.Id = 1))
    'db.SubmitChanges()

    ' Insert
    db.Student.InsertOnSubmit(New Student() With {.Id = 1, .Name = "a"})
    db.SubmitChanges()
End Using

■No85824 (ぬる さん) に返信

想像するばかりでは何なので No85827 で書いたことが正しいかどうか実際にコードを
書いて検証してみました。

DataContext にアタッチされたエンティティの状態を調べる方法が分からなかったので、それは調べ
ていませんが、 No85827 で書いた、

(a) 上記 (5) で InsertOnSubmit に代えて ExecuteCommand("insert ...") を使う、or

(b) furu さんの言われるようにコンテキストにアタッチされるエンティティを最新のものにしてから
　　db.Student.InsertOnSubmit ⇒ db.SubmitChanges を行う。

・・・で期待通りの結果になることは確認できました。なので、No85827 で書いた想像は当たっている
のではないかと思います。

ちなみに検証に使ったコードは以下の通りです。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace ConsoleAppLinqToSQL
{
    class Program
    {
        static void Main(string[] args)
        {
            using (var db = new DataClasses1DataContext())
            {
                var query = from item in db.Table
                            select item;

                foreach (Table table in query)
                {
                    Console.WriteLine("Id={0}, Name={1}, Price={2}", table.Id, table.Name, table.Price);
                }

                db.Table.InsertOnSubmit(new Table() { Id = 15, Name = "ABCDEF", Price = 100 });
                db.SubmitChanges();

                db.ExecuteCommand("delete from [Table] where Id = 15");
                // 以下のコードは意味なし ⇒ コメントアウト
                //db.SubmitChanges();

                // これは SubmitChanges でエラー
                //db.Table.InsertOnSubmit(new Table() { Id = 15, Name = "ACB", Price = 100 });
                //db.SubmitChanges();

                // これは OK
                db.ExecuteCommand("insert into [Table] (Id,Name,Price) values (15,'newABC',200)");
            }

            //　上の db.ExecuteCommand("insert ..."); に代えて以下のようにしても OK 
            //using (var db = new DataClasses1DataContext())
            //{
            //    db.Table.InsertOnSubmit(new Table() { Id = 15, Name = "newABC", Price = 200 });
            //    db.SubmitChanges();
            //}
        }
    }
}

■No85913 (ぬる さん) に返信

検証結果の連絡をありがとうございました。

自分でもちょっと調べてみましたが、以下の記事に書いてあるように Linq to SQL は ADO.NET 上で動いていて、
その記事の「接続」のセクションに書いてあるように、ADO.NET コマンドと DataContext の間で接続を共有でき
るようです。

ADO.NET and LINQ to SQLADO.NET および LINQ to SQL
https://docs.microsoft.com/ja-jp/dotnet/framework/data/adonet/sql/linq/ado-net-and-linq-to-sql

なので、最初の質問にあった、

> ' Delete
> db.ExecuteCommand("delete from Student where Id = 1")

もトランザクションに束ねることはできるということのようですね。

ADO.NET コマンドと DataContext の間で接続を共有できるのであれば、異なる DataContext の間でも接続を
共有できるのではないかと思って調べてみました。

一応以下のコードで可能でした。（ホントにこれでいいのか自信はありません。どこかに見落としがあるかも。
分散トランザクションが使えるならそちらの方が良いと思います）

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Data.SqlClient;

namespace ConsoleAppLinqToSQL
{
    class Program
    {
        static void Main(string[] args)
        {
            string connString = ConsoleAppLinqToSQL.Properties.Settings.Default.TestDatabaseConnectionString;
            SqlConnection connection = new SqlConnection(connString);

            try
            {
                connection.Open();
                SqlTransaction sqltx = connection.BeginTransaction();

                using (var db = new DataClasses1DataContext(connection))
                {
                    db.Transaction = sqltx;

                    db.Table.InsertOnSubmit(new Table() { Id = 15, Name = "ABCDEF", Price = 100 });
                    db.SubmitChanges();

                    db.ExecuteCommand("delete from [Table] where Id = 15");
                }

                using (var db = new DataClasses1DataContext(connection))
                {
                    db.Transaction = sqltx;

                    db.Table.InsertOnSubmit(new Table() { Id = 15, Name = "newABC", Price = 200 });
                    db.SubmitChanges();
                }

                // Commit するまでは SSMS から Table を読めない（ロックされている？）
                // Commit されると SSMS から Table を読める。上の最後の InsertOnSubmit が反映されている
                // コメントアウトすると Close で Rollback され、上記の結果は SQL Server には反映されない
                sqltx.Commit();
            }
            finally
            {
                // 未コミット状態のトランザクションは Close でロールバックされるので
                // 明示的に Rollback をかける必要はない
                connection.Close();
            }
        }
    }
}