imhven
/
abp
mirror of https://github.com/abpframework/abp
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add GetMany & SetMany unit tests.

Browse Source
pull/4523/head
maliming 5 years ago
parent a391e7a528
commit 57fdecc462
1 changed files with 143 additions and 0 deletions
Show Stats Download Patch File Download Diff File

143
framework/test/Volo.Abp.Caching.Tests/Volo/Abp/Caching/DistributedCache_Tests.cs
Unescape View File

@ -1,5 +1,6 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Shouldly;
using Volo.Abp.Testing;
@ -540,6 +541,148 @@ namespace Volo.Abp.Caching
cacheValue.ShouldBeNull();
}
[Fact]
public async Task Cache_Should_Only_Available_In_Uow_For_GetManyAsync()
{
var testkey = "testkey";
var testkey2 = "testkey2";
var testKeys = new[] {testkey, testkey2};
using (var uow = GetRequiredService<IUnitOfWorkManager>().Begin())
{
var personCache = GetRequiredService<IDistributedCache<PersonCacheItem>>();
var cacheValue = await personCache.GetManyAsync(testKeys, considerUow: true);
cacheValue.Where(x => x.Value != null).ShouldBeEmpty();
await personCache.SetManyAsync(new List<KeyValuePair<string, PersonCacheItem>>
{
new KeyValuePair<string, PersonCacheItem>(testkey, new PersonCacheItem("john")),
new KeyValuePair<string, PersonCacheItem>(testkey2, new PersonCacheItem("jack"))
}, considerUow: true);
cacheValue = await personCache.GetManyAsync(testKeys, considerUow: true);
cacheValue.Where(x => x.Value != null).ShouldNotBeEmpty();
cacheValue.ShouldContain(x => x.Value.Name == "john" || x.Value.Name == "jack");
cacheValue = await personCache.GetManyAsync(testKeys, considerUow: false);
cacheValue.Where(x => x.Value != null).ShouldBeEmpty();
uow.OnCompleted(async () =>
{
cacheValue = await personCache.GetManyAsync(testKeys, considerUow: false);
cacheValue.ShouldNotBeEmpty();
cacheValue.ShouldContain(x => x.Value.Name == "john" || x.Value.Name == "jack");
});
await uow.CompleteAsync();
}
}
[Fact]
public async Task Cache_Should_Rollback_With_Uow_For_GetManyAsync()
{
var testkey = "testkey";
var testkey2 = "testkey2";
var testKeys = new[] {testkey, testkey2};
var personCache = GetRequiredService<IDistributedCache<PersonCacheItem>>();
var cacheValue = await personCache.GetManyAsync(testKeys, considerUow: false);
cacheValue.Where(x => x.Value != null).ShouldBeEmpty();
using (var uow = GetRequiredService<IUnitOfWorkManager>().Begin())
{
cacheValue = await personCache.GetManyAsync(testKeys, considerUow: true);
cacheValue.Where(x => x.Value != null).ShouldBeEmpty();
await personCache.SetManyAsync(new List<KeyValuePair<string, PersonCacheItem>>
{
new KeyValuePair<string, PersonCacheItem>(testkey, new PersonCacheItem("john")),
new KeyValuePair<string, PersonCacheItem>(testkey2, new PersonCacheItem("jack"))
}, considerUow: true);
cacheValue = await personCache.GetManyAsync(testKeys, considerUow: true);
cacheValue.Where(x => x.Value != null).ShouldNotBeEmpty();
cacheValue.ShouldContain(x => x.Value.Name == "john" || x.Value.Name == "jack");
cacheValue = await personCache.GetManyAsync(testKeys, considerUow: false);
cacheValue.Where(x => x.Value != null).ShouldBeEmpty();
}
cacheValue = await personCache.GetManyAsync(testKeys, considerUow: false);
cacheValue.Where(x => x.Value != null).ShouldBeEmpty();
}
[Fact]
public async Task Cache_Should_Only_Available_In_Uow_For_SetManyAsync()
{
var testkey = "testkey";
var testkey2 = "testkey2";
var testKeys = new[] {testkey, testkey2};
using (var uow = GetRequiredService<IUnitOfWorkManager>().Begin())
{
var personCache = GetRequiredService<IDistributedCache<PersonCacheItem>>();
await personCache.SetManyAsync(new List<KeyValuePair<string, PersonCacheItem>>
{
new KeyValuePair<string, PersonCacheItem>(testkey, new PersonCacheItem("john")),
new KeyValuePair<string, PersonCacheItem>(testkey, new PersonCacheItem("jack"))
}, considerUow: true);
var cacheValue = await personCache.GetManyAsync(testKeys, considerUow: true);
cacheValue.Where(x => x.Value != null).ShouldNotBeEmpty();
cacheValue.ShouldContain(x => x.Value.Name == "john" || x.Value.Name == "jack");
cacheValue = await personCache.GetManyAsync(testKeys, considerUow: false);
cacheValue.Where(x => x.Value != null).ShouldBeEmpty();
uow.OnCompleted(async () =>
{
var cacheValue = await personCache.GetManyAsync(testKeys, considerUow: false);
cacheValue.Where(x => x.Value != null).ShouldNotBeEmpty();
cacheValue.ShouldContain(x => x.Value.Name == "john" || x.Value.Name == "jack");
});
await uow.CompleteAsync();
}
}
[Fact]
public async Task Cache_Should_Rollback_With_Uow_For_SetManyAsync()
{
var testkey = "testkey";
var testkey2 = "testkey2";
var testKeys = new[] {testkey, testkey2};
var personCache = GetRequiredService<IDistributedCache<PersonCacheItem>>();
var cacheValue = await personCache.GetManyAsync(testKeys, considerUow: false);
cacheValue.Where(x => x.Value != null).ShouldBeEmpty();
using (var uow = GetRequiredService<IUnitOfWorkManager>().Begin())
{
await personCache.SetManyAsync(new List<KeyValuePair<string, PersonCacheItem>>
{
new KeyValuePair<string, PersonCacheItem>(testkey, new PersonCacheItem("john")),
new KeyValuePair<string, PersonCacheItem>(testkey, new PersonCacheItem("jack"))
}, considerUow: true);
cacheValue = await personCache.GetManyAsync(testKeys, considerUow: true);
cacheValue.Where(x => x.Value != null).ShouldNotBeEmpty();
cacheValue.ShouldContain(x => x.Value.Name == "john" || x.Value.Name == "jack");
cacheValue = await personCache.GetManyAsync(testKeys, considerUow: false);
cacheValue.Where(x => x.Value != null).ShouldBeEmpty();
}
cacheValue = await personCache.GetManyAsync(testKeys, considerUow: false);
cacheValue.Where(x => x.Value != null).ShouldBeEmpty();
}
[Fact]
public async Task Should_Set_And_Get_Multiple_Items_Async()
{

Write Preview
Loading…
Cancel
Save