mirror of https://github.com/citusdata/citus.git
Fixes review notes
parent
b51183b2f6
commit
0d28702b27
|
@ -158,7 +158,7 @@ static void RunPreprocessMainDBCommand(Node *parsetree);
|
||||||
static void RunPostprocessMainDBCommand(Node *parsetree);
|
static void RunPostprocessMainDBCommand(Node *parsetree);
|
||||||
static bool IsStatementSupportedFromNonMainDb(Node *parsetree);
|
static bool IsStatementSupportedFromNonMainDb(Node *parsetree);
|
||||||
static bool StatementRequiresMarkDistributedFromNonMainDb(Node *parsetree);
|
static bool StatementRequiresMarkDistributedFromNonMainDb(Node *parsetree);
|
||||||
static void MarkObjectDistributedOnNonMainDb(Node *parsetree);
|
static void MarkObjectDistributedFromNonMainDb(Node *parsetree);
|
||||||
static MarkObjectDistributedParams GetMarkObjectDistributedParams(Node *parsetree);
|
static MarkObjectDistributedParams GetMarkObjectDistributedParams(Node *parsetree);
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
@ -1643,6 +1643,7 @@ RunPreprocessMainDBCommand(Node *parsetree)
|
||||||
{
|
{
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
char *queryString = DeparseTreeNode(parsetree);
|
char *queryString = DeparseTreeNode(parsetree);
|
||||||
StringInfo mainDBQuery = makeStringInfo();
|
StringInfo mainDBQuery = makeStringInfo();
|
||||||
appendStringInfo(mainDBQuery,
|
appendStringInfo(mainDBQuery,
|
||||||
|
@ -1668,7 +1669,7 @@ RunPostprocessMainDBCommand(Node *parsetree)
|
||||||
if (IsStatementSupportedFromNonMainDb(parsetree) &&
|
if (IsStatementSupportedFromNonMainDb(parsetree) &&
|
||||||
StatementRequiresMarkDistributedFromNonMainDb(parsetree))
|
StatementRequiresMarkDistributedFromNonMainDb(parsetree))
|
||||||
{
|
{
|
||||||
MarkObjectDistributedOnNonMainDb(parsetree);
|
MarkObjectDistributedFromNonMainDb(parsetree);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1718,11 +1719,11 @@ StatementRequiresMarkDistributedFromNonMainDb(Node *parsetree)
|
||||||
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* MarkObjectDistributedOnNonMainDb marks the given object as distributed on the
|
* MarkObjectDistributedFromNonMainDb marks the given object as distributed on the
|
||||||
* non-main database.
|
* non-main database.
|
||||||
*/
|
*/
|
||||||
static void
|
static void
|
||||||
MarkObjectDistributedOnNonMainDb(Node *parsetree)
|
MarkObjectDistributedFromNonMainDb(Node *parsetree)
|
||||||
{
|
{
|
||||||
MarkObjectDistributedParams markObjectDistributedParams =
|
MarkObjectDistributedParams markObjectDistributedParams =
|
||||||
GetMarkObjectDistributedParams(parsetree);
|
GetMarkObjectDistributedParams(parsetree);
|
||||||
|
|
Loading…
Reference in New Issue