Skip to content

Commit 911adb6

Browse files
committed
Cache
1 parent d2088ea commit 911adb6

17 files changed

Lines changed: 80 additions & 60 deletions

src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/DbContextAsyncExtensions.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,8 @@ public static Task<BulkDeleteResult> BulkDeleteAsync<T>(this DbContext dbContext
2222

2323
return new BulkDeleteBuilder<T>(connection, transaction)
2424
.WithId(primaryKeys)
25-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
26-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
25+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
26+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
2727
.ToTable(table)
2828
.ConfigureBulkOptions(configureOptions)
2929
.ExecuteAsync(data, cancellationToken);

src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/DbContextExtensions.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,8 @@ public static BulkDeleteResult BulkDelete<T>(this DbContext dbContext, IEnumerab
2020

2121
return new BulkDeleteBuilder<T>(connection, transaction)
2222
.WithId(primaryKeys)
23-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
24-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
23+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
24+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
2525
.ToTable(table)
2626
.ConfigureBulkOptions(configureOptions)
2727
.Execute(data);

src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkInsert/DbContextAsyncExtensions.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,8 @@ public static Task BulkInsertAsync<T>(this DbContext dbContext, IEnumerable<T> d
2727

2828
return new BulkInsertBuilder<T>(connection, transaction)
2929
.WithColumns(columns)
30-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
31-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
30+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
31+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
3232
.ToTable(table)
3333
.WithOutputId(idColumn?.PropertyName)
3434
.WithOutputIdMode(GetOutputIdMode(idColumn))
@@ -48,8 +48,8 @@ public static Task BulkInsertAsync<T>(this DbContext dbContext, IEnumerable<T> d
4848

4949
return new BulkInsertBuilder<T>(connection, transaction)
5050
.WithColumns(columnNamesSelector)
51-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
52-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
51+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
52+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
5353
.ToTable(table)
5454
.WithOutputId(idColumn?.PropertyName)
5555
.WithOutputIdMode(GetOutputIdMode(idColumn))

src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkInsert/DbContextExtensions.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,8 @@ public static void BulkInsert<T>(this DbContext dbContext, IEnumerable<T> data,
2525

2626
new BulkInsertBuilder<T>(connection, transaction)
2727
.WithColumns(columns)
28-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
29-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
28+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
29+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
3030
.ToTable(table)
3131
.WithOutputId(idColumn?.PropertyName)
3232
.WithOutputIdMode(GetOutputIdMode(idColumn))
@@ -46,8 +46,8 @@ public static void BulkInsert<T>(this DbContext dbContext, IEnumerable<T> data,
4646

4747
new BulkInsertBuilder<T>(connection, transaction)
4848
.WithColumns(columnNamesSelector)
49-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
50-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
49+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
50+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
5151
.ToTable(table)
5252
.WithOutputId(idColumn?.PropertyName)
5353
.WithOutputIdMode(GetOutputIdMode(idColumn))

src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMatch/DbContextAsyncExtensions.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,8 @@ public static Task<List<T>> BulkMatchAsync<T>(this DbContext dbContext, IEnumera
2121

2222
return new BulkMatchBuilder<T>(connection, transaction)
2323
.WithReturnedColumns(columns)
24-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
25-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
24+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
25+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
2626
.WithTable(table)
2727
.WithMatchedColumns(matchedColumnsSelector)
2828
.ConfigureBulkOptions(configureOptions)
@@ -38,8 +38,8 @@ public static Task<List<T>> BulkMatchAsync<T>(this DbContext dbContext, IEnumera
3838

3939
return new BulkMatchBuilder<T>(connection, transaction)
4040
.WithReturnedColumns(returnedColumnsSelector)
41-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
42-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
41+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
42+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
4343
.WithTable(table)
4444
.WithMatchedColumns(matchedColumnsSelector)
4545
.ConfigureBulkOptions(configureOptions)

src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMatch/DbContextExtensions.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,8 @@ public static List<T> BulkMatch<T>(this DbContext dbContext, IEnumerable<T> mach
1919

2020
return new BulkMatchBuilder<T>(connection, transaction)
2121
.WithReturnedColumns(columns)
22-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
23-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
22+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
23+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
2424
.WithTable(table)
2525
.WithMatchedColumns(matchedColumnsSelector)
2626
.ConfigureBulkOptions(configureOptions)
@@ -36,8 +36,8 @@ public static List<T> BulkMatch<T>(this DbContext dbContext, IEnumerable<T> mach
3636

3737
return new BulkMatchBuilder<T>(connection, transaction)
3838
.WithReturnedColumns(returnedColumnsSelector)
39-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
40-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
39+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
40+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
4141
.WithTable(table)
4242
.WithMatchedColumns(matchedColumnsSelector)
4343
.ConfigureBulkOptions(configureOptions)

src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMerge/DbContextAsyncExtensions.cs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,8 @@ public static Task<BulkMergeResult> BulkMergeAsync<T>(this DbContext dbContext,
2727
.WithId(idSelector)
2828
.WithUpdateColumns(updateColumnNamesSelector)
2929
.WithInsertColumns(insertColumnNamesSelector)
30-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
31-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
30+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
31+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
3232
.WithOutputId(outputIdColumn)
3333
.ToTable(table)
3434
.ConfigureBulkOptions(configureOptions)
@@ -50,8 +50,8 @@ public static Task<BulkMergeResult> BulkMergeAsync<T>(this DbContext dbContext,
5050
.WithId(idColumn)
5151
.WithUpdateColumns(updateColumnNames)
5252
.WithInsertColumns(insertColumnNames)
53-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
54-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
53+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
54+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
5555
.WithOutputId(outputIdColumn)
5656
.ToTable(table)
5757
.ConfigureBulkOptions(configureOptions)
@@ -73,8 +73,8 @@ public static Task<BulkMergeResult> BulkMergeAsync<T>(this DbContext dbContext,
7373
.WithId(idColumns)
7474
.WithUpdateColumns(updateColumnNames)
7575
.WithInsertColumns(insertColumnNames)
76-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
77-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
76+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
77+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
7878
.WithOutputId(outputIdColumn)
7979
.ToTable(table)
8080
.ConfigureBulkOptions(configureOptions)

src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMerge/DbContextExtensions.cs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,8 @@ public static BulkMergeResult BulkMerge<T>(this DbContext dbContext, IEnumerable
2525
.WithId(idSelector)
2626
.WithUpdateColumns(updateColumnNamesSelector)
2727
.WithInsertColumns(insertColumnNamesSelector)
28-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
29-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
28+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
29+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
3030
.WithOutputId(outputIdColumn)
3131
.ToTable(table)
3232
.ConfigureBulkOptions(configureOptions)
@@ -48,8 +48,8 @@ public static BulkMergeResult BulkMerge<T>(this DbContext dbContext, IEnumerable
4848
.WithId(idColumn)
4949
.WithUpdateColumns(updateColumnNames)
5050
.WithInsertColumns(insertColumnNames)
51-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
52-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
51+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
52+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
5353
.WithOutputId(outputIdColumn)
5454
.ToTable(table)
5555
.ConfigureBulkOptions(configureOptions)
@@ -71,8 +71,8 @@ public static BulkMergeResult BulkMerge<T>(this DbContext dbContext, IEnumerable
7171
.WithId(idColumns)
7272
.WithUpdateColumns(updateColumnNames)
7373
.WithInsertColumns(insertColumnNames)
74-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
75-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
74+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
75+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
7676
.WithOutputId(outputIdColumn)
7777
.ToTable(table)
7878
.ConfigureBulkOptions(configureOptions)

src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkUpdate/DbContextAsyncExtensions.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -24,8 +24,8 @@ public static Task<BulkUpdateResult> BulkUpdateAsync<T>(this DbContext dbContext
2424
return new BulkUpdateBuilder<T>(connection, transaction)
2525
.WithId(primaryKeys)
2626
.WithColumns(columnNamesSelector)
27-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
28-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
27+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
28+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
2929
.ToTable(table)
3030
.ConfigureBulkOptions(configureOptions)
3131
.ExecuteAsync(data, cancellationToken);
@@ -44,8 +44,8 @@ public static Task<BulkUpdateResult> BulkUpdateAsync<T>(this DbContext dbContext
4444
return new BulkUpdateBuilder<T>(connection, transaction)
4545
.WithId(primaryKeys)
4646
.WithColumns(columnNames)
47-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
48-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
47+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
48+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
4949
.ToTable(table)
5050
.ConfigureBulkOptions(configureOptions)
5151
.ExecuteAsync(data, cancellationToken);

src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkUpdate/DbContextExtensions.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,8 @@ public static BulkUpdateResult BulkUpdate<T>(this DbContext dbContext, IEnumerab
2222
return new BulkUpdateBuilder<T>(connection, transaction)
2323
.WithId(primaryKeys)
2424
.WithColumns(columnNamesSelector)
25-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
26-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
25+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
26+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
2727
.ToTable(table)
2828
.ConfigureBulkOptions(configureOptions)
2929
.Execute(data);
@@ -42,8 +42,8 @@ public static BulkUpdateResult BulkUpdate<T>(this DbContext dbContext, IEnumerab
4242
return new BulkUpdateBuilder<T>(connection, transaction)
4343
.WithId(primaryKeys)
4444
.WithColumns(columnNames)
45-
.WithDbColumnMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnName))
46-
.WithDbColumnTypeMappings(properties.ToDictionary(x => x.PropertyName, x => x.ColumnType))
45+
.WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
46+
.WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
4747
.ToTable(table)
4848
.ConfigureBulkOptions(configureOptions)
4949
.Execute(data);

0 commit comments

Comments
 (0)