チェンジセット 1601 (default)

日時:

2023/09/06 11:29:56 (13ヵ月前)

更新者:

hizuya@…

ログメッセージ:

• TransactionScope に Owner と Orign プロパティを追加。
• TransactionScope.MarkToCommit に引数を増やしたオーバーロードを追加。

場所:

framework/trunk/CoreLibrary/Sources/Data

ファイル:

• DataModelManager.cs (更新) (12個の差分)
• TransactionScope.cs (更新) (2個の差分)

framework/trunk/CoreLibrary/Sources/Data/DataModelManager.cs

@@ -299 +299 @@
         protected TransactionScope EnsureTransaction()
         {
-            return (managerForTransaction ?? this).CreateTransactionScope();
+            return (managerForTransaction ?? this).CreateTransactionScope(this);
         }
 
@@ -305 +305 @@
         /// トランザクションスコープを作成して返します。
         /// </summary>
+        /// <param name="owner">
+        /// このトランザクションスコープを作成したインスタンス。
+        /// </param>
         /// <returns>
         /// 作成したトランザクションスコープ。
@@ -311 +314 @@
         /// このメソッドはトップレベルのマネージャからのみ呼ぶことが出来ます。
         /// </remarks>
-        private TransactionScope CreateTransactionScope()
+        private TransactionScope CreateTransactionScope(DataModelManager owner)
         {
             // 状態をチェック
             Debug.Assert(managerForTransaction == null, "Parent manager is not null.");
 
-            return new TransactionScopeImpl(GetTransactionManager());
+            return new TransactionScopeImpl(GetTransactionManager(), owner);
         }
 
@@ -334 +337 @@
 
             return transactionManager
-                ?? (transactionManager = new TransactionManager(connection, transaction));
+                ?? (transactionManager = new TransactionManager(this, connection, transaction));
         }
 
@@ -351 +354 @@
 
             /// <summary>
+            /// このトランザクションスコープを作成したインスタンス。
+            /// </summary>
+            [DebuggerBrowsable(DebuggerBrowsableState.Never)]
+            private readonly DataModelManager owner;
+
+            /// <summary>
             /// コミット可能かどうか。
             /// </summary>
@@ -372 +381 @@
             /// トランザクションマネージャ。
             /// </param>
-            internal TransactionScopeImpl(TransactionManager transactionManager)
+            /// <param name="owner">
+            /// このトランザクションスコープを作成したインスタンス。
+            /// </param>
+            internal TransactionScopeImpl(TransactionManager transactionManager, DataModelManager owner)
             {
                 this.transactionManager = transactionManager;
+                this.owner = owner;
 
                 transactionManager.AddReference();
@@ -394 +407 @@
             }
 
+            /// <summary>
+            /// トランザクションスコープを作成した大元のインスタンスを取得します。
+            /// </summary>
+            /// <value>
+            /// トランザクションスコープを作成した大元のインスタンス。
+            /// </value>
+            /// <remarks>
+            /// トランザクションスコープがネストした場合、一番最初にトランザクションスコープを作成したオブジェクトです。
+            /// このインスタンスがトップレベルのトランザクションスコープの場合、<see cref="Owner"/> と同じです。
+            /// </remarks>
+            public override object Origin
+            {
+                get
+                {
+                    return transactionManager.Manager;
+                }
+            }
+
+            /// <summary>
+            /// このトランザクションスコープを作成したインスタンスを取得します。
+            /// </summary>
+            /// <value>
+            /// このトランザクションスコープを作成したインスタンス。
+            /// </value>
+            public override object Owner
+            {
+                get
+                {
+                    return owner;
+                }
+            }
+
 
             /// <summary>
@@ -446 +491 @@
         {
             /// <summary>
+            /// データモデルマネージャ。
+            /// </summary>
+            [DebuggerBrowsable(DebuggerBrowsableState.Never)]
+            private readonly DataModelManager manager;
+
+            /// <summary>
             /// コネクション。
             /// </summary>
@@ -453 +504 @@
             /// トランザクション。
             /// </summary>
+            [DebuggerBrowsable(DebuggerBrowsableState.Never)]
             private ICommonDbTransaction transaction;
 
@@ -469 +521 @@
             /// </summary>
             private int referenceCount;
-           
+
 
             /// <summary>
             /// インスタンスを作成します。
             /// </summary>
+            /// <param name="manager">
+            /// 作成元のデータモデルマネージャ。
+            /// </param>
             /// <param name="connection">
             /// コネクション。
@@ -480 +535 @@
             /// トランザクション。
             /// </param>
-            internal TransactionManager(ICommonDbConnection connection, ICommonDbTransaction transaction)
-            {
+            internal TransactionManager(DataModelManager manager, ICommonDbConnection connection, ICommonDbTransaction transaction)
+            {
+                this.manager = manager;
                 if (transaction == null)
                 {
@@ -494 +550 @@
             }
 
+
+            /// <summary>
+            /// データモデルマネージャを取得します。
+            /// </summary>
+            /// <value>
+            /// データモデルマネージャ。
+            /// </value>
+            internal DataModelManager Manager
+            {
+                get
+                {
+                    return manager;
+                }
+            }
 
             /// <summary>

framework/trunk/CoreLibrary/Sources/Data/TransactionScope.cs

@@ -70 +70 @@
         }
 
+        /// <summary>
+        /// トランザクションスコープを作成した大元のインスタンスを取得します。
+        /// </summary>
+        /// <value>
+        /// トランザクションスコープを作成した大元のインスタンス。
+        /// </value>
+        /// <remarks>
+        /// トランザクションスコープがネストした場合、一番最初にトランザクションスコープを作成したオブジェクトです。
+        /// このインスタンスがトップレベルのトランザクションスコープの場合、<see cref="Owner"/> と同じです。
+        /// </remarks>
+        public abstract object Origin
+        {
+            get;
+        }
+
+        /// <summary>
+        /// このトランザクションスコープを作成したインスタンスを取得します。
+        /// </summary>
+        /// <value>
+        /// このトランザクションスコープを作成したインスタンス。
+        /// </value>
+        public abstract object Owner
+        {
+            get;
+        }
+
 
         /// <summary>
@@ -127 +153 @@
 
             T result = action();
+            MarkToCommit();
+            return result;
+        }
+
+        /// <summary>
+        /// アクションを実行し成功した場合に、
+        /// このトランザクションスコープが成功したことを通知し、コミットが行われるのを許可します。
+        /// </summary>
+        /// <typeparam name="T1">アクションの引数1の型。</typeparam>
+        /// <typeparam name="TResult">アクションの戻り値の型。</typeparam>
+        /// <param name="action">実行するアクション。</param>
+        /// <param name="arg1"><paramref name="action"/> の引数1。</param>
+        /// <returns>
+        /// アクションからの戻り値。
+        /// </returns>
+        /// <exception cref="ArgumentNullException">
+        /// <paramref name="action"/> が <see langword="null"/> 参照です。
+        /// </exception>
+        public TResult MarkToCommit<T1, TResult>(Func<T1, TResult> action, T1 arg1)
+        {
+            // 引数をチェック
+            if (action == null)
+            {
+                throw new ArgumentNullException("action");
+            }
+
+            TResult result = action(arg1);
+            MarkToCommit();
+            return result;
+        }
+
+        /// <summary>
+        /// アクションを実行し成功した場合に、
+        /// このトランザクションスコープが成功したことを通知し、コミットが行われるのを許可します。
+        /// </summary>
+        /// <typeparam name="T1">アクションの引数1の型。</typeparam>
+        /// <typeparam name="T2">アクションの引数2の型。</typeparam>
+        /// <typeparam name="TResult">アクションの戻り値の型。</typeparam>
+        /// <param name="action">実行するアクション。</param>
+        /// <param name="arg1"><paramref name="action"/> の引数1。</param>
+        /// <param name="arg2"><paramref name="action"/> の引数2。</param>
+        /// <returns>
+        /// アクションからの戻り値。
+        /// </returns>
+        /// <exception cref="ArgumentNullException">
+        /// <paramref name="action"/> が <see langword="null"/> 参照です。
+        /// </exception>
+        public TResult MarkToCommit<T1, T2, TResult>(Func<T1, T2, TResult> action, T1 arg1, T2 arg2)
+        {
+            // 引数をチェック
+            if (action == null)
+            {
+                throw new ArgumentNullException("action");
+            }
+
+            TResult result = action(arg1, arg2);
+            MarkToCommit();
+            return result;
+        }
+
+        /// <summary>
+        /// アクションを実行し成功した場合に、
+        /// このトランザクションスコープが成功したことを通知し、コミットが行われるのを許可します。
+        /// </summary>
+        /// <typeparam name="T1">アクションの引数1の型。</typeparam>
+        /// <typeparam name="T2">アクションの引数2の型。</typeparam>
+        /// <typeparam name="T3">アクションの引数3の型。</typeparam>
+        /// <typeparam name="TResult">アクションの戻り値の型。</typeparam>
+        /// <param name="action">実行するアクション。</param>
+        /// <param name="arg1"><paramref name="action"/> の引数1。</param>
+        /// <param name="arg2"><paramref name="action"/> の引数2。</param>
+        /// <param name="arg3"><paramref name="action"/> の引数3。</param>
+        /// <returns>
+        /// アクションからの戻り値。
+        /// </returns>
+        /// <exception cref="ArgumentNullException">
+        /// <paramref name="action"/> が <see langword="null"/> 参照です。
+        /// </exception>
+        public TResult MarkToCommit<T1, T2, T3, TResult>(Func<T1, T2, T3, TResult> action, T1 arg1, T2 arg2, T3 arg3)
+        {
+            // 引数をチェック
+            if (action == null)
+            {
+                throw new ArgumentNullException("action");
+            }
+
+            TResult result = action(arg1, arg2, arg3);
+            MarkToCommit();
+            return result;
+        }
+
+        /// <summary>
+        /// アクションを実行し成功した場合に、
+        /// このトランザクションスコープが成功したことを通知し、コミットが行われるのを許可します。
+        /// </summary>
+        /// <typeparam name="T1">アクションの引数1の型。</typeparam>
+        /// <typeparam name="T2">アクションの引数2の型。</typeparam>
+        /// <typeparam name="T3">アクションの引数3の型。</typeparam>
+        /// <typeparam name="T4">アクションの引数4の型。</typeparam>
+        /// <typeparam name="TResult">アクションの戻り値の型。</typeparam>
+        /// <param name="action">実行するアクション。</param>
+        /// <param name="arg1"><paramref name="action"/> の引数1。</param>
+        /// <param name="arg2"><paramref name="action"/> の引数2。</param>
+        /// <param name="arg3"><paramref name="action"/> の引数3。</param>
+        /// <param name="arg4"><paramref name="action"/> の引数4。</param>
+        /// <returns>
+        /// アクションからの戻り値。
+        /// </returns>
+        /// <exception cref="ArgumentNullException">
+        /// <paramref name="action"/> が <see langword="null"/> 参照です。
+        /// </exception>
+        public TResult MarkToCommit<T1, T2, T3, T4, TResult>(Func<T1, T2, T3, T4, TResult> action, T1 arg1, T2 arg2, T3 arg3, T4 arg4)
+        {
+            // 引数をチェック
+            if (action == null)
+            {
+                throw new ArgumentNullException("action");
+            }
+
+            TResult result = action(arg1, arg2, arg3, arg4);
             MarkToCommit();
             return result;