diff options
| author | vvvv <vvvv@yandex-team.ru> | 2022-03-14 20:45:15 +0300 |
|---|---|---|
| committer | vvvv <vvvv@yandex-team.ru> | 2022-03-14 20:45:15 +0300 |
| commit | 155684596947619545253a469124225cf66cf4bc (patch) | |
| tree | 12384beec55c692f9173bfde9cb11865624cc5f1 | |
| parent | 7a5c0c036c26861a49af175b662464b62f3cfb9b (diff) | |
| download | ydb-155684596947619545253a469124225cf66cf4bc.tar.gz | |
YQL-13710 use default collation
ref:0bc544dd88a72416344b949a7454f3d12a9e0234
| -rw-r--r-- | ydb/library/yql/parser/pg_wrapper/comp_factory.cpp | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/ydb/library/yql/parser/pg_wrapper/comp_factory.cpp b/ydb/library/yql/parser/pg_wrapper/comp_factory.cpp index a127160acf4..bae3680e349 100644 --- a/ydb/library/yql/parser/pg_wrapper/comp_factory.cpp +++ b/ydb/library/yql/parser/pg_wrapper/comp_factory.cpp @@ -16,6 +16,7 @@ extern "C" { #include "postgres.h" #include "catalog/pg_type_d.h" +#include "catalog/pg_collation_d.h" #include "utils/builtins.h" #include "utils/memutils.h" #include "lib/stringinfo.h" @@ -273,6 +274,7 @@ public: Zero(callInfo); callInfo.flinfo = const_cast<FmgrInfo*>(finfo); callInfo.nargs = NumArgs; + callInfo.fncollation = DEFAULT_COLLATION_OID; } FunctionCallInfoBaseData& Ref() { @@ -737,6 +739,7 @@ void WriteYsonValueInTableFormatPg(TOutputBuf& buf, TPgType* type, const NUdf::T Zero(*callInfo); callInfo->flinfo = &finfo; callInfo->nargs = 1; + callInfo->fncollation = DEFAULT_COLLATION_OID; callInfo->isnull = false; callInfo->args[0] = { typeInfo.PassByValue ? ScalarDatumFromPod(value): @@ -822,6 +825,7 @@ void WriteYsonValuePg(TYsonResultWriter& writer, const NUdf::TUnboxedValuePod& v Zero(*callInfo); callInfo->flinfo = &finfo; callInfo->nargs = 1; + callInfo->fncollation = DEFAULT_COLLATION_OID; callInfo->isnull = false; callInfo->args[0] = { typeInfo.PassByValue ? ScalarDatumFromPod(value): @@ -917,6 +921,7 @@ NUdf::TUnboxedValue ReadYsonValuePg(TPgType* type, char cmd, TInputBuf& buf) { Zero(*callInfo); callInfo->flinfo = &finfo; callInfo->nargs = 3; + callInfo->fncollation = DEFAULT_COLLATION_OID; callInfo->isnull = false; callInfo->args[0] = { (Datum)&stringInfo, false }; callInfo->args[1] = { ObjectIdGetDatum(typeIOParam), false }; @@ -1028,6 +1033,7 @@ NKikimr::NUdf::TUnboxedValue ReadSkiffPg(NKikimr::NMiniKQL::TPgType* type, NComm Zero(*callInfo); callInfo->flinfo = &finfo; callInfo->nargs = 3; + callInfo->fncollation = DEFAULT_COLLATION_OID; callInfo->isnull = false; callInfo->args[0] = { (Datum)&stringInfo, false }; callInfo->args[1] = { ObjectIdGetDatum(typeIOParam), false }; @@ -1119,6 +1125,7 @@ void WriteSkiffPg(NKikimr::NMiniKQL::TPgType* type, const NKikimr::NUdf::TUnboxe Zero(*callInfo); callInfo->flinfo = &finfo; callInfo->nargs = 1; + callInfo->fncollation = DEFAULT_COLLATION_OID; callInfo->isnull = false; callInfo->args[0] = { typeInfo.PassByValue ? ScalarDatumFromPod(value) : @@ -1274,6 +1281,7 @@ void PGPackImpl(const TPgType* type, const NUdf::TUnboxedValuePod& value, TBuffe Zero(*callInfo); callInfo->flinfo = &finfo; callInfo->nargs = 1; + callInfo->fncollation = DEFAULT_COLLATION_OID; callInfo->isnull = false; callInfo->args[0] = { typeInfo.PassByValue ? ScalarDatumFromPod(value) : @@ -1365,6 +1373,7 @@ NUdf::TUnboxedValue PGUnpackImpl(const TPgType* type, TStringBuf& buf) { Zero(*callInfo); callInfo->flinfo = &finfo; callInfo->nargs = 3; + callInfo->fncollation = DEFAULT_COLLATION_OID; callInfo->isnull = false; callInfo->args[0] = { (Datum)&stringInfo, false }; callInfo->args[1] = { ObjectIdGetDatum(typeIOParam), false }; |