blob: 1bbde28ee2b4fa9aa3fdaf7c11ce6411eee2f256 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
|
#include "pg_include.h"
#include <yql/essentials/parser/pg_wrapper/interface/sign.h>
#include <yql/essentials/parser/pg_wrapper/pg_ops.h>
#include <yql/essentials/minikql/mkql_alloc.h>
namespace NYql {
std::expected<std::strong_ordering, TString> PgSign(TStringBuf value, ui32 typeId) {
try {
NKikimr::NMiniKQL::TOnlyThrowingBindTerminator bind;
NKikimr::NMiniKQL::TScopedAlloc alloc(__LOCATION__);
NKikimr::NMiniKQL::TPAllocScope scope;
TPgConst pgConst(typeId, value);
auto pgValue = pgConst.ExtractConst();
auto signFunc = TPgSign::Create(typeId);
auto sign = signFunc->MakeCallState()->GetSign(pgValue);
if (!sign) {
return std::unexpected(TString("Value is NULL"));
}
if (*sign < 0) {
return std::strong_ordering::less;
} else if (*sign > 0) {
return std::strong_ordering::greater;
} else {
return std::strong_ordering::equal;
}
} catch (const NYql::NPg::TProcNotFoundException& e) {
return std::unexpected(TString(e.what()));
} catch (const NYql::NPg::TOperatorNotFoundException& e) {
return std::unexpected(TString(e.what()));
}
}
} // namespace NYql
|
