hcq/openGauss-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix update sub partition failed.

Browse Source
This commit is contained in:
TotaJ
2022-01-10 14:12:39 +08:00
parent 9fc8923859
commit 302bbb6280
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/gausskernel/runtime/executor/execReplication.cpp
View File

@ -156,11 +156,13 @@ static bool PartitionFindReplTupleByIndex(EState *estate, Relation rel, Relation
ListCell *cell = NULL;
foreach (cell, fakeRelInfo->partList) {
Partition heapPart = (Partition)lfirst(cell);
Relation partionRel = partitionGetRelation(rel, heapPart);
Relation partionRel = RelationIsSubPartitioned(rel) ? SubPartitionGetRelation(rel, heapPart, NoLock) :
partitionGetRelation(rel, heapPart);
/* Get index partition of this heap partition */
Oid idxPartOid = getPartitionIndexOid(RelationGetRelid(idxrel), heapPart->pd_id);
Partition idxPart = partitionOpen(idxrel, idxPartOid, RowExclusiveLock);
Relation idxPartRel = partitionGetRelation(idxrel, idxPart);
Relation idxPartRel = RelationIsSubPartitioned(rel) ? SubPartitionGetRelation(idxrel, idxPart, NoLock) :
partitionGetRelation(idxrel, idxPart);
fakeRelInfo->partRel = partionRel;
fakeRelInfo->part = heapPart;
@ -198,7 +200,8 @@ static bool PartitionFindReplTupleSeq(Relation rel, LockTupleMode lockmode,
ListCell *cell = NULL;
foreach (cell, fakeRelInfo->partList) {
Partition heapPart = (Partition)lfirst(cell);
Relation partionRel = partitionGetRelation(rel, heapPart);
Relation partionRel = RelationIsSubPartitioned(rel) ? SubPartitionGetRelation(rel, heapPart, NoLock) :
partitionGetRelation(rel, heapPart);
fakeRelInfo->partRel = partionRel;
fakeRelInfo->part = heapPart;