external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Partition drop first

tx_metadata_sync
Onder Kalaci 2022-11-29 07:56:04 +01:00
parent 3157c3760a
commit 2db4ee7a50
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/worker/worker_drop_protocol.c
View File

@ -256,6 +256,8 @@ worker_drop_shell_table(PG_FUNCTION_ARGS)
performDeletion(distributedTableObject, DROP_CASCADE, performDeletion(distributedTableObject, DROP_CASCADE,
PERFORM_DELETION_INTERNAL); PERFORM_DELETION_INTERNAL);
CommandCounterInrement();
PG_RETURN_VOID(); PG_RETURN_VOID();
} }

2
src/include/distributed/metadata_sync.h
View File

@ -118,7 +118,7 @@ extern void SyncDeleteColocationGroupToNodes(uint32 colocationId);
#define DELETE_ALL_PARTITIONS "DELETE FROM pg_dist_partition" #define DELETE_ALL_PARTITIONS "DELETE FROM pg_dist_partition"
#define DELETE_ALL_COLOCATION "DELETE FROM pg_catalog.pg_dist_colocation" #define DELETE_ALL_COLOCATION "DELETE FROM pg_catalog.pg_dist_colocation"
#define REMOVE_PARTITIONED_SHELL_TABLES_COMMAND \ #define REMOVE_PARTITIONED_SHELL_TABLES_COMMAND \
"SELECT worker_drop_shell_table(logicalrelid::regclass::text) FROM pg_dist_partition JOIN pg_class ON (logicalrelid = oid) WHERE relkind = 'p'" "SELECT worker_drop_shell_table(logicalrelid::regclass::text) FROM pg_dist_partition JOIN pg_class ON (logicalrelid = oid) WHERE relkind != 'p'"
#define REMOVE_ALL_SHELL_TABLES_COMMAND \ #define REMOVE_ALL_SHELL_TABLES_COMMAND \
"SELECT worker_drop_shell_table(logicalrelid::regclass::text) FROM pg_dist_partition" "SELECT worker_drop_shell_table(logicalrelid::regclass::text) FROM pg_dist_partition"
#define REMOVE_ALL_CITUS_TABLES_COMMAND \ #define REMOVE_ALL_CITUS_TABLES_COMMAND \