[YQL-14487] Do not use raw atoms instead of PgType

ref:855e8df55dc28656966f956ca9715d470c65ebac

1 files changed, 5 insertions, 5 deletions

diff --git a/ydb/library/yql/sql/pg/pg_sql.cpp b/ydb/library/yql/sql/pg/pg_sql.cpp
index 0690192aff7..aabf04f8fc3 100644
--- a/ydb/library/yql/sql/pg/pg_sql.cpp
+++ b/ydb/library/yql/sql/pg/pg_sql.cpp
@@ -909,17 +909,17 @@ public:
         switch (NodeTag(val)) {
         case T_Integer: {
             return Settings.PgTypes ?
-                L(A("PgConst"), QA("int4"), QA(ToString(IntVal(val)))) :
+                L(A("PgConst"), L(A("PgType"), QA("int4")), QA(ToString(IntVal(val)))) :
                 L(A("Just"), L(A("Int32"), QA(ToString(IntVal(val)))));
         }
         case T_Float: {
             return Settings.PgTypes ?
-                L(A("PgConst"), QA("float8"), QA(ToString(StrFloatVal(val)))) :
+                L(A("PgConst"), L(A("PgType"), QA("float8")), QA(ToString(StrFloatVal(val)))) :
                 L(A("Just"), L(A("Double"), QA(ToString(StrFloatVal(val)))));
         }
         case T_String: {
             return Settings.PgTypes ?
-                L(A("PgConst"), QA("text"), QA(ToString(StrVal(val)))) :
+                L(A("PgConst"), L(A("PgType"), QA("text")), QA(ToString(StrVal(val)))) :
                 L(A("Just"), L(A("Utf8"), QA(ToString(StrVal(val)))));
         }
         case T_Null: {
@@ -1102,7 +1102,7 @@ public:
             if (NodeTag(CAST_NODE(A_Const, arg)->val) == T_String && targetType == "bool") {
                 auto str = StrVal(CAST_NODE(A_Const, arg)->val);
                 if (Settings.PgTypes) {
-                    return L(A("PgConst"), QA("bool"), QA(str));
+                    return L(A("PgConst"), L(A("PgType"), QA("bool")), QA(str));
                 }
 
                 if (!StrCompare(str, "t")) {
@@ -1145,7 +1145,7 @@ public:
                 finalType = "_" + finalType;
             }
 
-            return L(A("PgCast"), input, QA(finalType));
+            return L(A("PgCast"), input, L(A("PgType"), QA(finalType)));
         }
 
         AddError("Unsupported form of type cast");