diff options
| author | flown4qqqq <[email protected]> | 2025-02-11 18:13:29 +0300 |
|---|---|---|
| committer | flown4qqqq <[email protected]> | 2025-02-11 18:34:41 +0300 |
| commit | 5c6755b60fea0490015fbd14787ea4431736b3f9 (patch) | |
| tree | ac05ac804e398e4022b352cdd73531aef9f953fa /yql/essentials/sql/v1/query.cpp | |
| parent | 8b363a039a2bc94a03da342d5cffe4b723e63a21 (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.cpp | 6 |
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")) ))); |
