Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- [Fact]
- public async Task TestTest()
- {
- var storeTuple = await CreateDuoCluster();
- var storeSrc = storeTuple.source;
- using (storeSrc)
- {
- using (var bulkInsert = storeSrc.BulkInsert())
- {
- for (int i = 0; i < 1000 * 100; i++)
- {
- bulkInsert.Store(new User
- {
- Name = $"Egor{i}"
- }, $"user/{i}");
- }
- }
- using (var session = storeTuple.source.OpenAsyncSession())
- {
- for (int i = 0; i < 25000; i++)
- {
- var stream = new MemoryStream(Enumerable.Range(1, 3).Select(x => (byte)x).ToArray());
- session.Advanced.Attachments.Store($"user/{i}", "file", stream, "image/png");
- }
- await session.SaveChangesAsync();
- }
- }
- var storeDest = storeTuple.destination;
- using (storeDest)
- {
- using (var session = storeDest.OpenAsyncSession())
- {
- for (int i = 0; i < 1000 * 100; i++)
- {
- session.Delete($"user/{i}");
- }
- await session.SaveChangesAsync();
- }
- }
- }
Add Comment
Please, Sign In to add comment