fix

Author: LiamHamsters

src/Ydb.Sdk/src/Ado/BulkUpsert/IBulkUpsertImporter.cs

@@ -12,4 +12,4 @@ public interface IBulkUpsertImporter : IAsyncDisposable
 
     ValueTask FlushAsync(CancellationToken cancellationToken = default);
     IReadOnlyList<Ydb.Value> GetBufferedRows();
-}
+}

src/Ydb.Sdk/src/Ado/BulkUpsert/YdbBulkUpsertImporter.cs

@@ -123,4 +123,4 @@ private void ThrowIfDisposed()
         if (_disposed)
             throw new ObjectDisposedException(nameof(BulkUpsertImporter));
     }
-}
+}

src/Ydb.Sdk/src/Ado/YdbConnection.cs

@@ -2,19 +2,16 @@
 using System.Data.Common;
 using System.Diagnostics.CodeAnalysis;
 using Ydb.Sdk.Ado.BulkUpsert;
-using Ydb.Sdk.Ado.Internal;
 using Ydb.Sdk.Ado.Session;
 using Ydb.Sdk.Services.Query;
-using Ydb.Table;
-using Ydb.Table.V1;
 using static System.Data.IsolationLevel;
 
 namespace Ydb.Sdk.Ado;
 
 public sealed class YdbConnection : DbConnection
 {
     private const int MaxSendBufferSize = 64 * 1024 * 1024;
-    
+
     private static readonly StateChangeEventArgs ClosedToOpenEventArgs =
         new(ConnectionState.Closed, ConnectionState.Open);
 
@@ -67,10 +64,10 @@ public IBulkUpsertImporter BeginBulkUpsertImport(
         if (CurrentTransaction is { Completed: false })
             throw new InvalidOperationException("BulkUpsert cannot be used inside an active transaction.");
 
-        var database = (ConnectionStringBuilder.Database ?? "").TrimEnd('/');
+        var database = ConnectionStringBuilder.Database.TrimEnd('/');
         var tablePath = string.IsNullOrEmpty(database) ? name : $"{database}/{name}";
 
-        return new BulkUpsertImporter(this, tablePath, columns, types, MaxSendBufferSize);
+        return new BulkUpsertImporter(this, tablePath, columns, types);
     }
 
     protected override YdbTransaction BeginDbTransaction(IsolationLevel isolationLevel)

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

@@ -330,7 +330,8 @@ PRIMARY KEY (Id)
             }
 
             var columns = new[] { "Id", "Name" };
-            var types = new[] {
+            var types = new[]
+            {
                 new Type { TypeId = Type.Types.PrimitiveTypeId.Int32 },
                 new Type { TypeId = Type.Types.PrimitiveTypeId.Utf8 }
             };
@@ -402,7 +403,8 @@ PRIMARY KEY (Id)
             }
 
             var columns = new[] { "Id", "Name" };
-            var types = new[] {
+            var types = new[]
+            {
                 new Type { TypeId = Type.Types.PrimitiveTypeId.Int32 },
                 new Type { TypeId = Type.Types.PrimitiveTypeId.Utf8 }
             };
@@ -418,10 +420,7 @@ await Assert.ThrowsAsync<ArgumentException>(async () =>
                 {
                     new[] { YdbValue.MakeInt32(2) }
                 };
-                await Assert.ThrowsAsync<ArgumentException>(async () =>
-                {
-                    await importer.AddRowsAsync(rows);
-                });
+                await Assert.ThrowsAsync<ArgumentException>(async () => { await importer.AddRowsAsync(rows); });
             }
         }
         finally
@@ -453,7 +452,8 @@ PRIMARY KEY (Id)
             }
 
             var columns = new[] { "Id", "Name" };
-            var types = new[] {
+            var types = new[]
+            {
                 new Type { TypeId = Type.Types.PrimitiveTypeId.Int32 },
                 new Type { TypeId = Type.Types.PrimitiveTypeId.Utf8 }
             };
@@ -504,13 +504,13 @@ await Task.WhenAll(
                 Task.Run(async () =>
                 {
                     await using var importer = conn.BeginBulkUpsertImport(table1, columns, types);
-                    for (int i = 0; i < 20; i++)
+                    for (var i = 0; i < 20; i++)
                         await importer.AddRowAsync(YdbValue.MakeInt32(i), YdbValue.MakeUtf8($"A{i}"));
                 }),
                 Task.Run(async () =>
                 {
                     await using var importer = conn.BeginBulkUpsertImport(table2, columns, types);
-                    for (int i = 0; i < 20; i++)
+                    for (var i = 0; i < 20; i++)
                         await importer.AddRowAsync(YdbValue.MakeInt32(i), YdbValue.MakeUtf8($"B{i}"));
                 })
             );