thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-19 16:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #68139 from azat/system-storages-set-not-ready

Browse Source 
Better test for Not-ready Set is passed in system.* tables
This commit is contained in:
Alexey Milovidov 2024-08-20 04:05:27 +00:00 committed by GitHub
commit 949be425e2
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 35 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tests/queries/0_stateless/03223_system_tables_set_not_ready.reference Normal file
View File

@ -0,0 +1,5 @@
system.distribution_queue 1
system.rocksdb 1
system.databases 1
system.mutations 1
system.replication_queue 1

30
tests/queries/0_stateless/03223_system_tables_set_not_ready.sql Normal file
View File

@ -0,0 +1,30 @@
-- Tags: no-fasttest
-- Tag no-fasttest -- due to EmbeddedRocksDB
drop table if exists null;
drop table if exists dist;
create table null as system.one engine=Null;
create table dist as null engine=Distributed(test_cluster_two_shards, currentDatabase(), 'null', rand());
insert into dist settings prefer_localhost_replica=0 values (1);
select 'system.distribution_queue', count() from system.distribution_queue where exists(select 1) and database = currentDatabase();
drop table if exists rocksdb;
create table rocksdb (key Int) engine=EmbeddedRocksDB() primary key key;
insert into rocksdb values (1);
select 'system.rocksdb', count()>0 from system.rocksdb where exists(select 1) and database = currentDatabase();
select 'system.databases', count() from system.databases where exists(select 1) and database = currentDatabase();
drop table if exists mt;
create table mt (key Int) engine=MergeTree() order by key;
alter table mt delete where 1;
select 'system.mutations', count() from system.mutations where exists(select 1) and database = currentDatabase();
drop table if exists rep1;
drop table if exists rep2;
create table rep1 (key Int) engine=ReplicatedMergeTree('/{database}/rep', '{table}') order by key;
create table rep2 (key Int) engine=ReplicatedMergeTree('/{database}/rep', '{table}') order by key;
system stop fetches rep2;
insert into rep1 values (1);
system sync replica rep2 pull;
select 'system.replication_queue', count()>0 from system.replication_queue where exists(select 1) and database = currentDatabase();