From be1d91954bee411f6a958154a714831b6d28295c Mon Sep 17 00:00:00 2001 From: Nitish Upreti Date: Wed, 31 Aug 2022 10:30:04 -0700 Subject: [PATCH] Sequence Name fix --- src/backend/distributed/operations/shard_cleaner.c | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/src/backend/distributed/operations/shard_cleaner.c b/src/backend/distributed/operations/shard_cleaner.c index 74724ed1a..b0c41e53b 100644 --- a/src/backend/distributed/operations/shard_cleaner.c +++ b/src/backend/distributed/operations/shard_cleaner.c @@ -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,