-
Notifications
You must be signed in to change notification settings - Fork 26
/
BulkMatchMultipleColumnsBenchmarks.cs
121 lines (100 loc) · 3.82 KB
/
BulkMatchMultipleColumnsBenchmarks.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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
using BenchmarkDotNet.Attributes;
using EntityFrameworkCore.SqlServer.SimpleBulks.Benchmarks.Database;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkInsert;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkMatch;
using Microsoft.EntityFrameworkCore;
namespace EntityFrameworkCore.SqlServer.SimpleBulks.Benchmarks
{
[WarmupCount(0)]
[IterationCount(1)]
[InvocationCount(1)]
[MemoryDiagnoser]
public class BulkMatchMultipleColumnsBenchmarks
{
private TestDbContext _context;
private List<Customer> _customers;
private List<Contact> _contacts;
private List<Contact> _contactsToMatch;
[Params(100, 1000, 10_000, 100_000)]
public int RowsCount { get; set; }
//[Params(250_000, 500_000, 1_000_000)]
//public int RowsCount { get; set; }
[GlobalSetup]
public void GlobalSetup()
{
_context = new TestDbContext($"Server=127.0.0.1;Database=EntityFrameworkCore.SqlServer.SimpleBulks.Benchmarks.{Guid.NewGuid()};User Id=sa;Password=sqladmin123!@#;Encrypt=False");
_context.Database.EnsureCreated();
_context.Database.SetCommandTimeout(TimeSpan.FromMinutes(2));
var isoCodes = new string[] { "VN", "US", "GB" };
var random = new Random(2024);
_customers = new List<Customer>();
for (int i = 0; i < RowsCount; i++)
{
var customer = new Customer
{
FirstName = "FirstName " + i,
LastName = "LastName " + i,
Index = i,
CurrentCountryIsoCode = isoCodes[random.Next(isoCodes.Length)]
};
customer.Contacts = new List<Contact>();
for (int j = 0; j < 5; j++)
{
customer.Contacts.Add(new Contact
{
EmailAddress = $"EmailAddress {i} - {j}",
PhoneNumber = $"PhoneNumber {i} - {j}",
CountryIsoCode = isoCodes[random.Next(isoCodes.Length)],
Index = j,
});
}
_customers.Add(customer);
}
_context.BulkInsert(_customers,
opt =>
{
opt.Timeout = 0;
});
foreach (var customer in _customers)
{
foreach (var contact in customer.Contacts)
{
contact.CustomerId = customer.Id;
}
}
_contacts = _customers.SelectMany(x => x.Contacts).ToList();
_context.BulkInsert(_contacts,
opt =>
{
opt.Timeout = 0;
});
_contactsToMatch = _customers.Select(x => new Contact { CustomerId = x.Id, CountryIsoCode = x.CurrentCountryIsoCode }).ToList();
}
[GlobalCleanup]
public void GlobalCleanup()
{
_context.Database.EnsureDeleted();
}
[Benchmark]
public void EFCoreSelect()
{
var contacts = new List<Contact>();
foreach (var contact in _contactsToMatch)
{
contacts.AddRange(_context.Contacts.Where(x => x.CustomerId == contact.CustomerId && x.CountryIsoCode == contact.CountryIsoCode).AsNoTracking().ToList());
}
// Console.WriteLine(contacts.Count);
}
[Benchmark]
public void BulkMatch()
{
var contacts = _context.BulkMatch(_contactsToMatch,
x => new { x.CustomerId, x.CountryIsoCode },
opt =>
{
opt.Timeout = 0;
});
// Console.WriteLine(contacts.Count);
}
}
}