Skip to content

Commit 2872539

Browse files
authored
More explicit SQL translators in KQP (#14763)
1 parent acfa2cc commit 2872539

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

ydb/core/kqp/host/kqp_translate.cpp

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -332,13 +332,19 @@ TVector<TQueryAst> ParseStatements(const TString& queryText, bool isSql, TMaybe<
332332
NYql::TExprContext& ctx, TKqpTranslationSettingsBuilder& settingsBuilder) {
333333
TVector<TQueryAst> result;
334334
settingsBuilder.SetSqlVersion(sqlVersion);
335+
NSQLTranslation::TTranslators translators(
336+
NSQLTranslationV0::MakeTranslator(),
337+
NSQLTranslationV1::MakeTranslator(),
338+
NSQLTranslationPG::MakeTranslator()
339+
);
340+
335341
if (isSql) {
336342
auto settings = settingsBuilder.Build(ctx);
337343
TKqpAutoParamBuilderFactory autoParamBuilderFactory;
338344
settings.AutoParamBuilderFactory = &autoParamBuilderFactory;
339345
ui16 actualSyntaxVersion = 0;
340346
TVector<NYql::TStmtParseInfo> stmtParseInfo;
341-
auto astStatements = NSQLTranslation::SqlToAstStatements(queryText, settings, nullptr, &actualSyntaxVersion, &stmtParseInfo);
347+
auto astStatements = NSQLTranslation::SqlToAstStatements(translators, queryText, settings, nullptr, &actualSyntaxVersion, &stmtParseInfo);
342348
deprecatedSQL = (actualSyntaxVersion == 0);
343349
sqlVersion = actualSyntaxVersion;
344350
YQL_ENSURE(astStatements.size() == stmtParseInfo.size());

0 commit comments

Comments
 (0)