refactor SQL translators YQL-19594

commit_hash:401d21dd23ee9bb7ee52b2fc42e596cb3e4bdda7

3 files changed, 14 insertions, 3 deletions

diff --git a/yt/yql/providers/yt/provider/ut/ya.make b/yt/yql/providers/yt/provider/ut/ya.make
index f31ce067b6..d06eaa14f7 100644
--- a/yt/yql/providers/yt/provider/ut/ya.make
+++ b/yt/yql/providers/yt/provider/ut/ya.make
@@ -28,6 +28,7 @@ PEERDIR(
     yql/essentials/providers/config
     yql/essentials/providers/result/provider
     yql/essentials/sql
+    yql/essentials/sql/v1
     yql/essentials/minikql/invoke_builtins/llvm16
     yql/essentials/minikql/comp_nodes/llvm16
     yql/essentials/sql/pg
diff --git a/yt/yql/providers/yt/provider/ya.make b/yt/yql/providers/yt/provider/ya.make
index 29ebf0358d..fa23697866 100644
--- a/yt/yql/providers/yt/provider/ya.make
+++ b/yt/yql/providers/yt/provider/ya.make
@@ -80,6 +80,8 @@ PEERDIR(
     yql/essentials/public/udf
     yql/essentials/public/udf/tz
     yql/essentials/sql
+    yql/essentials/sql/v1
+    yql/essentials/parser/pg_wrapper/interface
     yql/essentials/utils
     yql/essentials/utils/log
     yql/essentials/core
diff --git a/yt/yql/providers/yt/provider/yql_yt_table_desc.cpp b/yt/yql/providers/yt/provider/yql_yt_table_desc.cpp
index 1e5db30816..32c1946610 100644
--- a/yt/yql/providers/yt/provider/yql_yt_table_desc.cpp
+++ b/yt/yql/providers/yt/provider/yql_yt_table_desc.cpp
@@ -7,6 +7,8 @@
 #include <yql/essentials/core/qplayer/storage/interface/yql_qstorage.h>
 #include <yql/essentials/core/issue/yql_issue.h>
 #include <yql/essentials/sql/sql.h>
+#include <yql/essentials/sql/v1/sql.h>
+#include <yql/essentials/parser/pg_wrapper/interface/parser.h>
 #include <yql/essentials/utils/yql_panic.h>
 
 #include <util/generic/scope.h>
@@ -180,7 +182,13 @@ TExprNode::TPtr CompileViewSql(const TString& provider, const TString& cluster,
         }
     }
 
-    NYql::TAstParseResult sqlRes = NSQLTranslation::SqlToYql(sql, settings);
+    NSQLTranslation::TTranslators translators(
+        nullptr,
+        NSQLTranslationV1::MakeTranslator(),
+        NSQLTranslationPG::MakeTranslator()
+    );
+
+    NYql::TAstParseResult sqlRes = NSQLTranslation::SqlToYql(translators, sql, settings);
     ctx.IssueManager.RaiseIssues(sqlRes.Issues);
     if (!sqlRes.IsOk()) {
         return {};
@@ -267,7 +275,7 @@ TExprNode::TPtr CompileViewSql(const TString& provider, const TString& cluster,
                 return node;
             }
 
-            return ctx.ChangeChild(*node, 0, 
+            return ctx.ChangeChild(*node, 0,
                 ctx.NewAtom(node->Head().Pos(), settings.FileAliasPrefix + origFunc));
         }
 
@@ -290,7 +298,7 @@ bool TYtViewDescription::Fill(const TString& provider, const TString& cluster, c
     IUdfResolver::TPtr udfResolver)
 {
     Sql = sql;
-    CompiledSql = CompileViewSql(provider, cluster, sql, syntaxVersion, viewId, qContext, 
+    CompiledSql = CompileViewSql(provider, cluster, sql, syntaxVersion, viewId, qContext,
         ctx, moduleResolver, urlListerManager, randomProvider, enableViewIsolation, udfResolver);
     return bool(CompiledSql);
 }