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

Refactor VacuumStmt checker to be single-return 

Decided this would be safer for the future (defaults to unsupported).
pull/2077/head
Jason Petersen 2017-11-27 11:49:46 -07:00 committed by velioglu
parent d851732f5b
commit f81987ea36
1 changed files with 12 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/backend/distributed/executor/multi_utility.c
View File

@ -1538,43 +1538,39 @@ static bool
IsSupportedDistributedVacuumStmt(Oid relationId, VacuumStmt *vacuumStmt)
{
const char *stmtName = (vacuumStmt->options & VACOPT_VACUUM) ? "VACUUM" : "ANALYZE";
bool distributeStmt = false;
if (vacuumStmt->relation == NULL)
{
/* WARN and exit early for unqualified VACUUM commands */
/* WARN for unqualified VACUUM commands */
ereport(WARNING, (errmsg("not propagating %s command to worker nodes", stmtName),
errhint("Provide a specific table in order to %s "
"distributed tables.", stmtName)));
return false;
}
if (!OidIsValid(relationId) || !IsDistributedTable(relationId))
else if (!OidIsValid(relationId) || !IsDistributedTable(relationId))
{
return false;
/* Nothing to do here; relation no longer exists or is not distributed */
}
if (!EnableDDLPropagation)
else if (!EnableDDLPropagation)
{
/* WARN and exit early if DDL propagation is not enabled */
/* WARN if DDL propagation is not enabled */
ereport(WARNING, (errmsg("not propagating %s command to worker nodes", stmtName),
errhint("Set citus.enable_ddl_propagation to true in order to "
"send targeted %s commands to worker nodes.",
stmtName)));
return false;
}
if (vacuumStmt->options & VACOPT_VERBOSE)
else if (vacuumStmt->options & VACOPT_VERBOSE)
{
ereport(ERROR, (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
errmsg("the VERBOSE option is currently unsupported in "
"distributed %s commands", stmtName)));
return false;
}
else
{
distributeStmt = true;
}
return true;
return distributeStmt;
}