Skip to content

Commit 99dec5e

Browse files
author
fabien.menager
committed
Fix merge issues
1 parent dbb8aa4 commit 99dec5e

1 file changed

Lines changed: 4 additions & 6 deletions

File tree

src/PhenX.EntityFrameworkCore.BulkInsert/BulkInsertProviderBase.cs

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
namespace PhenX.EntityFrameworkCore.BulkInsert;
1414

1515
#pragma warning disable CS9113 // Parameter is unread.
16-
internal abstract class BulkInsertProviderBase<TDialect, TOptions>(ILogger<BulkInsertProviderBase<TDialect>>? logger = null) : IBulkInsertProvider
16+
internal abstract class BulkInsertProviderBase<TDialect, TOptions>(ILogger<BulkInsertProviderBase<TDialect, TOptions>>? logger = null) : IBulkInsertProvider
1717
#pragma warning restore CS9113 // Parameter is unread.
1818
where TDialect : SqlDialectBuilder, new()
1919
where TOptions : BulkInsertOptions, new()
@@ -24,7 +24,7 @@ internal abstract class BulkInsertProviderBase<TDialect, TOptions>(ILogger<BulkI
2424

2525
protected abstract string CreateTableCopySql { get; }
2626
protected abstract string AddTableCopyBulkInsertId { get; }
27-
27+
2828
SqlDialectBuilder IBulkInsertProvider.SqlDialect => SqlDialect;
2929

3030
protected async Task<string> CreateTableCopyAsync<T>(
@@ -151,10 +151,8 @@ public virtual async Task<List<T>> BulkInsertReturnEntities<T>(
151151
{
152152
throw new InvalidOperationException($"Invalid options type: {options.GetType().Name}. Expected: {typeof(TOptions).Name}");
153153
}
154-
155-
List<T> result;
156154

157-
var (connection, wasClosed, transaction, wasBegan) = await context.GetConnection(sync, ctk);
155+
List<T> result;
158156

159157
var connectionInfo = await context.GetConnection(sync, ctk);
160158
try
@@ -243,7 +241,7 @@ public virtual async Task BulkInsert<T>(
243241
var connectionInfo = await context.GetConnection(sync, ctk);
244242
try
245243
{
246-
var (tableName, _) = await PerformBulkInsertAsync(sync, context, tableInfo, entities, options, tempTableRequired: true, ctk: ctk);
244+
var (tableName, _) = await PerformBulkInsertAsync(sync, context, tableInfo, entities, providerOptions, tempTableRequired: true, ctk: ctk);
247245

248246
await CopyFromTempTableAsync<T>(sync, context, tableInfo, tableName, false, providerOptions, onConflict, ctk);
249247

0 commit comments

Comments
 (0)