mirror of https://github.com/citusdata/citus.git
Merge pull request #2845 from citusdata/squash_migrations_56
Squash migrations for versions 5/6, don't use WITH OIDSpull/2852/head
Hadi Moshayedi
GitHub
commit
cd2905ec23
|
|
@ -1,7 +0,0 @@
|
||||||
/* citus--5.0--5.0-1.sql */
|
|
||||||
|
|
||||||
ALTER FUNCTION pg_catalog.citus_drop_trigger() SECURITY DEFINER;
|
|
||||||
|
|
||||||
GRANT SELECT ON pg_catalog.pg_dist_partition TO public;
|
|
||||||
GRANT SELECT ON pg_catalog.pg_dist_shard TO public;
|
|
||||||
GRANT SELECT ON pg_catalog.pg_dist_shard_placement TO public;
|
|
||||||
|
|
@ -1,8 +0,0 @@
|
||||||
/* citus--5.0-1--5.0-2.sql */
|
|
||||||
|
|
||||||
CREATE FUNCTION master_update_shard_statistics(shard_id bigint)
|
|
||||||
RETURNS bigint
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_update_shard_statistics$$;
|
|
||||||
COMMENT ON FUNCTION master_update_shard_statistics(bigint)
|
|
||||||
IS 'updates shard statistics and returns the updated shard size';
|
|
||||||
|
|
@ -1,3 +0,0 @@
|
||||||
/* citus--5.0-2--5.1-1.sql */
|
|
||||||
|
|
||||||
/* empty, but required to update the extension version */
|
|
||||||
|
|
@ -1,389 +0,0 @@
|
||||||
/* citus.sql */
|
|
||||||
|
|
||||||
-- complain if script is sourced in psql, rather than via CREATE EXTENSION
|
|
||||||
\echo Use "CREATE EXTENSION citus" to load this file. \quit
|
|
||||||
|
|
||||||
CREATE SCHEMA citus;
|
|
||||||
|
|
||||||
-- Ensure CREATE EXTENSION is not run against an old citus data
|
|
||||||
-- directory, we're not compatible (due to the builtin functions/tables)
|
|
||||||
DO $$
|
|
||||||
BEGIN
|
|
||||||
IF EXISTS(SELECT * FROM pg_proc WHERE proname = 'worker_apply_shard_ddl_command') THEN
|
|
||||||
RAISE 'cannot install citus extension in Citus 4 data directory';
|
|
||||||
END IF;
|
|
||||||
END;
|
|
||||||
$$;
|
|
||||||
|
|
||||||
/*****************************************************************************
|
|
||||||
* Enable SSL to encrypt all trafic by default
|
|
||||||
*****************************************************************************/
|
|
||||||
-- create temporary UDF that has the power to change settings within postgres and drop it
|
|
||||||
-- after ssl has been setup.
|
|
||||||
CREATE FUNCTION citus_setup_ssl()
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$citus_setup_ssl$$;
|
|
||||||
|
|
||||||
DO LANGUAGE plpgsql
|
|
||||||
$$
|
|
||||||
BEGIN
|
|
||||||
-- setup ssl when postgres is OpenSSL-enabled
|
|
||||||
IF current_setting('ssl_ciphers') != 'none' THEN
|
|
||||||
PERFORM citus_setup_ssl();
|
|
||||||
END IF;
|
|
||||||
END;
|
|
||||||
$$;
|
|
||||||
|
|
||||||
DROP FUNCTION citus_setup_ssl();
|
|
||||||
|
|
||||||
/*****************************************************************************
|
|
||||||
* Citus data types
|
|
||||||
*****************************************************************************/
|
|
||||||
CREATE TYPE citus.distribution_type AS ENUM (
|
|
||||||
'hash',
|
|
||||||
'range',
|
|
||||||
'append'
|
|
||||||
);
|
|
||||||
|
|
||||||
|
|
||||||
/*****************************************************************************
|
|
||||||
* Citus tables & corresponding indexes
|
|
||||||
*****************************************************************************/
|
|
||||||
CREATE TABLE citus.pg_dist_partition(
|
|
||||||
logicalrelid Oid NOT NULL, /* type changed to regclass as of version 6.0-1 */
|
|
||||||
partmethod "char" NOT NULL,
|
|
||||||
partkey text NOT NULL
|
|
||||||
);
|
|
||||||
/* SELECT granted to PUBLIC in upgrade script */
|
|
||||||
CREATE UNIQUE INDEX pg_dist_partition_logical_relid_index
|
|
||||||
ON citus.pg_dist_partition using btree(logicalrelid);
|
|
||||||
ALTER TABLE citus.pg_dist_partition SET SCHEMA pg_catalog;
|
|
||||||
|
|
||||||
CREATE TABLE citus.pg_dist_shard(
|
|
||||||
logicalrelid oid NOT NULL, /* type changed to regclass as of version 6.0-1 */
|
|
||||||
shardid int8 NOT NULL,
|
|
||||||
shardstorage "char" NOT NULL,
|
|
||||||
shardalias text,
|
|
||||||
shardminvalue text,
|
|
||||||
shardmaxvalue text
|
|
||||||
);
|
|
||||||
/* SELECT granted to PUBLIC in upgrade script */
|
|
||||||
CREATE UNIQUE INDEX pg_dist_shard_shardid_index
|
|
||||||
ON citus.pg_dist_shard using btree(shardid);
|
|
||||||
CREATE INDEX pg_dist_shard_logical_relid_index
|
|
||||||
ON citus.pg_dist_shard using btree(logicalrelid);
|
|
||||||
ALTER TABLE citus.pg_dist_shard SET SCHEMA pg_catalog;
|
|
||||||
|
|
||||||
CREATE TABLE citus.pg_dist_shard_placement(
|
|
||||||
shardid int8 NOT NULL,
|
|
||||||
shardstate int4 NOT NULL,
|
|
||||||
shardlength int8 NOT NULL,
|
|
||||||
nodename text NOT NULL,
|
|
||||||
nodeport int8 NOT NULL
|
|
||||||
) WITH oids;
|
|
||||||
/* SELECT granted to PUBLIC in upgrade script */
|
|
||||||
CREATE UNIQUE INDEX pg_dist_shard_placement_oid_index
|
|
||||||
ON citus.pg_dist_shard_placement using btree(oid);
|
|
||||||
CREATE INDEX pg_dist_shard_placement_shardid_index
|
|
||||||
ON citus.pg_dist_shard_placement using btree(shardid);
|
|
||||||
CREATE INDEX pg_dist_shard_placement_nodeid_index
|
|
||||||
ON citus.pg_dist_shard_placement using btree(nodename, nodeport);
|
|
||||||
ALTER TABLE citus.pg_dist_shard_placement SET SCHEMA pg_catalog;
|
|
||||||
|
|
||||||
|
|
||||||
/*****************************************************************************
|
|
||||||
* Citus sequences
|
|
||||||
*****************************************************************************/
|
|
||||||
|
|
||||||
/*
|
|
||||||
* Unternal sequence to generate 64-bit shard ids. These identifiers are then
|
|
||||||
* used to identify shards in the distributed database.
|
|
||||||
*/
|
|
||||||
CREATE SEQUENCE citus.pg_dist_shardid_seq
|
|
||||||
MINVALUE 102008
|
|
||||||
NO CYCLE;
|
|
||||||
ALTER SEQUENCE citus.pg_dist_shardid_seq SET SCHEMA pg_catalog;
|
|
||||||
|
|
||||||
/*
|
|
||||||
* internal sequence to generate 32-bit jobIds. These identifiers are then
|
|
||||||
* used to identify jobs in the distributed database; and they wrap at 32-bits
|
|
||||||
* to allow for slave nodes to independently execute their distributed jobs.
|
|
||||||
*/
|
|
||||||
CREATE SEQUENCE citus.pg_dist_jobid_seq
|
|
||||||
MINVALUE 2 /* first jobId reserved for clean up jobs */
|
|
||||||
MAXVALUE 4294967296;
|
|
||||||
ALTER SEQUENCE citus.pg_dist_jobid_seq SET SCHEMA pg_catalog;
|
|
||||||
|
|
||||||
|
|
||||||
/*****************************************************************************
|
|
||||||
* Citus functions
|
|
||||||
*****************************************************************************/
|
|
||||||
|
|
||||||
/* For backward compatibility and ease of use create functions et al. in pg_catalog */
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
/* master_* functions */
|
|
||||||
|
|
||||||
CREATE FUNCTION master_get_table_metadata(relation_name text, OUT logical_relid oid,
|
|
||||||
OUT part_storage_type "char",
|
|
||||||
OUT part_method "char", OUT part_key text,
|
|
||||||
OUT part_replica_count integer,
|
|
||||||
OUT part_max_size bigint,
|
|
||||||
OUT part_placement_policy integer)
|
|
||||||
RETURNS record
|
|
||||||
LANGUAGE C STABLE STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_get_table_metadata$$;
|
|
||||||
COMMENT ON FUNCTION master_get_table_metadata(relation_name text)
|
|
||||||
IS 'fetch metadata values for the table';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_get_table_ddl_events(text)
|
|
||||||
RETURNS SETOF text
|
|
||||||
LANGUAGE C STRICT ROWS 100
|
|
||||||
AS 'MODULE_PATHNAME', $$master_get_table_ddl_events$$;
|
|
||||||
COMMENT ON FUNCTION master_get_table_ddl_events(text)
|
|
||||||
IS 'fetch set of ddl statements for the table';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_get_new_shardid()
|
|
||||||
RETURNS bigint
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_get_new_shardid$$;
|
|
||||||
COMMENT ON FUNCTION master_get_new_shardid()
|
|
||||||
IS 'fetch unique shardId';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_create_empty_shard(text)
|
|
||||||
RETURNS bigint
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_create_empty_shard$$;
|
|
||||||
COMMENT ON FUNCTION master_create_empty_shard(text)
|
|
||||||
IS 'create an empty shard and shard placements for the table';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_append_table_to_shard(bigint, text, text, integer)
|
|
||||||
RETURNS real
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_append_table_to_shard$$;
|
|
||||||
COMMENT ON FUNCTION master_append_table_to_shard(bigint, text, text, integer)
|
|
||||||
IS 'append given table to all shard placements and update metadata';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_drop_all_shards(logicalrelid regclass,
|
|
||||||
schema_name text,
|
|
||||||
table_name text)
|
|
||||||
RETURNS integer
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_drop_all_shards$$;
|
|
||||||
COMMENT ON FUNCTION master_drop_all_shards(regclass, text, text)
|
|
||||||
IS 'drop all shards in a relation and update metadata';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_apply_delete_command(text)
|
|
||||||
RETURNS integer
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_apply_delete_command$$;
|
|
||||||
COMMENT ON FUNCTION master_apply_delete_command(text)
|
|
||||||
IS 'drop shards matching delete criteria and update metadata';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_get_active_worker_nodes(OUT node_name text, OUT node_port bigint)
|
|
||||||
RETURNS SETOF record
|
|
||||||
LANGUAGE C STRICT ROWS 100
|
|
||||||
AS 'MODULE_PATHNAME', $$master_get_active_worker_nodes$$;
|
|
||||||
COMMENT ON FUNCTION master_get_active_worker_nodes()
|
|
||||||
IS 'fetch set of active worker nodes';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_create_distributed_table(table_name regclass,
|
|
||||||
distribution_column text,
|
|
||||||
distribution_method citus.distribution_type)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_create_distributed_table$$;
|
|
||||||
COMMENT ON FUNCTION master_create_distributed_table(table_name regclass,
|
|
||||||
distribution_column text,
|
|
||||||
distribution_method citus.distribution_type)
|
|
||||||
IS 'define the table distribution functions';
|
|
||||||
|
|
||||||
-- define shard creation function for hash-partitioned tables
|
|
||||||
CREATE FUNCTION master_create_worker_shards(table_name text, shard_count integer,
|
|
||||||
replication_factor integer DEFAULT 2)
|
|
||||||
RETURNS void
|
|
||||||
AS 'MODULE_PATHNAME'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
/* task_tracker_* functions */
|
|
||||||
|
|
||||||
CREATE FUNCTION task_tracker_assign_task(bigint, integer, text)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$task_tracker_assign_task$$;
|
|
||||||
COMMENT ON FUNCTION task_tracker_assign_task(bigint, integer, text)
|
|
||||||
IS 'assign a task to execute';
|
|
||||||
|
|
||||||
CREATE FUNCTION task_tracker_task_status(bigint, integer)
|
|
||||||
RETURNS integer
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$task_tracker_task_status$$;
|
|
||||||
COMMENT ON FUNCTION task_tracker_task_status(bigint, integer)
|
|
||||||
IS 'check an assigned task''s execution status';
|
|
||||||
|
|
||||||
CREATE FUNCTION task_tracker_cleanup_job(bigint)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$task_tracker_cleanup_job$$;
|
|
||||||
COMMENT ON FUNCTION task_tracker_cleanup_job(bigint)
|
|
||||||
IS 'clean up all tasks associated with a job';
|
|
||||||
|
|
||||||
|
|
||||||
/* worker_* functions */
|
|
||||||
|
|
||||||
CREATE FUNCTION worker_fetch_partition_file(bigint, integer, integer, integer, text,
|
|
||||||
integer)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_fetch_partition_file$$;
|
|
||||||
COMMENT ON FUNCTION worker_fetch_partition_file(bigint, integer, integer, integer, text,
|
|
||||||
integer)
|
|
||||||
IS 'fetch partition file from remote node';
|
|
||||||
|
|
||||||
CREATE FUNCTION worker_range_partition_table(bigint, integer, text, text, oid, anyarray)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_range_partition_table$$;
|
|
||||||
COMMENT ON FUNCTION worker_range_partition_table(bigint, integer, text, text, oid,
|
|
||||||
anyarray)
|
|
||||||
IS 'range partition query results';
|
|
||||||
|
|
||||||
CREATE FUNCTION worker_hash_partition_table(bigint, integer, text, text, oid, integer)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_hash_partition_table$$;
|
|
||||||
COMMENT ON FUNCTION worker_hash_partition_table(bigint, integer, text, text, oid,
|
|
||||||
integer)
|
|
||||||
IS 'hash partition query results';
|
|
||||||
|
|
||||||
CREATE FUNCTION worker_merge_files_into_table(bigint, integer, text[], text[])
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_merge_files_into_table$$;
|
|
||||||
COMMENT ON FUNCTION worker_merge_files_into_table(bigint, integer, text[], text[])
|
|
||||||
IS 'merge files into a table';
|
|
||||||
|
|
||||||
CREATE FUNCTION worker_merge_files_and_run_query(bigint, integer, text, text)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_merge_files_and_run_query$$;
|
|
||||||
COMMENT ON FUNCTION worker_merge_files_and_run_query(bigint, integer, text, text)
|
|
||||||
IS 'merge files and run a reduce query on merged files';
|
|
||||||
|
|
||||||
CREATE FUNCTION worker_cleanup_job_schema_cache()
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_cleanup_job_schema_cache$$;
|
|
||||||
COMMENT ON FUNCTION worker_cleanup_job_schema_cache()
|
|
||||||
IS 'cleanup all job schemas in current database';
|
|
||||||
|
|
||||||
CREATE FUNCTION worker_apply_shard_ddl_command(bigint, text)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_apply_shard_ddl_command$$;
|
|
||||||
COMMENT ON FUNCTION worker_apply_shard_ddl_command(bigint, text)
|
|
||||||
IS 'extend ddl command with shardId and apply on database';
|
|
||||||
|
|
||||||
CREATE FUNCTION worker_append_table_to_shard(text, text, text, integer)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_append_table_to_shard$$;
|
|
||||||
COMMENT ON FUNCTION worker_append_table_to_shard(text, text, text, integer)
|
|
||||||
IS 'append a regular table''s contents to the shard';
|
|
||||||
|
|
||||||
|
|
||||||
/* trigger functions */
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION citus_drop_trigger()
|
|
||||||
RETURNS event_trigger
|
|
||||||
LANGUAGE plpgsql
|
|
||||||
SET search_path = pg_catalog
|
|
||||||
/* declared as SECURITY DEFINER in upgrade script */
|
|
||||||
AS $cdbdt$
|
|
||||||
DECLARE v_obj record;
|
|
||||||
BEGIN
|
|
||||||
FOR v_obj IN SELECT * FROM pg_event_trigger_dropped_objects() LOOP
|
|
||||||
IF v_obj.object_type NOT IN ('table', 'foreign table') THEN
|
|
||||||
CONTINUE;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
-- nothing to do if not a distributed table
|
|
||||||
IF NOT EXISTS(SELECT * FROM pg_dist_partition WHERE logicalrelid = v_obj.objid) THEN
|
|
||||||
CONTINUE;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
-- ensure all shards are dropped
|
|
||||||
PERFORM master_drop_all_shards(v_obj.objid, v_obj.schema_name, v_obj.object_name);
|
|
||||||
|
|
||||||
-- delete partition entry
|
|
||||||
DELETE FROM pg_dist_partition WHERE logicalrelid = v_obj.objid;
|
|
||||||
|
|
||||||
END LOOP;
|
|
||||||
END;
|
|
||||||
$cdbdt$;
|
|
||||||
COMMENT ON FUNCTION citus_drop_trigger()
|
|
||||||
IS 'perform checks and actions at the end of DROP actions';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_dist_partition_cache_invalidate()
|
|
||||||
RETURNS trigger
|
|
||||||
LANGUAGE C
|
|
||||||
AS 'MODULE_PATHNAME', $$master_dist_partition_cache_invalidate$$;
|
|
||||||
COMMENT ON FUNCTION master_dist_partition_cache_invalidate()
|
|
||||||
IS 'register relcache invalidation for changed rows';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_dist_shard_cache_invalidate()
|
|
||||||
RETURNS trigger
|
|
||||||
LANGUAGE C
|
|
||||||
AS 'MODULE_PATHNAME', $$master_dist_shard_cache_invalidate$$;
|
|
||||||
COMMENT ON FUNCTION master_dist_shard_cache_invalidate()
|
|
||||||
IS 'register relcache invalidation for changed rows';
|
|
||||||
|
|
||||||
|
|
||||||
/* internal functions, not user accessible */
|
|
||||||
|
|
||||||
CREATE FUNCTION citus_extradata_container(INTERNAL)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C
|
|
||||||
AS 'MODULE_PATHNAME', $$citus_extradata_container$$;
|
|
||||||
COMMENT ON FUNCTION pg_catalog.citus_extradata_container(INTERNAL)
|
|
||||||
IS 'placeholder function to store additional data in postgres node trees';
|
|
||||||
|
|
||||||
|
|
||||||
/*****************************************************************************
|
|
||||||
* Citus triggers
|
|
||||||
*****************************************************************************/
|
|
||||||
|
|
||||||
CREATE EVENT TRIGGER citus_cascade_to_partition
|
|
||||||
ON SQL_DROP
|
|
||||||
EXECUTE PROCEDURE citus_drop_trigger();
|
|
||||||
|
|
||||||
CREATE TRIGGER dist_partition_cache_invalidate
|
|
||||||
AFTER INSERT OR UPDATE OR DELETE
|
|
||||||
ON pg_catalog.pg_dist_partition
|
|
||||||
FOR EACH ROW EXECUTE PROCEDURE master_dist_partition_cache_invalidate();
|
|
||||||
|
|
||||||
CREATE TRIGGER dist_shard_cache_invalidate
|
|
||||||
AFTER INSERT OR UPDATE OR DELETE
|
|
||||||
ON pg_catalog.pg_dist_shard
|
|
||||||
FOR EACH ROW EXECUTE PROCEDURE master_dist_shard_cache_invalidate();
|
|
||||||
|
|
||||||
|
|
||||||
/*****************************************************************************
|
|
||||||
* Citus aggregates
|
|
||||||
*****************************************************************************/
|
|
||||||
CREATE AGGREGATE array_cat_agg(anyarray) (SFUNC = array_cat, STYPE = anyarray);
|
|
||||||
COMMENT ON AGGREGATE array_cat_agg(anyarray)
|
|
||||||
IS 'concatenate input arrays into a single array';
|
|
||||||
|
|
||||||
-- define shard repair function
|
|
||||||
CREATE FUNCTION master_copy_shard_placement(shard_id bigint,
|
|
||||||
source_node_name text,
|
|
||||||
source_node_port integer,
|
|
||||||
target_node_name text,
|
|
||||||
target_node_port integer)
|
|
||||||
RETURNS void
|
|
||||||
AS 'MODULE_PATHNAME'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,6 +0,0 @@
|
||||||
CREATE FUNCTION pg_catalog.master_modify_multiple_shards(text)
|
|
||||||
RETURNS integer
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_modify_multiple_shards$$;
|
|
||||||
COMMENT ON FUNCTION master_modify_multiple_shards(text)
|
|
||||||
IS 'push delete and update queries to shards';
|
|
||||||
|
|
@ -1,8 +0,0 @@
|
||||||
DROP FUNCTION IF EXISTS public.master_update_shard_statistics(shard_id bigint);
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.master_update_shard_statistics(shard_id bigint)
|
|
||||||
RETURNS bigint
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_update_shard_statistics$$;
|
|
||||||
COMMENT ON FUNCTION master_update_shard_statistics(bigint)
|
|
||||||
IS 'updates shard statistics and returns the updated shard size';
|
|
||||||
|
|
@ -1,8 +0,0 @@
|
||||||
DROP FUNCTION IF EXISTS pg_catalog.worker_apply_shard_ddl_command(bigint, text);
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.worker_apply_shard_ddl_command(bigint, text, text)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_apply_shard_ddl_command$$;
|
|
||||||
COMMENT ON FUNCTION worker_apply_shard_ddl_command(bigint, text, text)
|
|
||||||
IS 'extend ddl command with shardId and apply on database';
|
|
||||||
|
|
@ -1,17 +0,0 @@
|
||||||
DROP FUNCTION IF EXISTS pg_catalog.worker_fetch_foreign_file(text, bigint, text[], integer[]);
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.worker_fetch_foreign_file(text, text, bigint, text[], integer[])
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_fetch_foreign_file$$;
|
|
||||||
COMMENT ON FUNCTION pg_catalog.worker_fetch_foreign_file(text, text, bigint, text[], integer[])
|
|
||||||
IS 'fetch foreign file from remote node and apply file';
|
|
||||||
|
|
||||||
DROP FUNCTION IF EXISTS pg_catalog.worker_fetch_regular_table(text, bigint, text[], integer[]);
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.worker_fetch_regular_table(text, text, bigint, text[], integer[])
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_fetch_regular_table$$;
|
|
||||||
COMMENT ON FUNCTION pg_catalog.worker_fetch_regular_table(text, text, bigint, text[], integer[])
|
|
||||||
IS 'fetch PostgreSQL table from remote node';
|
|
||||||
|
|
@ -1,26 +0,0 @@
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.worker_apply_shard_ddl_command(bigint, text)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE sql
|
|
||||||
AS $worker_apply_shard_ddl_command$
|
|
||||||
SELECT pg_catalog.worker_apply_shard_ddl_command($1, 'public', $2);
|
|
||||||
$worker_apply_shard_ddl_command$;
|
|
||||||
COMMENT ON FUNCTION worker_apply_shard_ddl_command(bigint, text)
|
|
||||||
IS 'extend ddl command with shardId and apply on database';
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.worker_fetch_foreign_file(text, bigint, text[], integer[])
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE sql
|
|
||||||
AS $worker_fetch_foreign_file$
|
|
||||||
SELECT pg_catalog.worker_fetch_foreign_file('public', $1, $2, $3, $4);
|
|
||||||
$worker_fetch_foreign_file$;
|
|
||||||
COMMENT ON FUNCTION pg_catalog.worker_fetch_foreign_file(text, bigint, text[], integer[])
|
|
||||||
IS 'fetch foreign file from remote node and apply file';
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.worker_fetch_regular_table(text, bigint, text[], integer[])
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE sql
|
|
||||||
AS $worker_fetch_regular_table$
|
|
||||||
SELECT pg_catalog.worker_fetch_regular_table('public', $1, $2, $3, $4);
|
|
||||||
$worker_fetch_regular_table$;
|
|
||||||
COMMENT ON FUNCTION pg_catalog.worker_fetch_regular_table(text, bigint, text[], integer[])
|
|
||||||
IS 'fetch PostgreSQL table from remote node';
|
|
||||||
|
|
@ -1,17 +0,0 @@
|
||||||
DROP FUNCTION IF EXISTS pg_catalog.worker_fetch_foreign_file(text, text, bigint, text[], integer[]);
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.worker_fetch_foreign_file(text, bigint, text[], integer[])
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_fetch_foreign_file$$;
|
|
||||||
COMMENT ON FUNCTION pg_catalog.worker_fetch_foreign_file(text, bigint, text[], integer[])
|
|
||||||
IS 'fetch foreign file from remote node and apply file';
|
|
||||||
|
|
||||||
DROP FUNCTION IF EXISTS pg_catalog.worker_fetch_regular_table(text, text, bigint, text[], integer[]);
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.worker_fetch_regular_table(text, bigint, text[], integer[])
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_fetch_regular_table$$;
|
|
||||||
COMMENT ON FUNCTION pg_catalog.worker_fetch_regular_table(text, bigint, text[], integer[])
|
|
||||||
IS 'fetch PostgreSQL table from remote node';
|
|
||||||
|
|
@ -1,72 +0,0 @@
|
||||||
CREATE FUNCTION pg_catalog.master_drop_sequences(sequence_names text[],
|
|
||||||
node_name text,
|
|
||||||
node_port bigint)
|
|
||||||
RETURNS bool
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_drop_sequences$$;
|
|
||||||
COMMENT ON FUNCTION pg_catalog.master_drop_sequences(text[], text, bigint)
|
|
||||||
IS 'drop specified sequences from a node';
|
|
||||||
|
|
||||||
REVOKE ALL ON FUNCTION pg_catalog.master_drop_sequences(text[], text, bigint) FROM PUBLIC;
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.citus_drop_trigger()
|
|
||||||
RETURNS event_trigger
|
|
||||||
LANGUAGE plpgsql
|
|
||||||
SECURITY DEFINER
|
|
||||||
SET search_path = pg_catalog
|
|
||||||
AS $cdbdt$
|
|
||||||
DECLARE
|
|
||||||
v_obj record;
|
|
||||||
sequence_names text[] := '{}';
|
|
||||||
node_names text[] := '{}';
|
|
||||||
node_ports bigint[] := '{}';
|
|
||||||
node_name text;
|
|
||||||
node_port bigint;
|
|
||||||
BEGIN
|
|
||||||
-- collect set of dropped sequences to drop on workers later
|
|
||||||
SELECT array_agg(object_identity) INTO sequence_names
|
|
||||||
FROM pg_event_trigger_dropped_objects()
|
|
||||||
WHERE object_type = 'sequence';
|
|
||||||
|
|
||||||
-- Must accumulate set of affected nodes before deleting placements, as
|
|
||||||
-- master_drop_all_shards will erase their rows, making it impossible for
|
|
||||||
-- us to know where to drop sequences (which must be dropped after shards,
|
|
||||||
-- since they have default value expressions which depend on sequences).
|
|
||||||
SELECT array_agg(sp.nodename), array_agg(sp.nodeport)
|
|
||||||
INTO node_names, node_ports
|
|
||||||
FROM pg_event_trigger_dropped_objects() AS dobj,
|
|
||||||
pg_dist_shard AS s,
|
|
||||||
pg_dist_shard_placement AS sp
|
|
||||||
WHERE dobj.object_type IN ('table', 'foreign table')
|
|
||||||
AND dobj.objid = s.logicalrelid
|
|
||||||
AND s.shardid = sp.shardid;
|
|
||||||
|
|
||||||
FOR v_obj IN SELECT * FROM pg_event_trigger_dropped_objects() LOOP
|
|
||||||
IF v_obj.object_type NOT IN ('table', 'foreign table') THEN
|
|
||||||
CONTINUE;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
-- nothing to do if not a distributed table
|
|
||||||
IF NOT EXISTS(SELECT * FROM pg_dist_partition WHERE logicalrelid = v_obj.objid) THEN
|
|
||||||
CONTINUE;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
-- ensure all shards are dropped
|
|
||||||
PERFORM master_drop_all_shards(v_obj.objid, v_obj.schema_name, v_obj.object_name);
|
|
||||||
|
|
||||||
-- delete partition entry
|
|
||||||
DELETE FROM pg_dist_partition WHERE logicalrelid = v_obj.objid;
|
|
||||||
END LOOP;
|
|
||||||
|
|
||||||
IF cardinality(sequence_names) = 0 THEN
|
|
||||||
RETURN;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
FOR node_name, node_port IN
|
|
||||||
SELECT DISTINCT name, port
|
|
||||||
FROM unnest(node_names, node_ports) AS nodes(name, port)
|
|
||||||
LOOP
|
|
||||||
PERFORM master_drop_sequences(sequence_names, node_name, node_port);
|
|
||||||
END LOOP;
|
|
||||||
END;
|
|
||||||
$cdbdt$;
|
|
||||||
|
|
@ -1,3 +0,0 @@
|
||||||
/* citus--5.1-8--5.2-1.sql */
|
|
||||||
|
|
||||||
/* empty, but required to update the extension version */
|
|
||||||
|
|
@ -1,28 +0,0 @@
|
||||||
/* citus--5.2-1--5.2-2.sql */
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.citus_truncate_trigger()
|
|
||||||
RETURNS trigger
|
|
||||||
LANGUAGE plpgsql
|
|
||||||
SET search_path = 'pg_catalog'
|
|
||||||
AS $cdbtt$
|
|
||||||
DECLARE
|
|
||||||
partitionType char;
|
|
||||||
commandText text;
|
|
||||||
BEGIN
|
|
||||||
SELECT partmethod INTO partitionType
|
|
||||||
FROM pg_dist_partition WHERE logicalrelid = TG_RELID;
|
|
||||||
IF NOT FOUND THEN
|
|
||||||
RETURN NEW;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
IF (partitionType = 'a') THEN
|
|
||||||
PERFORM master_drop_all_shards(TG_RELID, TG_TABLE_SCHEMA, TG_TABLE_NAME);
|
|
||||||
ELSE
|
|
||||||
SELECT format('TRUNCATE TABLE %I.%I CASCADE', TG_TABLE_SCHEMA, TG_TABLE_NAME)
|
|
||||||
INTO commandText;
|
|
||||||
PERFORM master_modify_multiple_shards(commandText);
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
RETURN NEW;
|
|
||||||
END;
|
|
||||||
$cdbtt$;
|
|
||||||
|
|
@ -1,5 +0,0 @@
|
||||||
/* citus--5.2-2--5.2-3.sql */
|
|
||||||
CREATE OR REPLACE FUNCTION master_expire_table_cache(table_name regclass)
|
|
||||||
RETURNS VOID
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_expire_table_cache$$;
|
|
||||||
|
|
@ -1,7 +0,0 @@
|
||||||
/* citus--5.2-3--5.2-4.sql */
|
|
||||||
|
|
||||||
ALTER TABLE pg_dist_partition ADD COLUMN colocationid BIGINT DEFAULT 0 NOT NULL;
|
|
||||||
|
|
||||||
CREATE INDEX pg_dist_partition_colocationid_index
|
|
||||||
ON pg_dist_partition using btree(colocationid);
|
|
||||||
|
|
||||||
|
|
@ -1,5 +0,0 @@
|
||||||
/* citus--5.2-4--6.0-1.sql */
|
|
||||||
|
|
||||||
/* change logicalrelid type to regclass to allow implicit casts to text */
|
|
||||||
ALTER TABLE pg_catalog.pg_dist_partition ALTER COLUMN logicalrelid TYPE regclass;
|
|
||||||
ALTER TABLE pg_catalog.pg_dist_shard ALTER COLUMN logicalrelid TYPE regclass;
|
|
||||||
|
|
@ -1,9 +0,0 @@
|
||||||
/* citus--6.0-1--6.0-2.sql */
|
|
||||||
|
|
||||||
CREATE FUNCTION pg_catalog.shard_name(object_name regclass, shard_id bigint)
|
|
||||||
RETURNS text
|
|
||||||
LANGUAGE C STABLE
|
|
||||||
AS 'MODULE_PATHNAME', $$shard_name$$;
|
|
||||||
COMMENT ON FUNCTION pg_catalog.shard_name(object_name regclass, shard_id bigint)
|
|
||||||
IS 'returns shard-extended version of object name';
|
|
||||||
|
|
||||||
|
|
@ -1,112 +0,0 @@
|
||||||
/* citus--6.0-10--6.0-11.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE SEQUENCE citus.pg_dist_colocationid_seq
|
|
||||||
MINVALUE 1
|
|
||||||
MAXVALUE 4294967296;
|
|
||||||
|
|
||||||
ALTER SEQUENCE citus.pg_dist_colocationid_seq SET SCHEMA pg_catalog;
|
|
||||||
|
|
||||||
/* add pg_dist_colocation */
|
|
||||||
CREATE TABLE citus.pg_dist_colocation(
|
|
||||||
colocationid int NOT NULL PRIMARY KEY,
|
|
||||||
shardcount int NOT NULL,
|
|
||||||
replicationfactor int NOT NULL,
|
|
||||||
distributioncolumntype oid NOT NULL
|
|
||||||
);
|
|
||||||
|
|
||||||
ALTER TABLE citus.pg_dist_colocation SET SCHEMA pg_catalog;
|
|
||||||
|
|
||||||
CREATE INDEX pg_dist_colocation_configuration_index
|
|
||||||
ON pg_dist_colocation USING btree(shardcount, replicationfactor, distributioncolumntype);
|
|
||||||
|
|
||||||
CREATE FUNCTION create_distributed_table(table_name regclass,
|
|
||||||
distribution_column text,
|
|
||||||
distribution_type citus.distribution_type DEFAULT 'hash')
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$create_distributed_table$$;
|
|
||||||
COMMENT ON FUNCTION create_distributed_table(table_name regclass,
|
|
||||||
distribution_column text,
|
|
||||||
distribution_type citus.distribution_type)
|
|
||||||
IS 'creates a distributed table';
|
|
||||||
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.citus_drop_trigger()
|
|
||||||
RETURNS event_trigger
|
|
||||||
LANGUAGE plpgsql
|
|
||||||
SECURITY DEFINER
|
|
||||||
SET search_path = pg_catalog
|
|
||||||
AS $cdbdt$
|
|
||||||
DECLARE
|
|
||||||
v_obj record;
|
|
||||||
sequence_names text[] := '{}';
|
|
||||||
node_names text[] := '{}';
|
|
||||||
node_ports bigint[] := '{}';
|
|
||||||
node_name text;
|
|
||||||
node_port bigint;
|
|
||||||
table_colocation_id integer;
|
|
||||||
BEGIN
|
|
||||||
-- collect set of dropped sequences to drop on workers later
|
|
||||||
SELECT array_agg(object_identity) INTO sequence_names
|
|
||||||
FROM pg_event_trigger_dropped_objects()
|
|
||||||
WHERE object_type = 'sequence';
|
|
||||||
|
|
||||||
-- Must accumulate set of affected nodes before deleting placements, as
|
|
||||||
-- master_drop_all_shards will erase their rows, making it impossible for
|
|
||||||
-- us to know where to drop sequences (which must be dropped after shards,
|
|
||||||
-- since they have default value expressions which depend on sequences).
|
|
||||||
SELECT array_agg(sp.nodename), array_agg(sp.nodeport)
|
|
||||||
INTO node_names, node_ports
|
|
||||||
FROM pg_event_trigger_dropped_objects() AS dobj,
|
|
||||||
pg_dist_shard AS s,
|
|
||||||
pg_dist_shard_placement AS sp
|
|
||||||
WHERE dobj.object_type IN ('table', 'foreign table')
|
|
||||||
AND dobj.objid = s.logicalrelid
|
|
||||||
AND s.shardid = sp.shardid;
|
|
||||||
|
|
||||||
FOR v_obj IN SELECT * FROM pg_event_trigger_dropped_objects() LOOP
|
|
||||||
IF v_obj.object_type NOT IN ('table', 'foreign table') THEN
|
|
||||||
CONTINUE;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
-- nothing to do if not a distributed table
|
|
||||||
IF NOT EXISTS(SELECT * FROM pg_dist_partition WHERE logicalrelid = v_obj.objid) THEN
|
|
||||||
CONTINUE;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
-- ensure all shards are dropped
|
|
||||||
PERFORM master_drop_all_shards(v_obj.objid, v_obj.schema_name, v_obj.object_name);
|
|
||||||
|
|
||||||
-- get colocation group
|
|
||||||
SELECT colocationid INTO table_colocation_id FROM pg_dist_partition WHERE logicalrelid = v_obj.objid;
|
|
||||||
|
|
||||||
-- delete partition entry
|
|
||||||
DELETE FROM pg_dist_partition WHERE logicalrelid = v_obj.objid;
|
|
||||||
|
|
||||||
-- drop colocation group if all referencing tables are dropped
|
|
||||||
IF NOT EXISTS(SELECT * FROM pg_dist_partition WHERE colocationId = table_colocation_id) THEN
|
|
||||||
DELETE FROM pg_dist_colocation WHERE colocationId = table_colocation_id;
|
|
||||||
END IF;
|
|
||||||
END LOOP;
|
|
||||||
|
|
||||||
IF cardinality(sequence_names) = 0 THEN
|
|
||||||
RETURN;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
FOR node_name, node_port IN
|
|
||||||
SELECT DISTINCT name, port
|
|
||||||
FROM unnest(node_names, node_ports) AS nodes(name, port)
|
|
||||||
LOOP
|
|
||||||
PERFORM master_drop_sequences(sequence_names, node_name, node_port);
|
|
||||||
END LOOP;
|
|
||||||
END;
|
|
||||||
$cdbdt$;
|
|
||||||
|
|
||||||
COMMENT ON FUNCTION citus_drop_trigger()
|
|
||||||
IS 'perform checks and actions at the end of DROP actions';
|
|
||||||
|
|
||||||
ALTER TABLE pg_dist_partition ALTER COLUMN colocationid TYPE integer;
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,12 +0,0 @@
|
||||||
/* citus--6.0-11--6.0-12.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE FUNCTION create_reference_table(table_name regclass)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$create_reference_table$$;
|
|
||||||
COMMENT ON FUNCTION create_reference_table(table_name regclass)
|
|
||||||
IS 'create a distributed reference table';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,16 +0,0 @@
|
||||||
/* citus--6.0-12--6.0-13.sql */
|
|
||||||
|
|
||||||
CREATE FUNCTION pg_catalog.worker_apply_inter_shard_ddl_command(referencing_shard bigint,
|
|
||||||
referencing_schema_name text,
|
|
||||||
referenced_shard bigint,
|
|
||||||
referenced_schema_name text,
|
|
||||||
command text)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_apply_inter_shard_ddl_command$$;
|
|
||||||
COMMENT ON FUNCTION pg_catalog.worker_apply_inter_shard_ddl_command(referencing_shard bigint,
|
|
||||||
referencing_schema_name text,
|
|
||||||
referenced_shard bigint,
|
|
||||||
referenced_schema_name text,
|
|
||||||
command text)
|
|
||||||
IS 'executes inter shard ddl command';
|
|
||||||
|
|
@ -1,25 +0,0 @@
|
||||||
/* citus--6.0-13--6.0-14.sql */
|
|
||||||
|
|
||||||
DO $ff$
|
|
||||||
BEGIN
|
|
||||||
-- fix functions created in wrong namespace
|
|
||||||
ALTER FUNCTION public.recover_prepared_transactions()
|
|
||||||
SET SCHEMA pg_catalog;
|
|
||||||
|
|
||||||
ALTER FUNCTION public.column_name_to_column(table_name regclass, column_name text)
|
|
||||||
SET SCHEMA pg_catalog;
|
|
||||||
|
|
||||||
ALTER FUNCTION public.worker_drop_distributed_table(logicalrelid Oid)
|
|
||||||
SET SCHEMA pg_catalog;
|
|
||||||
|
|
||||||
ALTER FUNCTION public.master_get_new_placementid()
|
|
||||||
SET SCHEMA pg_catalog;
|
|
||||||
|
|
||||||
ALTER FUNCTION public.master_expire_table_cache(table_name regclass)
|
|
||||||
SET SCHEMA pg_catalog;
|
|
||||||
|
|
||||||
-- some installations don't need this corrective, so just skip...
|
|
||||||
EXCEPTION WHEN undefined_function THEN
|
|
||||||
-- do nothing
|
|
||||||
END
|
|
||||||
$ff$;
|
|
||||||
|
|
@ -1,14 +0,0 @@
|
||||||
/* citus--6.0-14--6.0-15.sql */
|
|
||||||
|
|
||||||
|
|
||||||
CREATE FUNCTION pg_catalog.master_dist_placement_cache_invalidate()
|
|
||||||
RETURNS trigger
|
|
||||||
LANGUAGE C
|
|
||||||
AS 'MODULE_PATHNAME', $$master_dist_placement_cache_invalidate$$;
|
|
||||||
COMMENT ON FUNCTION master_dist_placement_cache_invalidate()
|
|
||||||
IS 'register relcache invalidation for changed placements';
|
|
||||||
|
|
||||||
CREATE TRIGGER dist_placement_cache_invalidate
|
|
||||||
AFTER INSERT OR UPDATE OR DELETE
|
|
||||||
ON pg_catalog.pg_dist_shard_placement
|
|
||||||
FOR EACH ROW EXECUTE PROCEDURE master_dist_placement_cache_invalidate();
|
|
||||||
|
|
@ -1,12 +0,0 @@
|
||||||
/* citus--6.0-15--6.0-16.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE FUNCTION mark_tables_colocated(source_table_name regclass, target_table_names regclass[])
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$mark_tables_colocated$$;
|
|
||||||
COMMENT ON FUNCTION mark_tables_colocated(source_table_name regclass, target_table_names regclass[])
|
|
||||||
IS 'mark target distributed tables as colocated with the source table';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,24 +0,0 @@
|
||||||
/* citus--6.0-16--6.0-17.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
DROP FUNCTION pg_catalog.master_copy_shard_placement(bigint, text, integer, text, integer);
|
|
||||||
|
|
||||||
CREATE FUNCTION pg_catalog.master_copy_shard_placement(shard_id bigint,
|
|
||||||
source_node_name text,
|
|
||||||
source_node_port integer,
|
|
||||||
target_node_name text,
|
|
||||||
target_node_port integer,
|
|
||||||
do_repair bool DEFAULT true)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'citus', $$master_copy_shard_placement$$;
|
|
||||||
COMMENT ON FUNCTION pg_catalog.master_copy_shard_placement(shard_id bigint,
|
|
||||||
source_node_name text,
|
|
||||||
source_node_port integer,
|
|
||||||
target_node_name text,
|
|
||||||
target_node_port integer,
|
|
||||||
do_repair bool)
|
|
||||||
IS 'copy shard from remote node';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,21 +0,0 @@
|
||||||
/* citus--6.0-17--6.0-18.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
DROP FUNCTION IF EXISTS master_add_node(text, integer);
|
|
||||||
|
|
||||||
CREATE FUNCTION master_add_node(nodename text,
|
|
||||||
nodeport integer,
|
|
||||||
OUT nodeid integer,
|
|
||||||
OUT groupid integer,
|
|
||||||
OUT nodename text,
|
|
||||||
OUT nodeport integer,
|
|
||||||
OUT noderack text,
|
|
||||||
OUT hasmetadata boolean)
|
|
||||||
RETURNS record
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_add_node$$;
|
|
||||||
COMMENT ON FUNCTION master_add_node(nodename text, nodeport integer)
|
|
||||||
IS 'add node to the cluster';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,12 +0,0 @@
|
||||||
/* citus--6.0-18--6.1-1.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE FUNCTION start_metadata_sync_to_node(nodename text, nodeport integer)
|
|
||||||
RETURNS VOID
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$start_metadata_sync_to_node$$;
|
|
||||||
COMMENT ON FUNCTION start_metadata_sync_to_node(nodename text, nodeport integer)
|
|
||||||
IS 'sync metadata to node';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,4 +0,0 @@
|
||||||
/* citus--6.0-2--6.0-3.sql */
|
|
||||||
|
|
||||||
ALTER TABLE pg_catalog.pg_dist_partition
|
|
||||||
ADD COLUMN repmodel "char" DEFAULT 'c' NOT NULL;
|
|
||||||
|
|
@ -1,61 +0,0 @@
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE SEQUENCE citus.pg_dist_groupid_seq
|
|
||||||
MINVALUE 1
|
|
||||||
MAXVALUE 4294967296;
|
|
||||||
|
|
||||||
CREATE SEQUENCE citus.pg_dist_node_nodeid_seq
|
|
||||||
MINVALUE 1
|
|
||||||
MAXVALUE 4294967296;
|
|
||||||
|
|
||||||
ALTER SEQUENCE citus.pg_dist_groupid_seq SET SCHEMA pg_catalog;
|
|
||||||
ALTER SEQUENCE citus.pg_dist_node_nodeid_seq SET SCHEMA pg_catalog;
|
|
||||||
|
|
||||||
/* add pg_dist_node */
|
|
||||||
CREATE TABLE citus.pg_dist_node(
|
|
||||||
nodeid int NOT NULL DEFAULT nextval('pg_dist_groupid_seq') PRIMARY KEY,
|
|
||||||
groupid int NOT NULL DEFAULT nextval('pg_dist_node_nodeid_seq'),
|
|
||||||
nodename text NOT NULL,
|
|
||||||
nodeport int NOT NULL DEFAULT 5432,
|
|
||||||
noderack text NOT NULL DEFAULT 'default',
|
|
||||||
UNIQUE (nodename, nodeport)
|
|
||||||
);
|
|
||||||
|
|
||||||
ALTER TABLE citus.pg_dist_node SET SCHEMA pg_catalog;
|
|
||||||
|
|
||||||
CREATE FUNCTION master_dist_node_cache_invalidate()
|
|
||||||
RETURNS trigger
|
|
||||||
LANGUAGE C
|
|
||||||
AS 'MODULE_PATHNAME', $$master_dist_node_cache_invalidate$$;
|
|
||||||
COMMENT ON FUNCTION master_dist_node_cache_invalidate()
|
|
||||||
IS 'invalidate internal cache of nodes when pg_dist_nodes changes';
|
|
||||||
CREATE TRIGGER dist_node_cache_invalidate
|
|
||||||
AFTER INSERT OR UPDATE OR DELETE
|
|
||||||
ON pg_catalog.pg_dist_node
|
|
||||||
FOR EACH ROW EXECUTE PROCEDURE master_dist_node_cache_invalidate();
|
|
||||||
|
|
||||||
CREATE FUNCTION master_add_node(nodename text,
|
|
||||||
nodeport integer)
|
|
||||||
RETURNS record
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_add_node$$;
|
|
||||||
COMMENT ON FUNCTION master_add_node(nodename text,
|
|
||||||
nodeport integer)
|
|
||||||
IS 'add node to the cluster';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_remove_node(nodename text, nodeport integer)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_remove_node$$;
|
|
||||||
COMMENT ON FUNCTION master_remove_node(nodename text, nodeport integer)
|
|
||||||
IS 'remove node from the cluster';
|
|
||||||
|
|
||||||
/* this only needs to run once, now. */
|
|
||||||
CREATE FUNCTION master_initialize_node_metadata()
|
|
||||||
RETURNS BOOL
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_initialize_node_metadata$$;
|
|
||||||
|
|
||||||
SELECT master_initialize_node_metadata();
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,27 +0,0 @@
|
||||||
/*
|
|
||||||
* Replace oid column in pg_dist_shard_placement with a sequence column.
|
|
||||||
*/
|
|
||||||
CREATE SEQUENCE citus.pg_dist_shard_placement_placementid_seq
|
|
||||||
NO CYCLE;
|
|
||||||
ALTER SEQUENCE citus.pg_dist_shard_placement_placementid_seq
|
|
||||||
SET SCHEMA pg_catalog;
|
|
||||||
ALTER TABLE pg_catalog.pg_dist_shard_placement
|
|
||||||
ADD COLUMN placementid bigint;
|
|
||||||
-- keep existing oids, and update sequence to match max.
|
|
||||||
UPDATE pg_catalog.pg_dist_shard_placement SET placementid = oid;
|
|
||||||
ALTER TABLE pg_catalog.pg_dist_shard_placement
|
|
||||||
ALTER COLUMN placementid SET DEFAULT nextval('pg_catalog.pg_dist_shard_placement_placementid_seq'),
|
|
||||||
ALTER COLUMN placementid SET NOT NULL,
|
|
||||||
SET WITHOUT OIDS;
|
|
||||||
CREATE UNIQUE INDEX pg_dist_shard_placement_placementid_index
|
|
||||||
ON pg_catalog.pg_dist_shard_placement using btree(placementid);
|
|
||||||
SELECT setval('pg_catalog.pg_dist_shard_placement_placementid_seq', max(placementid))
|
|
||||||
FROM pg_catalog.pg_dist_shard_placement;
|
|
||||||
|
|
||||||
CREATE FUNCTION master_get_new_placementid()
|
|
||||||
RETURNS bigint
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_get_new_placementid$$;
|
|
||||||
COMMENT ON FUNCTION master_get_new_placementid()
|
|
||||||
IS 'fetch unique placementid';
|
|
||||||
|
|
||||||
|
|
@ -1,14 +0,0 @@
|
||||||
CREATE FUNCTION worker_drop_distributed_table(logicalrelid Oid)
|
|
||||||
RETURNS VOID
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_drop_distributed_table$$;
|
|
||||||
|
|
||||||
COMMENT ON FUNCTION worker_drop_distributed_table(logicalrelid Oid)
|
|
||||||
IS 'drop the clustered table and its reference from metadata tables';
|
|
||||||
|
|
||||||
CREATE FUNCTION column_name_to_column(table_name regclass, column_name text)
|
|
||||||
RETURNS text
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$column_name_to_column$$;
|
|
||||||
COMMENT ON FUNCTION column_name_to_column(table_name regclass, column_name text)
|
|
||||||
IS 'convert a column name to its textual Var representation';
|
|
||||||
|
|
@ -1,21 +0,0 @@
|
||||||
/* citus--6.0-6--6.0-7.sql */
|
|
||||||
|
|
||||||
CREATE FUNCTION pg_catalog.get_colocated_table_array(regclass)
|
|
||||||
RETURNS regclass[]
|
|
||||||
AS 'citus'
|
|
||||||
LANGUAGE C STRICT;
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.master_move_shard_placement(shard_id bigint,
|
|
||||||
source_node_name text,
|
|
||||||
source_node_port integer,
|
|
||||||
target_node_name text,
|
|
||||||
target_node_port integer)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_move_shard_placement$$;
|
|
||||||
COMMENT ON FUNCTION pg_catalog.master_move_shard_placement(shard_id bigint,
|
|
||||||
source_node_name text,
|
|
||||||
source_node_port integer,
|
|
||||||
target_node_name text,
|
|
||||||
target_node_port integer)
|
|
||||||
IS 'move shard from remote node';
|
|
||||||
|
|
@ -1,4 +0,0 @@
|
||||||
/*
|
|
||||||
* Drop shardalias from pg_dist_shard
|
|
||||||
*/
|
|
||||||
ALTER TABLE pg_dist_shard DROP shardalias;
|
|
||||||
|
|
@ -1,13 +0,0 @@
|
||||||
/* citus--6.0-8--6.0-9.sql */
|
|
||||||
|
|
||||||
CREATE TABLE citus.pg_dist_local_group(
|
|
||||||
groupid int NOT NULL PRIMARY KEY)
|
|
||||||
;
|
|
||||||
|
|
||||||
/* insert the default value for being the coordinator node */
|
|
||||||
INSERT INTO citus.pg_dist_local_group VALUES (0);
|
|
||||||
|
|
||||||
ALTER TABLE citus.pg_dist_local_group SET SCHEMA pg_catalog;
|
|
||||||
GRANT SELECT ON pg_catalog.pg_dist_local_group TO public;
|
|
||||||
|
|
||||||
ALTER TABLE pg_catalog.pg_dist_node ADD COLUMN hasmetadata bool NOT NULL DEFAULT false;
|
|
||||||
|
|
@ -1,24 +0,0 @@
|
||||||
/* citus--6.0-9--6.0-10.sql */
|
|
||||||
|
|
||||||
CREATE TABLE citus.pg_dist_transaction (
|
|
||||||
groupid int NOT NULL,
|
|
||||||
gid text NOT NULL
|
|
||||||
);
|
|
||||||
|
|
||||||
CREATE INDEX pg_dist_transaction_group_index
|
|
||||||
ON citus.pg_dist_transaction using btree(groupid);
|
|
||||||
|
|
||||||
ALTER TABLE citus.pg_dist_transaction SET SCHEMA pg_catalog;
|
|
||||||
ALTER TABLE pg_catalog.pg_dist_transaction
|
|
||||||
ADD CONSTRAINT pg_dist_transaction_unique_constraint UNIQUE (groupid, gid);
|
|
||||||
|
|
||||||
GRANT SELECT ON pg_catalog.pg_dist_transaction TO public;
|
|
||||||
|
|
||||||
CREATE FUNCTION recover_prepared_transactions()
|
|
||||||
RETURNS int
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$recover_prepared_transactions$$;
|
|
||||||
|
|
||||||
COMMENT ON FUNCTION recover_prepared_transactions()
|
|
||||||
IS 'recover prepared transactions started by this node';
|
|
||||||
|
|
||||||
|
|
@ -1,12 +0,0 @@
|
||||||
/* citus--6.1-1--6.1-2.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE FUNCTION worker_create_truncate_trigger(table_name regclass)
|
|
||||||
RETURNS VOID
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_create_truncate_trigger$$;
|
|
||||||
COMMENT ON FUNCTION worker_create_truncate_trigger(tablename regclass)
|
|
||||||
IS 'create truncate trigger for distributed table';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,60 +0,0 @@
|
||||||
/* citus--6.1-10--6.1-11.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
DROP FUNCTION master_drop_sequences(text[], text, bigint);
|
|
||||||
|
|
||||||
CREATE FUNCTION master_drop_sequences(sequence_names text[])
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_drop_sequences$$;
|
|
||||||
COMMENT ON FUNCTION master_drop_sequences(text[])
|
|
||||||
IS 'drop specified sequences from the cluster';
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.citus_drop_trigger()
|
|
||||||
RETURNS event_trigger
|
|
||||||
LANGUAGE plpgsql
|
|
||||||
SECURITY DEFINER
|
|
||||||
SET search_path = pg_catalog
|
|
||||||
AS $cdbdt$
|
|
||||||
DECLARE
|
|
||||||
v_obj record;
|
|
||||||
sequence_names text[] := '{}';
|
|
||||||
table_colocation_id integer;
|
|
||||||
propagate_drop boolean := false;
|
|
||||||
BEGIN
|
|
||||||
-- collect set of dropped sequences to drop on workers later
|
|
||||||
SELECT array_agg(object_identity) INTO sequence_names
|
|
||||||
FROM pg_event_trigger_dropped_objects()
|
|
||||||
WHERE object_type = 'sequence';
|
|
||||||
|
|
||||||
FOR v_obj IN SELECT * FROM pg_event_trigger_dropped_objects() JOIN
|
|
||||||
pg_dist_partition ON (logicalrelid = objid)
|
|
||||||
WHERE object_type IN ('table', 'foreign table')
|
|
||||||
LOOP
|
|
||||||
-- get colocation group
|
|
||||||
SELECT colocationid INTO table_colocation_id FROM pg_dist_partition WHERE logicalrelid = v_obj.objid;
|
|
||||||
|
|
||||||
-- ensure all shards are dropped
|
|
||||||
PERFORM master_drop_all_shards(v_obj.objid, v_obj.schema_name, v_obj.object_name);
|
|
||||||
|
|
||||||
PERFORM master_drop_distributed_table_metadata(v_obj.objid, v_obj.schema_name, v_obj.object_name);
|
|
||||||
|
|
||||||
-- drop colocation group if all referencing tables are dropped
|
|
||||||
IF NOT EXISTS(SELECT * FROM pg_dist_partition WHERE colocationId = table_colocation_id) THEN
|
|
||||||
DELETE FROM pg_dist_colocation WHERE colocationId = table_colocation_id;
|
|
||||||
END IF;
|
|
||||||
END LOOP;
|
|
||||||
|
|
||||||
IF cardinality(sequence_names) = 0 THEN
|
|
||||||
RETURN;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
PERFORM master_drop_sequences(sequence_names);
|
|
||||||
END;
|
|
||||||
$cdbdt$;
|
|
||||||
|
|
||||||
COMMENT ON FUNCTION citus_drop_trigger()
|
|
||||||
IS 'perform checks and actions at the end of DROP actions';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,12 +0,0 @@
|
||||||
/* citus--6.1-11--6.1-12.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE FUNCTION upgrade_to_reference_table(table_name regclass)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$upgrade_to_reference_table$$;
|
|
||||||
COMMENT ON FUNCTION upgrade_to_reference_table(table_name regclass)
|
|
||||||
IS 'upgrades an existing broadcast table to a reference table';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,12 +0,0 @@
|
||||||
/* citus--6.1-12--6.1-13.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_disable_node(nodename text, nodeport integer)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_disable_node$$;
|
|
||||||
COMMENT ON FUNCTION master_disable_node(nodename text, nodeport integer)
|
|
||||||
IS 'removes node from the cluster temporarily';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,288 +0,0 @@
|
||||||
/* citus--6.1-13--6.1-14.sql */
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.master_run_on_worker(worker_name text[],
|
|
||||||
port integer[],
|
|
||||||
command text[],
|
|
||||||
parallel boolean,
|
|
||||||
OUT node_name text,
|
|
||||||
OUT node_port integer,
|
|
||||||
OUT success boolean,
|
|
||||||
OUT result text )
|
|
||||||
RETURNS SETOF record
|
|
||||||
LANGUAGE C STABLE STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_run_on_worker$$;
|
|
||||||
|
|
||||||
|
|
||||||
CREATE TYPE citus.colocation_placement_type AS (
|
|
||||||
shardid1 bigint,
|
|
||||||
shardid2 bigint,
|
|
||||||
nodename text,
|
|
||||||
nodeport bigint
|
|
||||||
);
|
|
||||||
|
|
||||||
--
|
|
||||||
-- distributed_tables_colocated returns true if given tables are co-located, false otherwise.
|
|
||||||
-- The function checks shard definitions, matches shard placements for given tables.
|
|
||||||
--
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.distributed_tables_colocated(table1 regclass,
|
|
||||||
table2 regclass)
|
|
||||||
RETURNS bool
|
|
||||||
LANGUAGE plpgsql
|
|
||||||
AS $function$
|
|
||||||
DECLARE
|
|
||||||
colocated_shard_count int;
|
|
||||||
table1_shard_count int;
|
|
||||||
table2_shard_count int;
|
|
||||||
table1_placement_count int;
|
|
||||||
table2_placement_count int;
|
|
||||||
table1_placements citus.colocation_placement_type[];
|
|
||||||
table2_placements citus.colocation_placement_type[];
|
|
||||||
BEGIN
|
|
||||||
SELECT count(*),
|
|
||||||
(SELECT count(*) FROM pg_dist_shard a WHERE a.logicalrelid = table1),
|
|
||||||
(SELECT count(*) FROM pg_dist_shard b WHERE b.logicalrelid = table2)
|
|
||||||
INTO colocated_shard_count, table1_shard_count, table2_shard_count
|
|
||||||
FROM pg_dist_shard tba JOIN pg_dist_shard tbb USING(shardminvalue, shardmaxvalue)
|
|
||||||
WHERE tba.logicalrelid = table1 AND tbb.logicalrelid = table2;
|
|
||||||
|
|
||||||
IF (table1_shard_count != table2_shard_count OR
|
|
||||||
table1_shard_count != colocated_shard_count)
|
|
||||||
THEN
|
|
||||||
RETURN false;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
WITH colocated_shards AS (
|
|
||||||
SELECT tba.shardid as shardid1, tbb.shardid as shardid2
|
|
||||||
FROM pg_dist_shard tba JOIN pg_dist_shard tbb USING(shardminvalue, shardmaxvalue)
|
|
||||||
WHERE tba.logicalrelid = table1 AND tbb.logicalrelid = table2),
|
|
||||||
left_shard_placements AS (
|
|
||||||
SELECT cs.shardid1, cs.shardid2, sp.nodename, sp.nodeport
|
|
||||||
FROM colocated_shards cs JOIN pg_dist_shard_placement sp
|
|
||||||
ON (cs.shardid1 = sp.shardid)
|
|
||||||
WHERE sp.shardstate = 1)
|
|
||||||
SELECT
|
|
||||||
array_agg(
|
|
||||||
(lsp.shardid1, lsp.shardid2, lsp.nodename, lsp.nodeport)::citus.colocation_placement_type
|
|
||||||
ORDER BY shardid1, shardid2, nodename, nodeport),
|
|
||||||
count(distinct lsp.shardid1)
|
|
||||||
FROM left_shard_placements lsp
|
|
||||||
INTO table1_placements, table1_placement_count;
|
|
||||||
|
|
||||||
WITH colocated_shards AS (
|
|
||||||
SELECT tba.shardid as shardid1, tbb.shardid as shardid2
|
|
||||||
FROM pg_dist_shard tba JOIN pg_dist_shard tbb USING(shardminvalue, shardmaxvalue)
|
|
||||||
WHERE tba.logicalrelid = table1 AND tbb.logicalrelid = table2),
|
|
||||||
right_shard_placements AS (
|
|
||||||
SELECT cs.shardid1, cs.shardid2, sp.nodename, sp.nodeport
|
|
||||||
FROM colocated_shards cs LEFT JOIN pg_dist_shard_placement sp ON(cs.shardid2 = sp.shardid)
|
|
||||||
WHERE sp.shardstate = 1)
|
|
||||||
SELECT
|
|
||||||
array_agg(
|
|
||||||
(rsp.shardid1, rsp.shardid2, rsp.nodename, rsp.nodeport)::citus.colocation_placement_type
|
|
||||||
ORDER BY shardid1, shardid2, nodename, nodeport),
|
|
||||||
count(distinct rsp.shardid2)
|
|
||||||
FROM right_shard_placements rsp
|
|
||||||
INTO table2_placements, table2_placement_count;
|
|
||||||
|
|
||||||
IF (table1_shard_count != table1_placement_count
|
|
||||||
OR table1_placement_count != table2_placement_count) THEN
|
|
||||||
RETURN false;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
IF (array_length(table1_placements, 1) != array_length(table2_placements, 1)) THEN
|
|
||||||
RETURN false;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
FOR i IN 1..array_length(table1_placements,1) LOOP
|
|
||||||
IF (table1_placements[i].nodename != table2_placements[i].nodename OR
|
|
||||||
table1_placements[i].nodeport != table2_placements[i].nodeport) THEN
|
|
||||||
RETURN false;
|
|
||||||
END IF;
|
|
||||||
END LOOP;
|
|
||||||
|
|
||||||
RETURN true;
|
|
||||||
END;
|
|
||||||
$function$;
|
|
||||||
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.run_command_on_workers(command text,
|
|
||||||
parallel bool default true,
|
|
||||||
OUT nodename text,
|
|
||||||
OUT nodeport int,
|
|
||||||
OUT success bool,
|
|
||||||
OUT result text)
|
|
||||||
RETURNS SETOF record
|
|
||||||
LANGUAGE plpgsql
|
|
||||||
AS $function$
|
|
||||||
DECLARE
|
|
||||||
workers text[];
|
|
||||||
ports int[];
|
|
||||||
commands text[];
|
|
||||||
BEGIN
|
|
||||||
WITH citus_workers AS (
|
|
||||||
SELECT * FROM master_get_active_worker_nodes() ORDER BY node_name, node_port)
|
|
||||||
SELECT array_agg(node_name), array_agg(node_port), array_agg(command)
|
|
||||||
INTO workers, ports, commands
|
|
||||||
FROM citus_workers;
|
|
||||||
|
|
||||||
RETURN QUERY SELECT * FROM master_run_on_worker(workers, ports, commands, parallel);
|
|
||||||
END;
|
|
||||||
$function$;
|
|
||||||
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.run_command_on_placements(table_name regclass,
|
|
||||||
command text,
|
|
||||||
parallel bool default true,
|
|
||||||
OUT nodename text,
|
|
||||||
OUT nodeport int,
|
|
||||||
OUT shardid bigint,
|
|
||||||
OUT success bool,
|
|
||||||
OUT result text)
|
|
||||||
RETURNS SETOF record
|
|
||||||
LANGUAGE plpgsql
|
|
||||||
AS $function$
|
|
||||||
DECLARE
|
|
||||||
workers text[];
|
|
||||||
ports int[];
|
|
||||||
shards bigint[];
|
|
||||||
commands text[];
|
|
||||||
BEGIN
|
|
||||||
WITH citus_placements AS (
|
|
||||||
SELECT
|
|
||||||
ds.logicalrelid::regclass AS tablename,
|
|
||||||
ds.shardid AS shardid,
|
|
||||||
shard_name(ds.logicalrelid, ds.shardid) AS shardname,
|
|
||||||
dsp.nodename AS nodename, dsp.nodeport::int AS nodeport
|
|
||||||
FROM pg_dist_shard ds JOIN pg_dist_shard_placement dsp USING (shardid)
|
|
||||||
WHERE dsp.shardstate = 1 and ds.logicalrelid::regclass = table_name
|
|
||||||
ORDER BY ds.logicalrelid, ds.shardid, dsp.nodename, dsp.nodeport)
|
|
||||||
SELECT
|
|
||||||
array_agg(cp.nodename), array_agg(cp.nodeport), array_agg(cp.shardid),
|
|
||||||
array_agg(format(command, cp.shardname))
|
|
||||||
INTO workers, ports, shards, commands
|
|
||||||
FROM citus_placements cp;
|
|
||||||
|
|
||||||
RETURN QUERY
|
|
||||||
SELECT r.node_name, r.node_port, shards[ordinality],
|
|
||||||
r.success, r.result
|
|
||||||
FROM master_run_on_worker(workers, ports, commands, parallel) WITH ORDINALITY r;
|
|
||||||
END;
|
|
||||||
$function$;
|
|
||||||
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.run_command_on_colocated_placements(
|
|
||||||
table_name1 regclass,
|
|
||||||
table_name2 regclass,
|
|
||||||
command text,
|
|
||||||
parallel bool default true,
|
|
||||||
OUT nodename text,
|
|
||||||
OUT nodeport int,
|
|
||||||
OUT shardid1 bigint,
|
|
||||||
OUT shardid2 bigint,
|
|
||||||
OUT success bool,
|
|
||||||
OUT result text)
|
|
||||||
RETURNS SETOF record
|
|
||||||
LANGUAGE plpgsql
|
|
||||||
AS $function$
|
|
||||||
DECLARE
|
|
||||||
workers text[];
|
|
||||||
ports int[];
|
|
||||||
shards1 bigint[];
|
|
||||||
shards2 bigint[];
|
|
||||||
commands text[];
|
|
||||||
BEGIN
|
|
||||||
IF NOT (SELECT distributed_tables_colocated(table_name1, table_name2)) THEN
|
|
||||||
RAISE EXCEPTION 'tables % and % are not co-located', table_name1, table_name2;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
WITH active_shard_placements AS (
|
|
||||||
SELECT
|
|
||||||
ds.logicalrelid,
|
|
||||||
ds.shardid AS shardid,
|
|
||||||
shard_name(ds.logicalrelid, ds.shardid) AS shardname,
|
|
||||||
ds.shardminvalue AS shardminvalue,
|
|
||||||
ds.shardmaxvalue AS shardmaxvalue,
|
|
||||||
dsp.nodename AS nodename,
|
|
||||||
dsp.nodeport::int AS nodeport
|
|
||||||
FROM pg_dist_shard ds JOIN pg_dist_shard_placement dsp USING (shardid)
|
|
||||||
WHERE dsp.shardstate = 1 and (ds.logicalrelid::regclass = table_name1 or
|
|
||||||
ds.logicalrelid::regclass = table_name2)
|
|
||||||
ORDER BY ds.logicalrelid, ds.shardid, dsp.nodename, dsp.nodeport),
|
|
||||||
citus_colocated_placements AS (
|
|
||||||
SELECT
|
|
||||||
a.logicalrelid::regclass AS tablename1,
|
|
||||||
a.shardid AS shardid1,
|
|
||||||
shard_name(a.logicalrelid, a.shardid) AS shardname1,
|
|
||||||
b.logicalrelid::regclass AS tablename2,
|
|
||||||
b.shardid AS shardid2,
|
|
||||||
shard_name(b.logicalrelid, b.shardid) AS shardname2,
|
|
||||||
a.nodename AS nodename,
|
|
||||||
a.nodeport::int AS nodeport
|
|
||||||
FROM
|
|
||||||
active_shard_placements a, active_shard_placements b
|
|
||||||
WHERE
|
|
||||||
a.shardminvalue = b.shardminvalue AND
|
|
||||||
a.shardmaxvalue = b.shardmaxvalue AND
|
|
||||||
a.logicalrelid != b.logicalrelid AND
|
|
||||||
a.nodename = b.nodename AND
|
|
||||||
a.nodeport = b.nodeport AND
|
|
||||||
a.logicalrelid::regclass = table_name1 AND
|
|
||||||
b.logicalrelid::regclass = table_name2
|
|
||||||
ORDER BY a.logicalrelid, a.shardid, nodename, nodeport)
|
|
||||||
SELECT
|
|
||||||
array_agg(cp.nodename), array_agg(cp.nodeport), array_agg(cp.shardid1),
|
|
||||||
array_agg(cp.shardid2), array_agg(format(command, cp.shardname1, cp.shardname2))
|
|
||||||
INTO workers, ports, shards1, shards2, commands
|
|
||||||
FROM citus_colocated_placements cp;
|
|
||||||
|
|
||||||
RETURN QUERY SELECT r.node_name, r.node_port, shards1[ordinality],
|
|
||||||
shards2[ordinality], r.success, r.result
|
|
||||||
FROM master_run_on_worker(workers, ports, commands, parallel) WITH ORDINALITY r;
|
|
||||||
END;
|
|
||||||
$function$;
|
|
||||||
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.run_command_on_shards(table_name regclass,
|
|
||||||
command text,
|
|
||||||
parallel bool default true,
|
|
||||||
OUT shardid bigint,
|
|
||||||
OUT success bool,
|
|
||||||
OUT result text)
|
|
||||||
RETURNS SETOF record
|
|
||||||
LANGUAGE plpgsql
|
|
||||||
AS $function$
|
|
||||||
DECLARE
|
|
||||||
workers text[];
|
|
||||||
ports int[];
|
|
||||||
shards bigint[];
|
|
||||||
commands text[];
|
|
||||||
shard_count int;
|
|
||||||
BEGIN
|
|
||||||
SELECT COUNT(*) INTO shard_count FROM pg_dist_shard
|
|
||||||
WHERE logicalrelid = table_name;
|
|
||||||
|
|
||||||
WITH citus_shards AS (
|
|
||||||
SELECT ds.logicalrelid::regclass AS tablename,
|
|
||||||
ds.shardid AS shardid,
|
|
||||||
shard_name(ds.logicalrelid, ds.shardid) AS shardname,
|
|
||||||
array_agg(dsp.nodename) AS nodenames,
|
|
||||||
array_agg(dsp.nodeport) AS nodeports
|
|
||||||
FROM pg_dist_shard ds LEFT JOIN pg_dist_shard_placement dsp USING (shardid)
|
|
||||||
WHERE dsp.shardstate = 1 and ds.logicalrelid::regclass = table_name
|
|
||||||
GROUP BY ds.logicalrelid, ds.shardid
|
|
||||||
ORDER BY ds.logicalrelid, ds.shardid)
|
|
||||||
SELECT
|
|
||||||
array_agg(cs.nodenames[1]), array_agg(cs.nodeports[1]), array_agg(cs.shardid),
|
|
||||||
array_agg(format(command, cs.shardname))
|
|
||||||
INTO workers, ports, shards, commands
|
|
||||||
FROM citus_shards cs;
|
|
||||||
|
|
||||||
IF (shard_count != array_length(workers, 1)) THEN
|
|
||||||
RAISE NOTICE 'some shards do not have active placements';
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
RETURN QUERY
|
|
||||||
SELECT shards[ordinality], r.success, r.result
|
|
||||||
FROM master_run_on_worker(workers, ports, commands, parallel) WITH ORDINALITY r;
|
|
||||||
END;
|
|
||||||
$function$;
|
|
||||||
|
|
@ -1,17 +0,0 @@
|
||||||
/* citus--6.1-14--6.1-15.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_dist_local_group_cache_invalidate()
|
|
||||||
RETURNS trigger
|
|
||||||
LANGUAGE C
|
|
||||||
AS 'MODULE_PATHNAME', $$master_dist_local_group_cache_invalidate$$;
|
|
||||||
COMMENT ON FUNCTION master_dist_local_group_cache_invalidate()
|
|
||||||
IS 'register node cache invalidation for changed rows';
|
|
||||||
|
|
||||||
CREATE TRIGGER dist_local_group_cache_invalidate
|
|
||||||
AFTER UPDATE
|
|
||||||
ON pg_catalog.pg_dist_local_group
|
|
||||||
FOR EACH ROW EXECUTE PROCEDURE master_dist_local_group_cache_invalidate();
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,12 +0,0 @@
|
||||||
/* citus--6.1-15--6.1-16.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE FUNCTION worker_apply_sequence_command(text)
|
|
||||||
RETURNS VOID
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_apply_sequence_command$$;
|
|
||||||
COMMENT ON FUNCTION worker_apply_sequence_command(text)
|
|
||||||
IS 'create a sequence which products globally unique values';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,19 +0,0 @@
|
||||||
/* citus--6.1-16--6.1-17.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE FUNCTION isolate_tenant_to_new_shard(table_name regclass, tenant_id "any", cascade_option text DEFAULT '')
|
|
||||||
RETURNS bigint
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$isolate_tenant_to_new_shard$$;
|
|
||||||
COMMENT ON FUNCTION isolate_tenant_to_new_shard(table_name regclass, tenant_id "any", cascade_option text)
|
|
||||||
IS 'isolate a tenant to its own shard and return the new shard id';
|
|
||||||
|
|
||||||
CREATE FUNCTION worker_hash(value "any")
|
|
||||||
RETURNS integer
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$worker_hash$$;
|
|
||||||
COMMENT ON FUNCTION worker_hash(value "any")
|
|
||||||
IS 'calculate hashed value and return it';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,11 +0,0 @@
|
||||||
/* citus--6.1-17--6.2-1.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
DROP FUNCTION IF EXISTS master_get_local_first_candidate_nodes();
|
|
||||||
DROP FUNCTION IF EXISTS master_get_round_robin_candidate_nodes();
|
|
||||||
|
|
||||||
DROP FUNCTION IF EXISTS master_stage_shard_row();
|
|
||||||
DROP FUNCTION IF EXISTS master_stage_shard_placement_row();
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,12 +0,0 @@
|
||||||
/* citus--6.1-2--6.1-3.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE FUNCTION stop_metadata_sync_to_node(nodename text, nodeport integer)
|
|
||||||
RETURNS VOID
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$stop_metadata_sync_to_node$$;
|
|
||||||
COMMENT ON FUNCTION stop_metadata_sync_to_node(nodename text, nodeport integer)
|
|
||||||
IS 'stop metadata sync to node';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,12 +0,0 @@
|
||||||
/* citus--6.1-3--6.1-4.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE FUNCTION column_to_column_name(table_name regclass, column_var_text text)
|
|
||||||
RETURNS text
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$column_to_column_name$$;
|
|
||||||
COMMENT ON FUNCTION column_to_column_name(table_name regclass, column_var_text text)
|
|
||||||
IS 'convert the textual Var representation to a column name';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,20 +0,0 @@
|
||||||
/* citus--6.1-4--6.1-5.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
DROP FUNCTION create_distributed_table(regclass, text, citus.distribution_type);
|
|
||||||
|
|
||||||
CREATE FUNCTION create_distributed_table(table_name regclass,
|
|
||||||
distribution_column text,
|
|
||||||
distribution_type citus.distribution_type DEFAULT 'hash',
|
|
||||||
colocate_with text DEFAULT 'default')
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$create_distributed_table$$;
|
|
||||||
COMMENT ON FUNCTION create_distributed_table(table_name regclass,
|
|
||||||
distribution_column text,
|
|
||||||
distribution_type citus.distribution_type,
|
|
||||||
colocate_with text)
|
|
||||||
IS 'creates a distributed table';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,9 +0,0 @@
|
||||||
/* citus--6.1-5--6.1-6.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
-- we don't need this constraint any more since reference tables
|
|
||||||
-- wouldn't have partition columns, which we represent as NULL
|
|
||||||
ALTER TABLE pg_dist_partition ALTER COLUMN partkey DROP NOT NULL;
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,12 +0,0 @@
|
||||||
/* citus--6.1-6--6.1-7.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE FUNCTION get_shard_id_for_distribution_column(table_name regclass, distribution_value "any" DEFAULT NULL)
|
|
||||||
RETURNS bigint
|
|
||||||
LANGUAGE C
|
|
||||||
AS 'MODULE_PATHNAME', $$get_shard_id_for_distribution_column$$;
|
|
||||||
COMMENT ON FUNCTION get_shard_id_for_distribution_column(table_name regclass, distribution_value "any")
|
|
||||||
IS 'return shard id which belongs to given table and contains given value';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,19 +0,0 @@
|
||||||
/* citus--6.1-4--6.1-5.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE FUNCTION lock_shard_resources(lock_mode int, shard_id bigint[])
|
|
||||||
RETURNS VOID
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$lock_shard_resources$$;
|
|
||||||
COMMENT ON FUNCTION lock_shard_resources(lock_mode int, shard_id bigint[])
|
|
||||||
IS 'lock shard resource to serialise non-commutative writes';
|
|
||||||
|
|
||||||
CREATE FUNCTION lock_shard_metadata(lock_mode int, shard_id bigint[])
|
|
||||||
RETURNS VOID
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$lock_shard_metadata$$;
|
|
||||||
COMMENT ON FUNCTION lock_shard_metadata(lock_mode int, shard_id bigint[])
|
|
||||||
IS 'lock shard metadata to prevent writes during metadata changes';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,89 +0,0 @@
|
||||||
/* citus--6.1-8--6.1-9.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_drop_distributed_table_metadata(logicalrelid regclass,
|
|
||||||
schema_name text,
|
|
||||||
table_name text)
|
|
||||||
RETURNS void
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$master_drop_distributed_table_metadata$$;
|
|
||||||
COMMENT ON FUNCTION master_drop_distributed_table_metadata(logicalrelid regclass,
|
|
||||||
schema_name text,
|
|
||||||
table_name text)
|
|
||||||
IS 'delete metadata of the distributed table';
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.citus_drop_trigger()
|
|
||||||
RETURNS event_trigger
|
|
||||||
LANGUAGE plpgsql
|
|
||||||
SECURITY DEFINER
|
|
||||||
SET search_path = pg_catalog
|
|
||||||
AS $cdbdt$
|
|
||||||
DECLARE
|
|
||||||
v_obj record;
|
|
||||||
sequence_names text[] := '{}';
|
|
||||||
node_names text[] := '{}';
|
|
||||||
node_ports bigint[] := '{}';
|
|
||||||
node_name text;
|
|
||||||
node_port bigint;
|
|
||||||
table_colocation_id integer;
|
|
||||||
BEGIN
|
|
||||||
-- collect set of dropped sequences to drop on workers later
|
|
||||||
SELECT array_agg(object_identity) INTO sequence_names
|
|
||||||
FROM pg_event_trigger_dropped_objects()
|
|
||||||
WHERE object_type = 'sequence';
|
|
||||||
|
|
||||||
-- Must accumulate set of affected nodes before deleting placements, as
|
|
||||||
-- master_drop_all_shards will erase their rows, making it impossible for
|
|
||||||
-- us to know where to drop sequences (which must be dropped after shards,
|
|
||||||
-- since they have default value expressions which depend on sequences).
|
|
||||||
SELECT array_agg(sp.nodename), array_agg(sp.nodeport)
|
|
||||||
INTO node_names, node_ports
|
|
||||||
FROM pg_event_trigger_dropped_objects() AS dobj,
|
|
||||||
pg_dist_shard AS s,
|
|
||||||
pg_dist_shard_placement AS sp
|
|
||||||
WHERE dobj.object_type IN ('table', 'foreign table')
|
|
||||||
AND dobj.objid = s.logicalrelid
|
|
||||||
AND s.shardid = sp.shardid;
|
|
||||||
|
|
||||||
FOR v_obj IN SELECT * FROM pg_event_trigger_dropped_objects() LOOP
|
|
||||||
IF v_obj.object_type NOT IN ('table', 'foreign table') THEN
|
|
||||||
CONTINUE;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
-- nothing to do if not a distributed table
|
|
||||||
IF NOT EXISTS(SELECT * FROM pg_dist_partition WHERE logicalrelid = v_obj.objid) THEN
|
|
||||||
CONTINUE;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
-- get colocation group
|
|
||||||
SELECT colocationid INTO table_colocation_id FROM pg_dist_partition WHERE logicalrelid = v_obj.objid;
|
|
||||||
|
|
||||||
-- ensure all shards are dropped
|
|
||||||
PERFORM master_drop_all_shards(v_obj.objid, v_obj.schema_name, v_obj.object_name);
|
|
||||||
|
|
||||||
PERFORM master_drop_distributed_table_metadata(v_obj.objid, v_obj.schema_name, v_obj.object_name);
|
|
||||||
|
|
||||||
-- drop colocation group if all referencing tables are dropped
|
|
||||||
IF NOT EXISTS(SELECT * FROM pg_dist_partition WHERE colocationId = table_colocation_id) THEN
|
|
||||||
DELETE FROM pg_dist_colocation WHERE colocationId = table_colocation_id;
|
|
||||||
END IF;
|
|
||||||
END LOOP;
|
|
||||||
|
|
||||||
IF cardinality(sequence_names) = 0 THEN
|
|
||||||
RETURN;
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
FOR node_name, node_port IN
|
|
||||||
SELECT DISTINCT name, port
|
|
||||||
FROM unnest(node_names, node_ports) AS nodes(name, port)
|
|
||||||
LOOP
|
|
||||||
PERFORM master_drop_sequences(sequence_names, node_name, node_port);
|
|
||||||
END LOOP;
|
|
||||||
END;
|
|
||||||
$cdbdt$;
|
|
||||||
|
|
||||||
COMMENT ON FUNCTION citus_drop_trigger()
|
|
||||||
IS 'perform checks and actions at the end of DROP actions';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,10 +0,0 @@
|
||||||
/* citus--6.1-9--6.1-10.sql */
|
|
||||||
|
|
||||||
GRANT SELECT ON pg_catalog.pg_dist_node TO public;
|
|
||||||
GRANT SELECT ON pg_catalog.pg_dist_colocation TO public;
|
|
||||||
GRANT SELECT ON pg_catalog.pg_dist_colocationid_seq TO public;
|
|
||||||
GRANT SELECT ON pg_catalog.pg_dist_groupid_seq TO public;
|
|
||||||
GRANT SELECT ON pg_catalog.pg_dist_node_nodeid_seq TO public;
|
|
||||||
GRANT SELECT ON pg_catalog.pg_dist_shard_placement_placementid_seq TO public;
|
|
||||||
GRANT SELECT ON pg_catalog.pg_dist_shardid_seq TO public;
|
|
||||||
GRANT SELECT ON pg_catalog.pg_dist_jobid_seq TO public;
|
|
||||||
|
|
@ -1,26 +0,0 @@
|
||||||
/* citus--6.2-1--6.2-2.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
CREATE FUNCTION citus_table_size(logicalrelid regclass)
|
|
||||||
RETURNS bigint
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$citus_table_size$$;
|
|
||||||
COMMENT ON FUNCTION citus_table_size(logicalrelid regclass)
|
|
||||||
IS 'get disk space used by the specified table, excluding indexes';
|
|
||||||
|
|
||||||
CREATE FUNCTION citus_relation_size(logicalrelid regclass)
|
|
||||||
RETURNS bigint
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$citus_relation_size$$;
|
|
||||||
COMMENT ON FUNCTION citus_relation_size(logicalrelid regclass)
|
|
||||||
IS 'get disk space used by the ''main'' fork';
|
|
||||||
|
|
||||||
CREATE FUNCTION citus_total_relation_size(logicalrelid regclass)
|
|
||||||
RETURNS bigint
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$citus_total_relation_size$$;
|
|
||||||
COMMENT ON FUNCTION citus_total_relation_size(logicalrelid regclass)
|
|
||||||
IS 'get total disk space used by the specified table';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,54 +0,0 @@
|
||||||
/* citus--6.2-2--6.2-3.sql */
|
|
||||||
|
|
||||||
SET search_path = 'pg_catalog';
|
|
||||||
|
|
||||||
ALTER TABLE pg_dist_node ADD isactive bool NOT NULL DEFAULT true;
|
|
||||||
|
|
||||||
DROP FUNCTION IF EXISTS master_add_node(text, integer);
|
|
||||||
|
|
||||||
CREATE FUNCTION master_add_node(nodename text,
|
|
||||||
nodeport integer,
|
|
||||||
OUT nodeid integer,
|
|
||||||
OUT groupid integer,
|
|
||||||
OUT nodename text,
|
|
||||||
OUT nodeport integer,
|
|
||||||
OUT noderack text,
|
|
||||||
OUT hasmetadata boolean,
|
|
||||||
OUT isactive bool)
|
|
||||||
RETURNS record
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME',$$master_add_node$$;
|
|
||||||
COMMENT ON FUNCTION master_add_node(nodename text, nodeport integer)
|
|
||||||
IS 'add node to the cluster';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_add_inactive_node(nodename text,
|
|
||||||
nodeport integer,
|
|
||||||
OUT nodeid integer,
|
|
||||||
OUT groupid integer,
|
|
||||||
OUT nodename text,
|
|
||||||
OUT nodeport integer,
|
|
||||||
OUT noderack text,
|
|
||||||
OUT hasmetadata boolean,
|
|
||||||
OUT isactive bool)
|
|
||||||
RETURNS record
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME',$$master_add_inactive_node$$;
|
|
||||||
COMMENT ON FUNCTION master_add_inactive_node(nodename text,nodeport integer)
|
|
||||||
IS 'prepare node by adding it to pg_dist_node';
|
|
||||||
|
|
||||||
CREATE FUNCTION master_activate_node(nodename text,
|
|
||||||
nodeport integer,
|
|
||||||
OUT nodeid integer,
|
|
||||||
OUT groupid integer,
|
|
||||||
OUT nodename text,
|
|
||||||
OUT nodeport integer,
|
|
||||||
OUT noderack text,
|
|
||||||
OUT hasmetadata boolean,
|
|
||||||
OUT isactive bool)
|
|
||||||
RETURNS record
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME',$$master_activate_node$$;
|
|
||||||
COMMENT ON FUNCTION master_activate_node(nodename text, nodeport integer)
|
|
||||||
IS 'activate a node which is in the cluster';
|
|
||||||
|
|
||||||
RESET search_path;
|
|
||||||
|
|
@ -1,8 +0,0 @@
|
||||||
/* citus--6.2-3--6.2-4.sql */
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.citus_truncate_trigger()
|
|
||||||
RETURNS trigger
|
|
||||||
LANGUAGE C STRICT
|
|
||||||
AS 'MODULE_PATHNAME', $$citus_truncate_trigger$$;
|
|
||||||
COMMENT ON FUNCTION pg_catalog.citus_truncate_trigger()
|
|
||||||
IS 'trigger function called when truncating the distributed table';
|
|
||||||
|
|
@ -1,3 +0,0 @@
|
||||||
/* citus--6.2-4--7.0-1.sql */
|
|
||||||
|
|
||||||
/* empty, but required to update the extension version */
|
|
||||||
File diff suppressed because it is too large
Load Diff
|
|
@ -60,6 +60,10 @@ check-base-vg: all
|
||||||
--valgrind --pg_ctl-timeout=360 --connection-timeout=500000 --valgrind-path=valgrind --valgrind-log-file=$(VALGRIND_LOG_FILE) \
|
--valgrind --pg_ctl-timeout=360 --connection-timeout=500000 --valgrind-path=valgrind --valgrind-log-file=$(VALGRIND_LOG_FILE) \
|
||||||
-- $(MULTI_REGRESS_OPTS) --schedule=$(citus_abs_srcdir)/base_schedule $(EXTRA_TESTS)
|
-- $(MULTI_REGRESS_OPTS) --schedule=$(citus_abs_srcdir)/base_schedule $(EXTRA_TESTS)
|
||||||
|
|
||||||
|
check-empty: all
|
||||||
|
$(pg_regress_multi_check) --load-extension=citus \
|
||||||
|
-- $(MULTI_REGRESS_OPTS) $(EXTRA_TESTS)
|
||||||
|
|
||||||
check-multi: all tempinstall-main
|
check-multi: all tempinstall-main
|
||||||
$(pg_regress_multi_check) --load-extension=citus \
|
$(pg_regress_multi_check) --load-extension=citus \
|
||||||
-- $(MULTI_REGRESS_OPTS) --schedule=$(citus_abs_srcdir)/multi_schedule $(EXTRA_TESTS)
|
-- $(MULTI_REGRESS_OPTS) --schedule=$(citus_abs_srcdir)/multi_schedule $(EXTRA_TESTS)
|
||||||
|
|
|
||||||
|
|
@ -55,62 +55,7 @@ WHERE pgd.refclassid = 'pg_extension'::regclass AND
|
||||||
DROP EXTENSION citus;
|
DROP EXTENSION citus;
|
||||||
\c
|
\c
|
||||||
SET citus.enable_version_checks TO 'false';
|
SET citus.enable_version_checks TO 'false';
|
||||||
-- Create extension in oldest version
|
CREATE EXTENSION citus VERSION '7.0-1';
|
||||||
CREATE EXTENSION citus VERSION '5.0';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.0-1';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.0-2';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-1';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-2';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-3';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-4';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-5';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-6';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-7';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-8';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.2-1';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.2-2';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.2-3';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.2-4';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-1';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-2';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-3';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-4';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-5';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-6';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-7';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-8';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-9';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-10';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-11';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-12';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-13';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-14';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-15';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-16';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-17';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-18';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-1';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-2';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-3';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-4';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-5';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-6';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-7';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-8';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-9';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-10';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-11';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-12';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-13';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-14';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-15';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-16';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-17';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.2-1';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.2-2';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.2-3';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.2-4';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '7.0-1';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '7.0-2';
|
ALTER EXTENSION citus UPDATE TO '7.0-2';
|
||||||
ALTER EXTENSION citus UPDATE TO '7.0-3';
|
ALTER EXTENSION citus UPDATE TO '7.0-3';
|
||||||
ALTER EXTENSION citus UPDATE TO '7.0-4';
|
ALTER EXTENSION citus UPDATE TO '7.0-4';
|
||||||
|
|
@ -186,13 +131,13 @@ WHERE pgd.refclassid = 'pg_extension'::regclass AND
|
||||||
-- see incompatible version errors out
|
-- see incompatible version errors out
|
||||||
RESET citus.enable_version_checks;
|
RESET citus.enable_version_checks;
|
||||||
DROP EXTENSION citus;
|
DROP EXTENSION citus;
|
||||||
CREATE EXTENSION citus VERSION '5.0';
|
CREATE EXTENSION citus VERSION '7.0-1';
|
||||||
ERROR: specified version incompatible with loaded Citus library
|
ERROR: specified version incompatible with loaded Citus library
|
||||||
DETAIL: Loaded library requires 8.4, but 5.0 was specified.
|
DETAIL: Loaded library requires 8.4, but 7.0-1 was specified.
|
||||||
HINT: If a newer library is present, restart the database and try the command again.
|
HINT: If a newer library is present, restart the database and try the command again.
|
||||||
-- Test non-distributed queries work even in version mismatch
|
-- Test non-distributed queries work even in version mismatch
|
||||||
SET citus.enable_version_checks TO 'false';
|
SET citus.enable_version_checks TO 'false';
|
||||||
CREATE EXTENSION citus VERSION '6.2-1';
|
CREATE EXTENSION citus VERSION '7.1-1';
|
||||||
SET citus.enable_version_checks TO 'true';
|
SET citus.enable_version_checks TO 'true';
|
||||||
-- Test CREATE TABLE
|
-- Test CREATE TABLE
|
||||||
CREATE TABLE version_mismatch_table(column1 int);
|
CREATE TABLE version_mismatch_table(column1 int);
|
||||||
|
|
@ -231,24 +176,24 @@ ORDER BY 1;
|
||||||
-- We should not distribute table in version mistmatch
|
-- We should not distribute table in version mistmatch
|
||||||
SELECT create_distributed_table('version_mismatch_table', 'column1');
|
SELECT create_distributed_table('version_mismatch_table', 'column1');
|
||||||
ERROR: loaded Citus library version differs from installed extension version
|
ERROR: loaded Citus library version differs from installed extension version
|
||||||
DETAIL: Loaded library requires 8.4, but the installed extension version is 6.2-1.
|
DETAIL: Loaded library requires 8.4, but the installed extension version is 7.1-1.
|
||||||
HINT: Run ALTER EXTENSION citus UPDATE and try again.
|
HINT: Run ALTER EXTENSION citus UPDATE and try again.
|
||||||
-- This function will cause fail in next ALTER EXTENSION
|
-- This function will cause fail in next ALTER EXTENSION
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.citus_table_size(table_name regclass)
|
CREATE OR REPLACE FUNCTION pg_catalog.master_dist_authinfo_cache_invalidate()
|
||||||
RETURNS bigint LANGUAGE plpgsql
|
RETURNS void LANGUAGE plpgsql
|
||||||
AS $function$
|
AS $function$
|
||||||
BEGIN
|
BEGIN
|
||||||
END;
|
END;
|
||||||
$function$;
|
$function$;
|
||||||
SET citus.enable_version_checks TO 'false';
|
SET citus.enable_version_checks TO 'false';
|
||||||
-- This will fail because of previous function declaration
|
-- This will fail because of previous function declaration
|
||||||
ALTER EXTENSION citus UPDATE TO '6.2-2';
|
ALTER EXTENSION citus UPDATE TO '8.1-1';
|
||||||
ERROR: function "citus_table_size" already exists with same argument types
|
ERROR: function "master_dist_authinfo_cache_invalidate" already exists with same argument types
|
||||||
-- We can DROP problematic function and continue ALTER EXTENSION even when version checks are on
|
-- We can DROP problematic function and continue ALTER EXTENSION even when version checks are on
|
||||||
SET citus.enable_version_checks TO 'true';
|
SET citus.enable_version_checks TO 'true';
|
||||||
DROP FUNCTION citus_table_size(regclass);
|
DROP FUNCTION pg_catalog.master_dist_authinfo_cache_invalidate();
|
||||||
SET citus.enable_version_checks TO 'false';
|
SET citus.enable_version_checks TO 'false';
|
||||||
ALTER EXTENSION citus UPDATE TO '6.2-2';
|
ALTER EXTENSION citus UPDATE TO '8.1-1';
|
||||||
-- Test updating to the latest version without specifying the version number
|
-- Test updating to the latest version without specifying the version number
|
||||||
ALTER EXTENSION citus UPDATE;
|
ALTER EXTENSION citus UPDATE;
|
||||||
-- re-create in newest version
|
-- re-create in newest version
|
||||||
|
|
@ -259,7 +204,7 @@ CREATE EXTENSION citus;
|
||||||
\c - - - :worker_1_port
|
\c - - - :worker_1_port
|
||||||
DROP EXTENSION citus;
|
DROP EXTENSION citus;
|
||||||
SET citus.enable_version_checks TO 'false';
|
SET citus.enable_version_checks TO 'false';
|
||||||
CREATE EXTENSION citus VERSION '5.2-4';
|
CREATE EXTENSION citus VERSION '7.0-1';
|
||||||
SET citus.enable_version_checks TO 'true';
|
SET citus.enable_version_checks TO 'true';
|
||||||
-- during ALTER EXTENSION, we should invalidate the cache
|
-- during ALTER EXTENSION, we should invalidate the cache
|
||||||
ALTER EXTENSION citus UPDATE;
|
ALTER EXTENSION citus UPDATE;
|
||||||
|
|
|
||||||
|
|
@ -55,62 +55,7 @@ DROP EXTENSION citus;
|
||||||
|
|
||||||
SET citus.enable_version_checks TO 'false';
|
SET citus.enable_version_checks TO 'false';
|
||||||
|
|
||||||
-- Create extension in oldest version
|
CREATE EXTENSION citus VERSION '7.0-1';
|
||||||
CREATE EXTENSION citus VERSION '5.0';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.0-1';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.0-2';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-1';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-2';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-3';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-4';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-5';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-6';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-7';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.1-8';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.2-1';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.2-2';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.2-3';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '5.2-4';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-1';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-2';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-3';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-4';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-5';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-6';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-7';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-8';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-9';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-10';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-11';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-12';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-13';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-14';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-15';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-16';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-17';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.0-18';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-1';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-2';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-3';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-4';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-5';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-6';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-7';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-8';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-9';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-10';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-11';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-12';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-13';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-14';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-15';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-16';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.1-17';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.2-1';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.2-2';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.2-3';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '6.2-4';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '7.0-1';
|
|
||||||
ALTER EXTENSION citus UPDATE TO '7.0-2';
|
ALTER EXTENSION citus UPDATE TO '7.0-2';
|
||||||
ALTER EXTENSION citus UPDATE TO '7.0-3';
|
ALTER EXTENSION citus UPDATE TO '7.0-3';
|
||||||
ALTER EXTENSION citus UPDATE TO '7.0-4';
|
ALTER EXTENSION citus UPDATE TO '7.0-4';
|
||||||
|
|
@ -179,11 +124,11 @@ WHERE pgd.refclassid = 'pg_extension'::regclass AND
|
||||||
-- see incompatible version errors out
|
-- see incompatible version errors out
|
||||||
RESET citus.enable_version_checks;
|
RESET citus.enable_version_checks;
|
||||||
DROP EXTENSION citus;
|
DROP EXTENSION citus;
|
||||||
CREATE EXTENSION citus VERSION '5.0';
|
CREATE EXTENSION citus VERSION '7.0-1';
|
||||||
|
|
||||||
-- Test non-distributed queries work even in version mismatch
|
-- Test non-distributed queries work even in version mismatch
|
||||||
SET citus.enable_version_checks TO 'false';
|
SET citus.enable_version_checks TO 'false';
|
||||||
CREATE EXTENSION citus VERSION '6.2-1';
|
CREATE EXTENSION citus VERSION '7.1-1';
|
||||||
SET citus.enable_version_checks TO 'true';
|
SET citus.enable_version_checks TO 'true';
|
||||||
|
|
||||||
-- Test CREATE TABLE
|
-- Test CREATE TABLE
|
||||||
|
|
@ -215,8 +160,8 @@ ORDER BY 1;
|
||||||
SELECT create_distributed_table('version_mismatch_table', 'column1');
|
SELECT create_distributed_table('version_mismatch_table', 'column1');
|
||||||
|
|
||||||
-- This function will cause fail in next ALTER EXTENSION
|
-- This function will cause fail in next ALTER EXTENSION
|
||||||
CREATE OR REPLACE FUNCTION pg_catalog.citus_table_size(table_name regclass)
|
CREATE OR REPLACE FUNCTION pg_catalog.master_dist_authinfo_cache_invalidate()
|
||||||
RETURNS bigint LANGUAGE plpgsql
|
RETURNS void LANGUAGE plpgsql
|
||||||
AS $function$
|
AS $function$
|
||||||
BEGIN
|
BEGIN
|
||||||
END;
|
END;
|
||||||
|
|
@ -224,14 +169,14 @@ $function$;
|
||||||
|
|
||||||
SET citus.enable_version_checks TO 'false';
|
SET citus.enable_version_checks TO 'false';
|
||||||
-- This will fail because of previous function declaration
|
-- This will fail because of previous function declaration
|
||||||
ALTER EXTENSION citus UPDATE TO '6.2-2';
|
ALTER EXTENSION citus UPDATE TO '8.1-1';
|
||||||
|
|
||||||
-- We can DROP problematic function and continue ALTER EXTENSION even when version checks are on
|
-- We can DROP problematic function and continue ALTER EXTENSION even when version checks are on
|
||||||
SET citus.enable_version_checks TO 'true';
|
SET citus.enable_version_checks TO 'true';
|
||||||
DROP FUNCTION citus_table_size(regclass);
|
DROP FUNCTION pg_catalog.master_dist_authinfo_cache_invalidate();
|
||||||
|
|
||||||
SET citus.enable_version_checks TO 'false';
|
SET citus.enable_version_checks TO 'false';
|
||||||
ALTER EXTENSION citus UPDATE TO '6.2-2';
|
ALTER EXTENSION citus UPDATE TO '8.1-1';
|
||||||
|
|
||||||
-- Test updating to the latest version without specifying the version number
|
-- Test updating to the latest version without specifying the version number
|
||||||
ALTER EXTENSION citus UPDATE;
|
ALTER EXTENSION citus UPDATE;
|
||||||
|
|
@ -246,7 +191,7 @@ CREATE EXTENSION citus;
|
||||||
|
|
||||||
DROP EXTENSION citus;
|
DROP EXTENSION citus;
|
||||||
SET citus.enable_version_checks TO 'false';
|
SET citus.enable_version_checks TO 'false';
|
||||||
CREATE EXTENSION citus VERSION '5.2-4';
|
CREATE EXTENSION citus VERSION '7.0-1';
|
||||||
SET citus.enable_version_checks TO 'true';
|
SET citus.enable_version_checks TO 'true';
|
||||||
-- during ALTER EXTENSION, we should invalidate the cache
|
-- during ALTER EXTENSION, we should invalidate the cache
|
||||||
ALTER EXTENSION citus UPDATE;
|
ALTER EXTENSION citus UPDATE;
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue