Test

Author: SebastianStehle

src/PhenX.EntityFrameworkCore.BulkInsert.MySql/MySqlBulkInsertProvider.cs

@@ -37,9 +37,14 @@ CancellationToken ctk
     )
     {
         var connection = (MySqlConnection)context.Database.GetDbConnection();
-        var sqlTransaction = context.Database.CurrentTransaction!.GetDbTransaction() as MySqlTransaction;
+        var sqlTransaction = context.Database.CurrentTransaction!.GetDbTransaction()
+            ?? throw new InvalidOperationException("No open transaction found.");
+        if (sqlTransaction is not MySqlTransaction mySqlTransaction)
+        {
+            throw new InvalidOperationException($"Invalid transaction foud, got {sqlTransaction.GetType()}.");
+        }
 
-        var bulkCopy = new MySqlBulkCopy(connection, sqlTransaction);
+        var bulkCopy = new MySqlBulkCopy(connection, mySqlTransaction);
         bulkCopy.DestinationTableName = tableName;
         bulkCopy.BulkCopyTimeout = 60;
 

tests/PhenX.EntityFrameworkCore.BulkInsert.Tests/Tests/Basic/BasicTestsBase.cs

@@ -244,7 +244,7 @@ await _context.ExecuteBulkInsertAsync(entities, o =>
         Assert.Contains(insertedEntities, e => e.Name == $"{_run}_Entity2");
     }
 
-    [Fact]
+    [SkippableFact]
     public async Task InsertsEntitiesWithConflict_DoNothing()
     {
         Skip.If(_context.Database.ProviderName!.Contains("Mysql", StringComparison.InvariantCultureIgnoreCase));