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

WIP

release-10.2.onder.18.agu
Onder Kalaci 2022-08-18 13:30:43 +02:00
parent ebd83591bf
commit 75282bd5d1
1 changed files with 14 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/backend/distributed/commands/table.c
View File

@ -1738,11 +1738,14 @@ PostprocessAlterTableStmt(AlterTableStmt *alterTableStatement)
Oid seqOid = GetSequenceOid(relationId, attnum); Oid seqOid = GetSequenceOid(relationId, attnum);
if (seqOid != InvalidOid) if (seqOid != InvalidOid)
{ {
SequenceInfo *seqInfo = (SequenceInfo *) palloc(sizeof(SequenceInfo));
seqInfo->sequenceOid = seqOid;
seqInfo->attributeNumber = attnum;
seqInfo->isNextValDefault = true;
EnsureDistributedSequencesHaveOneType(relationId, EnsureDistributedSequencesHaveOneType(relationId,
list_make1_oid( list_make1(seqInfo));
seqOid),
list_make1_int(
attnum));
if (ShouldSyncTableMetadata(relationId) && if (ShouldSyncTableMetadata(relationId) &&
ClusterHasKnownMetadataWorkers()) ClusterHasKnownMetadataWorkers())
@ -1781,9 +1784,14 @@ PostprocessAlterTableStmt(AlterTableStmt *alterTableStatement)
Oid seqOid = GetSequenceOid(relationId, attnum); Oid seqOid = GetSequenceOid(relationId, attnum);
if (seqOid != InvalidOid) if (seqOid != InvalidOid)
{ {
SequenceInfo *seqInfo = (SequenceInfo *) palloc(sizeof(SequenceInfo));
seqInfo->sequenceOid = seqOid;
seqInfo->attributeNumber = attnum;
seqInfo->isNextValDefault = true;
EnsureDistributedSequencesHaveOneType(relationId, EnsureDistributedSequencesHaveOneType(relationId,
list_make1_oid(seqOid), list_make1(seqInfo));
list_make1_int(attnum));
if (ShouldSyncTableMetadata(relationId) && if (ShouldSyncTableMetadata(relationId) &&
ClusterHasKnownMetadataWorkers()) ClusterHasKnownMetadataWorkers())