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

Fixes indentation

pull/7253/head
gindibay 2023-10-11 18:09:45 +03:00
parent 37d2a5f5a8
commit fd521f2792
2 changed files with 39 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/backend/distributed/commands/database.c
View File

@ -182,16 +182,23 @@ PreprocessAlterDatabaseStmt(Node *node, const char *queryString,
char *sql = DeparseTreeNode((Node *) stmt); char *sql = DeparseTreeNode((Node *) stmt);
if (strstr(sql, "SET TABLESPACE") != NULL) { if (strstr(sql, "SET TABLESPACE") != NULL)
if (IsCoordinatorNode()){ {
ereport(NOTICE, (errmsg("Citus partially supports ALTER DATABASE SET TABLESPACE for " if (IsCoordinatorNode())
{
ereport(NOTICE, (errmsg(
"Citus partially supports ALTER DATABASE SET TABLESPACE for "
"distributed databases"), "distributed databases"),
errdetail("Citus does not propagate ALTER DATABASE SET TABLESPACE " errdetail(
"Citus does not propagate ALTER DATABASE SET TABLESPACE "
"command to workers"), "command to workers"),
errhint("You can manually alter a tablespace for a database and its " errhint(
"You can manually alter a tablespace for a database and its "
"extensions on workers."))); "extensions on workers.")));
} }
}else{ }
else
{
List *commands = list_make3(DISABLE_DDL_PROPAGATION, List *commands = list_make3(DISABLE_DDL_PROPAGATION,
(void *) sql, (void *) sql,
ENABLE_DDL_PROPAGATION); ENABLE_DDL_PROPAGATION);
@ -199,7 +206,6 @@ PreprocessAlterDatabaseStmt(Node *node, const char *queryString,
return NodeDDLTaskList(NON_COORDINATOR_NODES, commands); return NodeDDLTaskList(NON_COORDINATOR_NODES, commands);
} }
return NIL; return NIL;
} }
@ -422,7 +428,7 @@ citus_internal_database_command(PG_FUNCTION_ARGS)
if (OidIsValid(databaseOid)) if (OidIsValid(databaseOid))
{ {
AlterDatabase(NULL, (AlterDatabaseStmt *) parseTree,true); AlterDatabase(NULL, (AlterDatabaseStmt *) parseTree, true);
} }
} }
else else

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

@ -112,9 +112,13 @@ AppendGrantOnDatabaseStmt(StringInfo buf, GrantStmt *stmt)
AppendGrantSharedSuffix(buf, stmt); AppendGrantSharedSuffix(buf, stmt);
} }
static void static void
AppendBasicAlterDatabaseOptions(StringInfo buf,DefElem *def, bool prefix_appended_for_basic_options, char *dbname ){ AppendBasicAlterDatabaseOptions(StringInfo buf, DefElem *def, bool
if(!prefix_appended_for_basic_options){ prefix_appended_for_basic_options, char *dbname)
{
if (!prefix_appended_for_basic_options)
{
appendStringInfo(buf, "ALTER DATABASE %s WITH ", quote_identifier(dbname)); appendStringInfo(buf, "ALTER DATABASE %s WITH ", quote_identifier(dbname));
prefix_appended_for_basic_options = true; prefix_appended_for_basic_options = true;
} }
@ -122,12 +126,15 @@ AppendBasicAlterDatabaseOptions(StringInfo buf,DefElem *def, bool prefix_appende
alter_database_option_formats)); alter_database_option_formats));
} }
static void static void
AppendAlterDatabaseSetTablespace(StringInfo buf,DefElem *def, char *dbname ){ AppendAlterDatabaseSetTablespace(StringInfo buf, DefElem *def, char *dbname)
appendStringInfo(buf,"ALTER DATABASE %s SET TABLESPACE %s", {
quote_identifier(dbname),quote_identifier(defGetString(def))); appendStringInfo(buf, "ALTER DATABASE %s SET TABLESPACE %s",
quote_identifier(dbname), quote_identifier(defGetString(def)));
} }
static void static void
AppendAlterDatabaseStmt(StringInfo buf, AlterDatabaseStmt *stmt) AppendAlterDatabaseStmt(StringInfo buf, AlterDatabaseStmt *stmt)
{ {
@ -138,13 +145,16 @@ AppendAlterDatabaseStmt(StringInfo buf, AlterDatabaseStmt *stmt)
foreach(cell, stmt->options) foreach(cell, stmt->options)
{ {
DefElem *def = castNode(DefElem, lfirst(cell)); DefElem *def = castNode(DefElem, lfirst(cell));
if (strcmp(def->defname,"tablespace") == 0) if (strcmp(def->defname, "tablespace") == 0)
{ {
AppendAlterDatabaseSetTablespace(buf,def,stmt->dbname); AppendAlterDatabaseSetTablespace(buf, def, stmt->dbname);
break; break;
} }
else{ else
AppendBasicAlterDatabaseOptions(buf,def,prefix_appended_for_basic_options,stmt->dbname); {
AppendBasicAlterDatabaseOptions(buf, def,
prefix_appended_for_basic_options,
stmt->dbname);
} }
} }
} }