diff options
| author | dcherednik <[email protected]> | 2023-08-07 20:10:41 +0300 |
|---|---|---|
| committer | dcherednik <[email protected]> | 2023-08-07 22:29:37 +0300 |
| commit | f5526a6879f5a88a74077e276ed9b70b9790615b (patch) | |
| tree | b8482b95ce0464ab5ab14e1da3e77d996ff57951 | |
| parent | 537f5f2697b0c0e92ab728854718a818e87d87a9 (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.cpp | 14 |
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()); |
