tests on ado + blank

Author: Travonka

src/Ydb.Sdk/src/DriverConfig.cs

@@ -7,6 +7,7 @@ namespace Ydb.Sdk;
 public class DriverConfig
 {
     private readonly string _pid = Environment.ProcessId.ToString();
+
     public string Endpoint { get; }
     public string Database { get; }
     public ICredentialsProvider? Credentials { get; }

src/Ydb.Sdk/tests/Sys/QuerySessionTests.cs

@@ -1,28 +1,30 @@
 using Xunit;
 using Ydb.Sdk.Services.Query;
+using Ydb.Sdk.Tests.Ado.Specification;
 using Ydb.Sdk.Tests.Fixture;
 
 namespace Ydb.Sdk.Tests.Sys;
 
-public class QuerySessionTests : IClassFixture<QueryClientFixture>
+public class QuerySessionTests : YdbAdoNetFixture
 {
-    private readonly QueryClient _queryClient;
-
-    public QuerySessionTests(QueryClientFixture queryClientFixture)
+    public QuerySessionTests(YdbFactoryFixture fixture) : base(fixture)
     {
-        _queryClient = queryClientFixture.QueryClient;
     }
 
     [Fact]
     public async Task QuerySessionPidTest()
     {
-        const string sql = @"SELECT * FROM `.sys/query_sessions` LIMIT 1";
+        await using var connection = await CreateOpenConnectionAsync();
+        var dbCommand = connection.CreateCommand();
+        dbCommand.CommandText = "SELECT ClientPID FROM `.sys/query_sessions` LIMIT 1;";
+        
         var expectedPid = Environment.ProcessId.ToString();
+        
+        await dbCommand.ExecuteNonQueryAsync();
+        await using var reader = await dbCommand.ExecuteReaderAsync();
 
-        await _queryClient.Exec(sql);
-        var sessionRow = await _queryClient.ReadRow(sql);
-
-        Assert.NotNull(sessionRow);
-        Assert.Equal(sessionRow["ClientPID"].GetOptionalUtf8(), expectedPid);
+        Assert.True(reader.HasRows);
+        Assert.True(await reader.ReadAsync());
+        Assert.Equal(reader.GetString(0), expectedPid);
     }
 }