Ado.Net NextResultAsync on skipping any more messages in ExecuteScalarAsync & ExecuteNonQueryAsync (will faster and safety)

KirillKurdyukov · KirillKurdyukov · commit 17c7d2d0480e · 2024-12-19T19:24:48.000+03:00
diff --git a/src/Ydb.Sdk/src/Ado/YdbCommand.cs b/src/Ydb.Sdk/src/Ado/YdbCommand.cs
@@ -31,7 +31,7 @@ public override async Task<int> ExecuteNonQueryAsync(CancellationToken cancellat
     {
         await using var dataReader = await ExecuteReaderAsync(cancellationToken);
 
-        while (await dataReader.ReadAsync(cancellationToken))
+        while (await dataReader.NextResultAsync(cancellationToken))
         {
         }
 
@@ -51,7 +51,7 @@ public override async Task<int> ExecuteNonQueryAsync(CancellationToken cancellat
             ? dataReader.IsDBNull(0) ? null : dataReader.GetValue(0)
             : null;
 
-        while (await dataReader.ReadAsync(cancellationToken))
+        while (await dataReader.NextResultAsync(cancellationToken))
         {
         }
 

Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,7 @@ public override async Task<int> ExecuteNonQueryAsync(CancellationToken cancellat`
`31`	`31`	`{`
`32`	`32`	`await using var dataReader = await ExecuteReaderAsync(cancellationToken);`
`33`	`33`
`34`		`- while (await dataReader.ReadAsync(cancellationToken))`
	`34`	`+ while (await dataReader.NextResultAsync(cancellationToken))`
`35`	`35`	`{`
`36`	`36`	`}`
`37`	`37`
`@@ -51,7 +51,7 @@ public override async Task<int> ExecuteNonQueryAsync(CancellationToken cancellat`
`51`	`51`	`? dataReader.IsDBNull(0) ? null : dataReader.GetValue(0)`
`52`	`52`	`: null;`
`53`	`53`
`54`		`- while (await dataReader.ReadAsync(cancellationToken))`
	`54`	`+ while (await dataReader.NextResultAsync(cancellationToken))`
`55`	`55`	`{`
`56`	`56`	`}`
`57`	`57`