json query transaction mode (ydb-platform#5574) - merge stable-24-2 (y…

…db-platform#6131)
uzhastik · Sep 9, 2024 · bd05e4e · bd05e4e
1 parent f8f340f
commit bd05e4e
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/ydb/core/viewer/json_query.h b/ydb/core/viewer/json_query.h
@@ -170,6 +170,22 @@ class TJsonQuery : public TViewerPipeClient<TJsonQuery> {
         }
     }
 
+    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);