summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorspuchin <[email protected]>2025-02-18 18:01:22 +0300
committerGitHub <[email protected]>2025-02-18 18:01:22 +0300
commit6acf3864127e61abb53212a5cb520a31b53d0fd2 (patch)
tree871278fca1be073175e925267f489afc2fc3311e
parent2f33cfeeb75989cd58b2095c4e7ada9ca992ff84 (diff)
Add test for Dt64* parameters. (#14739)
-rw-r--r--ydb/core/kqp/ut/query/kqp_params_ut.cpp25
1 files changed, 18 insertions, 7 deletions
diff --git a/ydb/core/kqp/ut/query/kqp_params_ut.cpp b/ydb/core/kqp/ut/query/kqp_params_ut.cpp
index baf18be05af..98690721b1f 100644
--- a/ydb/core/kqp/ut/query/kqp_params_ut.cpp
+++ b/ydb/core/kqp/ut/query/kqp_params_ut.cpp
@@ -623,6 +623,10 @@ Y_UNIT_TEST_SUITE(KqpParams) {
.AddParam("$ParamTzDate").TzDate("2022-03-14,GMT").Build()
.AddParam("$ParamTzDateTime").TzDatetime("2022-03-14T00:00:00,GMT").Build()
.AddParam("$ParamTzTimestamp").TzTimestamp("2022-03-14T00:00:00.123,GMT").Build()
+ .AddParam("$ParamDate32").Date32(-17158).Build()
+ .AddParam("$ParamDatetime64").Datetime64(TInstant::ParseIso8601("2020-01-11 15:04:53").Seconds()).Build()
+ .AddParam("$ParamTimestamp64").Timestamp64(TInstant::ParseIso8601("2020-01-12 21:18:37").MicroSeconds()).Build()
+ .AddParam("$ParamInterval64").Interval64(3600).Build()
.AddParam("$ParamOpt").OptionalString("Opt").Build()
.AddParam("$ParamTuple")
.BeginTuple()
@@ -685,6 +689,10 @@ Y_UNIT_TEST_SUITE(KqpParams) {
DECLARE $ParamTzDate AS TzDate;
DECLARE $ParamTzDateTime AS TzDateTime;
DECLARE $ParamTzTimestamp AS TzTimestamp;
+ DECLARE $ParamDate32 AS Date32;
+ DECLARE $ParamDatetime64 AS Datetime64;
+ DECLARE $ParamTimestamp64 AS Timestamp64;
+ DECLARE $ParamInterval64 AS Interval64;
DECLARE $ParamOpt AS String?;
DECLARE $ParamTuple AS Tuple<Utf8, Int32>;
DECLARE $ParamList AS List<Uint64>;
@@ -717,6 +725,10 @@ Y_UNIT_TEST_SUITE(KqpParams) {
$ParamDatetime AS ValueDatetime,
$ParamTimestamp AS ValueTimestamp,
$ParamInterval AS ValueInterval,
+ $ParamDate32 AS ValueDate32,
+ $ParamDatetime64 AS ValueDatetime64,
+ $ParamTimestamp64 AS ValueTimestamp64,
+ $ParamInterval64 AS ValueInterval64,
$ParamTzDate AS ValueTzDate,
$ParamTzDateTime AS ValueTzDateTime,
$ParamTzTimestamp AS ValueTzTimestamp,
@@ -726,20 +738,19 @@ Y_UNIT_TEST_SUITE(KqpParams) {
$ParamEmptyList AS ValueEmptyList,
$ParamStruct AS ValueStruct,
$ParamDict AS ValueDict;
- )"), TTxControl::BeginTx(TTxSettings::SerializableRW()).CommitTx(), params).ExtractValueSync();
-
+ )"), TTxControl::BeginTx().CommitTx(), params).ExtractValueSync();
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());
auto actual = ReformatYson(FormatResultSetYson(result.GetResultSet(0)));
auto expected1 = ReformatYson(R"([[
%true;-5;5u;-8;8u;-10;10u;-20;20u;30.5;40.5;"50.5";"655555555555555.5";"9";".605e2";"StringValue";"Utf8Value";"[{Value=50}]";
- "[{\"Value\":60}]";"[{\"Value\":70}]";18271u;1578755093u;1578863917000000u;3600;"2022-03-14,GMT";
+ "[{\"Value\":60}]";"[{\"Value\":70}]";18271u;1578755093u;1578863917000000u;3600;-17158;1578755093;1578863917000000;3600;"2022-03-14,GMT";
"2022-03-14T00:00:00,GMT";"2022-03-14T00:00:00.123000,GMT";["Opt"];["Tuple0";1];[17u;19u];[];["Paul";-5];
[["Key2";20u];["Key1";10u]]
]])");
auto expected2 = ReformatYson(R"([[
%true;-5;5u;-8;8u;-10;10u;-20;20u;30.5;40.5;"50.5";"655555555555555.5";"9";".605e2";"StringValue";"Utf8Value";"[{Value=50}]";
- "[{\"Value\":60}]";"[{\"Value\":70}]";18271u;1578755093u;1578863917000000u;3600;"2022-03-14,GMT";
+ "[{\"Value\":60}]";"[{\"Value\":70}]";18271u;1578755093u;1578863917000000u;3600;-17158;1578755093;1578863917000000;3600;"2022-03-14,GMT";
"2022-03-14T00:00:00,GMT";"2022-03-14T00:00:00.123000,GMT";["Opt"];["Tuple0";1];[17u;19u];[];["Paul";-5];
[["Key1";10u];["Key2";20u]]
]])");
@@ -864,7 +875,7 @@ Y_UNIT_TEST_SUITE(KqpParams) {
($key, $key1, $key22, $key35, $value1, $value22, $value35);
)"), upsertParams);
UNIT_ASSERT_VALUES_EQUAL_C(status, EStatus::SUCCESS, issues);
- }
+ }
TString expected = R"([[[1];["2"];["1234.4321"];["1555555555555555.123456789"];["9"];["123.321"];["555555555555555.123456789"]]])";
auto selectParams = tableClient.GetParamsBuilder()
@@ -934,7 +945,7 @@ Y_UNIT_TEST_SUITE(KqpParams) {
UNIT_ASSERT_VALUES_EQUAL_C(status, EStatus::SUCCESS, issues);
CompareYson(expected, FormatResultSetYson(resultSet));
}
- }
+ }
// Declare wrong decimal params
{
@@ -1062,7 +1073,7 @@ Y_UNIT_TEST_SUITE(KqpParams) {
($key, $key1, $key22, $key35, $value1, $value22, $value35);
)"), upsertParams);
UNIT_ASSERT_VALUES_EQUAL_C(status, EStatus::SUCCESS, issues);
- }
+ }
// Good case: select overflowed and inf decimal
{
auto emptyParams = tableClient.GetParamsBuilder().Build();