summaryrefslogtreecommitdiffstats
path: root/yql/essentials/sql/v1/query.cpp
diff options
context:
space:
mode:
authorflown4qqqq <[email protected]>2025-02-11 18:13:29 +0300
committerflown4qqqq <[email protected]>2025-02-11 18:34:41 +0300
commit5c6755b60fea0490015fbd14787ea4431736b3f9 (patch)
treeac05ac804e398e4022b352cdd73531aef9f953fa /yql/essentials/sql/v1/query.cpp
parent8b363a039a2bc94a03da342d5cffe4b723e63a21 (diff)
Fix bugs with parsing alter database (+add ut on compiling)
commit_hash:7e6d742dce448b1c5f815abebd781049e7b22b46
Diffstat (limited to 'yql/essentials/sql/v1/query.cpp')
-rw-r--r--yql/essentials/sql/v1/query.cpp6
1 files changed, 2 insertions, 4 deletions
diff --git a/yql/essentials/sql/v1/query.cpp b/yql/essentials/sql/v1/query.cpp
index cac9b5aaf5f..780f7bb99e1 100644
--- a/yql/essentials/sql/v1/query.cpp
+++ b/yql/essentials/sql/v1/query.cpp
@@ -1337,15 +1337,13 @@ public:
auto options = Y(Q(Y(Q("mode"), Q("alterDatabase"))));
- options = L(options, Q(Y(Q("dbPath"), Q(Params.DbPath))));
-
if (Params.Owner.has_value()) {
- options = L(options, Q(Y(Q("owner"), Q(Params.Owner.value().Build()))));
+ options = L(options, Q(Y(Q("owner"), Params.Owner.value().Build())));
}
Add("block", Q(Y(
Y("let", "sink", Y("DataSink", BuildQuotedAtom(Pos, Service), cluster)),
- Y("let", "world", Y(TString(WriteName), "world", "sink", Q(options))),
+ Y("let", "world", Y(TString(WriteName), "world", "sink", Y("Key", Q(Y(Q("databasePath"), Y("String", Params.DbPath.Build())))), Y("Void"), Q(options))),
Y("return", ctx.PragmaAutoCommit ? Y(TString(CommitName), "world", "sink") : AstNode("world"))
)));