adjust tests

CheSema · CheSema · commit f3b63f7460da · 2026-02-24T15:37:03.000+01:00
diff --git a/tests/queries/0_stateless/01173_transaction_control_queries.sql b/tests/queries/0_stateless/01173_transaction_control_queries.sql
@@ -1,5 +1,7 @@
 -- Tags: no-ordinary-database, no-encrypted-storage
 
+set async_insert=0;
+
 drop table if exists mt1;
 drop table if exists mt2;
 
diff --git a/tests/queries/0_stateless/01413_rows_events.sql b/tests/queries/0_stateless/01413_rows_events.sql
@@ -5,15 +5,15 @@
 DROP TABLE IF EXISTS rows_events_test;
 CREATE TABLE rows_events_test (k UInt32, v UInt32) ENGINE = MergeTree ORDER BY k SETTINGS add_minmax_index_for_numeric_columns=0;
 
-INSERT INTO /* test 01413, query 1 */ rows_events_test VALUES (1,1);
+INSERT INTO /* test 01413, query 1 */ rows_events_test SETTINGS async_insert=0 VALUES (1,1);
 SYSTEM FLUSH LOGS query_log;
 
 SELECT written_rows FROM system.query_log WHERE current_database = currentDatabase() AND query LIKE 'INSERT INTO /* test 01413, query 1 */ rows_events_test%' AND type = 2 AND event_date >= yesterday() ORDER BY event_time DESC LIMIT 1;
 
 SELECT ProfileEvents['InsertedRows'] as value FROM system.query_log WHERE current_database = currentDatabase() AND query LIKE 'INSERT INTO /* test 01413, query 1 */ rows_events_test%' AND type = 2 AND event_date >= yesterday() ORDER BY event_time DESC LIMIT 1;
 
 
-INSERT INTO /* test 01413, query 2 */ rows_events_test VALUES (2,2), (3,3);
+INSERT INTO /* test 01413, query 2 */ rows_events_test SETTINGS async_insert=0 VALUES (2,2), (3,3);
 SYSTEM FLUSH LOGS query_log;
 
 SELECT written_rows FROM system.query_log WHERE current_database = currentDatabase() AND query LIKE 'INSERT INTO /* test 01413, query 2 */ rows_events_test%' AND type = 2 AND event_date >= yesterday() ORDER BY event_time DESC LIMIT 1;
diff --git a/tests/queries/0_stateless/02124_insert_deduplication_token_multiple_blocks.sh b/tests/queries/0_stateless/02124_insert_deduplication_token_multiple_blocks.sh
@@ -5,7 +5,7 @@ CURDIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
 
 QUERY_COUNT_ORIGIN_BLOCKS="SELECT COUNT(*) FROM system.parts WHERE database = currentDatabase() AND table = 'block_dedup_token' AND min_block_number == max_block_number;"
 QUERY_SELECT_FROM_TABLE_ORDERED="SELECT * FROM block_dedup_token ORDER BY id;"
-INSERT_BLOCK_SETTINGS="max_insert_block_size=1&min_insert_block_size_rows=0&min_insert_block_size_bytes=0"
+INSERT_BLOCK_SETTINGS="async_insert=0&max_insert_block_size=1&min_insert_block_size_rows=0&min_insert_block_size_bytes=0"
 
 $CLICKHOUSE_CLIENT --query="DROP TABLE IF EXISTS block_dedup_token SYNC"
 $CLICKHOUSE_CLIENT --query="CREATE TABLE block_dedup_token (id Int32) ENGINE=MergeTree() ORDER BY id SETTINGS non_replicated_deduplication_window=0xFFFFFFFF;"
diff --git a/tests/queries/0_stateless/02306_part_types_profile_events.sql b/tests/queries/0_stateless/02306_part_types_profile_events.sql
@@ -2,6 +2,8 @@
 -- no-async-insert: 1 part is inserted with async inserts
 DROP TABLE IF EXISTS t_parts_profile_events;
 
+SET async_insert = 0;
+
 CREATE TABLE t_parts_profile_events (a UInt32)
 ENGINE = MergeTree ORDER BY tuple()
 SETTINGS min_rows_for_wide_part = 10, min_bytes_for_wide_part = 0;
diff --git a/tests/queries/0_stateless/02310_profile_events_insert.sh b/tests/queries/0_stateless/02310_profile_events_insert.sh
@@ -6,9 +6,9 @@ CURDIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
 . "$CURDIR"/../shell_config.sh
 
 echo client
-$CLICKHOUSE_CLIENT --print-profile-events --profile-events-delay-ms=-1 -q "insert into function null('foo Int') values (1)" |& grep -o 'InsertedRows: .*'
+$CLICKHOUSE_CLIENT --async_insert=0 --print-profile-events --profile-events-delay-ms=-1 -q "insert into function null('foo Int') values (1)" |& grep -o 'InsertedRows: .*'
 
 echo local
-$CLICKHOUSE_LOCAL  --print-profile-events --profile-events-delay-ms=-1 -q "insert into function null('foo Int') values (1)" |& grep -o 'InsertedRows: .*'
+$CLICKHOUSE_LOCAL  --async_insert=0 --print-profile-events --profile-events-delay-ms=-1 -q "insert into function null('foo Int') values (1)" |& grep -o 'InsertedRows: .*'
 
 exit 0
diff --git a/tests/queries/0_stateless/02361_fsync_profile_events.sh b/tests/queries/0_stateless/02361_fsync_profile_events.sh
@@ -29,7 +29,7 @@ ret=1
 for i in {1..100}; do
     query_id="insert-$i-$CLICKHOUSE_DATABASE"
 
-    $CLICKHOUSE_CLIENT --query_id "$query_id" -q "insert into data_fsync_pe values (1)"
+    $CLICKHOUSE_CLIENT --query_id "$query_id" --async_insert=0 -q "insert into data_fsync_pe values (1)"
 
     read -r FileSync FileOpen DirectorySync FileSyncElapsedMicroseconds DirectorySyncElapsedMicroseconds <<<"$(
     $CLICKHOUSE_CLIENT -m --param_query_id "$query_id" -q "
diff --git a/tests/queries/0_stateless/02423_insert_stats_behaviour.sh b/tests/queries/0_stateless/02423_insert_stats_behaviour.sh
@@ -15,14 +15,14 @@ $CLICKHOUSE_CLIENT -q "CREATE MATERIALIZED VIEW floats_to_target TO target_1 AS
 $CLICKHOUSE_CLIENT -q "CREATE MATERIALIZED VIEW floats_to_target_2 TO target_2 AS SELECT v FROM floats, numbers(2) n"
 
 # Insertions into table without MVs
-$CLICKHOUSE_CLIENT -q "INSERT into target_1 FORMAT CSV 1.0"
-$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format Native | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&query=INSERT+INTO+target_1+FORMAT+Native" --data-binary @-
-$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format RowBinary | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&query=INSERT+INTO+target_1+FORMAT+RowBinary" --data-binary @-
+$CLICKHOUSE_CLIENT --async_insert=0 -q "INSERT into target_1 FORMAT CSV 1.0"
+$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format Native | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&async_insert=0&query=INSERT+INTO+target_1+FORMAT+Native" --data-binary @-
+$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format RowBinary | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&async_insert=0&query=INSERT+INTO+target_1+FORMAT+RowBinary" --data-binary @-
 
 # Insertions into table without 2 MVs (1:1 and 1:2 rows)
-$CLICKHOUSE_CLIENT -q "INSERT into floats FORMAT CSV 1.0"
-$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format Native | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&query=INSERT+INTO+floats+FORMAT+Native" --data-binary @-
-$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format RowBinary | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&query=INSERT+INTO+floats+FORMAT+RowBinary" --data-binary @-
+$CLICKHOUSE_CLIENT --async_insert=0 -q "INSERT into floats FORMAT CSV 1.0"
+$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format Native | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&async_insert=0&query=INSERT+INTO+floats+FORMAT+Native" --data-binary @-
+$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format RowBinary | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&async_insert=0&query=INSERT+INTO+floats+FORMAT+RowBinary" --data-binary @-
 
 # Wait for all 6 insert queries to appear in query_log.
 # There is a race between HTTP response being sent and the query_log entry being written,
diff --git a/tests/queries/0_stateless/02423_insert_summary_behaviour.sh b/tests/queries/0_stateless/02423_insert_summary_behaviour.sh
@@ -11,11 +11,11 @@ $CLICKHOUSE_CLIENT -q "CREATE MATERIALIZED VIEW floats_to_target TO target_1 AS
 $CLICKHOUSE_CLIENT -q "CREATE MATERIALIZED VIEW floats_to_target_2 TO target_2 AS SELECT v FROM floats, numbers(2) n"
 
 echo "No materialized views"
-${CLICKHOUSE_CURL} "${CLICKHOUSE_URL}&http_wait_end_of_query=1&query=INSERT+INTO+target_1" -d "VALUES(1.0)" -v 2>&1 | grep 'X-ClickHouse-Summary' | sed 's/,\"elapsed_ns[^}]*//'
-$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format Native | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&http_wait_end_of_query=1&query=INSERT+INTO+target_1+FORMAT+Native" --data-binary @- -v 2>&1 | grep 'X-ClickHouse-Summary' | sed 's/,\"elapsed_ns[^}]*//'
-$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format RowBinary | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&http_wait_end_of_query=1&query=INSERT+INTO+target_1+FORMAT+RowBinary" --data-binary @- -v 2>&1 | grep 'X-ClickHouse-Summary' | sed 's/,\"elapsed_ns[^}]*//'
+${CLICKHOUSE_CURL} "${CLICKHOUSE_URL}&async_insert=0&http_wait_end_of_query=1&query=INSERT+INTO+target_1" -d "VALUES(1.0)" -v 2>&1 | grep 'X-ClickHouse-Summary' | sed 's/,\"elapsed_ns[^}]*//'
+$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format Native | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&async_insert=0&http_wait_end_of_query=1&query=INSERT+INTO+target_1+FORMAT+Native" --data-binary @- -v 2>&1 | grep 'X-ClickHouse-Summary' | sed 's/,\"elapsed_ns[^}]*//'
+$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format RowBinary | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&async_insert=0&http_wait_end_of_query=1&query=INSERT+INTO+target_1+FORMAT+RowBinary" --data-binary @- -v 2>&1 | grep 'X-ClickHouse-Summary' | sed 's/,\"elapsed_ns[^}]*//'
 
 echo "With materialized views"
-${CLICKHOUSE_CURL} "${CLICKHOUSE_URL}&http_wait_end_of_query=1&query=INSERT+INTO+floats" -d "VALUES(1.0)" -v 2>&1 | grep 'X-ClickHouse-Summary' | sed 's/,\"elapsed_ns[^}]*//'
-$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format Native | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&http_wait_end_of_query=1&query=INSERT+INTO+floats+FORMAT+Native" --data-binary @- -v 2>&1 | grep 'X-ClickHouse-Summary' | sed 's/,\"elapsed_ns[^}]*//'
-$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format RowBinary | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&http_wait_end_of_query=1&query=INSERT+INTO+floats+FORMAT+RowBinary" --data-binary @- -v 2>&1 | grep 'X-ClickHouse-Summary' | sed 's/,\"elapsed_ns[^}]*//'
+${CLICKHOUSE_CURL} "${CLICKHOUSE_URL}&async_insert=0&http_wait_end_of_query=1&query=INSERT+INTO+floats" -d "VALUES(1.0)" -v 2>&1 | grep 'X-ClickHouse-Summary' | sed 's/,\"elapsed_ns[^}]*//'
+$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format Native | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&async_insert=0&http_wait_end_of_query=1&query=INSERT+INTO+floats+FORMAT+Native" --data-binary @- -v 2>&1 | grep 'X-ClickHouse-Summary' | sed 's/,\"elapsed_ns[^}]*//'
+$CLICKHOUSE_LOCAL -q "SELECT number::Float64 AS v FROM numbers(10)" --format RowBinary | ${CLICKHOUSE_CURL} -sS "${CLICKHOUSE_URL}&async_insert=0&http_wait_end_of_query=1&query=INSERT+INTO+floats+FORMAT+RowBinary" --data-binary @- -v 2>&1 | grep 'X-ClickHouse-Summary' | sed 's/,\"elapsed_ns[^}]*//'
diff --git a/tests/queries/0_stateless/02480_client_option_print_num_processed_rows.expect b/tests/queries/0_stateless/02480_client_option_print_num_processed_rows.expect
@@ -31,23 +31,23 @@ send -- "\$CLICKHOUSE_CLIENT --query 'CREATE TABLE num_processed_rows_test_0 (va
 expect "bash) "
 
 ### When requested we should get the count on exit:
-send -- "\$CLICKHOUSE_CLIENT --processed-rows --query \"INSERT INTO num_processed_rows_test_0 VALUES (\'x\');\" \r"
+send -- "\$CLICKHOUSE_CLIENT --async_insert=0 --processed-rows --query \"INSERT INTO num_processed_rows_test_0 VALUES (\'x\');\" \r"
 expect "Processed rows: 1"
 expect "bash) "
 
-send "yes | head -n7757 | \$CLICKHOUSE_CLIENT --processed-rows --query 'INSERT INTO num_processed_rows_test_0 format TSV\'\r"
+send "yes | head -n7757 | \$CLICKHOUSE_CLIENT --async_insert=0 --processed-rows --query 'INSERT INTO num_processed_rows_test_0 format TSV\'\r"
 expect "Processed rows: 7757"
 expect "bash) "
 
 
 
 ### By default it should not show up:
 
-send -- "\$CLICKHOUSE_CLIENT --query \"INSERT INTO num_processed_rows_test_0 VALUES (\'x\');\" && echo OK\r"
+send -- "\$CLICKHOUSE_CLIENT --async_insert=0 --query \"INSERT INTO num_processed_rows_test_0 VALUES (\'x\');\" && echo OK\r"
 expect -exact "OK\r"
 expect "bash) "
 
-send "yes | head -n7757 | \$CLICKHOUSE_CLIENT --query 'INSERT INTO num_processed_rows_test_0 format TSV\' && echo OK\r"
+send "yes | head -n7757 | \$CLICKHOUSE_CLIENT --async_insert=0 --query 'INSERT INTO num_processed_rows_test_0 format TSV\' && echo OK\r"
 expect -exact "OK\r"
 expect "bash) "
 
diff --git a/tests/queries/0_stateless/03008_deduplication_insert_into_partitioned_table.reference b/tests/queries/0_stateless/03008_deduplication_insert_into_partitioned_table.reference
@@ -11,6 +11,13 @@ mv_table is not deduplicated because the inserted blocks was different:
 2	B
 2	B
 2	C
+but partitioned_table is not deduplicated with async insert bacause async deduplication works in scope of one insertion:
+1	A
+1	A
+1	D
+2	B
+2	B
+2	C
 with user deduplication token
 partitioned_table is not deduplicated because different tokens:
 1	A
diff --git a/tests/queries/0_stateless/03008_deduplication_insert_into_partitioned_table.sql b/tests/queries/0_stateless/03008_deduplication_insert_into_partitioned_table.sql
@@ -18,15 +18,22 @@ CREATE MATERIALIZED VIEW mv_table (key Int64, value String)
     ORDER BY tuple()
     AS SELECT key, value FROM partitioned_table;
 
-INSERT INTO partitioned_table VALUES (1, 'A'), (2, 'B');
-INSERT INTO partitioned_table VALUES (1, 'A'), (2, 'C');
-INSERT INTO partitioned_table VALUES (1, 'D'), (2, 'B');
+INSERT INTO partitioned_table SETTINGS async_insert=0 VALUES (1, 'A'), (2, 'B');
+INSERT INTO partitioned_table SETTINGS async_insert=0 VALUES (1, 'A'), (2, 'C');
+INSERT INTO partitioned_table SETTINGS async_insert=0 VALUES (1, 'D'), (2, 'B');
 
 SELECT 'partitioned_table is deduplicated bacause deduplication works in scope of one partiotion:';
 SELECT * FROM partitioned_table ORDER BY ALL;
 SELECT 'mv_table is not deduplicated because the inserted blocks was different:';
 SELECT * FROM mv_table ORDER BY ALL;
 
+SELECT 'but partitioned_table is not deduplicated with async insert bacause async deduplication works in scope of one insertion:';
+TRUNCATE TABLE partitioned_table;
+INSERT INTO partitioned_table SETTINGS async_insert=1 VALUES (1, 'A'), (2, 'B');
+INSERT INTO partitioned_table SETTINGS async_insert=1 VALUES (1, 'A'), (2, 'C');
+INSERT INTO partitioned_table SETTINGS async_insert=1 VALUES (1, 'D'), (2, 'B');
+SELECT * FROM partitioned_table ORDER BY ALL;
+
 DROP TABLE partitioned_table;
 DROP TABLE mv_table;
 
diff --git a/tests/queries/0_stateless/03167_transactions_are_really_disabled.sql b/tests/queries/0_stateless/03167_transactions_are_really_disabled.sql
@@ -1,5 +1,7 @@
 -- Tags: no-encrypted-storage
 
+SET async_insert = 0;
+
 DROP TABLE IF EXISTS mv_table;
 DROP TABLE IF EXISTS null_table;
 
diff --git a/tests/queries/0_stateless/03802_insert_stream_timeout_flush.sh b/tests/queries/0_stateless/03802_insert_stream_timeout_flush.sh
@@ -18,12 +18,12 @@ ${CLICKHOUSE_CLIENT} --query "CREATE TABLE test_insert_timeout (id UInt64, data
         for i in $(seq 1 40); do
             echo "{\"id\":$(( (iteration*100) + i )),\"data\":\"batch_${iteration}\"}"
         done
-        
+
         sleep 6
-        
+
         echo "{\"id\":$(( (iteration*100) + 99 )),\"data\":\"trigger_${iteration}\"}"
     done
-}  | ${CLICKHOUSE_CLIENT} --query "INSERT INTO test_insert_timeout FORMAT JSONEachRow" \
+}  | ${CLICKHOUSE_CLIENT} --async_insert=0 --query "INSERT INTO test_insert_timeout FORMAT JSONEachRow" \
     --max_insert_block_size=1000 \
     --input_format_connection_handling=1 \
     --input_format_max_block_wait_ms=2000 \
@@ -36,14 +36,14 @@ echo "Total records inserted: ${record_count}"
 $CLICKHOUSE_CLIENT -q "SYSTEM FLUSH LOGS query_log, part_log;"
 
 parts_count=$(${CLICKHOUSE_CLIENT} --query "
-SELECT count(*) 
-FROM system.part_log 
-WHERE table = 'test_insert_timeout' 
+SELECT count(*)
+FROM system.part_log
+WHERE table = 'test_insert_timeout'
   AND event_type = 'NewPart'
   AND query_id = (
-        SELECT argMax(query_id, event_time) 
-        FROM system.query_log 
-        WHERE query LIKE '%INSERT INTO test_insert_timeout%' 
+        SELECT argMax(query_id, event_time)
+        FROM system.query_log
+        WHERE query LIKE '%INSERT INTO test_insert_timeout%'
           AND current_database = currentDatabase()
     )
 ")
@@ -52,4 +52,3 @@ WHERE table = 'test_insert_timeout'
 echo "Number of parts created: ${parts_count}"
 
 ${CLICKHOUSE_CLIENT} --query "DROP TABLE IF EXISTS test_insert_timeout"
-
diff --git a/tests/queries/0_stateless/03803_insert_on_connection_drop.sh b/tests/queries/0_stateless/03803_insert_on_connection_drop.sh
@@ -8,7 +8,7 @@ CURDIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
 
 CLICKHOUSE_TABLE="test_insert_on_connection_drop"
 SETTINGS="input_format_connection_handling=1,min_insert_block_size_bytes=0,min_insert_block_size_rows=0"
-CLICKHOUSE_INSERT_URL="${CLICKHOUSE_URL}&max_query_size=1000&query=INSERT%20INTO%20${CLICKHOUSE_TABLE}%20SETTINGS%20${SETTINGS//,/%2C}%20FORMAT%20CSV"
+CLICKHOUSE_INSERT_URL="${CLICKHOUSE_URL}&async_insert=0&max_query_size=1000&query=INSERT%20INTO%20${CLICKHOUSE_TABLE}%20SETTINGS%20${SETTINGS//,/%2C}%20FORMAT%20CSV"
 
 echo "DROP TABLE IF EXISTS ${CLICKHOUSE_TABLE}" | \
     curl -sS -d@- "$CLICKHOUSE_URL"
@@ -48,14 +48,14 @@ $CLICKHOUSE_CLIENT -q "SYSTEM FLUSH LOGS query_log, part_log;"
 
 
 parts_count=$(${CLICKHOUSE_CLIENT} --query "
-SELECT count(*) 
-FROM system.part_log 
-WHERE table = '${CLICKHOUSE_TABLE}' 
+SELECT count(*)
+FROM system.part_log
+WHERE table = '${CLICKHOUSE_TABLE}'
   AND event_type = 'NewPart'
   AND query_id = (
-        SELECT argMax(query_id, event_time) 
-        FROM system.query_log 
-        WHERE query LIKE CONCAT('%INSERT INTO ', '${CLICKHOUSE_TABLE}', '%') 
+        SELECT argMax(query_id, event_time)
+        FROM system.query_log
+        WHERE query LIKE CONCAT('%INSERT INTO ', '${CLICKHOUSE_TABLE}', '%')
           AND current_database = currentDatabase()
     )
 ")
@@ -64,4 +64,3 @@ echo "Number of parts created: ${parts_count}"
 
 echo "DROP TABLE IF EXISTS ${CLICKHOUSE_TABLE}" | \
     curl -sS -d@- "$CLICKHOUSE_URL"
-
