This commit is contained in:
feng lv 2021-01-03 08:47:30 +00:00
parent 459abca5b5
commit fddb71df8f

View File

@ -1,8 +1,8 @@
DROP TABLE IF EXISTS default.x; DROP TABLE IF EXISTS x;
DROP TABLE IF EXISTS default.y; DROP TABLE IF EXISTS y;
CREATE TABLE default.x AS system.numbers ENGINE = MergeTree ORDER BY number; CREATE TABLE x AS system.numbers ENGINE = MergeTree ORDER BY number;
CREATE TABLE default.y AS system.numbers ENGINE = MergeTree ORDER BY number; CREATE TABLE y AS system.numbers ENGINE = MergeTree ORDER BY number;
-- Just one shard, sharding key isn't necessary -- Just one shard, sharding key isn't necessary
INSERT INTO FUNCTION cluster('test_shard_localhost', currentDatabase(), x) SELECT * FROM numbers(10); INSERT INTO FUNCTION cluster('test_shard_localhost', currentDatabase(), x) SELECT * FROM numbers(10);
@ -15,9 +15,9 @@ INSERT INTO FUNCTION cluster('test_cluster_two_shards_localhost', currentDatabas
INSERT INTO FUNCTION remote('127.0.0.{1,2}', currentDatabase(), y, 'default') SELECT * FROM numbers(10); -- { serverError 55 } INSERT INTO FUNCTION remote('127.0.0.{1,2}', currentDatabase(), y, 'default') SELECT * FROM numbers(10); -- { serverError 55 }
INSERT INTO FUNCTION remote('127.0.0.{1,2}', currentDatabase(), y, 'default', rand()) SELECT * FROM numbers(10); INSERT INTO FUNCTION remote('127.0.0.{1,2}', currentDatabase(), y, 'default', rand()) SELECT * FROM numbers(10);
SELECT * FROM default.x ORDER BY number; SELECT * FROM x ORDER BY number;
SELECT * FROM remote('127.0.0.{1,2}', currentDatabase(), y) ORDER BY number; SELECT * FROM remote('127.0.0.{1,2}', currentDatabase(), y) ORDER BY number;
DROP TABLE default.x; DROP TABLE x;
DROP TABLE default.y; DROP TABLE y;