fix test

Author: KirillKurdyukov

src/Ydb.Sdk/src/Ado/YdbConnectionStringBuilder.cs

@@ -454,10 +454,10 @@ static YdbConnectionOption()
                 (builder, password) => builder.Password = password), "Password", "PWD", "PSW");
             AddOption(new YdbConnectionOption<int>(IntExtractor, (builder, maxSessionPool) =>
                     builder.MaxSessionPool = maxSessionPool), "MaxSessionPool", "Max Session Pool", "Maximum Pool Size",
-                "MaximumPoolSize", "Max Pool Size", "MaxPoolSize");
+                "MaximumPoolSize", "Max Pool Size", "MaxPoolSize", "MaxSessionSize", "Max Session Size");
             AddOption(new YdbConnectionOption<int>(IntExtractor, (builder, minSessionSize) =>
                     builder.MinSessionPool = minSessionSize), "MinSessionPool", "Min Session Pool", "Minimum Pool Size",
-                "MinimumPoolSize", "Min Pool Size", "MinPoolSize");
+                "MinimumPoolSize", "Min Pool Size", "MinPoolSize", "MinSessionSize", "Min Session Size");
             AddOption(new YdbConnectionOption<bool>(BoolExtractor, (builder, useTls) => builder.UseTls = useTls),
                 "UseTls", "Use Tls");
             AddOption(new YdbConnectionOption<string>(StringExtractor,

src/Ydb.Sdk/test/Ydb.Sdk.Ado.Tests/TestBase.cs

@@ -20,18 +20,9 @@ protected static YdbConnection CreateOpenConnection()
 
     protected static async Task<YdbConnection> CreateOpenConnectionAsync()
     {
-        try
-        {
-            var connection = CreateConnection();
-            await connection.OpenAsync();
-            return connection;
-        }
-        catch (YdbException e) when (e is { Code: StatusCode.Unspecified, Message: "Session Source is disposed." })
-        {
-            var connection = CreateConnection();
-            await connection.OpenAsync();
-            return connection;
-        }
+        var connection = CreateConnection();
+        await connection.OpenAsync();
+        return connection;
     }
 
     public async Task InitializeAsync() => await OnInitializeAsync().ConfigureAwait(false);

src/Ydb.Sdk/test/Ydb.Sdk.Ado.Tests/YdbConnectionTests.cs

@@ -19,31 +19,19 @@ public sealed class YdbConnectionTests : TestBase
     [Fact]
     public async Task ClearPool_WhenHasActiveConnection_CloseActiveConnectionOnClose()
     {
-        var tasks = GenerateTasks();
-        tasks.Add(YdbConnection.ClearPool(CreateConnection()));
-        tasks.AddRange(GenerateTasks());
-        await Task.WhenAll(tasks);
-        Assert.Equal(9900, _counter);
+        var connectionString = ConnectionString + ";MaxSessionPool=100";
 
-        tasks = GenerateTasks();
-        tasks.Add(YdbConnection.ClearPool(CreateConnection()));
-        await Task.WhenAll(tasks);
-        Assert.Equal(14850, _counter);
-    }
-
-    [Fact]
-    public async Task ClearPoolAllPools_WhenHasActiveConnection_CloseActiveConnectionOnClose()
-    {
-        var tasks = GenerateTasks();
-        tasks.Add(YdbConnection.ClearAllPools());
-        tasks.AddRange(GenerateTasks());
+        var tasks = GenerateTasks(connectionString);
+        tasks.Add(YdbConnection.ClearPool(new YdbConnection(connectionString)));
+        tasks.AddRange(GenerateTasks(connectionString));
         await Task.WhenAll(tasks);
         Assert.Equal(9900, _counter);
 
-        tasks = GenerateTasks();
-        tasks.Add(YdbConnection.ClearAllPools());
+        tasks = GenerateTasks(connectionString);
+        tasks.Add(YdbConnection.ClearPool(new YdbConnection(connectionString)));
         await Task.WhenAll(tasks);
         Assert.Equal(14850, _counter);
+        await YdbConnection.ClearPool(new YdbConnection(connectionString));
     }
 
     // docker cp ydb-local:/ydb_certs/ca.pem ~/
@@ -296,9 +284,24 @@ public async Task ExecuteReaderAsync_WhenExecutedYdbDataReaderThenCancelTokenIsC
         Assert.False(await ydbDataReader.NextResultAsync());
     }
 
-    private List<Task> GenerateTasks() => Enumerable.Range(0, 100).Select(async i =>
+    private List<Task> GenerateTasks(string connectionString) => Enumerable.Range(0, 1000).Select(async i =>
     {
-        await using var connection = await CreateOpenConnectionAsync();
+        YdbConnection ydbConnection;
+        try
+        {
+            ydbConnection = CreateConnection();
+            ydbConnection.ConnectionString = connectionString;
+            await ydbConnection.OpenAsync();
+        }
+        catch (YdbException e)
+        {
+            Assert.Equal(StatusCode.Unspecified, e.Code);
+            Assert.Equal("Session Source is disposed.", e.Message);
+            Interlocked.Add(ref _counter, i);
+            return;
+        }
+
+        await using var connection = ydbConnection;
         var command = connection.CreateCommand();
         command.CommandText = "SELECT " + i;
         var scalar = (int)(await command.ExecuteScalarAsync())!;