Commit431b316

committed

PG 11: check moved rows in router_lock_or_delete_tuple()

1 parent45e040a commit431b316Copy full SHA for 431b316

File tree

+14

-0

lines changed

+14

-0

lines changed

Lines changed: 10 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -529,6 +529,16 @@ char get_rel_persistence(Oid relid);`
`529`	`529`	`#endif`
`530`	`530`
`531`	`531`
	`532`	`+/*`
	`533`	`+ * ItemPointerIndicatesMovedPartitions()`
	`534`	`+ *`
	`535`	`+ * supported since v11, provide a stub for previous versions.`
	`536`	`+ */`
	`537`	`+#ifPG_VERSION_NUM<110000`
	`538`	`+#defineItemPointerIndicatesMovedPartitions(ctid) ( false )`
	`539`	`+#endif`
	`540`	`+`
	`541`	`+`
`532`	`542`	`/*`
`533`	`543`	`* make_restrictinfo()`
`534`	`544`	`*/`

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -575,6 +575,10 @@ router_lock_or_delete_tuple(PartitionRouterState *state,`
`575`	`575`	`ereport(ERROR,`
`576`	`576`	`(errcode(ERRCODE_T_R_SERIALIZATION_FAILURE),`
`577`	`577`	`errmsg("could not serialize access due to concurrent update")));`
	`578`	`+if (ItemPointerIndicatesMovedPartitions(&hufd.ctid))`
	`579`	`+ereport(ERROR,`
	`580`	`+(errcode(ERRCODE_T_R_SERIALIZATION_FAILURE),`
	`581`	`+errmsg("tuple to be updated was already moved to another partition due to concurrent update")));`
`578`	`582`
`579`	`583`	`if (!ItemPointerEquals(tupleid,&hufd.ctid))`
`580`	`584`	`{`

Comments

(0)