diff --git a/src/Ydb.Sdk/tests/Ado/YdbCommandTests.cs b/src/Ydb.Sdk/tests/Ado/YdbCommandTests.cs index 316c8450..d99b86b0 100644 --- a/src/Ydb.Sdk/tests/Ado/YdbCommandTests.cs +++ b/src/Ydb.Sdk/tests/Ado/YdbCommandTests.cs @@ -280,6 +280,10 @@ public void ExecuteDbDataReader_WhenPreviousIsNotClosed_ThrowException() Assert.Equal("A command is already in progress: SELECT 1; SELECT 1;", Assert.Throws(() => dbCommand.ExecuteReader()).Message); + Assert.True(ydbDataReader.NextResult()); + Assert.True(ydbDataReader.NextResult()); + Assert.False(ydbDataReader.NextResult()); + ydbDataReader.Close(); Assert.True(ydbDataReader.IsClosed); } @@ -331,6 +335,7 @@ public void GetChars_WhenSelectText_MoveCharsToBuffer() Assert.Equal(checkBuffer, bufferChars); Assert.Equal('a', ydbDataReader.GetChar(0)); + Assert.False(ydbDataReader.Read()); } [Fact] @@ -377,6 +382,7 @@ public void GetBytes_WhenSelectBytes_MoveBytesToBuffer() checkBuffer[6] = (byte)'b'; checkBuffer[7] = (byte)'a'; Assert.Equal(checkBuffer, bufferChars); + Assert.False(ydbDataReader.Read()); } [Fact] diff --git a/src/Ydb.Sdk/tests/Ado/YdbTransactionTests.cs b/src/Ydb.Sdk/tests/Ado/YdbTransactionTests.cs index f39f1c72..5036e3a4 100644 --- a/src/Ydb.Sdk/tests/Ado/YdbTransactionTests.cs +++ b/src/Ydb.Sdk/tests/Ado/YdbTransactionTests.cs @@ -137,6 +137,11 @@ public void CommitAndRollback_WhenStreamIsOpened_ThrowException() Assert.Equal("A command is already in progress: SELECT 1; SELECT 2; SELECT 3", Assert.Throws(() => ydbTransaction.Rollback()).Message); + Assert.True(dbDataReader.NextResult()); + Assert.True(dbDataReader.NextResult()); + Assert.True(dbDataReader.NextResult()); + Assert.False(dbDataReader.NextResult()); + dbDataReader.Close(); // Close stream ydbTransaction.Commit(); Assert.Equal("This YdbTransaction has completed; it is no longer usable",