mirror of https://github.com/citusdata/citus.git
Clean up after merge
parent
06babdbdbe
commit
1a88d2eb53
|
@ -2020,7 +2020,7 @@ columnar_tableam_init()
|
||||||
NULL,
|
NULL,
|
||||||
&EnableVersionChecksColumnar,
|
&EnableVersionChecksColumnar,
|
||||||
true,
|
true,
|
||||||
PGC_SUSET,
|
PGC_USERSET,
|
||||||
GUC_NO_SHOW_ALL,
|
GUC_NO_SHOW_ALL,
|
||||||
NULL, NULL, NULL);
|
NULL, NULL, NULL);
|
||||||
}
|
}
|
||||||
|
@ -2417,59 +2417,6 @@ ColumnarProcessUtility(PlannedStmt *pstmt,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (IsA(parsetree, CreateExtensionStmt))
|
|
||||||
{
|
|
||||||
CreateExtensionStmt *createExtensionStmt = castNode(CreateExtensionStmt,
|
|
||||||
parsetree);
|
|
||||||
|
|
||||||
if (get_extension_oid("citus_columnar", true) == InvalidOid)
|
|
||||||
{
|
|
||||||
if (strcmp(createExtensionStmt->extname, "citus_columnar") == 0)
|
|
||||||
{
|
|
||||||
DefElem *newVersionValue = GetExtensionOption(
|
|
||||||
createExtensionStmt->options,
|
|
||||||
"new_version");
|
|
||||||
if (newVersionValue)
|
|
||||||
{
|
|
||||||
const char *newVersion = defGetString(newVersionValue);
|
|
||||||
if (strcmp(newVersion, "11.1-0") == 0)
|
|
||||||
{
|
|
||||||
ereport(ERROR, (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
|
|
||||||
errmsg(
|
|
||||||
"unsupported citus_columnar version 11.1-0")));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/*latest citus requires install columnar first, existing citus can only be an older version */
|
|
||||||
if (get_extension_oid("citus", true) != InvalidOid)
|
|
||||||
{
|
|
||||||
ereport(ERROR, (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
|
|
||||||
errmsg(
|
|
||||||
"must upgrade citus to version 11.1-1 first")));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (IsA(parsetree, AlterExtensionStmt))
|
|
||||||
{
|
|
||||||
AlterExtensionStmt *alterExtensionStmt = castNode(AlterExtensionStmt, parsetree);
|
|
||||||
if (strcmp(alterExtensionStmt->extname, "citus_columnar") == 0)
|
|
||||||
{
|
|
||||||
DefElem *newVersionValue = GetExtensionOption(alterExtensionStmt->options,
|
|
||||||
"new_version");
|
|
||||||
if (newVersionValue)
|
|
||||||
{
|
|
||||||
const char *newVersion = defGetString(newVersionValue);
|
|
||||||
if (strcmp(newVersion, "11.1-0") == 0)
|
|
||||||
{
|
|
||||||
ereport(ERROR, (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
|
|
||||||
errmsg("unsupported citus_columnar version 11.1-0")));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
PrevProcessUtilityHook_compat(pstmt, queryString, false, context,
|
PrevProcessUtilityHook_compat(pstmt, queryString, false, context,
|
||||||
params, queryEnv, dest, completionTag);
|
params, queryEnv, dest, completionTag);
|
||||||
|
|
||||||
|
|
|
@ -16,3 +16,4 @@ DROP FUNCTION pg_catalog.run_command_on_coordinator(text,boolean);
|
||||||
|
|
||||||
DROP FUNCTION pg_catalog.start_metadata_sync_to_all_nodes();
|
DROP FUNCTION pg_catalog.start_metadata_sync_to_all_nodes();
|
||||||
DROP FUNCTION pg_catalog.citus_finalize_upgrade_to_citus11(boolean);
|
DROP FUNCTION pg_catalog.citus_finalize_upgrade_to_citus11(boolean);
|
||||||
|
#include "../udfs/citus_finalize_upgrade_to_citus11/11.0-1.sql"
|
||||||
|
|
Loading…
Reference in New Issue