Skip to content

Commit a2c703a

Browse files
committed
* Marked sessions which creates from database/sql driver as supported server-side session balancing
1 parent bbace28 commit a2c703a

File tree

2 files changed

+8
-1
lines changed

2 files changed

+8
-1
lines changed

CHANGELOG.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,5 @@
1+
* Marked sessions which creates from `database/sql` driver as supported server-side session balancing
2+
13
## v3.37.7
24
* Changed type of truncated result error from `StreamExecuteScanQuery` to retryable error
35
* Added closing sessions if node removed from discovery results

internal/xsql/connector.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ import (
55
"database/sql/driver"
66
"io"
77

8+
"github.com/ydb-platform/ydb-go-sdk/v3/internal/meta"
89
"github.com/ydb-platform/ydb-go-sdk/v3/internal/xerrors"
910
"github.com/ydb-platform/ydb-go-sdk/v3/scripting"
1011
"github.com/ydb-platform/ydb-go-sdk/v3/table"
@@ -115,7 +116,11 @@ func (c *Connector) Connect(ctx context.Context) (_ driver.Conn, err error) {
115116
defer func() {
116117
onDone(err)
117118
}()
118-
s, err := c.connection.Table().CreateSession(ctx)
119+
s, err := c.connection.Table().CreateSession(
120+
meta.WithAllowFeatures(ctx,
121+
meta.HintSessionBalancer,
122+
),
123+
)
119124
if err != nil {
120125
return nil, xerrors.WithStackTrace(err)
121126
}

0 commit comments

Comments
 (0)