Skip to content

Tests for async command processing #104

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 4 commits into from
Dec 25, 2020
Merged

Tests for async command processing #104

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
5448708
Adds async tests for CommandProcessors
alex-kulakov Dec 23, 2020
591b67d
Applies SessionScope/Scope changes from master
alex-kulakov Dec 23, 2020
536161f
Fixes some issues discovered after new tests
alex-kulakov Dec 23, 2020
7385d19
Merge branch '6.0' into async-command-processing-tests
alex-kulakov Dec 24, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
337 changes: 319 additions & 18 deletions ...nsive.Orm.Tests/Storage/CommandProcessing/BatchingCommandProcessorParametersManagement.cs
View file
Open in desktop

Large diffs are not rendered by default.

47 changes: 43 additions & 4 deletions Orm/Xtensive.Orm.Tests/Storage/CommandProcessing/BatchingOfVersionizedEntitiesTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@

using System;
using System.Linq;
using System.Threading.Tasks;
using NUnit.Framework;
using Xtensive.Core;
using Xtensive.Orm.Configuration;
Expand Down Expand Up @@ -119,10 +120,7 @@ public class BatchingOfVersionizedEntitiesTest : AutoBuildTest
private readonly SessionConfiguration sessionWithoutCheck =
new SessionConfiguration(SessionOptions.ServerProfile | SessionOptions.AutoActivation);

protected override void CheckRequirements()
{
Require.AllFeaturesSupported(ProviderFeatures.Batches);
}
protected override void CheckRequirements() => Require.AllFeaturesSupported(ProviderFeatures.Batches);

protected override DomainConfiguration BuildConfiguration()
{
Expand Down Expand Up @@ -370,6 +368,47 @@ public void VersionedEntityUpdateWithoutVersionCheckTest03()
}
}

[Test]
public async Task VersionedEntityUpdateWithoutVersionCheckAsyncTest03()
{
using (var session = await Domain.OpenSessionAsync(sessionWithoutCheck))
using (var counter = new CommandCounter(session))
using (var transaction = session.OpenTransaction()) {
var store = session.Query.All<Store>().Single(el => el.Name == "Store");
var book = session.Query.All<Book>().Single(el => el.Title == "Romeo and Juliet");
var author = session.Query.All<Author>().Single(el => el.FirstName == "William");

_ = new Store { Name = "NewStore1" };
_ = new Store { Name = "NewStore2" };
book.Title = "AnotherTitle";
store.Name = "AnotherStore";

_ = session.Query.ExecuteDelayed(q => q.All<Store>().Take(() => 1));
_ = session.Query.ExecuteDelayed(q => q.All<Store>().Take(() => 2));
_ = session.Query.ExecuteDelayed(q => q.All<Store>().Take(() => 3));
_ = session.Query.ExecuteDelayed(q => q.All<Store>().Take(() => 4));

using (counter.Attach()) {
(await session.Query.All<Author>().AsAsync()).Run();
}

Assert.That(counter.Count, Is.EqualTo(1));
counter.Reset();

_ = new Store { Name = "NewStore3" };
_ = new Store { Name = "NewStore4" };
_ = new Store { Name = "NewStore5" };

author.FirstName = "NotWilliam";

using (counter.Attach()) {
session.SaveChanges();
}

Assert.That(counter.Count, Is.EqualTo(1));
}
}

private bool IsUpdatesFirst()
{
return !(Domain.Configuration.Supports(ForeignKeyMode.Reference)
Expand Down
183 changes: 165 additions & 18 deletions ...tensive.Orm.Tests/Storage/CommandProcessing/SimpleCommandProcessorParametersManagement.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@

using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using NUnit.Framework;
using Xtensive.Core;
using Xtensive.Orm.Configuration;
Expand All @@ -16,10 +17,7 @@ namespace Xtensive.Orm.Tests.Storage.CommandProcessing
{
public class SimpleCommandProcessorParametersManagement : AutoBuildTest
{
public int StorageLimit
{
get { return ProviderInfo.MaxQueryParameterCount; }
}
public int StorageLimit => ProviderInfo.MaxQueryParameterCount;

protected override DomainConfiguration BuildConfiguration()
{
Expand All @@ -29,10 +27,7 @@ protected override DomainConfiguration BuildConfiguration()
return config;
}

protected override void CheckRequirements()
{
Require.AllFeaturesNotSupported(ProviderFeatures.Batches);
}
protected override void CheckRequirements() => Require.AllFeaturesNotSupported(ProviderFeatures.Batches);

protected override void PopulateData()
{
Expand Down Expand Up @@ -94,15 +89,65 @@ public void DelayedSelectsWithinLimitTest()
}
}

[Test]
public async Task DelayedSelectsWithinLimitAsyncTest()
{
RequireLimit();

using (var session = await Domain.OpenSessionAsync())
using (var transaction = session.OpenTransaction()) {
var ids = Enumerable.Range(1, StorageLimit - 1).ToArray(StorageLimit - 1);
var results = new List<IEnumerable<ALotOfFieldsEntityValid>>(10);

results.Add(session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, ids))));

results.Add(session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, ids))));

results.Add(session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, ids))));

results.Add(session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, ids))));

results.Add(session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, ids))));

results.Add(session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, ids))));

results.Add(session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, ids))));

results.Add(session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, ids))));

results.Add(session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, ids))));

results.Add(session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, ids))));

var inlineQuery = await session.Query.All<ALotOfFieldsEntityValid>()
.Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, ids)).AsAsync();
Assert.That(inlineQuery.Any(), Is.True);

foreach (var result in results) {
Assert.That(result.Any(), Is.True);
}
}
}

[Test]
public void DelayedSelectsOutOfLimitTest01()
{
RequireLimit();

using (var session = Domain.OpenSession())
using (var transaction = session.OpenTransaction()) {
var fittedIds = Enumerable.Range(1, StorageLimit - 1).ToArray();
var idsOutOfRange = Enumerable.Range(1, StorageLimit + 1).ToArray();
var fittedIds = Enumerable.Range(1, StorageLimit - 1).ToArray(StorageLimit - 1);
var idsOutOfRange = Enumerable.Range(1, StorageLimit + 1).ToArray(StorageLimit + 1);

var result = (DelayedSequence<ALotOfFieldsEntityValid>) session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, idsOutOfRange)));
Expand All @@ -112,15 +157,33 @@ public void DelayedSelectsOutOfLimitTest01()
}
}

[Test]
public async Task DelayedSelectsOutOfLimitAsyncTest01()
{
RequireLimit();

using (var session = await Domain.OpenSessionAsync())
using (var transaction = session.OpenTransaction()) {
var fittedIds = Enumerable.Range(1, StorageLimit - 1).ToArray(StorageLimit - 1);
var idsOutOfRange = Enumerable.Range(1, StorageLimit + 1).ToArray(StorageLimit + 1);

var result = (DelayedSequence<ALotOfFieldsEntityValid>) session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, idsOutOfRange)));

_ = Assert.ThrowsAsync<ParametersLimitExceededException>(async () => await result.AsAsync());
Assert.That(result.Task.Result.Count, Is.EqualTo(0));
}
}

[Test]
public void DelayedSelectsOutOfLimitTest02()
{
RequireLimit();

using (var session = Domain.OpenSession())
using (var transaction = session.OpenTransaction()) {
var fittedIds = Enumerable.Range(1, StorageLimit - 1).ToArray();
var idsOutOfRange = Enumerable.Range(1, StorageLimit + 1).ToArray();
var fittedIds = Enumerable.Range(1, StorageLimit - 1).ToArray(StorageLimit - 1);
var idsOutOfRange = Enumerable.Range(1, StorageLimit + 1).ToArray(StorageLimit + 1);

var result = (DelayedSequence<ALotOfFieldsEntityValid>) session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, idsOutOfRange)));
Expand All @@ -130,15 +193,33 @@ public void DelayedSelectsOutOfLimitTest02()
}
}

[Test]
public async Task DelayedSelectsOutOfLimitAsyncTest02()
{
RequireLimit();

using (var session = await Domain.OpenSessionAsync())
using (var transaction = session.OpenTransaction()) {
var fittedIds = Enumerable.Range(1, StorageLimit - 1).ToArray(StorageLimit - 1);
var idsOutOfRange = Enumerable.Range(1, StorageLimit + 1).ToArray(StorageLimit + 1);

var result = (DelayedSequence<ALotOfFieldsEntityValid>) session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, idsOutOfRange)));

_ = Assert.ThrowsAsync<ParametersLimitExceededException>(async () => (await session.Query.All<ALotOfFieldsEntityValid>().AsAsync()).Run());
Assert.That(result.Task.Result.Count, Is.EqualTo(0));
}
}

[Test]
public void DelayedSelectsOutOfLimitTest03()
{
RequireLimit();

using (var session = Domain.OpenSession())
using (var transaction = session.OpenTransaction()) {
var fittedIds = Enumerable.Range(1, StorageLimit - 1).ToArray();
var idsOutOfRange = Enumerable.Range(1, StorageLimit + 1).ToArray();
var fittedIds = Enumerable.Range(1, StorageLimit - 1).ToArray(StorageLimit - 1);
var idsOutOfRange = Enumerable.Range(1, StorageLimit + 1).ToArray(StorageLimit + 1);

var result = (DelayedSequence<ALotOfFieldsEntityValid>) session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, fittedIds)));
Expand All @@ -151,15 +232,36 @@ public void DelayedSelectsOutOfLimitTest03()
}
}

[Test]
public async Task DelayedSelectsOutOfLimitAsyncTest03()
{
RequireLimit();

using (var session = await Domain.OpenSessionAsync())
using (var transaction = session.OpenTransaction()) {
var fittedIds = Enumerable.Range(1, StorageLimit - 1).ToArray(StorageLimit - 1);
var idsOutOfRange = Enumerable.Range(1, StorageLimit + 1).ToArray(StorageLimit + 1);

var result = (DelayedSequence<ALotOfFieldsEntityValid>) session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, fittedIds)));

_ = session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, idsOutOfRange)));

_ = Assert.ThrowsAsync<ParametersLimitExceededException>(async () => (await session.Query.All<ALotOfFieldsEntityValid>().AsAsync()).Run());
Assert.That(result.Any(), Is.True);
}
}

[Test]
public void DelayedSelectsOutOfLimitTest04()
{
RequireLimit();

using (var session = Domain.OpenSession())
using (var transaction = session.OpenTransaction()) {
var fittedIds = Enumerable.Range(1, StorageLimit - 1).ToArray();
var idsOutOfRange = Enumerable.Range(1, StorageLimit + 1).ToArray();
var fittedIds = Enumerable.Range(1, StorageLimit - 1).ToArray(StorageLimit - 1);
var idsOutOfRange = Enumerable.Range(1, StorageLimit + 1).ToArray(StorageLimit + 1);

var result = (DelayedSequence<ALotOfFieldsEntityValid>) session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, idsOutOfRange)));
Expand All @@ -172,15 +274,36 @@ public void DelayedSelectsOutOfLimitTest04()
}
}

[Test]
public async Task DelayedSelectsOutOfLimitAsyncTest04()
{
RequireLimit();

using (var session = await Domain.OpenSessionAsync())
using (var transaction = session.OpenTransaction()) {
var fittedIds = Enumerable.Range(1, StorageLimit - 1).ToArray(StorageLimit - 1);
var idsOutOfRange = Enumerable.Range(1, StorageLimit + 1).ToArray(StorageLimit + 1);

var result = (DelayedSequence<ALotOfFieldsEntityValid>) session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, idsOutOfRange)));

_ = session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, fittedIds)));

_ = Assert.ThrowsAsync<ParametersLimitExceededException>(async () => (await session.Query.All<ALotOfFieldsEntityValid>().AsAsync()).Run());
Assert.That(result.Any(), Is.False);
}
}

[Test]
public void DelayedSelectsOutOfLimitTest05()
{
RequireLimit();

using (var session = Domain.OpenSession())
using (var transaction = session.OpenTransaction()) {
var fittedIds = Enumerable.Range(1, StorageLimit - 1).ToArray();
var idsOutOfRange = Enumerable.Range(1, StorageLimit + 1).ToArray();
var fittedIds = Enumerable.Range(1, StorageLimit - 1).ToArray(StorageLimit - 1);
var idsOutOfRange = Enumerable.Range(1, StorageLimit + 1).ToArray(StorageLimit + 1);

var result1 = (DelayedSequence<ALotOfFieldsEntityValid>) session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, fittedIds)));
Expand All @@ -196,6 +319,30 @@ public void DelayedSelectsOutOfLimitTest05()
}
}

[Test]
public async Task DelayedSelectsOutOfLimitAsyncTest05()
{
RequireLimit();

using (var session = await Domain.OpenSessionAsync())
using (var transaction = session.OpenTransaction()) {
var fittedIds = Enumerable.Range(1, StorageLimit - 1).ToArray(StorageLimit - 1);
var idsOutOfRange = Enumerable.Range(1, StorageLimit + 1).ToArray(StorageLimit + 1);

var result1 = (DelayedSequence<ALotOfFieldsEntityValid>) session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, fittedIds)));

var result2 = session.Query.ExecuteDelayed(q =>
q.All<ALotOfFieldsEntityValid>().Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, fittedIds)));

_ = Assert.ThrowsAsync<ParametersLimitExceededException>(
async () => (await session.Query.All<ALotOfFieldsEntityValid>()
.Where(e => e.Id.In(IncludeAlgorithm.ComplexCondition, idsOutOfRange)).AsAsync()).Run());
Assert.That(result1.Any(), Is.True);
Assert.That(result2.Any(), Is.True);
}
}

[Test]
public void InsertTest01()
{
Expand Down
Loading