mirror of https://github.com/citusdata/citus.git
Adds next shard ids to multi_create_table tests
parent
a701fc774a
commit
d574ac33a8
|
@ -5,6 +5,7 @@
|
||||||
-- execution functionality. Also create indexes to boost performance. Since we
|
-- execution functionality. Also create indexes to boost performance. Since we
|
||||||
-- need to cover both reference join and partitioned join, we have created
|
-- need to cover both reference join and partitioned join, we have created
|
||||||
-- reference and append distributed version of orders, customer and part tables.
|
-- reference and append distributed version of orders, customer and part tables.
|
||||||
|
SET citus.next_shard_id TO 360000;
|
||||||
CREATE TABLE lineitem (
|
CREATE TABLE lineitem (
|
||||||
l_orderkey bigint not null,
|
l_orderkey bigint not null,
|
||||||
l_partkey integer not null,
|
l_partkey integer not null,
|
||||||
|
@ -178,6 +179,7 @@ SELECT create_distributed_table('supplier_single_shard', 's_suppkey', 'append');
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
CREATE TABLE mx_table_test (col1 int, col2 text);
|
CREATE TABLE mx_table_test (col1 int, col2 text);
|
||||||
|
SET citus.next_shard_id TO 360009;
|
||||||
-- Test initial data loading
|
-- Test initial data loading
|
||||||
CREATE TABLE data_load_test (col1 int, col2 text, col3 serial);
|
CREATE TABLE data_load_test (col1 int, col2 text, col3 serial);
|
||||||
INSERT INTO data_load_test VALUES (132, 'hello');
|
INSERT INTO data_load_test VALUES (132, 'hello');
|
||||||
|
|
|
@ -1,4 +1,4 @@
|
||||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 360000;
|
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 360005;
|
||||||
ALTER SEQUENCE pg_catalog.pg_dist_colocationid_seq RESTART 100000;
|
ALTER SEQUENCE pg_catalog.pg_dist_colocationid_seq RESTART 100000;
|
||||||
-- Since we're superuser, we can set the replication model to 'streaming' to
|
-- Since we're superuser, we can set the replication model to 'streaming' to
|
||||||
-- create a one-off MX table... but if we forget to set the replication factor to one,
|
-- create a one-off MX table... but if we forget to set the replication factor to one,
|
||||||
|
@ -222,6 +222,7 @@ SELECT repmodel FROM pg_dist_partition WHERE logicalrelid='repmodel_test'::regcl
|
||||||
|
|
||||||
DROP TABLE repmodel_test;
|
DROP TABLE repmodel_test;
|
||||||
RESET citus.replication_model;
|
RESET citus.replication_model;
|
||||||
|
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 360025;
|
||||||
-- There should be no table on the worker node
|
-- There should be no table on the worker node
|
||||||
\c - - - :worker_1_port
|
\c - - - :worker_1_port
|
||||||
SELECT relname FROM pg_class WHERE relname LIKE 'data_load_test%';
|
SELECT relname FROM pg_class WHERE relname LIKE 'data_load_test%';
|
||||||
|
|
|
@ -7,6 +7,8 @@
|
||||||
-- need to cover both reference join and partitioned join, we have created
|
-- need to cover both reference join and partitioned join, we have created
|
||||||
-- reference and append distributed version of orders, customer and part tables.
|
-- reference and append distributed version of orders, customer and part tables.
|
||||||
|
|
||||||
|
SET citus.next_shard_id TO 360000;
|
||||||
|
|
||||||
CREATE TABLE lineitem (
|
CREATE TABLE lineitem (
|
||||||
l_orderkey bigint not null,
|
l_orderkey bigint not null,
|
||||||
l_partkey integer not null,
|
l_partkey integer not null,
|
||||||
|
@ -138,6 +140,8 @@ SELECT create_distributed_table('supplier_single_shard', 's_suppkey', 'append');
|
||||||
|
|
||||||
CREATE TABLE mx_table_test (col1 int, col2 text);
|
CREATE TABLE mx_table_test (col1 int, col2 text);
|
||||||
|
|
||||||
|
SET citus.next_shard_id TO 360009;
|
||||||
|
|
||||||
-- Test initial data loading
|
-- Test initial data loading
|
||||||
CREATE TABLE data_load_test (col1 int, col2 text, col3 serial);
|
CREATE TABLE data_load_test (col1 int, col2 text, col3 serial);
|
||||||
INSERT INTO data_load_test VALUES (132, 'hello');
|
INSERT INTO data_load_test VALUES (132, 'hello');
|
||||||
|
|
|
@ -1,5 +1,5 @@
|
||||||
|
|
||||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 360000;
|
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 360005;
|
||||||
ALTER SEQUENCE pg_catalog.pg_dist_colocationid_seq RESTART 100000;
|
ALTER SEQUENCE pg_catalog.pg_dist_colocationid_seq RESTART 100000;
|
||||||
|
|
||||||
-- Since we're superuser, we can set the replication model to 'streaming' to
|
-- Since we're superuser, we can set the replication model to 'streaming' to
|
||||||
|
@ -90,6 +90,8 @@ DROP TABLE repmodel_test;
|
||||||
|
|
||||||
RESET citus.replication_model;
|
RESET citus.replication_model;
|
||||||
|
|
||||||
|
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 360025;
|
||||||
|
|
||||||
-- There should be no table on the worker node
|
-- There should be no table on the worker node
|
||||||
\c - - :public_worker_1_host :worker_1_port
|
\c - - :public_worker_1_host :worker_1_port
|
||||||
SELECT relname FROM pg_class WHERE relname LIKE 'data_load_test%';
|
SELECT relname FROM pg_class WHERE relname LIKE 'data_load_test%';
|
||||||
|
|
Loading…
Reference in New Issue