From ef3a81fe79d7ce8bc0bb4557f8ca5f0ae2b3c431 Mon Sep 17 00:00:00 2001 From: Onder Kalaci Date: Fri, 2 Dec 2022 11:03:23 +0100 Subject: [PATCH] DROP TABLE becomes idempotent for metadata sync - deetach sq --- src/backend/distributed/commands/dependencies.c | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/backend/distributed/commands/dependencies.c b/src/backend/distributed/commands/dependencies.c index d36662e7e..8f7cc4594 100644 --- a/src/backend/distributed/commands/dependencies.c +++ b/src/backend/distributed/commands/dependencies.c @@ -519,10 +519,13 @@ CreateDropTableIfExistsCommand(Oid relationId) { char *schemaName = get_namespace_name(get_rel_namespace(relationId)); char *relationName = get_rel_name(relationId); + const char *quotedRelName = quote_qualified_identifier(schemaName, relationName); StringInfo workerDropQuery = makeStringInfo(); - const char *quotedRelName = quote_qualified_identifier(schemaName, relationName); + appendStringInfo(workerDropQuery, "SELECT worker_drop_sequence_dependency('%s');", + quotedRelName); + if (IsForeignTable(relationId)) { appendStringInfo(workerDropQuery, DROP_FOREIGN_TABLE_COMMAND, quotedRelName); @@ -532,6 +535,7 @@ CreateDropTableIfExistsCommand(Oid relationId) appendStringInfo(workerDropQuery, DROP_REGULAR_TABLE_COMMAND, quotedRelName); } + appendStringInfoString(workerDropQuery, ";"); return workerDropQuery->data; }