From d5c14f3b0bc3c0ae44ce5055c66b379ddea750f2 Mon Sep 17 00:00:00 2001 From: Sait Talha Nisanci Date: Wed, 20 Jan 2021 12:17:52 +0300 Subject: [PATCH] wip --- src/backend/distributed/cimv/create.c | 1 + src/backend/distributed/commands/utility_hook.c | 3 +++ 2 files changed, 4 insertions(+) diff --git a/src/backend/distributed/cimv/create.c b/src/backend/distributed/cimv/create.c index 7f5f3acd6..73fd21f93 100644 --- a/src/backend/distributed/cimv/create.c +++ b/src/backend/distributed/cimv/create.c @@ -719,6 +719,7 @@ CreateRefreshView(CimvCreate *cimvCreate) query->targetList = (List *) PartializeAggs((Node *) query->targetList, &inverse); AddCountAgg(query, true); + /* TODO:: we probably don't need this part until parse_analyze */ StringInfoData querybuf; initStringInfo(&querybuf); diff --git a/src/backend/distributed/commands/utility_hook.c b/src/backend/distributed/commands/utility_hook.c index 5dd58407e..41643c4ef 100644 --- a/src/backend/distributed/commands/utility_hook.c +++ b/src/backend/distributed/commands/utility_hook.c @@ -461,6 +461,9 @@ multi_ProcessUtility(PlannedStmt *pstmt, bool continueProcessing = true; if (IsA(parsetree, CreateTableAsStmt)) { + StringInfo buf = makeStringInfo(); + pg_get_query_def(parsetree, buf); + elog(WARNING, "%s", buf->data); continueProcessing = !ProcessCreateMaterializedViewStmt((const CreateTableAsStmt *) parsetree, queryString,