From 0d28702b27ec73bb73f177f4c9fe49860ab5fb26 Mon Sep 17 00:00:00 2001 From: gurkanindibay Date: Thu, 15 Feb 2024 15:17:30 +0300 Subject: [PATCH] Fixes review notes --- src/backend/distributed/commands/utility_hook.c | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/backend/distributed/commands/utility_hook.c b/src/backend/distributed/commands/utility_hook.c index a0234aec8..458c4b3a9 100644 --- a/src/backend/distributed/commands/utility_hook.c +++ b/src/backend/distributed/commands/utility_hook.c @@ -158,7 +158,7 @@ static void RunPreprocessMainDBCommand(Node *parsetree); static void RunPostprocessMainDBCommand(Node *parsetree); static bool IsStatementSupportedFromNonMainDb(Node *parsetree); static bool StatementRequiresMarkDistributedFromNonMainDb(Node *parsetree); -static void MarkObjectDistributedOnNonMainDb(Node *parsetree); +static void MarkObjectDistributedFromNonMainDb(Node *parsetree); static MarkObjectDistributedParams GetMarkObjectDistributedParams(Node *parsetree); /* @@ -1643,6 +1643,7 @@ RunPreprocessMainDBCommand(Node *parsetree) { return; } + char *queryString = DeparseTreeNode(parsetree); StringInfo mainDBQuery = makeStringInfo(); appendStringInfo(mainDBQuery, @@ -1668,7 +1669,7 @@ RunPostprocessMainDBCommand(Node *parsetree) if (IsStatementSupportedFromNonMainDb(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. */ static void -MarkObjectDistributedOnNonMainDb(Node *parsetree) +MarkObjectDistributedFromNonMainDb(Node *parsetree) { MarkObjectDistributedParams markObjectDistributedParams = GetMarkObjectDistributedParams(parsetree);