Skip to content

Commit 8c5702a

Browse files
phongnguyendphongnguyend
committed
ConnectionContextExtensions
1 parent 3127486 commit 8c5702a

12 files changed

+242
-242
lines changed

‎src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/SqlConnectionAsyncExtensions.cs‎ renamed to ‎src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/ConnectionContextAsyncExtensions.cs‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -6,16 +6,16 @@
66

77
namespace EntityFrameworkCore.SqlServer.SimpleBulks.BulkDelete;
88

9-
public static class SqlConnectionAsyncExtensions
9+
public static class ConnectionContextAsyncExtensions
1010
{
1111
public static Task<BulkDeleteResult> BulkDeleteAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, Expression<Func<T, object>> idSelector, Action<BulkDeleteOptions> configureOptions = null, CancellationToken cancellationToken = default)
1212
{
1313
var table = TableMapper.Resolve(typeof(T));
1414

1515
return new BulkDeleteBuilder<T>(connectionContext)
16-
.WithId(idSelector)
16+
.WithId(idSelector)
1717
.ToTable(table)
18-
.ConfigureBulkOptions(configureOptions)
18+
.ConfigureBulkOptions(configureOptions)
1919
.ExecuteAsync(data, cancellationToken);
2020
}
2121

@@ -33,10 +33,10 @@ public static Task<BulkDeleteResult> BulkDeleteAsync<T>(this ConnectionContext c
3333
public static Task<BulkDeleteResult> BulkDeleteAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, Expression<Func<T, object>> idSelector, Action<BulkDeleteOptions> configureOptions = null, CancellationToken cancellationToken = default)
3434
{
3535
return new BulkDeleteBuilder<T>(connectionContext)
36-
.WithId(idSelector)
37-
.ToTable(table)
38-
.ConfigureBulkOptions(configureOptions)
39-
.ExecuteAsync(data, cancellationToken);
36+
.WithId(idSelector)
37+
.ToTable(table)
38+
.ConfigureBulkOptions(configureOptions)
39+
.ExecuteAsync(data, cancellationToken);
4040
}
4141

4242
public static Task<BulkDeleteResult> BulkDeleteAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, IEnumerable<string> idColumns, Action<BulkDeleteOptions> configureOptions = null, CancellationToken cancellationToken = default)
@@ -47,4 +47,4 @@ public static Task<BulkDeleteResult> BulkDeleteAsync<T>(this ConnectionContext c
4747
.ConfigureBulkOptions(configureOptions)
4848
.ExecuteAsync(data, cancellationToken);
4949
}
50-
}
50+
}

‎src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/SqlConnectionExtensions.cs‎ renamed to ‎src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/ConnectionContextExtensions.cs‎

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -4,16 +4,16 @@
44

55
namespace EntityFrameworkCore.SqlServer.SimpleBulks.BulkDelete;
66

7-
public static class SqlConnectionExtensions
7+
public static class ConnectionContextExtensions
88
{
99
public static BulkDeleteResult BulkDelete<T>(this ConnectionContext connectionContext, IEnumerable<T> data, Expression<Func<T, object>> idSelector, Action<BulkDeleteOptions> configureOptions = null)
1010
{
1111
var table = TableMapper.Resolve(typeof(T));
1212

1313
return new BulkDeleteBuilder<T>(connectionContext)
14-
.WithId(idSelector)
15-
.ToTable(table)
16-
.ConfigureBulkOptions(configureOptions)
14+
.WithId(idSelector)
15+
.ToTable(table)
16+
.ConfigureBulkOptions(configureOptions)
1717
.Execute(data);
1818
}
1919

@@ -22,8 +22,8 @@ public static BulkDeleteResult BulkDelete<T>(this ConnectionContext connectionCo
2222
var table = TableMapper.Resolve(typeof(T));
2323

2424
return new BulkDeleteBuilder<T>(connectionContext)
25-
.WithId(idColumns)
26-
.ToTable(table)
25+
.WithId(idColumns)
26+
.ToTable(table)
2727
.ConfigureBulkOptions(configureOptions)
2828
.Execute(data);
2929
}
@@ -32,17 +32,17 @@ public static BulkDeleteResult BulkDelete<T>(this ConnectionContext connectionCo
3232
{
3333
return new BulkDeleteBuilder<T>(connectionContext)
3434
.WithId(idSelector)
35-
.ToTable(table)
35+
.ToTable(table)
3636
.ConfigureBulkOptions(configureOptions)
37-
.Execute(data);
37+
.Execute(data);
3838
}
3939

4040
public static BulkDeleteResult BulkDelete<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, IEnumerable<string> idColumns, Action<BulkDeleteOptions> configureOptions = null)
4141
{
4242
return new BulkDeleteBuilder<T>(connectionContext)
43-
.WithId(idColumns)
44-
.ToTable(table)
45-
.ConfigureBulkOptions(configureOptions)
46-
.Execute(data);
43+
.WithId(idColumns)
44+
.ToTable(table)
45+
.ConfigureBulkOptions(configureOptions)
46+
.Execute(data);
4747
}
48-
}
48+
}

‎src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkInsert/SqlConnectionAsyncExtensions.cs‎ renamed to ‎src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkInsert/ConnectionContextAsyncExtensions.cs‎

Lines changed: 22 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -6,16 +6,16 @@
66

77
namespace EntityFrameworkCore.SqlServer.SimpleBulks.BulkInsert;
88

9-
public static class SqlConnectionAsyncExtensions
9+
public static class ConnectionContextAsyncExtensions
1010
{
1111
public static Task BulkInsertAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, Expression<Func<T, object>> columnNamesSelector, Action<BulkInsertOptions> configureOptions = null, CancellationToken cancellationToken = default)
1212
{
1313
var table = TableMapper.Resolve(typeof(T));
1414

1515
return new BulkInsertBuilder<T>(connectionContext)
16-
.WithColumns(columnNamesSelector)
16+
.WithColumns(columnNamesSelector)
1717
.ToTable(table)
18-
.ConfigureBulkOptions(configureOptions)
18+
.ConfigureBulkOptions(configureOptions)
1919
.ExecuteAsync(data, cancellationToken);
2020
}
2121

@@ -25,9 +25,9 @@ public static Task BulkInsertAsync<T>(this ConnectionContext connectionContext,
2525

2626
return new BulkInsertBuilder<T>(connectionContext)
2727
.WithColumns(columnNamesSelector)
28-
.ToTable(table)
28+
.ToTable(table)
2929
.WithOutputId(idSelector)
30-
.ConfigureBulkOptions(configureOptions)
30+
.ConfigureBulkOptions(configureOptions)
3131
.ExecuteAsync(data, cancellationToken);
3232
}
3333

@@ -37,9 +37,9 @@ public static Task BulkInsertAsync<T>(this ConnectionContext connectionContext,
3737

3838
return new BulkInsertBuilder<T>(connectionContext)
3939
.WithColumns(columnNames)
40-
.ToTable(table)
41-
.ConfigureBulkOptions(configureOptions)
42-
.ExecuteAsync(data, cancellationToken);
40+
.ToTable(table)
41+
.ConfigureBulkOptions(configureOptions)
42+
.ExecuteAsync(data, cancellationToken);
4343
}
4444

4545
public static Task BulkInsertAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, IEnumerable<string> columnNames, string idColumnName, Action<BulkInsertOptions> configureOptions = null, CancellationToken cancellationToken = default)
@@ -48,47 +48,47 @@ public static Task BulkInsertAsync<T>(this ConnectionContext connectionContext,
4848

4949
return new BulkInsertBuilder<T>(connectionContext)
5050
.WithColumns(columnNames)
51-
.ToTable(table)
51+
.ToTable(table)
5252
.WithOutputId(idColumnName)
53-
.ConfigureBulkOptions(configureOptions)
53+
.ConfigureBulkOptions(configureOptions)
5454
.ExecuteAsync(data, cancellationToken);
5555
}
5656

5757
public static Task BulkInsertAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, Expression<Func<T, object>> columnNamesSelector, Action<BulkInsertOptions> configureOptions = null, CancellationToken cancellationToken = default)
5858
{
5959
return new BulkInsertBuilder<T>(connectionContext)
60-
.WithColumns(columnNamesSelector)
61-
.ToTable(table)
62-
.ConfigureBulkOptions(configureOptions)
60+
.WithColumns(columnNamesSelector)
61+
.ToTable(table)
62+
.ConfigureBulkOptions(configureOptions)
6363
.ExecuteAsync(data, cancellationToken);
6464
}
6565

6666
public static Task BulkInsertAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, Expression<Func<T, object>> columnNamesSelector, Expression<Func<T, object>> idSelector, Action<BulkInsertOptions> configureOptions = null, CancellationToken cancellationToken = default)
6767
{
6868
return new BulkInsertBuilder<T>(connectionContext)
6969
.WithColumns(columnNamesSelector)
70-
.ToTable(table)
71-
.WithOutputId(idSelector)
72-
.ConfigureBulkOptions(configureOptions)
73-
.ExecuteAsync(data, cancellationToken);
70+
.ToTable(table)
71+
.WithOutputId(idSelector)
72+
.ConfigureBulkOptions(configureOptions)
73+
.ExecuteAsync(data, cancellationToken);
7474
}
7575

7676
public static Task BulkInsertAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, IEnumerable<string> columnNames, Action<BulkInsertOptions> configureOptions = null, CancellationToken cancellationToken = default)
7777
{
7878
return new BulkInsertBuilder<T>(connectionContext)
79-
.WithColumns(columnNames)
79+
.WithColumns(columnNames)
8080
.ToTable(table)
8181
.ConfigureBulkOptions(configureOptions)
82-
.ExecuteAsync(data, cancellationToken);
82+
.ExecuteAsync(data, cancellationToken);
8383
}
8484

8585
public static Task BulkInsertAsync<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, IEnumerable<string> columnNames, string idColumnName, Action<BulkInsertOptions> configureOptions = null, CancellationToken cancellationToken = default)
8686
{
8787
return new BulkInsertBuilder<T>(connectionContext)
88-
.WithColumns(columnNames)
88+
.WithColumns(columnNames)
8989
.ToTable(table)
90-
.WithOutputId(idColumnName)
90+
.WithOutputId(idColumnName)
9191
.ConfigureBulkOptions(configureOptions)
9292
.ExecuteAsync(data, cancellationToken);
9393
}
94-
}
94+
}

‎src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkInsert/SqlConnectionExtensions.cs‎ renamed to ‎src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkInsert/ConnectionContextExtensions.cs‎

Lines changed: 27 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -4,80 +4,80 @@
44

55
namespace EntityFrameworkCore.SqlServer.SimpleBulks.BulkInsert;
66

7-
public static class SqlConnectionExtensions
7+
public static class ConnectionContextExtensions
88
{
99
public static void BulkInsert<T>(this ConnectionContext connectionContext, IEnumerable<T> data, Expression<Func<T, object>> columnNamesSelector, Action<BulkInsertOptions> configureOptions = null)
1010
{
1111
var table = TableMapper.Resolve(typeof(T));
1212

1313
new BulkInsertBuilder<T>(connectionContext)
14-
.WithColumns(columnNamesSelector)
15-
.ToTable(table)
16-
.ConfigureBulkOptions(configureOptions)
17-
.Execute(data);
14+
.WithColumns(columnNamesSelector)
15+
.ToTable(table)
16+
.ConfigureBulkOptions(configureOptions)
17+
.Execute(data);
1818
}
1919

2020
public static void BulkInsert<T>(this ConnectionContext connectionContext, IEnumerable<T> data, Expression<Func<T, object>> columnNamesSelector, Expression<Func<T, object>> idSelector, Action<BulkInsertOptions> configureOptions = null)
2121
{
2222
var table = TableMapper.Resolve(typeof(T));
2323

2424
new BulkInsertBuilder<T>(connectionContext)
25-
.WithColumns(columnNamesSelector)
26-
.ToTable(table)
25+
.WithColumns(columnNamesSelector)
26+
.ToTable(table)
2727
.WithOutputId(idSelector)
28-
.ConfigureBulkOptions(configureOptions)
29-
.Execute(data);
28+
.ConfigureBulkOptions(configureOptions)
29+
.Execute(data);
3030
}
3131

3232
public static void BulkInsert<T>(this ConnectionContext connectionContext, IEnumerable<T> data, IEnumerable<string> columnNames, Action<BulkInsertOptions> configureOptions = null)
3333
{
3434
var table = TableMapper.Resolve(typeof(T));
3535

3636
new BulkInsertBuilder<T>(connectionContext)
37-
.WithColumns(columnNames)
37+
.WithColumns(columnNames)
3838
.ToTable(table)
39-
.ConfigureBulkOptions(configureOptions)
40-
.Execute(data);
39+
.ConfigureBulkOptions(configureOptions)
40+
.Execute(data);
4141
}
4242

4343
public static void BulkInsert<T>(this ConnectionContext connectionContext, IEnumerable<T> data, IEnumerable<string> columnNames, string idColumnName, Action<BulkInsertOptions> configureOptions = null)
4444
{
4545
var table = TableMapper.Resolve(typeof(T));
4646

4747
new BulkInsertBuilder<T>(connectionContext)
48-
.WithColumns(columnNames)
49-
.ToTable(table)
50-
.WithOutputId(idColumnName)
51-
.ConfigureBulkOptions(configureOptions)
52-
.Execute(data);
48+
.WithColumns(columnNames)
49+
.ToTable(table)
50+
.WithOutputId(idColumnName)
51+
.ConfigureBulkOptions(configureOptions)
52+
.Execute(data);
5353
}
5454

5555
public static void BulkInsert<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, Expression<Func<T, object>> columnNamesSelector, Action<BulkInsertOptions> configureOptions = null)
5656
{
5757
new BulkInsertBuilder<T>(connectionContext)
58-
.WithColumns(columnNamesSelector)
58+
.WithColumns(columnNamesSelector)
5959
.ToTable(table)
60-
.ConfigureBulkOptions(configureOptions)
61-
.Execute(data);
60+
.ConfigureBulkOptions(configureOptions)
61+
.Execute(data);
6262
}
6363

6464
public static void BulkInsert<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, Expression<Func<T, object>> columnNamesSelector, Expression<Func<T, object>> idSelector, Action<BulkInsertOptions> configureOptions = null)
6565
{
6666
new BulkInsertBuilder<T>(connectionContext)
6767
.WithColumns(columnNamesSelector)
68-
.ToTable(table)
68+
.ToTable(table)
6969
.WithOutputId(idSelector)
70-
.ConfigureBulkOptions(configureOptions)
71-
.Execute(data);
70+
.ConfigureBulkOptions(configureOptions)
71+
.Execute(data);
7272
}
7373

7474
public static void BulkInsert<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, IEnumerable<string> columnNames, Action<BulkInsertOptions> configureOptions = null)
7575
{
7676
new BulkInsertBuilder<T>(connectionContext)
7777
.WithColumns(columnNames)
7878
.ToTable(table)
79-
.ConfigureBulkOptions(configureOptions)
80-
.Execute(data);
79+
.ConfigureBulkOptions(configureOptions)
80+
.Execute(data);
8181
}
8282

8383
public static void BulkInsert<T>(this ConnectionContext connectionContext, IEnumerable<T> data, TableInfor table, IEnumerable<string> columnNames, string idColumnName, Action<BulkInsertOptions> configureOptions = null)
@@ -87,6 +87,6 @@ public static void BulkInsert<T>(this ConnectionContext connectionContext, IEnum
8787
.ToTable(table)
8888
.WithOutputId(idColumnName)
8989
.ConfigureBulkOptions(configureOptions)
90-
.Execute(data);
90+
.Execute(data);
9191
}
92-
}
92+
}

0 commit comments

Comments
 (0)