diff options
author | tesseract <[email protected]> | 2025-07-10 16:44:40 +0300 |
---|---|---|
committer | tesseract <[email protected]> | 2025-07-10 17:03:23 +0300 |
commit | ad23f535a9e3590dffcd0cebcebbc0600c521652 (patch) | |
tree | 2fadae51e07ad37facd2f0e79f48d803d0c76040 /yql/essentials/sql/v1/sql_query.cpp | |
parent | ab4a6f4beadc1b478f8c208d07226687821b5fc2 (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.cpp | 8 |
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), |