Skip to content

Commit eeb0728

Browse files
azevaykinazevaykin
authored
Move KQP type tests to another file (#5593)
1 parent f93a9f3 commit eeb0728

File tree

2 files changed

+189
-186
lines changed

2 files changed

+189
-186
lines changed

‎ydb/core/kqp/ut/query/kqp_query_ut.cpp

-186
Original file line numberDiff line numberDiff line change
@@ -974,79 +974,6 @@ Y_UNIT_TEST_SUITE(KqpQuery) {
974974
}
975975
}
976976

977-
Y_UNIT_TEST(UnsafeTimestampCastV0) {
978-
TKikimrRunner kikimr;
979-
auto db = kikimr.GetTableClient();
980-
auto session = db.CreateSession().GetValueSync().GetSession();
981-
982-
UNIT_ASSERT(session.ExecuteSchemeQuery(R"(
983-
CREATE TABLE `/Root/TsTest` (
984-
Key Timestamp,
985-
Value String,
986-
PRIMARY KEY (Key)
987-
);
988-
)").GetValueSync().IsSuccess());
989-
990-
const TString query = R"(
991-
--!syntax_v0
992-
DECLARE $key AS Uint64;
993-
DECLARE $value AS String;
994-
995-
UPSERT INTO `/Root/TsTest` (Key, Value) VALUES
996-
($key, $value);
997-
)";
998-
999-
auto params = TParamsBuilder()
1000-
.AddParam("$key").Uint64(1).Build()
1001-
.AddParam("$value").String("foo").Build()
1002-
.Build();
1003-
1004-
auto result = session.ExecuteDataQuery(
1005-
query,
1006-
TTxControl::BeginTx().CommitTx(),
1007-
params
1008-
).ExtractValueSync();
1009-
1010-
result.GetIssues().PrintTo(Cerr);
1011-
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());
1012-
}
1013-
1014-
Y_UNIT_TEST(UnsafeTimestampCastV1) {
1015-
TKikimrRunner kikimr;
1016-
auto db = kikimr.GetTableClient();
1017-
auto session = db.CreateSession().GetValueSync().GetSession();
1018-
1019-
UNIT_ASSERT(session.ExecuteSchemeQuery(R"(
1020-
CREATE TABLE `/Root/TsTest` (
1021-
Key Timestamp,
1022-
Value String,
1023-
PRIMARY KEY (Key)
1024-
);
1025-
)").GetValueSync().IsSuccess());
1026-
1027-
const TString query = Q1_(R"(
1028-
DECLARE $key AS Uint64;
1029-
DECLARE $value AS String;
1030-
1031-
UPSERT INTO `/Root/TsTest` (Key, Value) VALUES
1032-
($key, $value);
1033-
)");
1034-
1035-
auto params = TParamsBuilder()
1036-
.AddParam("$key").Uint64(1).Build()
1037-
.AddParam("$value").String("foo").Build()
1038-
.Build();
1039-
1040-
auto result = session.ExecuteDataQuery(
1041-
query,
1042-
TTxControl::BeginTx().CommitTx(),
1043-
params
1044-
).ExtractValueSync();
1045-
1046-
result.GetIssues().PrintTo(Cerr);
1047-
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::GENERIC_ERROR, result.GetIssues().ToString());
1048-
}
1049-
1050977
Y_UNIT_TEST(QueryStats) {
1051978
TKikimrRunner kikimr;
1052979
auto db = kikimr.GetTableClient();
@@ -1331,98 +1258,6 @@ Y_UNIT_TEST_SUITE(KqpQuery) {
13311258
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::KIKIMR_BAD_OPERATION, issueChecker));
13321259
}
13331260

1334-
Y_UNIT_TEST(DyNumberCompare) {
1335-
TKikimrRunner kikimr;
1336-
auto db = kikimr.GetTableClient();
1337-
auto session = db.CreateSession().GetValueSync().GetSession();
1338-
1339-
// Compare DyNumber
1340-
auto result = session.ExecuteDataQuery(Q1_(R"(
1341-
$dn1 = CAST("13.1" AS DyNumber);
1342-
$dn2 = CAST("10.2" AS DyNumber);
1343-
1344-
SELECT
1345-
$dn1 = $dn2,
1346-
$dn1 != $dn2,
1347-
$dn1 > $dn2,
1348-
$dn1 <= $dn2;
1349-
)"), TTxControl::BeginTx().CommitTx()).ExtractValueSync();
1350-
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());
1351-
CompareYson(R"([[[%false];[%true];[%true];[%false]]])", FormatResultSetYson(result.GetResultSet(0)));
1352-
1353-
// Compare to float
1354-
result = session.ExecuteDataQuery(Q1_(R"(
1355-
$dn1 = CAST("13.1" AS DyNumber);
1356-
1357-
SELECT
1358-
$dn1 = 13.1,
1359-
$dn1 != 13.1,
1360-
$dn1 > 10.2,
1361-
$dn1 <= 10.2,
1362-
)"), TTxControl::BeginTx().CommitTx()).ExtractValueSync();
1363-
result.GetIssues().PrintTo(Cerr);
1364-
UNIT_ASSERT_VALUES_EQUAL(result.GetStatus(), EStatus::GENERIC_ERROR);
1365-
1366-
// Compare to int
1367-
result = session.ExecuteDataQuery(Q1_(R"(
1368-
$dn1 = CAST("15" AS DyNumber);
1369-
1370-
SELECT
1371-
$dn1 = 15,
1372-
$dn1 != 15,
1373-
$dn1 > 10,
1374-
$dn1 <= 10,
1375-
)"), TTxControl::BeginTx().CommitTx()).ExtractValueSync();
1376-
result.GetIssues().PrintTo(Cerr);
1377-
UNIT_ASSERT_VALUES_EQUAL(result.GetStatus(), EStatus::GENERIC_ERROR);
1378-
1379-
// Compare to decimal
1380-
result = session.ExecuteDataQuery(Q1_(R"(
1381-
$dn1 = CAST("13.1" AS DyNumber);
1382-
$dc1 = CAST("13.1" AS Decimal(22,9));
1383-
1384-
SELECT
1385-
$dn1 = $dc1,
1386-
$dn1 != $dc1,
1387-
$dn1 > $dc1,
1388-
$dn1 <= $dc1,
1389-
)"), TTxControl::BeginTx().CommitTx()).ExtractValueSync();
1390-
result.GetIssues().PrintTo(Cerr);
1391-
UNIT_ASSERT_VALUES_EQUAL(result.GetStatus(), EStatus::GENERIC_ERROR);
1392-
}
1393-
1394-
Y_UNIT_TEST(SelectNull) {
1395-
TKikimrRunner kikimr;
1396-
auto db = kikimr.GetTableClient();
1397-
auto session = db.CreateSession().GetValueSync().GetSession();
1398-
1399-
auto result = session.ExecuteDataQuery(Q_(R"(
1400-
SELECT Null
1401-
)"), TTxControl::BeginTx(TTxSettings::SerializableRW()).CommitTx()).ExtractValueSync();
1402-
AssertSuccessResult(result);
1403-
1404-
auto rs = TResultSetParser(result.GetResultSet(0));
1405-
UNIT_ASSERT(rs.TryNextRow());
1406-
1407-
auto& cp = rs.ColumnParser(0);
1408-
1409-
UNIT_ASSERT_VALUES_EQUAL(TTypeParser::ETypeKind::Null, cp.GetKind());
1410-
}
1411-
1412-
Y_UNIT_TEST(MultipleCurrentUtcTimestamp) {
1413-
TKikimrRunner kikimr;
1414-
auto db = kikimr.GetTableClient();
1415-
auto session = db.CreateSession().GetValueSync().GetSession();
1416-
1417-
auto query = Q1_(R"(
1418-
SELECT * FROM `/Root/Logs` WHERE Ts > Cast(CurrentUtcTimestamp() as Int64)
1419-
UNION ALL
1420-
SELECT * FROM `/Root/Logs` WHERE Ts < Cast(CurrentUtcTimestamp() as Int64);
1421-
)");
1422-
1423-
auto result = session.ExecuteDataQuery(query, TTxControl::BeginTx().CommitTx()).ExtractValueSync();
1424-
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());
1425-
}
14261261

14271262
Y_UNIT_TEST(SelectWhereInSubquery) {
14281263
TKikimrRunner kikimr;
@@ -1481,27 +1316,6 @@ Y_UNIT_TEST_SUITE(KqpQuery) {
14811316
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::BAD_REQUEST, result.GetIssues().ToString());
14821317
}
14831318

1484-
Y_UNIT_TEST(QuerySpecialTypes) {
1485-
TKikimrRunner kikimr;
1486-
auto db = kikimr.GetTableClient();
1487-
auto session = db.CreateSession().GetValueSync().GetSession();
1488-
1489-
auto result = session.ExecuteDataQuery(Q1_(R"(
1490-
SELECT null;
1491-
)"), TTxControl::BeginTx().CommitTx()).ExtractValueSync();
1492-
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());
1493-
1494-
result = session.ExecuteDataQuery(Q1_(R"(
1495-
SELECT [];
1496-
)"), TTxControl::BeginTx().CommitTx()).ExtractValueSync();
1497-
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());
1498-
1499-
result = session.ExecuteDataQuery(Q1_(R"(
1500-
SELECT {};
1501-
)"), TTxControl::BeginTx().CommitTx()).ExtractValueSync();
1502-
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());
1503-
}
1504-
15051319
Y_UNIT_TEST(QueryFromSqs) {
15061320
TKikimrRunner kikimr;
15071321
auto db = kikimr.GetTableClient();

0 commit comments

Comments
 (0)