This is an automated email from the ASF dual-hosted git repository. ptupitsyn pushed a commit to branch ignite-22133-bak in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit 9326a03d8fe82525fe85d5f02c46dc596e1e8d36 Author: Pavel Tupitsyn <[email protected]> AuthorDate: Fri Jun 27 14:28:16 2025 +0300 wip --- .../Apache.Ignite.EntityFrameworkCore.Tests/BasicTest.cs | 13 ------------- .../DataCommon/IgniteCommand.cs | 9 ++++++--- 2 files changed, 6 insertions(+), 16 deletions(-) diff --git a/modules/platforms/dotnet/Apache.Ignite.EntityFrameworkCore.Tests/BasicTest.cs b/modules/platforms/dotnet/Apache.Ignite.EntityFrameworkCore.Tests/BasicTest.cs index 8d6207cc02c..53bfb6721f2 100644 --- a/modules/platforms/dotnet/Apache.Ignite.EntityFrameworkCore.Tests/BasicTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.EntityFrameworkCore.Tests/BasicTest.cs @@ -24,19 +24,6 @@ using NUnit.Framework; public class BasicTest { - [SetUp] - public async Task SetUp() - { - using var client = await IgniteClient.StartAsync(new(GetIgniteEndpoint())); - - var tables = await client.Tables.GetTablesAsync(); - - foreach (var table in tables) - { - await client.Sql.ExecuteAsync(null, $"DROP TABLE \"{table.Name}\""); - } - } - [Test] public async Task TestIgniteEfCore() { diff --git a/modules/platforms/dotnet/Apache.Ignite.EntityFrameworkCore/DataCommon/IgniteCommand.cs b/modules/platforms/dotnet/Apache.Ignite.EntityFrameworkCore/DataCommon/IgniteCommand.cs index 237d7dc7e60..05baf3dca2e 100644 --- a/modules/platforms/dotnet/Apache.Ignite.EntityFrameworkCore/DataCommon/IgniteCommand.cs +++ b/modules/platforms/dotnet/Apache.Ignite.EntityFrameworkCore/DataCommon/IgniteCommand.cs @@ -65,15 +65,18 @@ public class IgniteCommand : DbCommand public override async Task<int> ExecuteNonQueryAsync(CancellationToken cancellationToken) { - var args = _parameters?.ToObjectArray() ?? Array.Empty<object>(); + var args = _parameters?.ToObjectArray() ?? []; // TODO: Remove debug output. - Console.WriteLine($"IgniteCommand.ExecuteNonQueryAsync [statement={CommandText}, parameters={string.Join(", ", args)}]"); + var statement = new SqlStatement(CommandText); + + Console.WriteLine($"IgniteCommand.ExecuteNonQueryAsync [statement={statement}, parameters={string.Join(", ", args)}]"); // TODO: Propagate transaction somehow. await using IResultSet<object> resultSet = await Sql.ExecuteAsync<object>( transaction: null, - CommandText, + statement, + cancellationToken, args); Debug.Assert(!resultSet.HasRowSet, "!resultSet.HasRowSet");
