diff options
author | Teodor Sigaev <teodor@sigaev.ru> | 2005-08-30 08:36:52 +0000 |
---|---|---|
committer | Teodor Sigaev <teodor@sigaev.ru> | 2005-08-30 08:36:52 +0000 |
commit | d4235f9f18160c160a088c4ded9f953420146147 (patch) | |
tree | 6a080c33bff51a5a190440ebef516c3bdfc47ab2 /src/backend/access/gist/gistscan.c | |
parent | 2ba05400242c31604c14a1d0276abeabc7d7ed77 (diff) | |
download | postgresql-d4235f9f18160c160a088c4ded9f953420146147.tar.gz postgresql-d4235f9f18160c160a088c4ded9f953420146147.zip |
Fix missing rows in query
update a=.. where a... with GiST index on column 'a'
Backpatch from 8.0 branch
Diffstat (limited to 'src/backend/access/gist/gistscan.c')
-rw-r--r-- | src/backend/access/gist/gistscan.c | 38 |
1 files changed, 25 insertions, 13 deletions
diff --git a/src/backend/access/gist/gistscan.c b/src/backend/access/gist/gistscan.c index 790048aef38..9616d4d19c2 100644 --- a/src/backend/access/gist/gistscan.c +++ b/src/backend/access/gist/gistscan.c @@ -8,7 +8,7 @@ * Portions Copyright (c) 1994, Regents of the University of California * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/access/gist/gistscan.c,v 1.47 2003/08/04 02:39:57 momjian Exp $ + * $Header: /cvsroot/pgsql/src/backend/access/gist/gistscan.c,v 1.47.4.1 2005/08/30 08:36:52 teodor Exp $ * *------------------------------------------------------------------------- */ @@ -24,7 +24,7 @@ static void gistregscan(IndexScanDesc s); static void gistdropscan(IndexScanDesc s); static void gistadjone(IndexScanDesc s, int op, BlockNumber blkno, OffsetNumber offnum); -static void adjuststack(GISTSTACK *stk, BlockNumber blkno); +static void adjuststack(GISTSTACK *stk, int op,BlockNumber blkno, OffsetNumber offnum); static void adjustiptr(IndexScanDesc s, ItemPointer iptr, int op, BlockNumber blkno, OffsetNumber offnum); @@ -313,11 +313,8 @@ gistadjone(IndexScanDesc s, so = (GISTScanOpaque) s->opaque; - if (op == GISTOP_SPLIT) - { - adjuststack(so->s_stack, blkno); - adjuststack(so->s_markstk, blkno); - } + adjuststack(so->s_stack, op, blkno, offnum); + adjuststack(so->s_markstk, op, blkno, offnum); } /* @@ -399,16 +396,31 @@ adjustiptr(IndexScanDesc s, * access method update code for heaps; if we've modified the tuple we * are looking at already in this transaction, we ignore the update * request. + * If index tuple on our parent stack has been deleted, we need + * to make step back to avoid miss. */ -/*ARGSUSED*/ static void -adjuststack(GISTSTACK *stk, - BlockNumber blkno) +adjuststack(GISTSTACK *stk, int op, BlockNumber blkno, OffsetNumber offnum) { - while (stk != (GISTSTACK *) NULL) + while (stk != NULL) { - if (stk->gs_blk == blkno) - stk->gs_child = FirstOffsetNumber; + if (stk->gs_blk == blkno) { + switch (op) { + case GISTOP_DEL: + if ( stk->gs_child >= offnum ) { + if ( stk->gs_child > FirstOffsetNumber ) + stk->gs_child = OffsetNumberPrev( stk->gs_child ); + else + stk->gs_child = InvalidOffsetNumber; + } + break; + case GISTOP_SPLIT: + stk->gs_child = InvalidOffsetNumber; + break; + default: + elog(ERROR, "Bad operation in GiST scan adjust: %d", op); + } + } stk = stk->gs_parent; } |