Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

extended test for deduplicate_blocks_in_dependent_materialized_views #9693

Merged
merged 2 commits into from
Mar 17, 2020
Merged

extended test for deduplicate_blocks_in_dependent_materialized_views #9693

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
f1f1c1c
extended test for deduplicate_blocks_in_dependent_materialized_views
den-crane Mar 16, 2020
d6e843d
Update test.py
den-crane Mar 16, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
44 changes: 39 additions & 5 deletions dbms/tests/integration/test_force_deduplication/test.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,21 +24,55 @@ def test_basic(start_cluster):
node.query(
'''
CREATE TABLE test (A Int64) ENGINE = ReplicatedMergeTree ('/clickhouse/test/tables/test','1') ORDER BY tuple();
CREATE MATERIALIZED VIEW test_mv Engine=ReplicatedMergeTree ('/clickhouse/test/tables/test_mv','1') partition by A order by tuple() AS SELECT A FROM test;
CREATE MATERIALIZED VIEW test_mv_a Engine=ReplicatedMergeTree ('/clickhouse/test/tables/test_mv_a','1') order by tuple() AS SELECT A FROM test;
CREATE MATERIALIZED VIEW test_mv_b Engine=ReplicatedMergeTree ('/clickhouse/test/tables/test_mv_b','1') partition by A order by tuple() AS SELECT A FROM test;
CREATE MATERIALIZED VIEW test_mv_c Engine=ReplicatedMergeTree ('/clickhouse/test/tables/test_mv_c','1') order by tuple() AS SELECT A FROM test;
INSERT INTO test values(999);
INSERT INTO test values(999);
SET max_partitions_per_insert_block = 3;
INSERT INTO test SELECT number FROM numbers(10);
'''
)

assert int(node.query("SELECT count() FROM test")) == 11
assert int(node.query("SELECT count() FROM test_mv_a")) == 11
assert int(node.query("SELECT count() FROM test_mv_b")) == 1
assert int(node.query("SELECT count() FROM test_mv_c")) == 1

node.query("INSERT INTO test SELECT number FROM numbers(10)")
assert int(node.query("SELECT count() FROM test")) == 10
assert int(node.query("SELECT count() FROM test_mv")) == 0
assert int(node.query("SELECT count() FROM test")) == 11
assert int(node.query("SELECT count() FROM test_mv_a")) == 11
assert int(node.query("SELECT count() FROM test_mv_b")) == 1
assert int(node.query("SELECT count() FROM test_mv_c")) == 1

node.query(
'''
SET deduplicate_blocks_in_dependent_materialized_views = 1;
INSERT INTO test SELECT number FROM numbers(10);
'''
)
assert int(node.query("SELECT count() FROM test")) == 10
assert int(node.query("SELECT count() FROM test_mv")) == 10
assert int(node.query("SELECT count() FROM test")) == 11
assert int(node.query("SELECT count() FROM test_mv_a")) == 21 # first insert was succesfull with disabled dedup..
assert int(node.query("SELECT count() FROM test_mv_b")) == 11
assert int(node.query("SELECT count() FROM test_mv_c")) == 11

with pytest.raises(QueryRuntimeException):
node.query(
'''
SET max_partitions_per_insert_block = 3;
SET deduplicate_blocks_in_dependent_materialized_views = 1;
INSERT INTO test SELECT number FROM numbers(100,10);
'''
)

node.query(
'''
SET deduplicate_blocks_in_dependent_materialized_views = 1;
INSERT INTO test SELECT number FROM numbers(100,10);
'''
)

assert int(node.query("SELECT count() FROM test")) == 21
assert int(node.query("SELECT count() FROM test_mv_a")) == 31
assert int(node.query("SELECT count() FROM test_mv_b")) == 21
assert int(node.query("SELECT count() FROM test_mv_c")) == 21