summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authordcherednik <[email protected]>2023-08-07 20:10:41 +0300
committerdcherednik <[email protected]>2023-08-07 22:29:37 +0300
commitf5526a6879f5a88a74077e276ed9b70b9790615b (patch)
treeb8482b95ce0464ab5ab14e1da3e77d996ff57951
parent537f5f2697b0c0e92ab728854718a818e87d87a9 (diff)
Add ORDER BY in to ut to avoid undetermined order in case of sharded table.
-rw-r--r--ydb/core/kqp/ut/tx/kqp_mvcc_ut.cpp14
1 files changed, 7 insertions, 7 deletions
diff --git a/ydb/core/kqp/ut/tx/kqp_mvcc_ut.cpp b/ydb/core/kqp/ut/tx/kqp_mvcc_ut.cpp
index bed632eee97..b59407d5022 100644
--- a/ydb/core/kqp/ut/tx/kqp_mvcc_ut.cpp
+++ b/ydb/core/kqp/ut/tx/kqp_mvcc_ut.cpp
@@ -23,7 +23,7 @@ Y_UNIT_TEST_SUITE(KqpSnapshotRead) {
auto session2 = db.CreateSession().GetValueSync().GetSession();
auto result = session1.ExecuteDataQuery(Q_(R"(
- SELECT * FROM `/Root/TwoShard` WHERE Key = 1u OR Key = 4000000001u;
+ SELECT * FROM `/Root/TwoShard` WHERE Key = 1u OR Key = 4000000001u ORDER BY Key;
)"), TTxControl::BeginTx(TTxSettings::SerializableRW())).ExtractValueSync();
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());
@@ -88,7 +88,7 @@ Y_UNIT_TEST_SUITE(KqpSnapshotRead) {
auto session2 = db.CreateSession().GetValueSync().GetSession();
auto result = session1.ExecuteDataQuery(Q_(R"(
- SELECT * FROM `/Root/TwoShard` WHERE Key = 1u OR Key = 4000000001u;
+ SELECT * FROM `/Root/TwoShard` WHERE Key = 1u OR Key = 4000000001u ORDER BY Key;
)"), TTxControl::BeginTx(TTxSettings::SerializableRW())).ExtractValueSync();
auto tx = result.GetTransaction();
@@ -124,7 +124,7 @@ Y_UNIT_TEST_SUITE(KqpSnapshotRead) {
])", FormatResultSetYson(result.GetResultSet(0)));
result = session1.ExecuteDataQuery(Q_(R"(
- SELECT * FROM `/Root/TwoShard` WHERE Key = 2u OR Key = 4000000002u;
+ SELECT * FROM `/Root/TwoShard` WHERE Key = 2u OR Key = 4000000002u ORDER BY Key;
)"), TTxControl::Tx(*tx).CommitTx()).ExtractValueSync();
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());
@@ -207,7 +207,7 @@ Y_UNIT_TEST_SUITE(KqpSnapshotRead) {
auto session2 = db.CreateSession().GetValueSync().GetSession();
auto result = session1.ExecuteDataQuery(Q_(R"(
- SELECT * FROM `/Root/TwoShard` WHERE Key = 1u OR Key = 4000000001u;
+ SELECT * FROM `/Root/TwoShard` WHERE Key = 1u OR Key = 4000000001u ORDER BY Key;
)"), TTxControl::BeginTx(TTxSettings::SerializableRW())).ExtractValueSync();
auto tx = result.GetTransaction();
@@ -244,7 +244,7 @@ Y_UNIT_TEST_SUITE(KqpSnapshotRead) {
auto session2 = db.CreateSession().GetValueSync().GetSession();
auto result = session1.ExecuteDataQuery(Q_(R"(
- SELECT * FROM `/Root/TwoShard` WHERE Key = 1u OR Key = 4000000001u;
+ SELECT * FROM `/Root/TwoShard` WHERE Key = 1u OR Key = 4000000001u ORDER BY Key;
)"), TTxControl::BeginTx(TTxSettings::SerializableRW())).ExtractValueSync();
auto tx = result.GetTransaction();
@@ -292,7 +292,7 @@ Y_UNIT_TEST_SUITE(KqpSnapshotRead) {
auto session2 = db.CreateSession().GetValueSync().GetSession();
auto result = session1.ExecuteDataQuery(Q_(R"(
- SELECT * FROM `/Root/TwoShard` WHERE Key = 1u OR Key = 4000000001u;
+ SELECT * FROM `/Root/TwoShard` WHERE Key = 1u OR Key = 4000000001u ORDER BY Key;
)"), TTxControl::BeginTx(TTxSettings::SerializableRW())).ExtractValueSync();
auto tx = result.GetTransaction();
@@ -310,7 +310,7 @@ Y_UNIT_TEST_SUITE(KqpSnapshotRead) {
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());
result = session1.ExecuteDataQuery(Q_(R"(
- SELECT * FROM `/Root/TwoShard` WHERE Key = 2u OR Key = 4000000002u;
+ SELECT * FROM `/Root/TwoShard` WHERE Key = 2u OR Key = 4000000002u ORDER BY Key;
)"), TTxControl::Tx(*tx)).ExtractValueSync();
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());