Commit11d0677

authored and

committed

Fix bug in handling tables without primary key

1 parentd4bcc33 commit11d0677Copy full SHA for 11d0677

File tree

-6

lines changed

-6

lines changed

Lines changed: 9 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -2395,15 +2395,18 @@ MtmExecutorFinish(QueryDesc *queryDesc)`
`2395`	`2395`	`for (i=0;i<estate->es_num_result_relations;i++) {`
`2396`	`2396`	`Relationrel=estate->es_result_relations[i].ri_RelationDesc;`
`2397`	`2397`	`if (RelationNeedsWAL(rel)) {`
	`2398`	`+if (MtmIgnoreTablesWithoutPk) {`
	`2399`	`+if (!rel->rd_indexvalid) {`
	`2400`	`+RelationGetIndexList(rel);`
	`2401`	`+}`
	`2402`	`+if (rel->rd_replidindex==InvalidOid) {`
	`2403`	`+MtmMakeRelationLocal(RelationGetRelid(rel));`
	`2404`	`+continue;`
	`2405`	`+}`
	`2406`	`+}`
`2398`	`2407`	`MtmTx.containsDML= true;`
`2399`	`2408`	`break;`
`2400`	`2409`	`}`
`2401`		`-if (MtmIgnoreTablesWithoutPk) {`
`2402`		`-if (!rel->rd_indexvalid) {`
`2403`		`-RelationGetIndexList(rel);`
`2404`		`-}`
`2405`		`-MtmMakeRelationLocal(rel->rd_replidindex);`
`2406`		`-}`
`2407`	`2410`	`}`
`2408`	`2411`	`}`
`2409`	`2412`	`if (MtmTx.isDistributed&&MtmTx.containsDML&& !IsTransactionBlock()) {`

Comments

(0)