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

Example process utility

tmp-process-utility
Jeff Davis 2022-04-14 15:21:34 -07:00
parent 6254f30305
commit 637c334865
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/backend/distributed/commands/utility_hook.c
View File

@ -40,6 +40,7 @@
#include "catalog/dependency.h" #include "catalog/dependency.h"
#include "commands/dbcommands.h" #include "commands/dbcommands.h"
#include "commands/defrem.h" #include "commands/defrem.h"
#include "commands/extension.h"
#include "commands/tablecmds.h" #include "commands/tablecmds.h"
#include "distributed/adaptive_executor.h" #include "distributed/adaptive_executor.h"
#include "distributed/colocation_utils.h" #include "distributed/colocation_utils.h"
@ -193,6 +194,21 @@ multi_ProcessUtility(PlannedStmt *pstmt,
ErrorIfUnstableCreateOrAlterExtensionStmt(parsetree); ErrorIfUnstableCreateOrAlterExtensionStmt(parsetree);
} }
if (IsA(parsetree, CreateExtensionStmt))
{
CreateExtensionStmt *createExtensionStmt = castNode(CreateExtensionStmt, parsetree);
if (strcmp(createExtensionStmt->extname, "citus") == 0)
{
CreateExtensionStmt *createCitusStmt = makeNode(CreateExtensionStmt);
createCitusStmt->extname = "foo";
createCitusStmt->if_not_exists = true;
createCitusStmt->options = NIL;
CreateExtension(NULL, createCitusStmt);
CommandCounterIncrement();
}
}
if (!CitusHasBeenLoaded()) if (!CitusHasBeenLoaded())
{ {
/* /*