コミット: a62016050ef8f95981a88a15ef4b6eba1d5cccab - CleanAuLait48.Db (git)

コミットメタ情報

• リビジョン: a62016050ef8f95981a88a15ef4b6eba1d5cccab (tree)
• 日時: 2022-05-27 23:07:55
• 作者: yoshy <yoshy.org.bitbucket@gz.j...>
• コミッター: yoshy

ログメッセージ

[ADD] 手動でトランザクションを終端できる機能を追加

変更サマリ

• modified: Adaptor/Controller/Handler/Tx/AbstractAsyncDbTransactionHandler.cs
• modified: Adaptor/Controller/Handler/Tx/AbstractDbTransactionHandler.cs
• modified: OuterEdge/Repository/Db/Tx/DbTransactionWrapper.cs
• modified: OuterEdge/Repository/Db/Tx/IDbTransactionWrapper.cs

差分

--- a/Adaptor/Controller/Handler/Tx/AbstractAsyncDbTransactionHandler.cs
+++ b/Adaptor/Controller/Handler/Tx/AbstractAsyncDbTransactionHandler.cs
@@ -39,13 +39,27 @@ namespace CleanAuLait48.Adaptor.Controller.Handler.tx
                     {
                         UseCaseResponse res = await context.HandleNextAsync(req, context);
 
-                        tx.Commit(false);
+                        if (!tx.IsTerminated)
+                        {
+                            tx.Commit(false);
+                        }
+                        else
+                        {
+                            logger.Trace("トランザクション境界 [{0}] は手動で終端されているためコミットをスキップします。", name);
+                        }
 
                         return res;
                     }
                     catch (Exception)
                     {
-                        tx.Rollback(false);
+                        if (!tx.IsTerminated)
+                        {
+                            tx.Rollback(false);
+                        }
+                        else
+                        {
+                            logger.Trace("トランザクション境界 [{0}] は手動で終端されているためロールバックをスキップします。", name);
+                        }
 
                         throw;
                     }

--- a/Adaptor/Controller/Handler/Tx/AbstractDbTransactionHandler.cs
+++ b/Adaptor/Controller/Handler/Tx/AbstractDbTransactionHandler.cs
@@ -38,15 +38,27 @@ namespace CleanAuLait48.Adaptor.Controller.Handler.tx
                     {
                         UseCaseResponse res = context.HandleNext(req, context);
 
-                        tx.Commit(false);
+                        if (!tx.IsTerminated)
+                        {
+                            tx.Commit(false);
+                        }
+                        else
+                        {
+                            logger.Trace("トランザクション境界 [{0}] は手動で終端されているためコミットをスキップします。", name);
+                        }
 
                         return res;
                     }
-                    catch (Exception e)
+                    catch (Exception)
                     {
-                        logger.Error(e, "例外がスローされたためロールバックします");
-
-                        tx.Rollback(false);
+                        if (!tx.IsTerminated)
+                        {
+                            tx.Rollback(false);
+                        }
+                        else
+                        {
+                            logger.Trace("トランザクション境界 [{0}] は手動で終端されているためロールバックをスキップします。", name);
+                        }
 
                         throw;
                     }

--- a/OuterEdge/Repository/Db/Tx/DbTransactionWrapper.cs
+++ b/OuterEdge/Repository/Db/Tx/DbTransactionWrapper.cs
@@ -9,13 +9,14 @@ namespace CleanAuLait48.OuterEdge.Repository.Db.Tx
     {
         private static readonly ILogger logger = LogManager.GetCurrentClassLogger();
 
+        public bool IsTerminated { get; private set; }
+
+        private readonly string name;
+
         private readonly ITransactionManager txMan;
         private IDbConnectionWrapper conn;
         private IDbTransaction tx;
 
-        private readonly string name;
-
-        private bool terminatedValue;
         private bool disposedValue;
 
         public IDbConnection Connection => this.tx.Connection;
@@ -36,7 +37,15 @@ namespace CleanAuLait48.OuterEdge.Repository.Db.Tx
                     name, ToRawConnID(), ToTransactionID());
         }
 
-        private void SwitchTransaction(bool needNewTx)
+        public void TerminateTransaction()
+        {
+            logger.Trace("DB接続 [{0}] {1}: トランザクションを手動で終端します",
+                name, ToRawConnID());
+
+            TerminateTransaction(false);
+        }
+
+        private void TerminateTransaction(bool needNewTx)
         {
             if (this.tx != null)
             {
@@ -49,9 +58,18 @@ namespace CleanAuLait48.OuterEdge.Repository.Db.Tx
             if (!needNewTx)
             {
                 this.tx = null;
-                this.terminatedValue = true;
+                this.IsTerminated = true;
                 logger.Trace("DB接続 [{0}] {1}: トランザクションを終端しました",
                     name, ToRawConnID());
+            }
+        }
+
+        private void SwitchTransaction(bool needNewTx)
+        {
+            TerminateTransaction(needNewTx);
+
+            if (!needNewTx)
+            {
                 return;
             }
 
@@ -81,7 +99,7 @@ namespace CleanAuLait48.OuterEdge.Repository.Db.Tx
 
         public void Commit(bool needNewTx)
         {
-            if (this.terminatedValue)
+            if (this.IsTerminated)
             {
                 logger.Trace("DB接続 [{0}]: トランザクションは終端されているため、コミットできません", name);
                 return;
@@ -105,7 +123,7 @@ namespace CleanAuLait48.OuterEdge.Repository.Db.Tx
 
         public void Rollback(bool needNewTx)
         {
-            if (this.terminatedValue)
+            if (this.IsTerminated)
             {
                 logger.Trace("DB接続 [{0}]: トランザクションは終端されているため、ロールバックできません", name);
                 return;
@@ -130,7 +148,7 @@ namespace CleanAuLait48.OuterEdge.Repository.Db.Tx
                 {
                     // TODO: マネージド状態を破棄します (マネージド オブジェクト)
 
-                    if (!this.terminatedValue)
+                    if (!this.IsTerminated)
                     {
                         logger.Trace("DB接続 [{0}] {1}: トランザクション {2} の破棄が開始されました",
                             name, ToRawConnID(), ToTransactionID());

--- a/OuterEdge/Repository/Db/Tx/IDbTransactionWrapper.cs
+++ b/OuterEdge/Repository/Db/Tx/IDbTransactionWrapper.cs
@@ -4,6 +4,8 @@ namespace CleanAuLait48.OuterEdge.Repository.Db.Tx
 {
     public interface IDbTransactionWrapper : IDbTransaction
     {
+        bool IsTerminated { get; }
+        void TerminateTransaction();
         void Commit(bool needNewTx);
         void Rollback(bool needNewTx);
     }