diff options
| author | spuchin <[email protected]> | 2025-02-18 18:01:22 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2025-02-18 18:01:22 +0300 |
| commit | 6acf3864127e61abb53212a5cb520a31b53d0fd2 (patch) | |
| tree | 871278fca1be073175e925267f489afc2fc3311e | |
| parent | 2f33cfeeb75989cd58b2095c4e7ada9ca992ff84 (diff) | |
Add test for Dt64* parameters. (#14739)
| -rw-r--r-- | ydb/core/kqp/ut/query/kqp_params_ut.cpp | 25 |
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(); |
