From 75282bd5d1fd85ab577edeb57bb349a2bcbe79f0 Mon Sep 17 00:00:00 2001 From: Onder Kalaci Date: Thu, 18 Aug 2022 13:30:43 +0200 Subject: [PATCH] WIP --- src/backend/distributed/commands/table.c | 20 ++++++++++++++------ 1 file changed, 14 insertions(+), 6 deletions(-) diff --git a/src/backend/distributed/commands/table.c b/src/backend/distributed/commands/table.c index fe396e7d9..e1a5b3481 100644 --- a/src/backend/distributed/commands/table.c +++ b/src/backend/distributed/commands/table.c @@ -1738,11 +1738,14 @@ PostprocessAlterTableStmt(AlterTableStmt *alterTableStatement) Oid seqOid = GetSequenceOid(relationId, attnum); if (seqOid != InvalidOid) { + SequenceInfo *seqInfo = (SequenceInfo *) palloc(sizeof(SequenceInfo)); + + seqInfo->sequenceOid = seqOid; + seqInfo->attributeNumber = attnum; + seqInfo->isNextValDefault = true; + EnsureDistributedSequencesHaveOneType(relationId, - list_make1_oid( - seqOid), - list_make1_int( - attnum)); + list_make1(seqInfo)); if (ShouldSyncTableMetadata(relationId) && ClusterHasKnownMetadataWorkers()) @@ -1781,9 +1784,14 @@ PostprocessAlterTableStmt(AlterTableStmt *alterTableStatement) Oid seqOid = GetSequenceOid(relationId, attnum); if (seqOid != InvalidOid) { + SequenceInfo *seqInfo = (SequenceInfo *) palloc(sizeof(SequenceInfo)); + + seqInfo->sequenceOid = seqOid; + seqInfo->attributeNumber = attnum; + seqInfo->isNextValDefault = true; + EnsureDistributedSequencesHaveOneType(relationId, - list_make1_oid(seqOid), - list_make1_int(attnum)); + list_make1(seqInfo)); if (ShouldSyncTableMetadata(relationId) && ClusterHasKnownMetadataWorkers())