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

Update truncate with delete from for metadata table

velioglu/wo_seq_test_1
Burak Velioglu 2022-01-15 22:10:59 +03:00
parent f29af1e23e
commit 060e6bf02f
No known key found for this signature in database
GPG Key ID: F6827E620F6549C6
2 changed files with 9 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -69,11 +69,11 @@ extern void GetDependentSequencesWithRelation(Oid relationId, List **attnumList,
attnum); attnum);
extern Oid GetAttributeTypeOid(Oid relationId, AttrNumber attnum); extern Oid GetAttributeTypeOid(Oid relationId, AttrNumber attnum);
#define DELETE_ALL_NODES "TRUNCATE pg_dist_node CASCADE" #define DELETE_ALL_NODES "DELETE FROM pg_dist_node CASCADE"
#define DELETE_ALL_PLACEMENTS "TRUNCATE pg_dist_placement CASCADE" #define DELETE_ALL_PLACEMENTS "DELETE FROM pg_dist_placement CASCADE"
#define DELETE_ALL_SHARDS "TRUNCATE pg_dist_shard CASCADE" #define DELETE_ALL_SHARDS "DELETE FROM pg_dist_shard CASCADE"
#define DELETE_ALL_DISTRIBUTED_OBJECTS "TRUNCATE citus.pg_dist_object" #define DELETE_ALL_DISTRIBUTED_OBJECTS "DELETE FROM citus.pg_dist_object"
#define DELETE_ALL_PARTITIONS "TRUNCATE pg_dist_partition CASCADE" #define DELETE_ALL_PARTITIONS "DELETE FROM pg_dist_partition CASCADE"
#define REMOVE_ALL_CLUSTERED_TABLES_ONLY_COMMAND \ #define REMOVE_ALL_CLUSTERED_TABLES_ONLY_COMMAND \
"SELECT worker_drop_distributed_table_only(logicalrelid::regclass::text) FROM pg_dist_partition" "SELECT worker_drop_distributed_table_only(logicalrelid::regclass::text) FROM pg_dist_partition"
#define REMOVE_ALL_CITUS_TABLES_COMMAND \ #define REMOVE_ALL_CITUS_TABLES_COMMAND \

19
src/test/regress/spec/isolation_replicate_reference_tables_to_coordinator.spec
View File

@ -1,23 +1,12 @@
setup setup
{ {
SELECT citus_internal.replace_isolation_tester_func(); //SELECT citus_internal.replace_isolation_tester_func();
SELECT citus_internal.refresh_isolation_tester_prepared_statement(); //SELECT citus_internal.refresh_isolation_tester_prepared_statement();
SELECT master_add_node('localhost', 57636);
CREATE TABLE ref_table(a int primary key);
SELECT create_reference_table('ref_table');
INSERT INTO ref_table VALUES (1), (3), (5), (7);
CREATE TABLE dist_table(a int, b int);
SELECT create_distributed_table('dist_table', 'a');
} }
teardown teardown
{ {
SELECT citus_internal.restore_isolation_tester_func(); // SELECT citus_internal.restore_isolation_tester_func();
DROP TABLE ref_table, dist_table;
SELECT master_remove_node('localhost', 57636);
} }
session "s1" session "s1"
@ -123,7 +112,7 @@ step "deadlock-checker-call"
// verify that locks on the placement of the reference table on the coordinator is // verify that locks on the placement of the reference table on the coordinator is
// taken into account when looking for distributed deadlocks // taken into account when looking for distributed deadlocks
permutation "s1-begin" "s2-begin" "s1-update-dist-table" "s2-lock-ref-table-placement-on-coordinator" "s1-lock-ref-table-placement-on-coordinator" "s2-update-dist-table" "deadlock-checker-call" "s1-end" "s2-end" // permutation "s1-begin" "s2-begin" "s1-update-dist-table" "s2-lock-ref-table-placement-on-coordinator" "s1-lock-ref-table-placement-on-coordinator" "s2-update-dist-table" "deadlock-checker-call" "s1-end" "s2-end"
// verify that *_dist_stat_activity() functions return the correct result when query // verify that *_dist_stat_activity() functions return the correct result when query
// has a task on the coordinator. // has a task on the coordinator.