diff --git a/ydb/core/viewer/json_query.h b/ydb/core/viewer/json_query.h index dabfe440f714..0afa9828e620 100644 --- a/ydb/core/viewer/json_query.h +++ b/ydb/core/viewer/json_query.h @@ -170,6 +170,22 @@ class TJsonQuery : public TViewerPipeClient { } } + void SetTransactionMode(NKikimrKqp::TQueryRequest& request) { + if (TransactionMode == "serializable-read-write") { + request.mutable_txcontrol()->mutable_begin_tx()->mutable_serializable_read_write(); + request.mutable_txcontrol()->set_commit_tx(true); + } else if (TransactionMode == "online-read-only") { + request.mutable_txcontrol()->mutable_begin_tx()->mutable_online_read_only(); + request.mutable_txcontrol()->set_commit_tx(true); + } else if (TransactionMode == "stale-read-only") { + request.mutable_txcontrol()->mutable_begin_tx()->mutable_stale_read_only(); + request.mutable_txcontrol()->set_commit_tx(true); + } else if (TransactionMode == "snapshot-read-only") { + request.mutable_txcontrol()->mutable_begin_tx()->mutable_snapshot_read_only(); + request.mutable_txcontrol()->set_commit_tx(true); + } + } + void SendKpqProxyRequest() { if (QueryId) { TActorId actorId = Viewer->FindRunningQuery(QueryId);