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

Address reviews

velioglu/wo_seq_test_1
Burak Velioglu 2022-01-24 12:21:22 +03:00
parent 3c9aa360f5
commit 524ee83a9a
No known key found for this signature in database
GPG Key ID: F6827E620F6549C6
3 changed files with 38 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/backend/distributed/metadata/node_metadata.c
View File

@ -785,13 +785,21 @@ SyncObjectDependenciesCommandList(WorkerNode *workerNode)
static void
SyncObjectDependenciesToNode(WorkerNode *workerNode)
{
if (NodeIsPrimary(workerNode))
if (NodeIsCoordinator(workerNode))
{
EnsureNoModificationsHaveBeenDone();
/* coordinator has all the objects */
return;
}
Assert(ShouldPropagate());
if (!NodeIsCoordinator(workerNode))
if (!NodeIsPrimary(workerNode))
{
/* secondary nodes gets the objects from their primaries via replication */
return;
}
EnsureNoModificationsHaveBeenDone();
Assert(ShouldPropagate());
List *commandList = SyncObjectDependenciesCommandList(workerNode);
/* send commands to new workers, the current user should be a superuser */
@ -802,8 +810,6 @@ SyncObjectDependenciesToNode(WorkerNode *workerNode)
CurrentUserName(),
commandList);
}
}
}
/*

12
src/backend/distributed/worker/worker_data_fetch_protocol.c
View File

@ -466,18 +466,18 @@ worker_apply_sequence_command(PG_FUNCTION_ARGS)
/*
* If sequence with the same name exist for different type, it must have been
* stayed on that node after a rollbacked create_distributed_table operation.
* We must drop it first to create the sequence with the correct type.
* We must change it's name first to create the sequence with the correct type.
*/
Oid sequenceOid;
CreateSeqStmt *createSequenceStatement = (CreateSeqStmt *) commandNode;
char *sequenceName = createSequenceStatement->sequence->relname;
char *sequenceSchema = createSequenceStatement->sequence->schemaname;
RangeVar *sequenceRange = makeRangeVar(sequenceSchema, sequenceName, -1);
Oid sequenceRelationId = RangeVarGetRelid(sequenceRange, AccessShareLock, true);
if (sequenceRelationId != InvalidOid)
RangeVarGetAndCheckCreationNamespace(createSequenceStatement->sequence, NoLock,
&sequenceOid);
if (OidIsValid(sequenceOid))
{
Form_pg_sequence pgSequenceForm = pg_get_sequencedef(sequenceRelationId);
Form_pg_sequence pgSequenceForm = pg_get_sequencedef(sequenceOid);
if (pgSequenceForm->seqtypid != sequenceTypeId)
{
StringInfo dropSequenceString = makeStringInfo();

11
src/test/regress/sql/multi_test_helpers_superuser.sql
View File

@ -22,8 +22,17 @@ WITH dist_node_summary AS (
master_run_on_worker(ARRAY[hostname, 'localhost'], ARRAY[port, master_port],
ARRAY[dist_node_summary.query, dist_node_summary.query],
false)
), dist_placement_summary AS (
SELECT 'SELECT jsonb_agg(pg_dist_placement ORDER BY placementid) FROM pg_dist_placement' AS query
), dist_placement_check AS (
SELECT count(distinct result) = 1 AS matches
FROM dist_placement_summary CROSS JOIN LATERAL
master_run_on_worker(ARRAY[hostname, 'localhost'], ARRAY[port, master_port],
ARRAY[dist_placement_summary.query, dist_placement_summary.query],
false)
)
SELECT dist_node_check.matches FROM dist_node_check
SELECT dist_node_check.matches AND dist_placement_check.matches
FROM dist_node_check CROSS JOIN dist_placement_check
$$;