Add a new parameter IsolationLevel for BeginTransaction method.

Author: yang-xiaodong

src/DotNetCore.CAP.MySql/ICapTransaction.MySql.cs

@@ -8,6 +8,7 @@
 using System.Threading;
 using System.Threading.Tasks;
 using DotNetCore.CAP.Transport;
+using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Infrastructure;
 using Microsoft.EntityFrameworkCore.Storage;
 using Microsoft.Extensions.DependencyInjection;
@@ -119,7 +120,7 @@ public static ICapTransaction Begin(this ICapTransaction transaction,
     /// <param name="database">The <see cref="DatabaseFacade" />.</param>
     /// <param name="publisher">The <see cref="ICapPublisher" />.</param>
     /// <param name="autoCommit">Whether the transaction is automatically committed when the message is published</param>
-    /// <returns>The <see cref="IDbContextTransaction" /> of EF dbcontext transaction object.</returns>
+    /// <returns>The <see cref="IDbContextTransaction" /> of EF DbContext transaction object.</returns>
     public static IDbContextTransaction BeginTransaction(this DatabaseFacade database,
         ICapPublisher publisher, bool autoCommit = false)
     {
@@ -129,6 +130,23 @@ public static IDbContextTransaction BeginTransaction(this DatabaseFacade databas
         return new CapEFDbTransaction(capTrans);
     }
 
+    /// <summary>
+    /// Start the CAP transaction
+    /// </summary>
+    /// <param name="database">The <see cref="DatabaseFacade" />.</param>
+    /// <param name="publisher">The <see cref="ICapPublisher" />.</param>
+    /// <param name="isolationLevel">The <see cref="IsolationLevel" /> to use</param>
+    /// <param name="autoCommit">Whether the transaction is automatically committed when the message is published</param>
+    /// <returns>The <see cref="IDbContextTransaction" /> of EF DbContext transaction object.</returns>
+    public static IDbContextTransaction BeginTransaction(this DatabaseFacade database,
+        IsolationLevel isolationLevel, ICapPublisher publisher, bool autoCommit = false)
+    {
+        var trans = database.BeginTransaction(isolationLevel);
+        publisher.Transaction.Value = ActivatorUtilities.CreateInstance<MySqlCapTransaction>(publisher.ServiceProvider);
+        var capTrans = publisher.Transaction.Value.Begin(trans, autoCommit);
+        return new CapEFDbTransaction(capTrans);
+    }
+
     /// <summary>
     /// Start the CAP transaction
     /// </summary>

src/DotNetCore.CAP.PostgreSql/ICapTransaction.PostgreSql.cs

@@ -8,6 +8,7 @@
 using System.Threading;
 using System.Threading.Tasks;
 using DotNetCore.CAP.Transport;
+using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Infrastructure;
 using Microsoft.EntityFrameworkCore.Storage;
 using Microsoft.Extensions.DependencyInjection;
@@ -144,5 +145,22 @@ public static IDbContextTransaction BeginTransaction(this DatabaseFacade databas
             var capTrans = publisher.Transaction.Value.Begin(trans, autoCommit);
             return new CapEFDbTransaction(capTrans);
         }
+
+        /// <summary>
+        /// Start the CAP transaction
+        /// </summary>
+        /// <param name="database">The <see cref="DatabaseFacade" />.</param>
+        /// <param name="publisher">The <see cref="ICapPublisher" />.</param>
+        /// <param name="isolationLevel">The <see cref="IsolationLevel" /> to use</param>
+        /// <param name="autoCommit">Whether the transaction is automatically committed when the message is published</param>
+        /// <returns>The <see cref="IDbContextTransaction" /> of EF DbContext transaction object.</returns>
+        public static IDbContextTransaction BeginTransaction(this DatabaseFacade database,
+            IsolationLevel isolationLevel, ICapPublisher publisher, bool autoCommit = false)
+        {
+            var trans = database.BeginTransaction(isolationLevel);
+            publisher.Transaction.Value = ActivatorUtilities.CreateInstance<PostgreSqlCapTransaction>(publisher.ServiceProvider);
+            var capTrans = publisher.Transaction.Value.Begin(trans, autoCommit);
+            return new CapEFDbTransaction(capTrans);
+        }
     }
 }

src/DotNetCore.CAP.SqlServer/ICapTransaction.SqlServer.cs

@@ -12,6 +12,7 @@
 using DotNetCore.CAP.SqlServer.Diagnostics;
 using DotNetCore.CAP.Transport;
 using Microsoft.Data.SqlClient;
+using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Infrastructure;
 using Microsoft.EntityFrameworkCore.Storage;
 using Microsoft.Extensions.DependencyInjection;
@@ -177,7 +178,7 @@ public static IDbTransaction BeginTransaction(this IDbConnection dbConnection,
     /// <param name="database">The <see cref="DatabaseFacade" />.</param>
     /// <param name="publisher">The <see cref="ICapPublisher" />.</param>
     /// <param name="autoCommit">Whether the transaction is automatically committed when the message is published</param>
-    /// <returns>The <see cref="IDbContextTransaction" /> of EF dbcontext transaction object.</returns>
+    /// <returns>The <see cref="IDbContextTransaction" /> of EF DbContext transaction object.</returns>
     public static IDbContextTransaction BeginTransaction(this DatabaseFacade database,
         ICapPublisher publisher, bool autoCommit = false)
     {
@@ -187,4 +188,21 @@ public static IDbContextTransaction BeginTransaction(this DatabaseFacade databas
         var capTrans = publisher.Transaction.Value.Begin(trans, autoCommit);
         return new CapEFDbTransaction(capTrans);
     }
+
+    /// <summary>
+    /// Start the CAP transaction
+    /// </summary>
+    /// <param name="database">The <see cref="DatabaseFacade" />.</param>
+    /// <param name="publisher">The <see cref="ICapPublisher" />.</param>
+    /// <param name="isolationLevel">The <see cref="IsolationLevel" /> to use</param>
+    /// <param name="autoCommit">Whether the transaction is automatically committed when the message is published</param>
+    /// <returns>The <see cref="IDbContextTransaction" /> of EF DbContext transaction object.</returns>
+    public static IDbContextTransaction BeginTransaction(this DatabaseFacade database,
+        IsolationLevel isolationLevel, ICapPublisher publisher, bool autoCommit = false)
+    {
+        var trans = database.BeginTransaction(isolationLevel);
+        publisher.Transaction.Value = ActivatorUtilities.CreateInstance<SqlServerCapTransaction>(publisher.ServiceProvider);
+        var capTrans = publisher.Transaction.Value.Begin(trans, autoCommit);
+        return new CapEFDbTransaction(capTrans);
+    }
 }