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

AlterStatisticsSchemaStmtObjectAddress can also be called before standard_ProcessUtility

pull/6114/head
aykutbozkurt 2022-08-01 18:45:59 +03:00
parent 5060d0ab17
commit ef528442a8
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -359,9 +359,19 @@ AlterStatisticsSchemaStmtObjectAddress(Node *node, bool missingOk)
AlterObjectSchemaStmt *stmt = castNode(AlterObjectSchemaStmt, node); AlterObjectSchemaStmt *stmt = castNode(AlterObjectSchemaStmt, node);
ObjectAddress *address = palloc0(sizeof(ObjectAddress)); ObjectAddress *address = palloc0(sizeof(ObjectAddress));
String *statName = llast((List *) stmt->object); List *statName = (List *) stmt->object;
Oid statsOid = get_statistics_object_oid(list_make2(makeString(stmt->newschema), Oid statsOid = get_statistics_object_oid(statName, true);
statName), missingOk);
if (statsOid == InvalidOid)
{
/*
* couldn't find the stat, might have already been moved to the new schema, we
* construct a new stat name that uses the new schema to search in.
*/
List *newStatName = list_make2(makeString(stmt->newschema), llast(statName));
statsOid = get_statistics_object_oid(newStatName, missingOk);
}
ObjectAddressSet(*address, StatisticExtRelationId, statsOid); ObjectAddressSet(*address, StatisticExtRelationId, statsOid);
return list_make1(address); return list_make1(address);