summaryrefslogtreecommitdiffstats
path: root/yql/essentials/sql/v1/sql_query.cpp
diff options
context:
space:
mode:
authortesseract <[email protected]>2025-07-10 16:44:40 +0300
committertesseract <[email protected]>2025-07-10 17:03:23 +0300
commitad23f535a9e3590dffcd0cebcebbc0600c521652 (patch)
tree2fadae51e07ad37facd2f0e79f48d803d0c76040 /yql/essentials/sql/v1/sql_query.cpp
parentab4a6f4beadc1b478f8c208d07226687821b5fc2 (diff)
Fixed grammar of the transfer
commit_hash:98f460965618cdddf9fc25373b20741b4e85a303
Diffstat (limited to 'yql/essentials/sql/v1/sql_query.cpp')
-rw-r--r--yql/essentials/sql/v1/sql_query.cpp8
1 files changed, 3 insertions, 5 deletions
diff --git a/yql/essentials/sql/v1/sql_query.cpp b/yql/essentials/sql/v1/sql_query.cpp
index d77500463d5..5461ec09de0 100644
--- a/yql/essentials/sql/v1/sql_query.cpp
+++ b/yql/essentials/sql/v1/sql_query.cpp
@@ -1855,7 +1855,7 @@ bool TSqlQuery::Statement(TVector<TNodePtr>& blocks, const TRule_sql_stmt_core&
std::map<TString, TNodePtr> settings;
TSqlExpression expr(Ctx_, Mode_);
- if (!TransferSettings(settings, node.GetRule_transfer_settings11(), expr, true)) {
+ if (node.GetBlock10().HasRule_transfer_settings3() && !TransferSettings(settings, node.GetBlock10().GetRule_transfer_settings3(), expr, true)) {
return false;
}
@@ -1863,10 +1863,8 @@ bool TSqlQuery::Statement(TVector<TNodePtr>& blocks, const TRule_sql_stmt_core&
const TString source = Id(node.GetRule_object_ref5().GetRule_id_or_at2(), *this).second;
const TString target = Id(node.GetRule_object_ref7().GetRule_id_or_at2(), *this).second;
TString transformLambda;
- if (node.GetBlock8().HasRule_lambda_or_parameter2()) {
- if (!ParseTransferLambda(transformLambda, node.GetBlock8().GetRule_lambda_or_parameter2())) {
- return false;
- }
+ if (!ParseTransferLambda(transformLambda, node.GetRule_lambda_or_parameter9())) {
+ return false;
}
AddStatementToBlocks(blocks, BuildCreateTransfer(Ctx_.Pos(), BuildTablePath(prefixPath, id),