diff options
author | vitya-smirnov <[email protected]> | 2025-10-07 09:34:39 +0300 |
---|---|---|
committer | vitya-smirnov <[email protected]> | 2025-10-07 09:52:14 +0300 |
commit | babe7533f18c11be1f8a195ed2324d2d9a89436a (patch) | |
tree | 45b7627141bf5a52b45a3d61fd1fbdd564bb8dd9 /yql/essentials/sql/v1/sql.cpp | |
parent | 8fe7cfe254fde2772477a8933a163b5f303716b4 (diff) |
YQL-20086 sql/v1
commit_hash:55bc611cdaa0d8a0fc3c4c7708ed9f17cc4976cf
Diffstat (limited to 'yql/essentials/sql/v1/sql.cpp')
-rw-r--r-- | yql/essentials/sql/v1/sql.cpp | 36 |
1 files changed, 17 insertions, 19 deletions
diff --git a/yql/essentials/sql/v1/sql.cpp b/yql/essentials/sql/v1/sql.cpp index 7ddc2a40b18..1fb88c6089b 100644 --- a/yql/essentials/sql/v1/sql.cpp +++ b/yql/essentials/sql/v1/sql.cpp @@ -42,7 +42,7 @@ TAstNode* SqlASTsToYqls(const std::vector<::NSQLv1Generated::TRule_sql_stmt_core } void SqlASTToYqlImpl(NYql::TAstParseResult& res, const google::protobuf::Message& protoAst, - TContext& ctx) { + TContext& ctx) { res.Root = SqlASTToYql(protoAst, ctx); res.Pool = std::move(ctx.Pool); if (!res.Root) { @@ -50,8 +50,7 @@ void SqlASTToYqlImpl(NYql::TAstParseResult& res, const google::protobuf::Message ctx.IncrementMonCounter("sql_errors", "AstToYqlError"); } else { ctx.IncrementMonCounter("sql_errors", "AstToYqlSilentError"); - ctx.Error() << "Error occurred on parse SQL query, but no error is collected" << - ", please send this request over bug report into YQL interface or write on yql@ maillist"; + ctx.Error() << "Error occurred on parse SQL query, but no error is collected" << ", please send this request over bug report into YQL interface or write on yql@ maillist"; } } else { ctx.WarnUnusedHints(); @@ -66,8 +65,7 @@ void SqlASTsToYqlsImpl(NYql::TAstParseResult& res, const std::vector<::NSQLv1Gen ctx.IncrementMonCounter("sql_errors", "AstToYqlError"); } else { ctx.IncrementMonCounter("sql_errors", "AstToYqlSilentError"); - ctx.Error() << "Error occurred on parse SQL query, but no error is collected" << - ", please send this request over bug report into YQL interface or write on yql@ maillist"; + ctx.Error() << "Error occurred on parse SQL query, but no error is collected" << ", please send this request over bug report into YQL interface or write on yql@ maillist"; } } else { ctx.WarnUnusedHints(); @@ -75,10 +73,10 @@ void SqlASTsToYqlsImpl(NYql::TAstParseResult& res, const std::vector<::NSQLv1Gen } NYql::TAstParseResult SqlASTToYql(const TLexers& lexers, const TParsers& parsers, - const TString& query, - const google::protobuf::Message& protoAst, - const NSQLTranslation::TSQLHints& hints, - const NSQLTranslation::TTranslationSettings& settings) + const TString& query, + const google::protobuf::Message& protoAst, + const NSQLTranslation::TSQLHints& hints, + const NSQLTranslation::TTranslationSettings& settings) { YQL_ENSURE(IsQueryMode(settings.Mode)); TAstParseResult res; @@ -103,7 +101,7 @@ NYql::TAstParseResult SqlToYql(const TLexers& lexers, const TParsers& parsers, c TContext ctx(lexers, parsers, settings, hints, res.Issues, query); NSQLTranslation::TErrorCollectorOverIssues collector(res.Issues, settings.MaxErrors, settings.File); - google::protobuf::Message* ast(SqlAST(parsers, query, queryName, collector, settings.AnsiLexer, settings.Antlr4Parser, settings.Arena)); + google::protobuf::Message* ast(SqlAST(parsers, query, queryName, collector, settings.AnsiLexer, settings.Antlr4Parser, settings.Arena)); if (ast) { SqlASTToYqlImpl(res, *ast, ctx); } else { @@ -194,7 +192,7 @@ bool NeedUseForAllStatements(const TRule_sql_stmt_core::AltCase& subquery) { } TVector<NYql::TAstParseResult> SqlToAstStatements(const TLexers& lexers, const TParsers& parsers, const TString& queryText, const NSQLTranslation::TTranslationSettings& settings, NYql::TWarningRules* warningRules, - TVector<NYql::TStmtParseInfo>* stmtParseInfo) + TVector<NYql::TStmtParseInfo>* stmtParseInfo) { TVector<TAstParseResult> result; const TString queryName = settings.File; @@ -230,7 +228,7 @@ TVector<NYql::TAstParseResult> SqlToAstStatements(const TLexers& lexers, const T result.back().Issues = std::move(issues); issues.Clear(); } - for (auto block: statements.GetBlock3()) { + for (auto block : statements.GetBlock3()) { if (NeedUseForAllStatements(block.GetRule_sql_stmt2().GetRule_sql_stmt_core2().Alt_case())) { commonStates.push_back(block.GetRule_sql_stmt2().GetRule_sql_stmt_core2()); continue; @@ -258,7 +256,7 @@ TVector<NYql::TAstParseResult> SqlToAstStatements(const TLexers& lexers, const T } bool SplitQueryToStatements(const TLexers& lexers, const TParsers& parsers, const TString& query, TVector<TString>& statements, NYql::TIssues& issues, - const NSQLTranslation::TTranslationSettings& settings) { + const NSQLTranslation::TTranslationSettings& settings) { auto lexer = NSQLTranslationV1::MakeLexer(lexers, settings.AnsiLexer, settings.Antlr4Parser); TVector<TString> parts; @@ -269,7 +267,7 @@ bool SplitQueryToStatements(const TLexers& lexers, const TParsers& parsers, cons for (auto& currentQuery : parts) { NYql::TIssues parserIssues; auto message = NSQLTranslationV1::SqlAST(parsers, currentQuery, settings.File, parserIssues, NSQLTranslation::SQL_MAX_PARSER_ERRORS, - settings.AnsiLexer, settings.Antlr4Parser, settings.Arena); + settings.AnsiLexer, settings.Antlr4Parser, settings.Arena); if (!message) { // Skip empty statements continue; @@ -281,7 +279,7 @@ bool SplitQueryToStatements(const TLexers& lexers, const TParsers& parsers, cons return true; } -class TTranslator : public NSQLTranslation::ITranslator { +class TTranslator: public NSQLTranslation::ITranslator { public: TTranslator(const TLexers& lexers, const TParsers& parsers) : Lexers_(lexers) @@ -294,23 +292,23 @@ public: } NYql::TAstParseResult TextToAst(const TString& query, const NSQLTranslation::TTranslationSettings& settings, - NYql::TWarningRules* warningRules, NYql::TStmtParseInfo* stmtParseInfo) final { + NYql::TWarningRules* warningRules, NYql::TStmtParseInfo* stmtParseInfo) final { Y_UNUSED(stmtParseInfo); return SqlToYql(Lexers_, Parsers_, query, settings, warningRules); } google::protobuf::Message* TextToMessage(const TString& query, const TString& queryName, - NYql::TIssues& issues, size_t maxErrors, const NSQLTranslation::TTranslationSettings& settings) final { + NYql::TIssues& issues, size_t maxErrors, const NSQLTranslation::TTranslationSettings& settings) final { return SqlAST(Parsers_, query, queryName, issues, maxErrors, settings.AnsiLexer, settings.Antlr4Parser, settings.Arena); } NYql::TAstParseResult TextAndMessageToAst(const TString& query, const google::protobuf::Message& protoAst, - const NSQLTranslation::TSQLHints& hints, const NSQLTranslation::TTranslationSettings& settings) final { + const NSQLTranslation::TSQLHints& hints, const NSQLTranslation::TTranslationSettings& settings) final { return SqlASTToYql(Lexers_, Parsers_, query, protoAst, hints, settings); } TVector<NYql::TAstParseResult> TextToManyAst(const TString& query, const NSQLTranslation::TTranslationSettings& settings, - NYql::TWarningRules* warningRules, TVector<NYql::TStmtParseInfo>* stmtParseInfo) final { + NYql::TWarningRules* warningRules, TVector<NYql::TStmtParseInfo>* stmtParseInfo) final { return SqlToAstStatements(Lexers_, Parsers_, query, settings, warningRules, stmtParseInfo); } |