database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-07-28 23:42:10 +03:00
Code Activity

Fixed concurrent visibility bug.

Browse Source 
Jan
This commit is contained in:
Jan Wieck
1999-12-08 20:41:22 +00:00
parent b7539d92f9
commit 0882951b0c
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/backend/utils/adt/ri_triggers.c
View File

@ -6,7 +6,7 @@
* *
* 1999 Jan Wieck * 1999 Jan Wieck
* *
* $Header: /cvsroot/pgsql/src/backend/utils/adt/ri_triggers.c,v 1.8 1999/12/07 00:13:41 wieck Exp $ * $Header: /cvsroot/pgsql/src/backend/utils/adt/ri_triggers.c,v 1.9 1999/12/08 20:41:22 wieck Exp $
* *
* ---------- * ----------
*/ */
@ -231,7 +231,8 @@ RI_FKey_check (FmgrInfo *proinfo)
* SELECT oid FROM <pktable> * SELECT oid FROM <pktable>
* ---------- * ----------
*/ */
sprintf(querystr, "SELECT oid FROM \"%s\"", sprintf(querystr, "SELECT oid FROM \"%s\" FOR UPDATE OF \"%s\"",
tgargs[RI_PK_RELNAME_ARGNO],
tgargs[RI_PK_RELNAME_ARGNO]); tgargs[RI_PK_RELNAME_ARGNO]);
/* ---------- /* ----------
@ -378,6 +379,9 @@ RI_FKey_check (FmgrInfo *proinfo)
queryoids[i] = SPI_gettypeid(fk_rel->rd_att, queryoids[i] = SPI_gettypeid(fk_rel->rd_att,
qkey.keypair[i][RI_KEYPAIR_FK_IDX]); qkey.keypair[i][RI_KEYPAIR_FK_IDX]);
} }
sprintf(buf, " FOR UPDATE OF \"%s\"",
tgargs[RI_PK_RELNAME_ARGNO]);
strcat(querystr, buf);
/* ---------- /* ----------
* Prepare, save and remember the new plan. * Prepare, save and remember the new plan.
@ -1021,6 +1025,9 @@ RI_FKey_restrict_del (FmgrInfo *proinfo)
queryoids[i] = SPI_gettypeid(pk_rel->rd_att, queryoids[i] = SPI_gettypeid(pk_rel->rd_att,
qkey.keypair[i][RI_KEYPAIR_PK_IDX]); qkey.keypair[i][RI_KEYPAIR_PK_IDX]);
} }
sprintf(buf, " FOR UPDATE OF \"%s\"",
tgargs[RI_FK_RELNAME_ARGNO]);
strcat(querystr, buf);
/* ---------- /* ----------
* Prepare, save and remember the new plan. * Prepare, save and remember the new plan.
@ -1234,6 +1241,9 @@ RI_FKey_restrict_upd (FmgrInfo *proinfo)
queryoids[i] = SPI_gettypeid(pk_rel->rd_att, queryoids[i] = SPI_gettypeid(pk_rel->rd_att,
qkey.keypair[i][RI_KEYPAIR_PK_IDX]); qkey.keypair[i][RI_KEYPAIR_PK_IDX]);
} }
sprintf(buf, " FOR UPDATE OF \"%s\"",
tgargs[RI_FK_RELNAME_ARGNO]);
strcat(querystr, buf);
/* ---------- /* ----------
* Prepare, save and remember the new plan. * Prepare, save and remember the new plan.