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

Merge branch 'niupre/TestDeferredDropAndCleanup' of https://github.com/citusdata/citus into niupre/TestDeferredDropAndCleanup

niupre/TestDeferredDropAndCleanup
Nitish Upreti 2022-09-06 10:51:12 -07:00
parent 2d5984cabd be1d91954b
commit 0e4295236c
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/backend/distributed/operations/shard_cleaner.c
View File

@ -660,8 +660,14 @@ GetNextOperationId()
}
/* Generate sequence using a subtransaction. else we can hold replication slot creation for operations */
StringInfo sequenceName = makeStringInfo();
appendStringInfo(sequenceName, "%s.%s",
PG_CATALOG,
OPERATIONID_SEQUENCE_NAME);
StringInfo nextValueCommand = makeStringInfo();
appendStringInfo(nextValueCommand, "SELECT nextval(%s);", OPERATIONID_SEQUENCE_NAME);
appendStringInfo(nextValueCommand, "SELECT nextval(%s);",
quote_literal_cstr(sequenceName->data));
int connectionFlag = FORCE_NEW_CONNECTION;
MultiConnection *connection = GetNodeUserDatabaseConnection(connectionFlag,