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

Testing purpose: test 'alter extension update'

pull/5911/head
Yanwen Jin 2022-06-07 12:54:07 -07:00
parent 1960e978da
commit 7174fb87a0
1 changed files with 28 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -77,6 +77,7 @@
#include "nodes/makefuncs.h"
#include "tcop/utility.h"
#include "utils/builtins.h"
#include "utils/fmgroids.h"
#include "utils/lsyscache.h"
#include "utils/syscache.h"
@ -212,7 +213,6 @@ multi_ProcessUtility(PlannedStmt *pstmt,
{
const char *newVersion = defGetString(newVersionValue);
const char schemaVersionSeparator = '-';
char *leftSeperatorPosition = strchr(newVersion, schemaVersionSeparator);
versionNumber = strtod(leftSeperatorPosition, NULL);
}
@ -673,6 +673,18 @@ ProcessUtilityInternal(PlannedStmt *pstmt,
AlterExtensionUpdateStmt("citus_columnar", "11.1-0");
}
}
else
{
Oid citusColumnarOid = get_extension_oid("citus_columnar", true);
double versionNumber = strtod(CITUS_MAJORVERSION, NULL);
if (versionNumber >= 11.1)
{
if (citusColumnarOid == InvalidOid)
{
CreateExtensionWithVersion("citus_columnar", "11.1-0");
}
}
}
}
PrevProcessUtility_compat(pstmt, queryString, false, context,
@ -706,6 +718,21 @@ ProcessUtilityInternal(PlannedStmt *pstmt,
}
}
}
else
{
Oid citusColumnarOid = get_extension_oid("citus_columnar", true);
Oid citusOid = get_extension_oid("citus", true);
double versionNumber = strtod(CITUS_MAJORVERSION, NULL);
if (versionNumber >= 11.1)
{
char *curColumnarVersion = get_extension_version(citusColumnarOid);
char *citusversion = get_extension_version(citusOid);
if (strcmp(citusversion, "11.1-1") == 0)
{
AlterExtensionUpdateStmt("citus_columnar", "11.1-1");
}
}
}
}
/*