-
Notifications
You must be signed in to change notification settings - Fork 27
/
Copy pathProgram.cs
87 lines (73 loc) · 2.9 KB
/
Program.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkDelete;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkInsert;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkMerge;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkUpdate;
using EntityFrameworkCore.SqlServer.SimpleBulks.Demo.Entities;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
namespace EntityFrameworkCore.SqlServer.SimpleBulks.Demo;
class Program
{
static void Main(string[] args)
{
using (var dbct = new DemoDbContext())
{
dbct.Database.Migrate();
var deleteResult = dbct.BulkDelete(dbct.Set<ConfigurationEntry>().AsNoTracking(),
opt =>
{
opt.LogTo = Console.WriteLine;
});
Console.WriteLine($"Deleted: {deleteResult.AffectedRows} row(s)");
var configurationEntries = new List<ConfigurationEntry>();
for (int i = 0; i < 1000; i++)
{
configurationEntries.Add(new ConfigurationEntry
{
Key = $"Key{i}",
Value = $"Value{i}",
CreatedDateTime = DateTimeOffset.Now,
});
}
dbct.BulkInsert(configurationEntries,
opt =>
{
opt.LogTo = Console.WriteLine;
});
foreach (var row in configurationEntries)
{
row.Key += "xx";
row.UpdatedDateTime = DateTimeOffset.Now;
row.IsSensitive = true;
row.Description = row.Id.ToString();
}
var updateResult = dbct.BulkUpdate(configurationEntries,
x => new { x.Key, x.UpdatedDateTime, x.IsSensitive, x.Description },
opt =>
{
opt.LogTo = Console.WriteLine;
});
Console.WriteLine($"Updated: {updateResult.AffectedRows} row(s)");
configurationEntries.Add(new ConfigurationEntry
{
Key = $"Key{1001}",
Value = $"Value{1001}",
CreatedDateTime = DateTimeOffset.Now,
});
var mergeResult = dbct.BulkMerge(configurationEntries,
x => x.Id,
x => new { x.Key, x.UpdatedDateTime, x.IsSensitive, x.Description },
x => new { x.Key, x.Value, x.IsSensitive, x.CreatedDateTime },
opt =>
{
opt.LogTo = Console.WriteLine;
});
Console.WriteLine($"Updated: {mergeResult.UpdatedRows} row(s)");
Console.WriteLine($"Inserted: {mergeResult.InsertedRows} row(s)");
Console.WriteLine($"Affected: {mergeResult.AffectedRows} row(s)");
}
Console.WriteLine("Finished!");
Console.ReadLine();
}
}