Remove Single Id Parameter Support

phongnguyend · phongnguyend · commit 312748614b7f · 2025-10-30T21:49:08.000+07:00
diff --git a/README.md b/README.md
@@ -79,7 +79,7 @@ await dbct.BulkUpdateAsync(compositeKeyRows,
     [ "Column3", "Column2" ]);
 
 await dbct.BulkMergeAsync(rows,
-    "Id",
+    ["Id"],
     [ "Column1", "Column2" ],
     [ "Column1", "Column2", "Column3" ]);
 await dbct.BulkMergeAsync(compositeKeyRows,
@@ -150,22 +150,22 @@ await connection.BulkInsertAsync(compositeKeyRows,
            [ "Id1", "Id2", "Column1", "Column2", "Column3" ]);
 
 await connection.BulkUpdateAsync(rows,
-           "Id",
+           ["Id"],
            [ "Column3", "Column2" ]);
 await connection.BulkUpdateAsync(compositeKeyRows,
            [ "Id1", "Id2" ],
            [ "Column3", "Column2" ]);
 
 await connection.BulkMergeAsync(rows,
-           "Id",
+           ["Id"],
            [ "Column1", "Column2" ],
            [ "Column1", "Column2", "Column3" ]);
 await connection.BulkMergeAsync(compositeKeyRows,
            [ "Id1", "Id2" ],
            [ "Column1", "Column2", "Column3" ],
            [ "Id1", "Id2", "Column1", "Column2", "Column3" ]);
 
-await connection.BulkDeleteAsync(rows, "Id");
+await connection.BulkDeleteAsync(rows, ["Id"]);
 await connection.BulkDeleteAsync(compositeKeyRows, [ "Id1", "Id2" ]);
 ```
 ### Using Builder Approach in case you need to mix both Dynamic & Lambda Expression
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.ConnectionExtensionsTests/ConnectionExtensions/BulkDeleteAsyncTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.ConnectionExtensionsTests/ConnectionExtensions/BulkDeleteAsyncTests.cs
@@ -90,7 +90,7 @@ await connectionContext.BulkDeleteAsync(rows, row => row.Id,
         {
             if (omitTableName)
             {
-                await connectionContext.BulkDeleteAsync(rows, "Id",
+                await connectionContext.BulkDeleteAsync(rows, ["Id"],
                      options =>
              {
                  options.LogTo = _output.WriteLine;
@@ -103,7 +103,7 @@ await connectionContext.BulkDeleteAsync(compositeKeyRows, ["Id1", "Id2"],
             }
             else
             {
-                await connectionContext.BulkDeleteAsync(rows, new SqlTableInfor(_schema, "SingleKeyRows"), "Id",
+                await connectionContext.BulkDeleteAsync(rows, new SqlTableInfor(_schema, "SingleKeyRows"), ["Id"],
             options =>
                      {
                          options.LogTo = _output.WriteLine;
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.ConnectionExtensionsTests/ConnectionExtensions/BulkDeleteTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.ConnectionExtensionsTests/ConnectionExtensions/BulkDeleteTests.cs
@@ -90,7 +90,7 @@ public void Bulk_Delete_Without_Transaction(bool useLinq, bool omitTableName)
         {
             if (omitTableName)
             {
-                connectionContext.BulkDelete(rows, "Id",
+                connectionContext.BulkDelete(rows, ["Id"],
               options =>
                 {
                     options.LogTo = _output.WriteLine;
@@ -103,7 +103,7 @@ public void Bulk_Delete_Without_Transaction(bool useLinq, bool omitTableName)
             }
             else
             {
-                connectionContext.BulkDelete(rows, new SqlTableInfor(_schema, "SingleKeyRows"), "Id",
+                connectionContext.BulkDelete(rows, new SqlTableInfor(_schema, "SingleKeyRows"), ["Id"],
               options =>
               {
                   options.LogTo = _output.WriteLine;
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.ConnectionExtensionsTests/ConnectionExtensions/BulkUpdateAsyncTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.ConnectionExtensionsTests/ConnectionExtensions/BulkUpdateAsyncTests.cs
@@ -182,7 +182,7 @@ await connectionContext.BulkMergeAsync(compositeKeyRows,
             if (omitTableName)
             {
                 await connectionContext.BulkUpdateAsync(rows,
-         "Id",
+         ["Id"],
             ["Column3", "Column2"],
                options =>
        {
@@ -200,7 +200,7 @@ await connectionContext.BulkUpdateAsync(compositeKeyRows,
             else
             {
                 await connectionContext.BulkUpdateAsync(rows, new SqlTableInfor(_schema, "SingleKeyRows"),
-                  "Id",
+                  ["Id"],
                        ["Column3", "Column2"],
                 options =>
                        {
@@ -241,7 +241,7 @@ await connectionContext.BulkUpdateAsync(compositeKeyRows,
             if (omitTableName)
             {
                 await connectionContext.BulkMergeAsync(rows,
-           "Id",
+           ["Id"],
          ["Column1", "Column2"],
                ["Column1", "Column2", "Column3"],
               options =>
@@ -261,7 +261,7 @@ await connectionContext.BulkMergeAsync(compositeKeyRows,
             else
             {
                 await connectionContext.BulkMergeAsync(rows, new SqlTableInfor(_schema, "SingleKeyRows"),
-            "Id",
+            ["Id"],
                      ["Column1", "Column2"],
                 ["Column1", "Column2", "Column3"],
                   options =>
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.ConnectionExtensionsTests/ConnectionExtensions/BulkUpdateTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.ConnectionExtensionsTests/ConnectionExtensions/BulkUpdateTests.cs
@@ -182,7 +182,7 @@ public void Bulk_Update_Without_Transaction(bool useLinq, bool omitTableName)
             if (omitTableName)
             {
                 connectionContext.BulkUpdate(rows,
-              "Id",
+              ["Id"],
                       ["Column3", "Column2"],
              options =>
                       {
@@ -200,7 +200,7 @@ public void Bulk_Update_Without_Transaction(bool useLinq, bool omitTableName)
             else
             {
                 connectionContext.BulkUpdate(rows, new SqlTableInfor(_schema, "SingleKeyRows"),
-                 "Id",
+                 ["Id"],
                     ["Column3", "Column2"],
                   options =>
                   {
@@ -241,7 +241,7 @@ public void Bulk_Update_Without_Transaction(bool useLinq, bool omitTableName)
             if (omitTableName)
             {
                 connectionContext.BulkMerge(rows,
-                   "Id",
+                   ["Id"],
             ["Column1", "Column2"],
                   ["Column1", "Column2", "Column3"],
               options =>
@@ -261,7 +261,7 @@ public void Bulk_Update_Without_Transaction(bool useLinq, bool omitTableName)
             else
             {
                 connectionContext.BulkMerge(rows, new SqlTableInfor(_schema, "SingleKeyRows"),
-                     "Id",
+                     ["Id"],
                 ["Column1", "Column2"],
                    ["Column1", "Column2", "Column3"],
               options =>
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.DbContextExtensionsTests/DbContextExtensions/BulkMergeAsyncTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.DbContextExtensionsTests/DbContextExtensions/BulkMergeAsyncTests.cs
@@ -211,7 +211,7 @@ public async Task BulkMerge_Using_Dynamic_String_With_Transaction(int length, in
         }
 
         var result1 = await _context.BulkMergeAsync(rows,
-            "Id",
+            ["Id"],
             ["Column1", "Column2", "Column3", "Season", "SeasonAsString"],
             ["Column1", "Column2", "Column3", "Season", "SeasonAsString"],
             options =>
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.DbContextExtensionsTests/DbContextExtensions/BulkMergeTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.DbContextExtensionsTests/DbContextExtensions/BulkMergeTests.cs
@@ -211,7 +211,7 @@ public void BulkMerge_Using_Dynamic_String_With_Transaction(int length, int inse
         }
 
         var result1 = _context.BulkMerge(rows,
-            "Id",
+            ["Id"],
             ["Column1", "Column2", "Column3", "Season", "SeasonAsString"],
             ["Column1", "Column2", "Column3", "Season", "SeasonAsString"],
             options =>
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.DbContextExtensionsTests/DbContextExtensions/BulkUpdateAsyncTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.DbContextExtensionsTests/DbContextExtensions/BulkUpdateAsyncTests.cs
@@ -230,7 +230,7 @@ public async Task Bulk_Update_Using_Dynamic_String_With_Transaction(int length)
         });
 
         await _context.BulkMergeAsync(rows,
-            "Id",
+            ["Id"],
             ["Column1", "Column2", "Season", "SeasonAsString"],
             ["Column1", "Column2", "Column3", "Season", "SeasonAsString"],
             options =>
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.DbContextExtensionsTests/DbContextExtensions/BulkUpdateTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.DbContextExtensionsTests/DbContextExtensions/BulkUpdateTests.cs
@@ -230,7 +230,7 @@ public void Bulk_Update_Using_Dynamic_String_With_Transaction(int length)
         });
 
         _context.BulkMerge(rows,
-            "Id",
+            ["Id"],
             ["Column1", "Column2", "Season", "SeasonAsString"],
             ["Column1", "Column2", "Column3", "Season", "SeasonAsString"],
             options =>
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.DbContextExtensionsTests/DbContextExtensions/UpsertAsyncTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.DbContextExtensionsTests/DbContextExtensions/UpsertAsyncTests.cs
@@ -253,7 +253,7 @@ public async Task Upsert_Existing_Using_Dynamic_String_With_Transaction(int leng
         existingCompositeKeyRows.SeasonAsString = Season.Spring;
 
         var result1 = await _context.UpsertAsync(existingRow,
-            "Id",
+            ["Id"],
             ["Column1", "Column2", "Column3", "Season", "SeasonAsString"],
             ["Column1", "Column2", "Column3", "Season", "SeasonAsString"],
             options =>
@@ -341,7 +341,7 @@ public async Task Upsert_NonExisting_Using_Dynamic_String_With_Transaction(int l
         };
 
         var result1 = await _context.UpsertAsync(newRow,
-            "Id",
+            ["Id"],
             ["Column1", "Column2", "Column3", "Season", "SeasonAsString"],
             ["Column1", "Column2", "Column3", "Season", "SeasonAsString"],
             options =>
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.DbContextExtensionsTests/DbContextExtensions/UpsertTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.DbContextExtensionsTests/DbContextExtensions/UpsertTests.cs
@@ -253,7 +253,7 @@ public void Upsert_Existing_Using_Dynamic_String_With_Transaction(int length)
         existingCompositeKeyRows.SeasonAsString = Season.Spring;
 
         var result1 = _context.Upsert(existingRow,
-            "Id",
+            ["Id"],
             ["Column1", "Column2", "Column3", "Season", "SeasonAsString"],
             ["Column1", "Column2", "Column3", "Season", "SeasonAsString"],
             options =>
@@ -341,7 +341,7 @@ public void Upsert_NonExisting_Using_Dynamic_String_With_Transaction(int length)
         };
 
         var result1 = _context.Upsert(newRow,
-            "Id",
+            ["Id"],
             ["Column1", "Column2", "Column3", "Season", "SeasonAsString"],
             ["Column1", "Column2", "Column3", "Season", "SeasonAsString"],
             options =>
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/BulkDeleteBuilder.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/BulkDeleteBuilder.cs
@@ -26,12 +26,6 @@ public BulkDeleteBuilder<T> ToTable(TableInfor table)
         return this;
     }
 
-    public BulkDeleteBuilder<T> WithId(string idColumn)
-    {
-        _idColumns = [idColumn];
-        return this;
-    }
-
     public BulkDeleteBuilder<T> WithId(IEnumerable<string> idColumns)
     {
         _idColumns = idColumns;
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/SqlConnectionAsyncExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/SqlConnectionAsyncExtensions.cs
@@ -19,17 +19,6 @@ public static Task<BulkDeleteResult> BulkDeleteAsync<T>(this ConnectionContext c
    .ExecuteAsync(data, cancellationToken);
     }
 
-    public static Task<BulkDeleteResult> BulkDeleteAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, string idColumn, Action<BulkDeleteOptions> configureOptions = null, CancellationToken cancellationToken = default)
-    {
-        var table = TableMapper.Resolve(typeof(T));
-
-        return new BulkDeleteBuilder<T>(connectionContext)
-     .WithId(idColumn)
-         .ToTable(table)
-     .ConfigureBulkOptions(configureOptions)
-            .ExecuteAsync(data, cancellationToken);
-    }
-
     public static Task<BulkDeleteResult> BulkDeleteAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, IEnumerable<string> idColumns, Action<BulkDeleteOptions> configureOptions = null, CancellationToken cancellationToken = default)
     {
         var table = TableMapper.Resolve(typeof(T));
@@ -50,15 +39,6 @@ public static Task<BulkDeleteResult> BulkDeleteAsync<T>(this ConnectionContext c
         .ExecuteAsync(data, cancellationToken);
     }
 
-    public static Task<BulkDeleteResult> BulkDeleteAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, string idColumn, Action<BulkDeleteOptions> configureOptions = null, CancellationToken cancellationToken = default)
-    {
-        return new BulkDeleteBuilder<T>(connectionContext)
-            .WithId(idColumn)
-        .ToTable(table)
-      .ConfigureBulkOptions(configureOptions)
-      .ExecuteAsync(data, cancellationToken);
-    }
-
     public static Task<BulkDeleteResult> BulkDeleteAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, IEnumerable<string> idColumns, Action<BulkDeleteOptions> configureOptions = null, CancellationToken cancellationToken = default)
     {
         return new BulkDeleteBuilder<T>(connectionContext)
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/SqlConnectionExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/SqlConnectionExtensions.cs
@@ -17,17 +17,6 @@ public static BulkDeleteResult BulkDelete<T>(this ConnectionContext connectionCo
       .Execute(data);
     }
 
-    public static BulkDeleteResult BulkDelete<T>(this ConnectionContext connectionContext, IEnumerable<T> data, string idColumn, Action<BulkDeleteOptions> configureOptions = null)
-    {
-        var table = TableMapper.Resolve(typeof(T));
-
-        return new BulkDeleteBuilder<T>(connectionContext)
- .WithId(idColumn)
-        .ToTable(table)
-  .ConfigureBulkOptions(configureOptions)
-            .Execute(data);
-    }
-
     public static BulkDeleteResult BulkDelete<T>(this ConnectionContext connectionContext, IEnumerable<T> data, IEnumerable<string> idColumns, Action<BulkDeleteOptions> configureOptions = null)
     {
         var table = TableMapper.Resolve(typeof(T));
@@ -48,15 +37,6 @@ public static BulkDeleteResult BulkDelete<T>(this ConnectionContext connectionCo
            .Execute(data);
     }
 
-    public static BulkDeleteResult BulkDelete<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, string idColumn, Action<BulkDeleteOptions> configureOptions = null)
-    {
-        return new BulkDeleteBuilder<T>(connectionContext)
-        .WithId(idColumn)
-                 .ToTable(table)
-       .ConfigureBulkOptions(configureOptions)
-                 .Execute(data);
-    }
-
     public static BulkDeleteResult BulkDelete<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, IEnumerable<string> idColumns, Action<BulkDeleteOptions> configureOptions = null)
     {
         return new BulkDeleteBuilder<T>(connectionContext)
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMerge/BulkMergeBuilder.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMerge/BulkMergeBuilder.cs
@@ -30,12 +30,6 @@ public BulkMergeBuilder<T> ToTable(TableInfor table)
         return this;
     }
 
-    public BulkMergeBuilder<T> WithId(string idColumn)
-    {
-        _idColumns = [idColumn];
-        return this;
-    }
-
     public BulkMergeBuilder<T> WithId(IEnumerable<string> idColumns)
     {
         _idColumns = idColumns;
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMerge/DbContextAsyncExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMerge/DbContextAsyncExtensions.cs
@@ -25,21 +25,6 @@ public static Task<BulkMergeResult> BulkMergeAsync<T>(this DbContext dbContext,
         .ExecuteAsync(data, cancellationToken);
     }
 
-    public static Task<BulkMergeResult> BulkMergeAsync<T>(this DbContext dbContext, IEnumerable<T> data, string idColumn, IEnumerable<string> updateColumnNames, IEnumerable<string> insertColumnNames, Action<BulkMergeOptions> configureOptions = null, CancellationToken cancellationToken = default)
-    {
-        var connectionContext = dbContext.GetConnectionContext();
-        var outputIdColumn = dbContext.GetOutputId(typeof(T))?.PropertyName;
-
-        return new BulkMergeBuilder<T>(connectionContext)
-   .WithId(idColumn)
-  .WithUpdateColumns(updateColumnNames)
-   .WithInsertColumns(insertColumnNames)
-      .WithOutputId(outputIdColumn)
-     .ToTable(dbContext.GetTableInfor(typeof(T)))
-      .ConfigureBulkOptions(configureOptions)
-     .ExecuteAsync(data, cancellationToken);
-    }
-
     public static Task<BulkMergeResult> BulkMergeAsync<T>(this DbContext dbContext, IEnumerable<T> data, IEnumerable<string> idColumns, IEnumerable<string> updateColumnNames, IEnumerable<string> insertColumnNames, Action<BulkMergeOptions> configureOptions = null, CancellationToken cancellationToken = default)
     {
         var connectionContext = dbContext.GetConnectionContext();
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMerge/DbContextExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMerge/DbContextExtensions.cs
@@ -23,21 +23,6 @@ public static BulkMergeResult BulkMerge<T>(this DbContext dbContext, IEnumerable
          .Execute(data);
     }
 
-    public static BulkMergeResult BulkMerge<T>(this DbContext dbContext, IEnumerable<T> data, string idColumn, IEnumerable<string> updateColumnNames, IEnumerable<string> insertColumnNames, Action<BulkMergeOptions> configureOptions = null)
-    {
-        var connectionContext = dbContext.GetConnectionContext();
-        var outputIdColumn = dbContext.GetOutputId(typeof(T))?.PropertyName;
-
-        return new BulkMergeBuilder<T>(connectionContext)
-    .WithId(idColumn)
-      .WithUpdateColumns(updateColumnNames)
-     .WithInsertColumns(insertColumnNames)
-         .WithOutputId(outputIdColumn)
-        .ToTable(dbContext.GetTableInfor(typeof(T)))
-      .ConfigureBulkOptions(configureOptions)
-     .Execute(data);
-    }
-
     public static BulkMergeResult BulkMerge<T>(this DbContext dbContext, IEnumerable<T> data, IEnumerable<string> idColumns, IEnumerable<string> updateColumnNames, IEnumerable<string> insertColumnNames, Action<BulkMergeOptions> configureOptions = null)
     {
         var connectionContext = dbContext.GetConnectionContext();
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMerge/SqlConnectionAsyncExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMerge/SqlConnectionAsyncExtensions.cs
@@ -21,19 +21,6 @@ public static Task<BulkMergeResult> BulkMergeAsync<T>(this ConnectionContext con
             .ExecuteAsync(data, cancellationToken);
     }
 
-    public static Task<BulkMergeResult> BulkMergeAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, string idColumn, IEnumerable<string> updateColumnNames, IEnumerable<string> insertColumnNames, Action<BulkMergeOptions> configureOptions = null, CancellationToken cancellationToken = default)
-    {
-        var table = TableMapper.Resolve(typeof(T));
-
-        return new BulkMergeBuilder<T>(connectionContext)
-            .WithId(idColumn)
-            .WithUpdateColumns(updateColumnNames)
-            .WithInsertColumns(insertColumnNames)
-            .ToTable(table)
-            .ConfigureBulkOptions(configureOptions)
-            .ExecuteAsync(data, cancellationToken);
-    }
-
     public static Task<BulkMergeResult> BulkMergeAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, IEnumerable<string> idColumns, IEnumerable<string> updateColumnNames, IEnumerable<string> insertColumnNames, Action<BulkMergeOptions> configureOptions = null, CancellationToken cancellationToken = default)
     {
         var table = TableMapper.Resolve(typeof(T));
@@ -58,17 +45,6 @@ public static Task<BulkMergeResult> BulkMergeAsync<T>(this ConnectionContext con
             .ExecuteAsync(data, cancellationToken);
     }
 
-    public static Task<BulkMergeResult> BulkMergeAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, string idColumn, IEnumerable<string> updateColumnNames, IEnumerable<string> insertColumnNames, Action<BulkMergeOptions> configureOptions = null, CancellationToken cancellationToken = default)
-    {
-        return new BulkMergeBuilder<T>(connectionContext)
-            .WithId(idColumn)
-            .WithUpdateColumns(updateColumnNames)
-            .WithInsertColumns(insertColumnNames)
-            .ToTable(table)
-            .ConfigureBulkOptions(configureOptions)
-            .ExecuteAsync(data, cancellationToken);
-    }
-
     public static Task<BulkMergeResult> BulkMergeAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, IEnumerable<string> idColumns, IEnumerable<string> updateColumnNames, IEnumerable<string> insertColumnNames, Action<BulkMergeOptions> configureOptions = null, CancellationToken cancellationToken = default)
     {
         return new BulkMergeBuilder<T>(connectionContext)
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMerge/SqlConnectionExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMerge/SqlConnectionExtensions.cs
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkUpdate/BulkUpdateBuilder.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkUpdate/BulkUpdateBuilder.cs
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkUpdate/SqlConnectionAsyncExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkUpdate/SqlConnectionAsyncExtensions.cs
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkUpdate/SqlConnectionExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkUpdate/SqlConnectionExtensions.cs
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/Upsert/DbContextAsyncExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/Upsert/DbContextAsyncExtensions.cs
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/Upsert/DbContextExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/Upsert/DbContextExtensions.cs
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/Upsert/SqlConnectionAsyncExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/Upsert/SqlConnectionAsyncExtensions.cs
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/Upsert/SqlConnectionExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/Upsert/SqlConnectionExtensions.cs

Original file line number	Diff line number	Diff line change
`@@ -90,7 +90,7 @@ await connectionContext.BulkDeleteAsync(rows, row => row.Id,`
`90`	`90`	`{`
`91`	`91`	`if (omitTableName)`
`92`	`92`	`{`
`93`		`- await connectionContext.BulkDeleteAsync(rows, "Id",`
	`93`	`+ await connectionContext.BulkDeleteAsync(rows, ["Id"],`
`94`	`94`	`options =>`
`95`	`95`	`{`
`96`	`96`	`options.LogTo = _output.WriteLine;`
`@@ -103,7 +103,7 @@ await connectionContext.BulkDeleteAsync(compositeKeyRows, ["Id1", "Id2"],`
`103`	`103`	`}`
`104`	`104`	`else`
`105`	`105`	`{`
`106`		`- await connectionContext.BulkDeleteAsync(rows, new SqlTableInfor(_schema, "SingleKeyRows"), "Id",`
	`106`	`+ await connectionContext.BulkDeleteAsync(rows, new SqlTableInfor(_schema, "SingleKeyRows"), ["Id"],`
`107`	`107`	`options =>`
`108`	`108`	`{`
`109`	`109`	`options.LogTo = _output.WriteLine;`
Original file line number	Diff line number	Diff line change
`@@ -90,7 +90,7 @@ public void Bulk_Delete_Without_Transaction(bool useLinq, bool omitTableName)`
`90`	`90`	`{`
`91`	`91`	`if (omitTableName)`
`92`	`92`	`{`
`93`		`- connectionContext.BulkDelete(rows, "Id",`
	`93`	`+ connectionContext.BulkDelete(rows, ["Id"],`
`94`	`94`	`options =>`
`95`	`95`	`{`
`96`	`96`	`options.LogTo = _output.WriteLine;`
`@@ -103,7 +103,7 @@ public void Bulk_Delete_Without_Transaction(bool useLinq, bool omitTableName)`
`103`	`103`	`}`
`104`	`104`	`else`
`105`	`105`	`{`
`106`		`- connectionContext.BulkDelete(rows, new SqlTableInfor(_schema, "SingleKeyRows"), "Id",`
	`106`	`+ connectionContext.BulkDelete(rows, new SqlTableInfor(_schema, "SingleKeyRows"), ["Id"],`
`107`	`107`	`options =>`
`108`	`108`	`{`
`109`	`109`	`options.LogTo = _output.WriteLine;`
Original file line number	Diff line number	Diff line change
`@@ -182,7 +182,7 @@ await connectionContext.BulkMergeAsync(compositeKeyRows,`
`182`	`182`	`if (omitTableName)`
`183`	`183`	`{`
`184`	`184`	`await connectionContext.BulkUpdateAsync(rows,`
`185`		`- "Id",`
	`185`	`+ ["Id"],`
`186`	`186`	`["Column3", "Column2"],`
`187`	`187`	`options =>`
`188`	`188`	`{`
`@@ -200,7 +200,7 @@ await connectionContext.BulkUpdateAsync(compositeKeyRows,`
`200`	`200`	`else`
`201`	`201`	`{`
`202`	`202`	`await connectionContext.BulkUpdateAsync(rows, new SqlTableInfor(_schema, "SingleKeyRows"),`
`203`		`- "Id",`
	`203`	`+ ["Id"],`
`204`	`204`	`["Column3", "Column2"],`
`205`	`205`	`options =>`
`206`	`206`	`{`
`@@ -241,7 +241,7 @@ await connectionContext.BulkUpdateAsync(compositeKeyRows,`
`241`	`241`	`if (omitTableName)`
`242`	`242`	`{`
`243`	`243`	`await connectionContext.BulkMergeAsync(rows,`
`244`		`- "Id",`
	`244`	`+ ["Id"],`
`245`	`245`	`["Column1", "Column2"],`
`246`	`246`	`["Column1", "Column2", "Column3"],`
`247`	`247`	`options =>`
`@@ -261,7 +261,7 @@ await connectionContext.BulkMergeAsync(compositeKeyRows,`
`261`	`261`	`else`
`262`	`262`	`{`
`263`	`263`	`await connectionContext.BulkMergeAsync(rows, new SqlTableInfor(_schema, "SingleKeyRows"),`
`264`		`- "Id",`
	`264`	`+ ["Id"],`
`265`	`265`	`["Column1", "Column2"],`
`266`	`266`	`["Column1", "Column2", "Column3"],`
`267`	`267`	`options =>`
Original file line number	Diff line number	Diff line change
`@@ -182,7 +182,7 @@ public void Bulk_Update_Without_Transaction(bool useLinq, bool omitTableName)`
`182`	`182`	`if (omitTableName)`
`183`	`183`	`{`
`184`	`184`	`connectionContext.BulkUpdate(rows,`
`185`		`- "Id",`
	`185`	`+ ["Id"],`
`186`	`186`	`["Column3", "Column2"],`
`187`	`187`	`options =>`
`188`	`188`	`{`
`@@ -200,7 +200,7 @@ public void Bulk_Update_Without_Transaction(bool useLinq, bool omitTableName)`
`200`	`200`	`else`
`201`	`201`	`{`
`202`	`202`	`connectionContext.BulkUpdate(rows, new SqlTableInfor(_schema, "SingleKeyRows"),`
`203`		`- "Id",`
	`203`	`+ ["Id"],`
`204`	`204`	`["Column3", "Column2"],`
`205`	`205`	`options =>`
`206`	`206`	`{`
`@@ -241,7 +241,7 @@ public void Bulk_Update_Without_Transaction(bool useLinq, bool omitTableName)`
`241`	`241`	`if (omitTableName)`
`242`	`242`	`{`
`243`	`243`	`connectionContext.BulkMerge(rows,`
`244`		`- "Id",`
	`244`	`+ ["Id"],`
`245`	`245`	`["Column1", "Column2"],`
`246`	`246`	`["Column1", "Column2", "Column3"],`
`247`	`247`	`options =>`
`@@ -261,7 +261,7 @@ public void Bulk_Update_Without_Transaction(bool useLinq, bool omitTableName)`
`261`	`261`	`else`
`262`	`262`	`{`
`263`	`263`	`connectionContext.BulkMerge(rows, new SqlTableInfor(_schema, "SingleKeyRows"),`
`264`		`- "Id",`
	`264`	`+ ["Id"],`
`265`	`265`	`["Column1", "Column2"],`
`266`	`266`	`["Column1", "Column2", "Column3"],`
`267`	`267`	`options =>`
Original file line number	Diff line number	Diff line change
`@@ -211,7 +211,7 @@ public async Task BulkMerge_Using_Dynamic_String_With_Transaction(int length, in`
`211`	`211`	`}`
`212`	`212`
`213`	`213`	`var result1 = await _context.BulkMergeAsync(rows,`
`214`		`- "Id",`
	`214`	`+ ["Id"],`
`215`	`215`	`["Column1", "Column2", "Column3", "Season", "SeasonAsString"],`
`216`	`216`	`["Column1", "Column2", "Column3", "Season", "SeasonAsString"],`
`217`	`217`	`options =>`
Original file line number	Diff line number	Diff line change
`@@ -211,7 +211,7 @@ public void BulkMerge_Using_Dynamic_String_With_Transaction(int length, int inse`
`211`	`211`	`}`
`212`	`212`
`213`	`213`	`var result1 = _context.BulkMerge(rows,`
`214`		`- "Id",`
	`214`	`+ ["Id"],`
`215`	`215`	`["Column1", "Column2", "Column3", "Season", "SeasonAsString"],`
`216`	`216`	`["Column1", "Column2", "Column3", "Season", "SeasonAsString"],`
`217`	`217`	`options =>`