mirror of https://github.com/citusdata/citus.git
Call InvalidateForeignKeyGraph before fetching connected relations
parent
5304eeb291
commit
29f2891e66
|
|
@ -598,7 +598,7 @@ NoticeRelationIsAlreadyAddedToMetadata(Oid relationId)
|
||||||
char *relname = get_rel_name(relationId);
|
char *relname = get_rel_name(relationId);
|
||||||
ereport(NOTICE, (errmsg("relation \"%s\" is already added to metadata", relname),
|
ereport(NOTICE, (errmsg("relation \"%s\" is already added to metadata", relname),
|
||||||
errdetail("This relation will not be removed from metadata even if "
|
errdetail("This relation will not be removed from metadata even if "
|
||||||
"it is not connected to a reference table via foreign "
|
"it is not connected to a reference table via foreign "
|
||||||
"key(s), since it is added to metadata by the user")));
|
"key(s), since it is added to metadata by the user")));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -627,6 +627,7 @@ GetCascadeTypeForCitusLocalTables(bool autoConverted)
|
||||||
static void
|
static void
|
||||||
UpdateAutoConvertedForConnectedRelations(Oid relationId, bool autoConverted)
|
UpdateAutoConvertedForConnectedRelations(Oid relationId, bool autoConverted)
|
||||||
{
|
{
|
||||||
|
InvalidateForeignKeyGraph();
|
||||||
List *relationIdList = GetForeignKeyConnectedRelationIdList(relationId);
|
List *relationIdList = GetForeignKeyConnectedRelationIdList(relationId);
|
||||||
Oid relid = InvalidOid;
|
Oid relid = InvalidOid;
|
||||||
foreach_oid(relid, relationIdList)
|
foreach_oid(relid, relationIdList)
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue