From bd05e4e878948294c6fe01c63154a634685c7209 Mon Sep 17 00:00:00 2001 From: Andrei Rykov Date: Fri, 5 Jul 2024 00:13:35 +0200 Subject: [PATCH] json query transaction mode (#5574) - merge stable-24-2 (#6131) --- ydb/core/viewer/json_query.h | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) 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);