Skip to content

Commit 01cf5ab

Browse files
phongnguyendphongnguyend
committed
release v8.4.0
1 parent 4148b9e commit 01cf5ab

File tree

3 files changed

+52
-52
lines changed

3 files changed

+52
-52
lines changed

‎README.md‎

Lines changed: 47 additions & 47 deletions
Original file line numberDiff line numberDiff line change
@@ -40,31 +40,31 @@ using EntityFrameworkCore.SqlServer.SimpleBulks.BulkMerge;
4040
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkUpdate;
4141

4242
// Insert all columns
43-
dbct.BulkInsert(rows);
44-
dbct.BulkInsert(compositeKeyRows);
43+
await dbct.BulkInsertAsync(rows);
44+
await dbct.BulkInsertAsync(compositeKeyRows);
4545

4646
// Insert selected columns only
47-
dbct.BulkInsert(rows,
47+
await dbct.BulkInsertAsync(rows,
4848
row => new { row.Column1, row.Column2, row.Column3 });
49-
dbct.BulkInsert(compositeKeyRows,
49+
await dbct.BulkInsertAsync(compositeKeyRows,
5050
row => new { row.Id1, row.Id2, row.Column1, row.Column2, row.Column3 });
5151

52-
dbct.BulkUpdate(rows,
52+
await dbct.BulkUpdateAsync(rows,
5353
row => new { row.Column3, row.Column2 });
54-
dbct.BulkUpdate(compositeKeyRows,
54+
await dbct.BulkUpdateAsync(compositeKeyRows,
5555
row => new { row.Column3, row.Column2 });
5656

57-
dbct.BulkMerge(rows,
57+
await dbct.BulkMergeAsync(rows,
5858
row => row.Id,
5959
row => new { row.Column1, row.Column2 },
6060
row => new { row.Column1, row.Column2, row.Column3 });
61-
dbct.BulkMerge(compositeKeyRows,
61+
await dbct.BulkMergeAsync(compositeKeyRows,
6262
row => new { row.Id1, row.Id2 },
6363
row => new { row.Column1, row.Column2, row.Column3 },
6464
row => new { row.Id1, row.Id2, row.Column1, row.Column2, row.Column3 });
6565

66-
dbct.BulkDelete(rows);
67-
dbct.BulkDelete(compositeKeyRows);
66+
await dbct.BulkDeleteAsync(rows);
67+
await dbct.BulkDeleteAsync(compositeKeyRows);
6868
```
6969
### Using Dynamic String
7070
```c#
@@ -73,30 +73,30 @@ using EntityFrameworkCore.SqlServer.SimpleBulks.BulkInsert;
7373
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkMerge;
7474
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkUpdate;
7575

76-
dbct.BulkUpdate(rows,
76+
await dbct.BulkUpdateAsync(rows,
7777
[ "Column3", "Column2" ]);
78-
dbct.BulkUpdate(compositeKeyRows,
78+
await dbct.BulkUpdateAsync(compositeKeyRows,
7979
[ "Column3", "Column2" ]);
8080

81-
dbct.BulkMerge(rows,
81+
await dbct.BulkMergeAsync(rows,
8282
"Id",
8383
[ "Column1", "Column2" ],
8484
[ "Column1", "Column2", "Column3" ]);
85-
dbct.BulkMerge(compositeKeyRows,
85+
await dbct.BulkMergeAsync(compositeKeyRows,
8686
[ "Id1", "Id2" ],
8787
[ "Column1", "Column2", "Column3" ],
8888
[ "Id1", "Id2", "Column1", "Column2", "Column3" ]);
8989
```
9090
### Using Builder Approach in case you need to mix both Dynamic & Lambda Expression
9191
```c#
92-
new BulkInsertBuilder<Row>(dbct.GetSqlConnection())
92+
await new BulkInsertBuilder<Row>(dbct.GetSqlConnection())
9393
.WithColumns(row => new { row.Column1, row.Column2, row.Column3 })
9494
// or .WithColumns([ "Column1", "Column2", "Column3" ])
9595
.WithOutputId(row => row.Id)
9696
// or .WithOutputId("Id")
9797
.ToTable(dbct.GetTableName(typeof(Row)))
9898
// or .ToTable("Rows")
99-
.Execute(rows);
99+
.ExecuteAsync(rows);
100100
```
101101

102102
## SqlConnectionExtensions
@@ -111,29 +111,29 @@ using EntityFrameworkCore.SqlServer.SimpleBulks.BulkUpdate;
111111
TableMapper.Register(typeof(Row), "Rows");
112112
TableMapper.Register(typeof(CompositeKeyRow), "CompositeKeyRows");
113113

114-
connection.BulkInsert(rows,
114+
await connection.BulkInsertAsync(rows,
115115
row => new { row.Column1, row.Column2, row.Column3 });
116-
connection.BulkInsert(compositeKeyRows,
116+
await connection.BulkInsertAsync(compositeKeyRows,
117117
row => new { row.Id1, row.Id2, row.Column1, row.Column2, row.Column3 });
118118

119-
connection.BulkUpdate(rows,
119+
await connection.BulkUpdateAsync(rows,
120120
row => row.Id,
121121
row => new { row.Column3, row.Column2 });
122-
connection.BulkUpdate(compositeKeyRows,
122+
await connection.BulkUpdateAsync(compositeKeyRows,
123123
row => new { row.Id1, row.Id2 },
124124
row => new { row.Column3, row.Column2 });
125125

126-
connection.BulkMerge(rows,
126+
await connection.BulkMergeAsync(rows,
127127
row => row.Id,
128128
row => new { row.Column1, row.Column2 },
129129
row => new { row.Column1, row.Column2, row.Column3 });
130-
connection.BulkMerge(compositeKeyRows,
130+
await connection.BulkMergeAsync(compositeKeyRows,
131131
row => new { row.Id1, row.Id2 },
132132
row => new { row.Column1, row.Column2, row.Column3 },
133133
row => new { row.Id1, row.Id2, row.Column1, row.Column2, row.Column3 });
134134

135-
connection.BulkDelete(rows, row => row.Id);
136-
connection.BulkDelete(compositeKeyRows, row => new { row.Id1, row.Id2 });
135+
await connection.BulkDeleteAsync(rows, row => row.Id);
136+
await connection.BulkDeleteAsync(compositeKeyRows, row => new { row.Id1, row.Id2 });
137137
```
138138
### Using Dynamic String
139139
```c#
@@ -142,47 +142,47 @@ using EntityFrameworkCore.SqlServer.SimpleBulks.BulkInsert;
142142
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkMerge;
143143
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkUpdate;
144144

145-
connection.BulkInsert(rows, "Rows",
145+
await connection.BulkInsertAsync(rows,
146146
[ "Column1", "Column2", "Column3" ]);
147-
connection.BulkInsert(rows.Take(1000), "Rows",
147+
await connection.BulkInsertAsync(rows.Take(1000),
148148
typeof(Row).GetDbColumnNames("Id"));
149-
connection.BulkInsert(compositeKeyRows, "CompositeKeyRows",
149+
await connection.BulkInsertAsync(compositeKeyRows,
150150
[ "Id1", "Id2", "Column1", "Column2", "Column3" ]);
151151

152-
connection.BulkUpdate(rows, "Rows",
152+
await connection.BulkUpdateAsync(rows,
153153
"Id",
154154
[ "Column3", "Column2" ]);
155-
connection.BulkUpdate(compositeKeyRows, "CompositeKeyRows",
155+
await connection.BulkUpdateAsync(compositeKeyRows,
156156
[ "Id1", "Id2" ],
157157
[ "Column3", "Column2" ]);
158158

159-
connection.BulkMerge(rows, "Rows",
159+
await connection.BulkMergeAsync(rows,
160160
"Id",
161161
[ "Column1", "Column2" ],
162162
[ "Column1", "Column2", "Column3" ]);
163-
connection.BulkMerge(compositeKeyRows, "CompositeKeyRows",
163+
await connection.BulkMergeAsync(compositeKeyRows,
164164
[ "Id1", "Id2" ],
165165
[ "Column1", "Column2", "Column3" ],
166166
[ "Id1", "Id2", "Column1", "Column2", "Column3" ]);
167167

168-
connection.BulkDelete(rows, "Rows", "Id");
169-
connection.BulkDelete(compositeKeyRows, "CompositeKeyRows", [ "Id1", "Id2" ]);
168+
await connection.BulkDeleteAsync(rows, "Id");
169+
await connection.BulkDeleteAsync(compositeKeyRows, [ "Id1", "Id2" ]);
170170
```
171171
### Using Builder Approach in case you need to mix both Dynamic & Lambda Expression
172172
```c#
173-
new BulkInsertBuilder<Row>(connection)
173+
await new BulkInsertBuilder<Row>(connection)
174174
.WithColumns(row => new { row.Column1, row.Column2, row.Column3 })
175175
// or .WithColumns([ "Column1", "Column2", "Column3" ])
176176
.WithOutputId(row => row.Id)
177177
// or .WithOutputId("Id")
178178
.ToTable("Rows")
179-
.Execute(rows);
179+
.ExecuteAsync(rows);
180180
```
181181

182182
## Configuration
183183
### BulkInsert
184184
```c#
185-
_context.BulkInsert(rows,
185+
await _context.BulkInsertAsync(rows,
186186
row => new { row.Column1, row.Column2, row.Column3 },
187187
options =>
188188
{
@@ -194,7 +194,7 @@ _context.BulkInsert(rows,
194194
```
195195
### BulkUpdate
196196
```c#
197-
_context.BulkUpdate(rows,
197+
await _context.BulkUpdateAsync(rows,
198198
row => new { row.Column3, row.Column2 },
199199
options =>
200200
{
@@ -205,7 +205,7 @@ _context.BulkUpdate(rows,
205205
```
206206
### BulkDelete
207207
```c#
208-
_context.BulkDelete(rows,
208+
await _context.BulkDeleteAsync(rows,
209209
options =>
210210
{
211211
options.BatchSize = 0;
@@ -215,7 +215,7 @@ _context.BulkDelete(rows,
215215
```
216216
### BulkMerge
217217
```c#
218-
_context.BulkMerge(rows,
218+
await _context.BulkMergeAsync(rows,
219219
row => row.Id,
220220
row => new { row.Column1, row.Column2 },
221221
row => new { row.Column1, row.Column2, row.Column3 },
@@ -230,7 +230,7 @@ _context.BulkMerge(rows,
230230
```
231231
### BulkMatch
232232
```c#
233-
var contactsFromDb = _context.BulkMatch(matchedContacts,
233+
var contactsFromDb = await _context.BulkMatchAsync(matchedContacts,
234234
x => new { x.CustomerId, x.CountryIsoCode },
235235
options =>
236236
{
@@ -241,7 +241,7 @@ var contactsFromDb = _context.BulkMatch(matchedContacts,
241241
```
242242
### TempTable
243243
```c#
244-
var customerTableName = _context.CreateTempTable(customers,
244+
var customerTableName = await _context.CreateTempTableAsync(customers,
245245
x => new
246246
{
247247
x.IdNumber,
@@ -258,7 +258,7 @@ var customerTableName = _context.CreateTempTable(customers,
258258
```
259259
### DirectInsert
260260
```c#
261-
_context.DirectInsert(row,
261+
await _context.DirectInsertAsync(row,
262262
row => new { row.Column1, row.Column2, row.Column3 },
263263
options =>
264264
{
@@ -268,7 +268,7 @@ _context.DirectInsert(row,
268268
```
269269
### DirectUpdate
270270
```c#
271-
_context.DirectUpdate(row,
271+
await _context.DirectUpdateAsync(row,
272272
row => new { row.Column3, row.Column2 },
273273
options =>
274274
{
@@ -278,7 +278,7 @@ _context.DirectUpdate(row,
278278
```
279279
### DirectDelete
280280
```c#
281-
_context.DirectDelete(row,
281+
await _context.DirectDeleteAsync(row,
282282
options =>
283283
{
284284
options.Timeout = 30;
@@ -289,19 +289,19 @@ _context.DirectDelete(row,
289289
## Returned Result
290290
### BulkUpdate
291291
```c#
292-
var updateResult = dbct.BulkUpdate(rows, row => new { row.Column3, row.Column2 });
292+
var updateResult = await dbct.BulkUpdateAsync(rows, row => new { row.Column3, row.Column2 });
293293

294294
Console.WriteLine($"Updated: {updateResult.AffectedRows} row(s)");
295295
```
296296
### BulkDelete
297297
```c#
298-
var deleteResult = dbct.BulkDelete(rows);
298+
var deleteResult = await dbct.BulkDeleteAsync(rows);
299299

300300
Console.WriteLine($"Deleted: {deleteResult.AffectedRows} row(s)");
301301
```
302302
### BulkMerge
303303
```c#
304-
var mergeResult = dbct.BulkMerge(rows,
304+
var mergeResult = await dbct.BulkMergeAsync(rows,
305305
row => row.Id,
306306
row => new { row.Column1, row.Column2 },
307307
row => new { row.Column1, row.Column2, row.Column3 });

‎src/EntityFrameworkCore.SqlServer.SimpleBulks.Demo/Program.cs‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
{
1414
dbct.Database.Migrate();
1515

16-
var deleteResult = dbct.BulkDelete(dbct.Set<ConfigurationEntry>().AsNoTracking(),
16+
var deleteResult = await dbct.BulkDeleteAsync(dbct.Set<ConfigurationEntry>().AsNoTracking(),
1717
opt =>
1818
{
1919
opt.LogTo = Console.WriteLine;
@@ -33,7 +33,7 @@
3333
});
3434
}
3535

36-
dbct.BulkInsert(configurationEntries,
36+
await dbct.BulkInsertAsync(configurationEntries,
3737
opt =>
3838
{
3939
opt.LogTo = Console.WriteLine;
@@ -47,7 +47,7 @@
4747
row.Description = row.Id.ToString();
4848
}
4949

50-
var updateResult = dbct.BulkUpdate(configurationEntries,
50+
var updateResult = await dbct.BulkUpdateAsync(configurationEntries,
5151
x => new { x.Key, x.UpdatedDateTime, x.IsSensitive, x.Description },
5252
opt =>
5353
{
@@ -63,7 +63,7 @@
6363
CreatedDateTime = DateTimeOffset.Now,
6464
});
6565

66-
var mergeResult = dbct.BulkMerge(configurationEntries,
66+
var mergeResult = await dbct.BulkMergeAsync(configurationEntries,
6767
x => x.Id,
6868
x => new { x.Key, x.UpdatedDateTime, x.IsSensitive, x.Description },
6969
x => new { x.Key, x.Value, x.IsSensitive, x.CreatedDateTime },

‎src/EntityFrameworkCore.SqlServer.SimpleBulks/EntityFrameworkCore.SqlServer.SimpleBulks.csproj‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
<PropertyGroup>
44
<TargetFramework>net8.0</TargetFramework>
5-
<Version>8.3.0</Version>
5+
<Version>8.4.0</Version>
66
<PackageProjectUrl>https://github.com/phongnguyend/EntityFrameworkCore.SqlServer.SimpleBulks</PackageProjectUrl>
77
<RepositoryUrl>https://github.com/phongnguyend/EntityFrameworkCore.SqlServer.SimpleBulks</RepositoryUrl>
88
<PackageRequireLicenseAcceptance>false</PackageRequireLicenseAcceptance>

0 commit comments

Comments
 (0)