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

Fixes comments

pull/7240/head
gindibay 2023-11-13 14:23:37 +03:00
parent 3731c45c29
commit 712fd8ebf3
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/backend/distributed/deparser/deparse_database_stmts.c
View File

@ -332,7 +332,7 @@ AppendDropDatabaseStmt(StringInfo buf, DropdbStmt *stmt)
foreach_ptr(option, stmt->options) foreach_ptr(option, stmt->options)
{ {
//if it is the first option then append with "WITH" else append with "," /*if it is the first option then append with "WITH" else append with "," */
if (option == linitial(stmt->options)) if (option == linitial(stmt->options))
{ {
appendStringInfo(buf, " WITH ( "); appendStringInfo(buf, " WITH ( ");
@ -353,12 +353,11 @@ AppendDropDatabaseStmt(StringInfo buf, DropdbStmt *stmt)
option->defname))); option->defname)));
} }
//if it is the last option then append with ")" /*if it is the last option then append with ")" */
if (option == llast(stmt->options)) if (option == llast(stmt->options))
{ {
appendStringInfo(buf, " )"); appendStringInfo(buf, " )");
} }
} }
} }

2
src/backend/distributed/metadata/distobject.c
View File

@ -386,7 +386,7 @@ UnmarkNodeWideObjectsDistributed(Node *node)
Oid dbOid = get_database_oid(dbName, stmt->missing_ok); Oid dbOid = get_database_oid(dbName, stmt->missing_ok);
ObjectAddress *dbObjectAddress = palloc0(sizeof(ObjectAddress)); ObjectAddress *dbObjectAddress = palloc0(sizeof(ObjectAddress));
ObjectAddressSet(*dbObjectAddress, DatabaseRelationId, dbOid); ObjectAddressSet(*dbObjectAddress, DatabaseRelationId, dbOid);
if(IsAnyObjectDistributed(list_make1(dbObjectAddress))) if (IsAnyObjectDistributed(list_make1(dbObjectAddress)))
{ {
UnmarkObjectDistributed(dbObjectAddress); UnmarkObjectDistributed(dbObjectAddress);
} }