Merge pull request #1731 from ydb-platform/auto-tx

Added `query.EmptyTxControl()` + Marked as deprecated `query.NoTx()`

Author: asmyasnikov

CHANGELOG.md

@@ -1,3 +1,6 @@
+* Added `query.EmptyTxControl()` for empty transaction control (server-side defines transaction control by internal logic)
+* Marked as deprecated `query.NoTx()` because this is wrong name for server-side transaction control inference
+
 ## v3.107.0
 * Refactored internal client balancer: added singleton for getting gRPC-connection (auto dial and auto reconnect on non-ready state) for use in discovery attempts
 * Added `topicoptions.IncludePartitionStats()` for `Topic().Describe()` in order to get partition stats from server

query/transaction.go

@@ -46,13 +46,23 @@ func TxControl(opts ...tx.ControlOption) *TransactionControl {
 	return tx.NewControl(opts...)
 }
 
-func NoTx() *TransactionControl {
+// EmptyTxControl defines transaction control inference on server-side by query content
+func EmptyTxControl() *TransactionControl {
 	return nil
 }
 
+// NoTx defines nil transaction control
+// This is wrong name for transaction control inference on server-side by query content
+// Deprecated: Use EmptyTxControl instead.
+// Will be removed after Oct 2025.
+// Read about versioning policy: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#deprecated
+func NoTx() *TransactionControl {
+	return EmptyTxControl()
+}
+
 // DefaultTxControl returns default transaction control for use default tx control on server-side
 func DefaultTxControl() *TransactionControl {
-	return NoTx()
+	return EmptyTxControl()
 }
 
 // SerializableReadWriteTxControl returns transaction control with serializable read-write isolation mode

tests/slo/native/query/storage.go

@@ -216,7 +216,7 @@ func (s *Storage) CreateTable(ctx context.Context) error {
 				fmt.Sprintf(createTableQuery, s.tablePath, s.cfg.MinPartitionsCount, s.cfg.PartitionSize,
 					s.cfg.MinPartitionsCount, s.cfg.MaxPartitionsCount,
 				),
-				query.WithTxControl(query.NoTx()),
+				query.WithTxControl(query.EmptyTxControl()),
 			)
 		}, query.WithIdempotent(),
 		query.WithLabel("CREATE TABLE"),
@@ -235,7 +235,7 @@ func (s *Storage) DropTable(ctx context.Context) error {
 		func(ctx context.Context, session query.Session) error {
 			return session.Exec(ctx,
 				fmt.Sprintf(dropTableQuery, s.tablePath),
-				query.WithTxControl(query.NoTx()),
+				query.WithTxControl(query.EmptyTxControl()),
 			)
 		},
 		query.WithIdempotent(),