mirror of https://github.com/citusdata/citus.git
181 lines
5.3 KiB
Plaintext
181 lines
5.3 KiB
Plaintext
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 990000;
|
|
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 990000;
|
|
-- ===================================================================
|
|
-- test utility statement functionality
|
|
-- ===================================================================
|
|
CREATE TABLE sharded_table ( name text, id bigint );
|
|
SELECT master_create_distributed_table('sharded_table', 'id', 'hash');
|
|
master_create_distributed_table
|
|
---------------------------------
|
|
|
|
(1 row)
|
|
|
|
SELECT master_create_worker_shards('sharded_table', 2, 1);
|
|
master_create_worker_shards
|
|
-----------------------------
|
|
|
|
(1 row)
|
|
|
|
-- COPY out is supported with distributed tables
|
|
COPY sharded_table TO STDOUT;
|
|
COPY (SELECT COUNT(*) FROM sharded_table) TO STDOUT;
|
|
0
|
|
-- cursors may not involve distributed tables
|
|
DECLARE all_sharded_rows CURSOR FOR SELECT * FROM sharded_table;
|
|
ERROR: DECLARE CURSOR can only be used in transaction blocks
|
|
-- verify PREPARE functionality
|
|
PREPARE sharded_insert AS INSERT INTO sharded_table VALUES ('adam', 1);
|
|
PREPARE sharded_update AS UPDATE sharded_table SET name = 'bob' WHERE id = 1;
|
|
PREPARE sharded_delete AS DELETE FROM sharded_table WHERE id = 1;
|
|
PREPARE sharded_query AS SELECT name FROM sharded_table WHERE id = 1;
|
|
EXECUTE sharded_query;
|
|
name
|
|
------
|
|
(0 rows)
|
|
|
|
EXECUTE sharded_insert;
|
|
EXECUTE sharded_query;
|
|
name
|
|
------
|
|
adam
|
|
(1 row)
|
|
|
|
EXECUTE sharded_update;
|
|
EXECUTE sharded_query;
|
|
name
|
|
------
|
|
bob
|
|
(1 row)
|
|
|
|
EXECUTE sharded_delete;
|
|
EXECUTE sharded_query;
|
|
name
|
|
------
|
|
(0 rows)
|
|
|
|
-- try to drop shards with where clause
|
|
SELECT master_apply_delete_command('DELETE FROM sharded_table WHERE id > 0');
|
|
ERROR: cannot delete from distributed table
|
|
DETAIL: Delete statements on hash-partitioned tables with where clause is not supported
|
|
-- drop all shards
|
|
SELECT master_apply_delete_command('DELETE FROM sharded_table');
|
|
master_apply_delete_command
|
|
-----------------------------
|
|
2
|
|
(1 row)
|
|
|
|
-- drop table
|
|
DROP TABLE sharded_table;
|
|
-- VACUUM tests
|
|
-- create a table with a single shard (for convenience)
|
|
CREATE TABLE dustbunnies (id integer, name text);
|
|
SELECT master_create_distributed_table('dustbunnies', 'id', 'hash');
|
|
master_create_distributed_table
|
|
---------------------------------
|
|
|
|
(1 row)
|
|
|
|
SELECT master_create_worker_shards('dustbunnies', 1, 2);
|
|
master_create_worker_shards
|
|
-----------------------------
|
|
|
|
(1 row)
|
|
|
|
-- add some data to the distributed table
|
|
\copy dustbunnies from stdin with csv
|
|
-- run VACUUM and ANALYZE against the table on the master
|
|
VACUUM dustbunnies;
|
|
ANALYZE dustbunnies;
|
|
-- verify that the VACUUM and ANALYZE ran
|
|
\c - - - :worker_1_port
|
|
SELECT pg_sleep(.500);
|
|
pg_sleep
|
|
----------
|
|
|
|
(1 row)
|
|
|
|
SELECT pg_stat_get_vacuum_count('dustbunnies_990002'::regclass);
|
|
pg_stat_get_vacuum_count
|
|
--------------------------
|
|
1
|
|
(1 row)
|
|
|
|
SELECT pg_stat_get_analyze_count('dustbunnies_990002'::regclass);
|
|
pg_stat_get_analyze_count
|
|
---------------------------
|
|
1
|
|
(1 row)
|
|
|
|
-- get file node to verify VACUUM FULL
|
|
SELECT relfilenode AS oldnode FROM pg_class WHERE oid='dustbunnies_990002'::regclass
|
|
\gset
|
|
-- send a VACUUM FULL and a VACUUM ANALYZE
|
|
\c - - - :master_port
|
|
VACUUM (FULL) dustbunnies;
|
|
VACUUM ANALYZE dustbunnies;
|
|
-- verify that relfilenode changed
|
|
\c - - - :worker_1_port
|
|
SELECT relfilenode != :oldnode AS table_rewritten FROM pg_class
|
|
WHERE oid='dustbunnies_990002'::regclass;
|
|
table_rewritten
|
|
-----------------
|
|
t
|
|
(1 row)
|
|
|
|
-- verify the VACUUM ANALYZE incremented both vacuum and analyze counts
|
|
SELECT pg_sleep(.500);
|
|
pg_sleep
|
|
----------
|
|
|
|
(1 row)
|
|
|
|
SELECT pg_stat_get_vacuum_count('dustbunnies_990002'::regclass);
|
|
pg_stat_get_vacuum_count
|
|
--------------------------
|
|
2
|
|
(1 row)
|
|
|
|
SELECT pg_stat_get_analyze_count('dustbunnies_990002'::regclass);
|
|
pg_stat_get_analyze_count
|
|
---------------------------
|
|
2
|
|
(1 row)
|
|
|
|
-- disable auto-VACUUM for next test
|
|
ALTER TABLE dustbunnies_990002 SET (autovacuum_enabled = false);
|
|
SELECT relfrozenxid AS frozenxid FROM pg_class WHERE oid='dustbunnies_990002'::regclass
|
|
\gset
|
|
-- send a VACUUM FREEZE after adding a new row
|
|
\c - - - :master_port
|
|
INSERT INTO dustbunnies VALUES (5, 'peter');
|
|
VACUUM (FREEZE) dustbunnies;
|
|
-- verify that relfrozenxid increased
|
|
\c - - - :worker_1_port
|
|
SELECT relfrozenxid::text::integer > :frozenxid AS frozen_performed FROM pg_class
|
|
WHERE oid='dustbunnies_990002'::regclass;
|
|
frozen_performed
|
|
------------------
|
|
t
|
|
(1 row)
|
|
|
|
\c - - - :master_port
|
|
-- verify warning for unqualified VACUUM
|
|
VACUUM;
|
|
WARNING: not propagating VACUUM command to worker nodes
|
|
HINT: Provide a specific table in order to VACUUM distributed tables.
|
|
-- and warning when using targeted VACUUM without DDL propagation
|
|
SET citus.enable_ddl_propagation to false;
|
|
VACUUM dustbunnies;
|
|
WARNING: not propagating VACUUM command to worker nodes
|
|
HINT: Set citus.enable_ddl_propagation to true in order to send targeted VACUUM commands to worker nodes.
|
|
SET citus.enable_ddl_propagation to DEFAULT;
|
|
-- verify error messages for unsupported options
|
|
VACUUM (ANALYZE) dustbunnies (id);
|
|
ERROR: specifying a column list is currently unsupported in distributed VACUUM commands
|
|
ANALYZE dustbunnies (id);
|
|
ERROR: specifying a column list is currently unsupported in distributed ANALYZE commands
|
|
-- TODO: support VERBOSE
|
|
-- VACUUM VERBOSE dustbunnies;
|
|
-- VACUUM (FULL, VERBOSE) dustbunnies;
|
|
-- ANALYZE VERBOSE dustbunnies;
|