fix

Author: LiamHamsters

src/Ydb.Sdk/CHANGELOG.md

@@ -1,4 +1,4 @@
-- ADO.NET: Added `BulkUpsertAsync` for batch upsert operations with transaction checks and integration tests.
+- ADO.NET: Added `BeginBulkUpsertImport` for batch upsert operations with transaction checks and integration tests.
 - Optimization: On BadSession, do not invoke the `DeleteSession()` method.
 - Canceling AttachStream after calling the `DeleteSession` method.
 - Fixed bug: fixed issue where session was not deleted (`ClientTransportTimeout`).

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

@@ -15,7 +15,7 @@ public sealed class BulkUpsertImporter : IBulkUpsertImporter
     private readonly RepeatedField<Ydb.Value> _rows = new();
     private readonly CancellationToken _cancellationToken;
     private StructType? _structType;
-    private int _currentBytes = 0;
+    private int _currentBytes;
 
     public BulkUpsertImporter(
         IDriver driver,
@@ -38,8 +38,7 @@ public async ValueTask AddRowAsync(object?[] values)
             throw new ArgumentException("Values count must match columns count", nameof(values));
 
         var ydbValues = values.Select(v =>
-            v as YdbValue ?? (v is YdbParameter param ? param.YdbValue :
-                new YdbParameter { Value = v }.YdbValue)
+            v as YdbValue ?? (v is YdbParameter param ? param.YdbValue : new YdbParameter { Value = v }.YdbValue)
         ).ToArray();
 
         var protoStruct = new Ydb.Value();
@@ -96,4 +95,4 @@ public async ValueTask FlushAsync(CancellationToken cancellationToken = default)
         _rows.Clear();
         _currentBytes = 0;
     }
-}
+}

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

@@ -4,4 +4,4 @@ public interface IBulkUpsertImporter
 {
     ValueTask AddRowAsync(object?[] rows);
     ValueTask FlushAsync(CancellationToken cancellationToken = default);
-}
+}

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

@@ -489,9 +489,6 @@ public async Task BulkUpsertImporter_ThrowsOnNonexistentTable()
 
         await importer.AddRowAsync([YdbValue.MakeInt32(1), YdbValue.MakeUtf8("NotExists")]);
 
-        await Assert.ThrowsAsync<YdbException>(async () =>
-        {
-            await importer.FlushAsync();
-        });
+        await Assert.ThrowsAsync<YdbException>(async () => { await importer.FlushAsync(); });
     }
 }