diff --git a/src/backend/distributed/commands/database.c b/src/backend/distributed/commands/database.c index 444745b4c..88aea7abb 100644 --- a/src/backend/distributed/commands/database.c +++ b/src/backend/distributed/commands/database.c @@ -241,7 +241,6 @@ PreprocessAlterDatabaseSetStmt(Node *node, const char *queryString, } - AlterDatabaseSetStmt *stmt = castNode(AlterDatabaseSetStmt, node); EnsureCoordinator(); @@ -353,14 +352,19 @@ citus_internal_database_command(PG_FUNCTION_ARGS) PG_RETURN_VOID(); } -static char * GetUnmarkDatabaseDistributedSql(char* dbName){ + +static char * +GetUnmarkDatabaseDistributedSql(char *dbName) +{ StringInfoData pg_dist_object_delete = { 0 }; initStringInfo(&pg_dist_object_delete); appendStringInfo(&pg_dist_object_delete, "delete from pg_dist_object where " - "objid in (select oid from pg_database where datname = '%s')",dbName); + "objid in (select oid from pg_database where datname = '%s')", + dbName); return pg_dist_object_delete.data; } + List * PreprocessDropDatabaseStmt(Node *node, const char *queryString, ProcessUtilityContext processUtilityContext) @@ -383,7 +387,6 @@ PreprocessDropDatabaseStmt(Node *node, const char *queryString, } - ObjectAddress dbAddress = { 0 }; ObjectAddressSet(dbAddress, DatabaseRelationId, databaseOid); if (!IsObjectDistributed(&dbAddress))