~drizzle-trunk/drizzle/development

1 by brian
clean slate
1
/* Copyright (C) 2000-2002 MySQL AB
2
3
   This program is free software; you can redistribute it and/or modify
4
   it under the terms of the GNU General Public License as published by
5
   the Free Software Foundation; version 2 of the License.
6
7
   This program is distributed in the hope that it will be useful,
8
   but WITHOUT ANY WARRANTY; without even the implied warranty of
9
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
10
   GNU General Public License for more details.
11
12
   You should have received a copy of the GNU General Public License
13
   along with this program; if not, write to the Free Software
14
   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
15
16
#include "heapdef.h"
17
18
/* Read next record with the same key */
19
481 by Brian Aker
Remove all of uchar.
20
int heap_rnext(HP_INFO *info, unsigned char *record)
1 by brian
clean slate
21
{
481 by Brian Aker
Remove all of uchar.
22
  unsigned char *pos;
1 by brian
clean slate
23
  HP_SHARE *share=info->s;
24
  HP_KEYDEF *keyinfo;
25
  
26
  if (info->lastinx < 0)
51.3.1 by Jay Pipes
Removed all DBUG symbols from heap storage engine
27
    return(my_errno=HA_ERR_WRONG_INDEX);
1 by brian
clean slate
28
29
  keyinfo = share->keydef + info->lastinx;
30
  if (keyinfo->algorithm == HA_KEY_ALG_BTREE)
31
  {
32
    heap_rb_param custom_arg;
33
34
    if (info->last_pos)
35
    {
36
      /*
37
        We enter this branch for non-DELETE queries after heap_rkey()
38
        or heap_rfirst(). As last key position (info->last_pos) is available,
39
        we only need to climb the tree using tree_search_next().
40
      */
41
      pos = tree_search_next(&keyinfo->rb_tree, &info->last_pos,
42
                             offsetof(TREE_ELEMENT, left),
43
                             offsetof(TREE_ELEMENT, right));
44
    }
45
    else if (!info->lastkey_len)
46
    {
47
      /*
48
        We enter this branch only for DELETE queries after heap_rfirst(). E.g.
49
        DELETE FROM t1 WHERE a<10. As last key position is not available
50
        (last key is removed by heap_delete()), we must restart search as it
51
        is done in heap_rfirst().
52
53
        It should be safe to handle this situation without this branch. That is
54
        branch below should find smallest element in a tree as lastkey_len is
55
        zero. tree_search_edge() is a kind of optimisation here as it should be
56
        faster than tree_search_key().
57
      */
58
      pos= tree_search_edge(&keyinfo->rb_tree, info->parents,
59
                            &info->last_pos, offsetof(TREE_ELEMENT, left));
60
    }
61
    else
62
    {
63
      /*
64
        We enter this branch only for DELETE queries after heap_rkey(). E.g.
65
        DELETE FROM t1 WHERE a=10. As last key position is not available
66
        (last key is removed by heap_delete()), we must restart search as it
67
        is done in heap_rkey().
68
      */
69
      custom_arg.keyseg = keyinfo->seg;
70
      custom_arg.key_length = info->lastkey_len;
71
      custom_arg.search_flag = SEARCH_SAME | SEARCH_FIND;
72
      pos = tree_search_key(&keyinfo->rb_tree, info->lastkey, info->parents, 
73
                           &info->last_pos, info->last_find_flag, &custom_arg);
74
    }
75
    if (pos)
76
    {
77
      memcpy(&pos, pos + (*keyinfo->get_key_length)(keyinfo, pos), 
481 by Brian Aker
Remove all of uchar.
78
	     sizeof(unsigned char*));
1 by brian
clean slate
79
      info->current_ptr = pos;
80
    }
81
    else
82
    {
83
      my_errno = HA_ERR_KEY_NOT_FOUND;
84
    }
85
  }
86
  else
87
  {
88
    if (info->current_hash_ptr)
89
      pos= hp_search_next(info, keyinfo, info->lastkey,
90
			   info->current_hash_ptr);
91
    else
92
    {
93
      if (!info->current_ptr && (info->update & HA_STATE_NEXT_FOUND))
94
      {
95
	pos=0;					/* Read next after last */
96
	my_errno=HA_ERR_KEY_NOT_FOUND;
97
      }
98
      else if (!info->current_ptr)		/* Deleted or first call */
99
	pos= hp_search(info, keyinfo, info->lastkey, 0);
100
      else
101
	pos= hp_search(info, keyinfo, info->lastkey, 1);
102
    }
103
  }
104
  if (!pos)
105
  {
106
    info->update=HA_STATE_NEXT_FOUND;		/* For heap_rprev */
107
    if (my_errno == HA_ERR_KEY_NOT_FOUND)
108
      my_errno=HA_ERR_END_OF_FILE;
51.3.1 by Jay Pipes
Removed all DBUG symbols from heap storage engine
109
    return(my_errno);
1 by brian
clean slate
110
  }
244.1.1 by Harrison Fisk
Port Ebay/Google memory storage engine variable width columns.
111
  hp_extract_record(share, record, pos);
1 by brian
clean slate
112
  info->update=HA_STATE_AKTIV | HA_STATE_NEXT_FOUND;
51.3.1 by Jay Pipes
Removed all DBUG symbols from heap storage engine
113
  return(0);
1 by brian
clean slate
114
}