WIP-35-5-0

Author: Enjection

ydb/core/tx/datashard/datashard_ut_incremental_backup.cpp

@@ -3338,7 +3338,7 @@ Y_UNIT_TEST_SUITE(IncrementalBackup) {
         SimulateSleep(server, TDuration::Seconds(5));
 
         // Capture expected state for all indexes
-        auto expectedTable = KqpSimpleExec(runtime, R"(
+        auto expectedTable = KqpSimpleExecSuccess(runtime, R"(
             SELECT key, value1, value2, value3 FROM `/Root/MultiIndexTable` ORDER BY key
         )");
 
@@ -3348,45 +3348,45 @@ Y_UNIT_TEST_SUITE(IncrementalBackup) {
         runtime.SimulateSleep(TDuration::Seconds(10));
 
         // Verify table data
-        auto actualTable = KqpSimpleExec(runtime, R"(
+        auto actualTable = KqpSimpleExecSuccess(runtime, R"(
             SELECT key, value1, value2, value3 FROM `/Root/MultiIndexTable` ORDER BY key
         )");
         UNIT_ASSERT_VALUES_EQUAL(expectedTable, actualTable);
 
         // Verify all indexes work
-        auto index1Query = KqpSimpleExec(runtime, R"(
+        auto index1Query = KqpSimpleExecSuccess(runtime, R"(
             SELECT key FROM `/Root/MultiIndexTable` VIEW index1 WHERE value1 = 14
         )");
         UNIT_ASSERT_C(index1Query.find("uint32_value: 4") != TString::npos, "Index1 should work");
 
-        auto index2Query = KqpSimpleExec(runtime, R"(
+        auto index2Query = KqpSimpleExecSuccess(runtime, R"(
             SELECT key FROM `/Root/MultiIndexTable` VIEW index2 WHERE value2 = 24
         )");
         UNIT_ASSERT_C(index2Query.find("uint32_value: 4") != TString::npos, "Index2 should work");
 
-        auto index3Query = KqpSimpleExec(runtime, R"(
+        auto index3Query = KqpSimpleExecSuccess(runtime, R"(
             SELECT key FROM `/Root/MultiIndexTable` VIEW index3 WHERE value3 = 34
         )");
         UNIT_ASSERT_C(index3Query.find("uint32_value: 4") != TString::npos, "Index3 should work");
 
         // Verify all index implementation tables were restored
-        auto index1ImplCount = KqpSimpleExec(runtime, R"(
+        auto index1ImplCount = KqpSimpleExecSuccess(runtime, R"(
             SELECT COUNT(*) FROM `/Root/MultiIndexTable/index1/indexImplTable`
         )");
         UNIT_ASSERT_C(index1ImplCount.find("uint64_value: 4") != TString::npos, "Index1 impl table should have 4 rows");
 
-        auto index2ImplCount = KqpSimpleExec(runtime, R"(
+        auto index2ImplCount = KqpSimpleExecSuccess(runtime, R"(
             SELECT COUNT(*) FROM `/Root/MultiIndexTable/index2/indexImplTable`
         )");
         UNIT_ASSERT_C(index2ImplCount.find("uint64_value: 4") != TString::npos, "Index2 impl table should have 4 rows");
 
-        auto index3ImplCount = KqpSimpleExec(runtime, R"(
+        auto index3ImplCount = KqpSimpleExecSuccess(runtime, R"(
             SELECT COUNT(*) FROM `/Root/MultiIndexTable/index3/indexImplTable`
         )");
         UNIT_ASSERT_C(index3ImplCount.find("uint64_value: 4") != TString::npos, "Index3 impl table should have 4 rows");
 
         // Verify index3 impl table data (spot check)
-        auto index3ImplData = KqpSimpleExec(runtime, R"(
+        auto index3ImplData = KqpSimpleExecSuccess(runtime, R"(
             SELECT value3, key FROM `/Root/MultiIndexTable/index3/indexImplTable` WHERE value3 = 34
         )");
         UNIT_ASSERT_C(index3ImplData.find("uint32_value: 34") != TString::npos, "Index3 impl should have value3=34");