creation version

add_default_version
Onder Kalaci 2021-12-21 13:59:55 +01:00
parent 61e65a742d
commit 11aeeb59c8
3 changed files with 10 additions and 2 deletions

View File

@ -2282,7 +2282,7 @@ DistNodeNodeIdIndexId(void)
Oid
DistLocalGroupIdRelationId(void)
{
CachedRelationLookup("pg_dist_local_group",
CachedRelationLookup("pg_dist_local_node_info",
&MetadataCache.distLocalGroupRelationId);
return MetadataCache.distLocalGroupRelationId;

View File

@ -1487,7 +1487,7 @@ LocalGroupIdUpdateCommand(int32 groupId)
{
StringInfo updateCommand = makeStringInfo();
appendStringInfo(updateCommand, "UPDATE pg_dist_local_group SET groupid = %d",
appendStringInfo(updateCommand, "UPDATE pg_dist_local_node_info SET groupid = %d",
groupId);
return updateCommand->data;

View File

@ -30,3 +30,11 @@ BEGIN
END IF;
END;
$$;
ALTER TABLE pg_dist_local_group DISABLE TRIGGER dist_local_group_cache_invalidate;
ALTER TABLE pg_dist_local_group RENAME TO pg_dist_local_node_info;
ALTER TABLE pg_dist_local_node_info ADD COLUMN citus_creation_version TEXT DEFAULT NULL;
UPDATE pg_dist_local_node_info SET citus_creation_version = (SELECT default_version FROM pg_available_extensions WHERE name = 'citus');
ALTER TRIGGER dist_local_group_cache_invalidate ON pg_dist_local_node_info RENAME TO dist_local_info_cache_invalidate;
ALTER TABLE pg_dist_local_node_info ENABLE TRIGGER dist_local_info_cache_invalidate;