mirror of https://github.com/citusdata/citus.git
add test with analyze & normalize test outputs
parent
d4c33b3cea
commit
bed896256d
|
@ -60,6 +60,10 @@ s/(job_[0-9]+\/task_[0-9]+\/p_[0-9]+\.)[0-9]+/\1xxxx/g
|
||||||
# isolation_ref2ref_foreign_keys
|
# isolation_ref2ref_foreign_keys
|
||||||
s/"(ref_table_[0-9]_|ref_table_[0-9]_value_fkey_)[0-9]+"/"\1xxxxxxx"/g
|
s/"(ref_table_[0-9]_|ref_table_[0-9]_value_fkey_)[0-9]+"/"\1xxxxxxx"/g
|
||||||
|
|
||||||
|
# commands cascading to shard relations
|
||||||
|
s/(NOTICE: .*_)[0-9]{5,}( CASCADE)/\1xxxxx\2/g
|
||||||
|
s/(NOTICE: [a-z]+ cascades to table ".*)_[0-9]{5,}"/\1_xxxxx"/g
|
||||||
|
|
||||||
# Line info varies between versions
|
# Line info varies between versions
|
||||||
/^LINE [0-9]+:.*$/d
|
/^LINE [0-9]+:.*$/d
|
||||||
/^ *\^$/d
|
/^ *\^$/d
|
||||||
|
|
|
@ -602,12 +602,12 @@ NOTICE: executing the command locally: SELECT count(*) AS count FROM local_shar
|
||||||
|
|
||||||
TRUNCATE distributed_table CASCADE;
|
TRUNCATE distributed_table CASCADE;
|
||||||
NOTICE: truncate cascades to table "second_distributed_table"
|
NOTICE: truncate cascades to table "second_distributed_table"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_1470001 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_xxxxx CASCADE
|
||||||
NOTICE: truncate cascades to table "second_distributed_table_1470005"
|
NOTICE: truncate cascades to table "second_distributed_table_xxxxx"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_1470003 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_xxxxx CASCADE
|
||||||
NOTICE: truncate cascades to table "second_distributed_table_1470007"
|
NOTICE: truncate cascades to table "second_distributed_table_xxxxx"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_1470005 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_1470007 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_xxxxx CASCADE
|
||||||
ROLLBACK;
|
ROLLBACK;
|
||||||
-- a local query is followed by a command that cannot be executed locally
|
-- a local query is followed by a command that cannot be executed locally
|
||||||
BEGIN;
|
BEGIN;
|
||||||
|
@ -901,17 +901,17 @@ WHERE
|
||||||
|
|
||||||
-- get ready for the next commands
|
-- get ready for the next commands
|
||||||
TRUNCATE reference_table, distributed_table, second_distributed_table;
|
TRUNCATE reference_table, distributed_table, second_distributed_table;
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.reference_table_1470000 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.reference_table_xxxxx CASCADE
|
||||||
NOTICE: truncate cascades to table "distributed_table_1470001"
|
NOTICE: truncate cascades to table "distributed_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "distributed_table_1470003"
|
NOTICE: truncate cascades to table "distributed_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "second_distributed_table_1470005"
|
NOTICE: truncate cascades to table "second_distributed_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "second_distributed_table_1470007"
|
NOTICE: truncate cascades to table "second_distributed_table_xxxxx"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_1470001 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_xxxxx CASCADE
|
||||||
NOTICE: truncate cascades to table "second_distributed_table_1470005"
|
NOTICE: truncate cascades to table "second_distributed_table_xxxxx"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_1470003 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_xxxxx CASCADE
|
||||||
NOTICE: truncate cascades to table "second_distributed_table_1470007"
|
NOTICE: truncate cascades to table "second_distributed_table_xxxxx"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_1470005 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_1470007 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_xxxxx CASCADE
|
||||||
-- local execution of returning of reference tables
|
-- local execution of returning of reference tables
|
||||||
INSERT INTO reference_table VALUES (1),(2),(3),(4),(5),(6) RETURNING *;
|
INSERT INTO reference_table VALUES (1),(2),(3),(4),(5),(6) RETURNING *;
|
||||||
NOTICE: executing the command locally: INSERT INTO local_shard_execution.reference_table_1470000 AS citus_table_alias (key) VALUES (1), (2), (3), (4), (5), (6) RETURNING citus_table_alias.key
|
NOTICE: executing the command locally: INSERT INTO local_shard_execution.reference_table_1470000 AS citus_table_alias (key) VALUES (1), (2), (3), (4), (5), (6) RETURNING citus_table_alias.key
|
||||||
|
@ -1337,17 +1337,17 @@ ROLLBACK;
|
||||||
TRUNCATE reference_table CASCADE;
|
TRUNCATE reference_table CASCADE;
|
||||||
NOTICE: truncate cascades to table "distributed_table"
|
NOTICE: truncate cascades to table "distributed_table"
|
||||||
NOTICE: truncate cascades to table "second_distributed_table"
|
NOTICE: truncate cascades to table "second_distributed_table"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.reference_table_1470000 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.reference_table_xxxxx CASCADE
|
||||||
NOTICE: truncate cascades to table "distributed_table_1470001"
|
NOTICE: truncate cascades to table "distributed_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "distributed_table_1470003"
|
NOTICE: truncate cascades to table "distributed_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "second_distributed_table_1470005"
|
NOTICE: truncate cascades to table "second_distributed_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "second_distributed_table_1470007"
|
NOTICE: truncate cascades to table "second_distributed_table_xxxxx"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_1470001 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_xxxxx CASCADE
|
||||||
NOTICE: truncate cascades to table "second_distributed_table_1470005"
|
NOTICE: truncate cascades to table "second_distributed_table_xxxxx"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_1470003 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_xxxxx CASCADE
|
||||||
NOTICE: truncate cascades to table "second_distributed_table_1470007"
|
NOTICE: truncate cascades to table "second_distributed_table_xxxxx"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_1470005 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_1470007 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_xxxxx CASCADE
|
||||||
INSERT INTO reference_table SELECT i FROM generate_series(500, 600) i;
|
INSERT INTO reference_table SELECT i FROM generate_series(500, 600) i;
|
||||||
INSERT INTO distributed_table SELECT i, i::text, i % 10 + 25 FROM generate_series(500, 600) i;
|
INSERT INTO distributed_table SELECT i, i::text, i % 10 + 25 FROM generate_series(500, 600) i;
|
||||||
-- show that both local, and mixed local-distributed executions
|
-- show that both local, and mixed local-distributed executions
|
||||||
|
@ -1617,17 +1617,17 @@ COMMIT;
|
||||||
TRUNCATE reference_table CASCADE;
|
TRUNCATE reference_table CASCADE;
|
||||||
NOTICE: truncate cascades to table "distributed_table"
|
NOTICE: truncate cascades to table "distributed_table"
|
||||||
NOTICE: truncate cascades to table "second_distributed_table"
|
NOTICE: truncate cascades to table "second_distributed_table"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.reference_table_1470000 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.reference_table_xxxxx CASCADE
|
||||||
NOTICE: truncate cascades to table "distributed_table_1470001"
|
NOTICE: truncate cascades to table "distributed_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "distributed_table_1470003"
|
NOTICE: truncate cascades to table "distributed_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "second_distributed_table_1470005"
|
NOTICE: truncate cascades to table "second_distributed_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "second_distributed_table_1470007"
|
NOTICE: truncate cascades to table "second_distributed_table_xxxxx"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_1470001 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_xxxxx CASCADE
|
||||||
NOTICE: truncate cascades to table "second_distributed_table_1470005"
|
NOTICE: truncate cascades to table "second_distributed_table_xxxxx"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_1470003 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.distributed_table_xxxxx CASCADE
|
||||||
NOTICE: truncate cascades to table "second_distributed_table_1470007"
|
NOTICE: truncate cascades to table "second_distributed_table_xxxxx"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_1470005 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_1470007 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_shard_execution.second_distributed_table_xxxxx CASCADE
|
||||||
-- load some data on a remote shard
|
-- load some data on a remote shard
|
||||||
INSERT INTO reference_table (key) VALUES (2);
|
INSERT INTO reference_table (key) VALUES (2);
|
||||||
NOTICE: executing the command locally: INSERT INTO local_shard_execution.reference_table_1470000 (key) VALUES (2)
|
NOTICE: executing the command locally: INSERT INTO local_shard_execution.reference_table_1470000 (key) VALUES (2)
|
||||||
|
|
|
@ -51,29 +51,29 @@ INSERT INTO dist_table VALUES(1);
|
||||||
-- case that coordinator have some local distributed table shards.
|
-- case that coordinator have some local distributed table shards.
|
||||||
TRUNCATE ref_table CASCADE;
|
TRUNCATE ref_table CASCADE;
|
||||||
NOTICE: truncate cascades to table "dist_table"
|
NOTICE: truncate cascades to table "dist_table"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.ref_table_1500000 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.ref_table_xxxxx CASCADE
|
||||||
NOTICE: truncate cascades to table "dist_table_1500001"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500004"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500007"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500010"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500013"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500016"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500019"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500022"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500025"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500028"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500031"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500001 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500004 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500007 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500010 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500013 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500016 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500019 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500022 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500025 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500028 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500031 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
-- show that TRUNCATE is successfull
|
-- show that TRUNCATE is successfull
|
||||||
SELECT COUNT(*) FROM ref_table, dist_table;
|
SELECT COUNT(*) FROM ref_table, dist_table;
|
||||||
count
|
count
|
||||||
|
@ -96,17 +96,17 @@ NOTICE: executing the command locally: SELECT count(*) AS count FROM local_comm
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
TRUNCATE dist_table;
|
TRUNCATE dist_table;
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500001 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500004 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500007 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500010 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500013 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500016 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500019 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500022 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500025 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500028 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500031 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
COMMIT;
|
COMMIT;
|
||||||
-- show that TRUNCATE is successfull
|
-- show that TRUNCATE is successfull
|
||||||
SELECT COUNT(*) FROM dist_table;
|
SELECT COUNT(*) FROM dist_table;
|
||||||
|
@ -193,35 +193,65 @@ BEGIN;
|
||||||
NOTICE: truncate cascades to table "dist_table"
|
NOTICE: truncate cascades to table "dist_table"
|
||||||
ERROR: cannot execute DDL on reference table "ref_table" because there was a parallel SELECT access to distributed table "dist_table" in the same transaction
|
ERROR: cannot execute DDL on reference table "ref_table" because there was a parallel SELECT access to distributed table "dist_table" in the same transaction
|
||||||
COMMIT;
|
COMMIT;
|
||||||
|
-- as we do not support local ANALYZE execution yet, below block would error out
|
||||||
|
BEGIN;
|
||||||
|
TRUNCATE ref_table CASCADE;
|
||||||
|
NOTICE: truncate cascades to table "dist_table"
|
||||||
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.ref_table_xxxxx CASCADE
|
||||||
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
|
ANALYZE ref_table;
|
||||||
|
ERROR: cannot execute command because a local execution has accessed a placement in the transaction
|
||||||
|
COMMIT;
|
||||||
-- insert some data
|
-- insert some data
|
||||||
INSERT INTO ref_table VALUES(7);
|
INSERT INTO ref_table VALUES(7);
|
||||||
NOTICE: executing the command locally: INSERT INTO local_commands_test_schema.ref_table_1500000 (a) VALUES (7)
|
NOTICE: executing the command locally: INSERT INTO local_commands_test_schema.ref_table_1500000 (a) VALUES (7)
|
||||||
INSERT INTO dist_table VALUES(7);
|
INSERT INTO dist_table VALUES(7);
|
||||||
-- we can TRUNCATE those two tables within the same command
|
-- we can TRUNCATE those two tables within the same command
|
||||||
TRUNCATE ref_table, dist_table;
|
TRUNCATE ref_table, dist_table;
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.ref_table_1500000 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.ref_table_xxxxx CASCADE
|
||||||
NOTICE: truncate cascades to table "dist_table_1500001"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500004"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500007"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500010"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500013"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500016"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500019"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500022"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500025"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500028"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: truncate cascades to table "dist_table_1500031"
|
NOTICE: truncate cascades to table "dist_table_xxxxx"
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500001 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500004 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500007 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500010 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500013 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500016 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500019 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500022 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500025 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500028 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_1500031 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
-- show that TRUNCATE is successfull
|
-- show that TRUNCATE is successfull
|
||||||
SELECT COUNT(*) FROM ref_table, dist_table;
|
SELECT COUNT(*) FROM ref_table, dist_table;
|
||||||
count
|
count
|
||||||
|
@ -239,7 +269,7 @@ ERROR: cannot drop table ref_table because other objects depend on it
|
||||||
DROP TABLE ref_table, dist_table;
|
DROP TABLE ref_table, dist_table;
|
||||||
-- drop the other standalone table locally
|
-- drop the other standalone table locally
|
||||||
DROP TABLE ref_table_1;
|
DROP TABLE ref_table_1;
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.ref_table_1_1500033 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.ref_table_1_xxxxx CASCADE
|
||||||
-- show that DROP commands are successfull
|
-- show that DROP commands are successfull
|
||||||
SELECT tablename FROM pg_tables where schemaname='local_commands_test_schema' ORDER BY tablename;
|
SELECT tablename FROM pg_tables where schemaname='local_commands_test_schema' ORDER BY tablename;
|
||||||
tablename
|
tablename
|
||||||
|
@ -264,7 +294,7 @@ NOTICE: executing the command locally: SELECT count(*) AS count FROM local_comm
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
DROP TABLE ref_table;
|
DROP TABLE ref_table;
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.ref_table_1500034 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.ref_table_xxxxx CASCADE
|
||||||
COMMIT;
|
COMMIT;
|
||||||
CREATE TABLE ref_table (a int primary key);
|
CREATE TABLE ref_table (a int primary key);
|
||||||
SELECT create_reference_table('ref_table');
|
SELECT create_reference_table('ref_table');
|
||||||
|
@ -356,17 +386,17 @@ NOTICE: executing the command locally: SELECT count(*) AS count FROM local_comm
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
DROP TABLE dist_table CASCADE;
|
DROP TABLE dist_table CASCADE;
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500100 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500103 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500106 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500109 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500112 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500115 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500118 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500121 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500124 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500127 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500130 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
ROLLBACK;
|
ROLLBACK;
|
||||||
-- show that DROP command is rollback'd successfully (should print 1)
|
-- show that DROP command is rollback'd successfully (should print 1)
|
||||||
SELECT 1 FROM pg_tables where tablename='dist_table';
|
SELECT 1 FROM pg_tables where tablename='dist_table';
|
||||||
|
@ -449,19 +479,19 @@ NOTICE: executing the command locally: SELECT count(*) AS count FROM ((local_co
|
||||||
|
|
||||||
-- observe DROP on a self-referencing table also works
|
-- observe DROP on a self-referencing table also works
|
||||||
DROP TABLE ref_table_1, ref_table, dist_table;
|
DROP TABLE ref_table_1, ref_table, dist_table;
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500100 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500103 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500106 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500109 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500112 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500115 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500118 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500121 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500124 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500127 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_1500130 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.dist_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.ref_table_1500035 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.ref_table_xxxxx CASCADE
|
||||||
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.ref_table_1_1500132 CASCADE
|
NOTICE: executing the command locally: DROP TABLE IF EXISTS local_commands_test_schema.ref_table_1_xxxxx CASCADE
|
||||||
-- show that DROP command is successfull
|
-- show that DROP command is successfull
|
||||||
SELECT tablename FROM pg_tables where schemaname='local_commands_test_schema' ORDER BY tablename;
|
SELECT tablename FROM pg_tables where schemaname='local_commands_test_schema' ORDER BY tablename;
|
||||||
tablename
|
tablename
|
||||||
|
|
|
@ -129,7 +129,7 @@ DEBUG: Plan is router executable
|
||||||
NOTICE: executing the command locally: INSERT INTO mx_add_coordinator.ref_7000000 (a) VALUES (1)
|
NOTICE: executing the command locally: INSERT INTO mx_add_coordinator.ref_7000000 (a) VALUES (1)
|
||||||
-- get it ready for the next executions
|
-- get it ready for the next executions
|
||||||
TRUNCATE ref;
|
TRUNCATE ref;
|
||||||
NOTICE: executing the command locally: TRUNCATE TABLE mx_add_coordinator.ref_7000000 CASCADE
|
NOTICE: executing the command locally: TRUNCATE TABLE mx_add_coordinator.ref_xxxxx CASCADE
|
||||||
-- test that changes from a metadata node is reflected in the coordinator placement
|
-- test that changes from a metadata node is reflected in the coordinator placement
|
||||||
\c - - - :worker_1_port
|
\c - - - :worker_1_port
|
||||||
SET search_path TO mx_add_coordinator,public;
|
SET search_path TO mx_add_coordinator,public;
|
||||||
|
|
|
@ -109,6 +109,12 @@ BEGIN;
|
||||||
TRUNCATE ref_table CASCADE;
|
TRUNCATE ref_table CASCADE;
|
||||||
COMMIT;
|
COMMIT;
|
||||||
|
|
||||||
|
-- as we do not support local ANALYZE execution yet, below block would error out
|
||||||
|
BEGIN;
|
||||||
|
TRUNCATE ref_table CASCADE;
|
||||||
|
ANALYZE ref_table;
|
||||||
|
COMMIT;
|
||||||
|
|
||||||
-- insert some data
|
-- insert some data
|
||||||
INSERT INTO ref_table VALUES(7);
|
INSERT INTO ref_table VALUES(7);
|
||||||
INSERT INTO dist_table VALUES(7);
|
INSERT INTO dist_table VALUES(7);
|
||||||
|
|
Loading…
Reference in New Issue