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

DROP TABLE becomes idempotent for metadata sync - t2

metadata_sync_partially_non_tx
Onder Kalaci 2022-12-02 11:28:26 +01:00
parent ef3a81fe79
commit e0f2c3fa52
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/backend/distributed/commands/dependencies.c
View File

@ -517,22 +517,21 @@ GetDependencyCreateDDLCommands(const ObjectAddress *dependency)
static char * static char *
CreateDropTableIfExistsCommand(Oid relationId) CreateDropTableIfExistsCommand(Oid relationId)
{ {
char *schemaName = get_namespace_name(get_rel_namespace(relationId)); char *relationName = generate_qualified_relation_name(relationId);
char *relationName = get_rel_name(relationId);
const char *quotedRelName = quote_qualified_identifier(schemaName, relationName);
StringInfo workerDropQuery = makeStringInfo(); StringInfo workerDropQuery = makeStringInfo();
appendStringInfo(workerDropQuery, "SELECT worker_drop_sequence_dependency('%s');", appendStringInfo(workerDropQuery, "SELECT worker_drop_sequence_dependency(%s);",
quotedRelName); quote_literal_cstr(relationName));
if (IsForeignTable(relationId)) if (IsForeignTable(relationId))
{ {
appendStringInfo(workerDropQuery, DROP_FOREIGN_TABLE_COMMAND, quotedRelName); appendStringInfo(workerDropQuery, DROP_FOREIGN_TABLE_COMMAND, relationName);
} }
else else
{ {
appendStringInfo(workerDropQuery, DROP_REGULAR_TABLE_COMMAND, quotedRelName); appendStringInfo(workerDropQuery, DROP_REGULAR_TABLE_COMMAND, relationName);
} }
appendStringInfoString(workerDropQuery, ";"); appendStringInfoString(workerDropQuery, ";");