[fix](regression-test) add more check to address flaky test_partial_u…

…pdate_with_delete_stmt #26474 (#26628)
apache · Nov 9, 2023 · d3f2170 · d3f2170
1 parent 524c850
commit d3f2170
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/...sion-test/data/unique_with_mow_p0/partial_update/test_partial_update_with_delete_stmt.out b/...sion-test/data/unique_with_mow_p0/partial_update/test_partial_update_with_delete_stmt.out
@@ -3,6 +3,9 @@
 1	doris	1000	123	1
 2	doris2	2000	223	1
 
+-- !select_before_delete --
+2
+
 -- !select_join --
 1	doris	1000	123	1
 
diff --git a/...test/suites/unique_with_mow_p0/partial_update/test_partial_update_with_delete_stmt.groovy b/...test/suites/unique_with_mow_p0/partial_update/test_partial_update_with_delete_stmt.groovy
@@ -126,10 +126,18 @@ suite("test_primary_key_partial_update_with_delete_stmt", "p0") {
 
     sql "sync"
 
-    sql """
+    qt_select_before_delete """
+        select ${tableName}.id from ${tableName} inner join ${tableNameJoinA} inner join ${tableNameJoinB} on ${tableNameJoinA}.id = ${tableNameJoinB}.id
+        and ${tableName}.id = ${tableNameJoinA}.id
+    """
+
+    def result3 = sql """
         delete from ${tableName} using ${tableNameJoinA} inner join ${tableNameJoinB} on ${tableNameJoinA}.id = ${tableNameJoinB}.id
         where ${tableName}.id = ${tableNameJoinA}.id
     """
+    assertTrue(result3.size() == 1)
+    assertTrue(result3[0].size() == 1)
+    assertTrue(result3[0][0] == 1, "Query OK, 1 row affected")
 
     sql "sync"