fixed SLO

Author: asmyasnikov

tests/slo/gorm/query/storage.go

@@ -10,7 +10,6 @@ import (
 	environ "github.com/ydb-platform/ydb-go-sdk-auth-environ"
 	ydbSDK "github.com/ydb-platform/ydb-go-sdk/v3"
 	"github.com/ydb-platform/ydb-go-sdk/v3/retry"
-	"github.com/ydb-platform/ydb-go-sdk/v3/table"
 	"github.com/ydb-platform/ydb-go-sdk/v3/trace"
 	"gorm.io/gorm"
 	"gorm.io/gorm/clause"
@@ -30,19 +29,6 @@ WITH (
     UNIFORM_PARTITIONS = %d
 )`
 
-var (
-	readTx = table.TxControl(
-		table.BeginTx(
-			table.WithOnlineReadOnly(),
-		),
-		table.CommitTx(),
-	)
-
-	writeTx = table.SerializableReadWriteTxControl(
-		table.CommitTx(),
-	)
-)
-
 type Storage struct {
 	db           *gorm.DB
 	cfg          *config.Config
@@ -91,7 +77,7 @@ func (s *Storage) Read(ctx context.Context, id generator.RowID) (r generator.Row
 		return generator.Row{}, attempts, err
 	}
 
-	err = retry.Do(ydbSDK.WithTxControl(ctx, readTx), db,
+	err = retry.Do(ctx, db,
 		func(ctx context.Context, cc *sql.Conn) (err error) {
 			if err = ctx.Err(); err != nil {
 				return err
@@ -139,7 +125,7 @@ func (s *Storage) Write(ctx context.Context, row generator.Row) (attempts int, e
 		return attempts, err
 	}
 
-	err = retry.Do(ydbSDK.WithTxControl(ctx, writeTx), db,
+	err = retry.Do(ctx, db,
 		func(ctx context.Context, cc *sql.Conn) (err error) {
 			if err = ctx.Err(); err != nil {
 				return err

tests/slo/native/query/storage.go

@@ -120,7 +120,7 @@ func (s *Storage) Read(ctx context.Context, entryID generator.RowID) (_ generato
 						Build(),
 				),
 				query.WithTxControl(query.TxControl(
-					query.BeginTx(query.WithOnlineReadOnly()),
+					query.BeginTx(query.WithSnapshotReadOnly()),
 					query.CommitTx(),
 				)),
 			)

tests/slo/xorm/query/storage.go

@@ -11,7 +11,6 @@ import (
 
 	"github.com/ydb-platform/ydb-go-sdk/v3"
 	"github.com/ydb-platform/ydb-go-sdk/v3/retry"
-	"github.com/ydb-platform/ydb-go-sdk/v3/table"
 	"github.com/ydb-platform/ydb-go-sdk/v3/trace"
 	"xorm.io/xorm"
 	"xorm.io/xorm/core"
@@ -21,19 +20,6 @@ import (
 	"slo/internal/generator"
 )
 
-var (
-	readTx = table.TxControl(
-		table.BeginTx(
-			table.WithOnlineReadOnly(),
-		),
-		table.CommitTx(),
-	)
-
-	writeTx = table.SerializableReadWriteTxControl(
-		table.CommitTx(),
-	)
-)
-
 type mapper struct {
 	tableName  string
 	objectName string
@@ -126,7 +112,7 @@ func (s *Storage) Read(ctx context.Context, id generator.RowID) (row generator.R
 
 	row.ID = id
 
-	err = retry.Do(ydb.WithTxControl(ctx, readTx), s.x.DB().DB,
+	err = retry.Do(ctx, s.x.DB().DB,
 		func(ctx context.Context, _ *sql.Conn) (err error) {
 			has, err := s.x.Context(ctx).Where("hash = Digest::NumericHash(?)", id).Get(&row)
 			if err != nil {
@@ -161,7 +147,7 @@ func (s *Storage) Write(ctx context.Context, row generator.Row) (attempts int, e
 	ctx, cancel := context.WithTimeout(ctx, time.Duration(s.cfg.WriteTimeout)*time.Millisecond)
 	defer cancel()
 
-	err = retry.Do(ydb.WithTxControl(ctx, writeTx), s.x.DB().DB,
+	err = retry.Do(ctx, s.x.DB().DB,
 		func(ctx context.Context, _ *sql.Conn) (err error) {
 			if err = ctx.Err(); err != nil {
 				return err