Skip to content

Commit 3088199

Browse files
committed
CHANGELOG.md
1 parent 629b019 commit 3088199

File tree

2 files changed

+9
-3
lines changed

2 files changed

+9
-3
lines changed

CHANGELOG.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,5 @@
1+
* Fixed closing of child driver with shared balancer
2+
13
## v3.89.6
24
* Refactored `database/sql` driver internals for query-service client support in the future
35

tests/integration/driver_test.go

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@ import (
3232
"github.com/ydb-platform/ydb-go-sdk/v3/internal/xtest"
3333
"github.com/ydb-platform/ydb-go-sdk/v3/log"
3434
"github.com/ydb-platform/ydb-go-sdk/v3/retry"
35+
"github.com/ydb-platform/ydb-go-sdk/v3/table/result/indexed"
3536
"github.com/ydb-platform/ydb-go-sdk/v3/trace"
3637
)
3738

@@ -168,11 +169,14 @@ func TestDriver(sourceTest *testing.T) {
168169
t.Run("WithSharedBalancer", func(t *testing.T) {
169170
child, err := db.With(ctx, ydb.WithSharedBalancer(db))
170171
require.NoError(t, err)
171-
row, err := child.Query().QueryRow(ctx, `SELECT 1`)
172+
result, err := child.Scripting().Execute(ctx, `SELECT 1`, nil)
172173
require.NoError(t, err)
173-
var result int32
174-
err = row.Scan(&result)
174+
require.NoError(t, result.NextResultSetErr(ctx))
175+
require.True(t, result.NextRow())
176+
var value int32
177+
err = result.Scan(indexed.Required(&value))
175178
require.NoError(t, err)
179+
require.EqualValues(t, 1, value)
176180
err = child.Close(ctx)
177181
require.NoError(t, err)
178182
})

0 commit comments

Comments
 (0)