pg text->unknown for prepared statement

2 files changed, 2 insertions, 2 deletions

diff --git a/ydb/library/yql/sql/pg/pg_sql.cpp b/ydb/library/yql/sql/pg/pg_sql.cpp
index fa478e33436..f43abbc10b8 100644
--- a/ydb/library/yql/sql/pg/pg_sql.cpp
+++ b/ydb/library/yql/sql/pg/pg_sql.cpp
@@ -275,7 +275,7 @@ public:
             const auto paramName = PREPARED_PARAM_PREFIX + ToString(i + 1);
             const auto typeOid = Settings.PgParameterTypeOids[i];
             const auto& typeName =
-                typeOid != UNKNOWNOID ? NPg::LookupType(typeOid).Name : "text";
+                typeOid != UNKNOWNOID ? NPg::LookupType(typeOid).Name : DEFAULT_PARAM_TYPE;
             ParamNameToPgTypeName[paramName] = typeName;
         }
     }
diff --git a/ydb/library/yql/sql/pg/pg_sql_ut.cpp b/ydb/library/yql/sql/pg/pg_sql_ut.cpp
index c1029ab2b43..60ab18b7301 100644
--- a/ydb/library/yql/sql/pg/pg_sql_ut.cpp
+++ b/ydb/library/yql/sql/pg/pg_sql_ut.cpp
@@ -308,7 +308,7 @@ Y_UNIT_TEST_SUITE(PgSqlParsingOnly) {
             settings);
         TMap<TString, TString> expectedParamToType {
             {"$p1", "'int4"},
-            {"$p2", "'text"},
+            {"$p2", "'unknown"},
             {"$p3", "'int4"},
         };
         UNIT_ASSERT(res.Root);