← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/memory/hp_rnext.cc

  • Committer: Daniel Nichter
  • Date: 2011-10-23 16:01:37 UTC
  • mto: This revision was merged to the branch mainline in revision 2448.
  • Revision ID: daniel@percona.com-20111023160137-7ac3blgz8z4tf8za
Add Administration Getting Started and Logging.  Capitalize SQL clause keywords.

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/memory/hp_rnext.cc
11
11
 
12
12
   You should have received a copy of the GNU General Public License
13
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 */
 
14
   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA */
15
15
 
16
 
#include "heapdef.h"
 
16
#include "heap_priv.h"
17
17
 
18
18
#include <string.h>
 
19
#include <drizzled/error_t.h>
 
20
 
 
21
using namespace drizzled;
19
22
 
20
23
/* Read next record with the same key */
21
24
 
22
25
int heap_rnext(HP_INFO *info, unsigned char *record)
23
26
{
24
27
  unsigned char *pos;
25
 
  HP_SHARE *share=info->s;
 
28
  HP_SHARE *share=info->getShare();
26
29
  HP_KEYDEF *keyinfo;
27
 
  
 
30
 
28
31
  if (info->lastinx < 0)
29
 
    return(my_errno=HA_ERR_WRONG_INDEX);
 
32
    return(errno=HA_ERR_WRONG_INDEX);
30
33
 
31
34
  keyinfo = share->keydef + info->lastinx;
32
 
  if (keyinfo->algorithm == HA_KEY_ALG_BTREE)
33
 
  {
34
 
    heap_rb_param custom_arg;
35
 
 
36
 
    if (info->last_pos)
37
 
    {
38
 
      /*
39
 
        We enter this branch for non-DELETE queries after heap_rkey()
40
 
        or heap_rfirst(). As last key position (info->last_pos) is available,
41
 
        we only need to climb the tree using tree_search_next().
42
 
      */
43
 
      pos = tree_search_next(&keyinfo->rb_tree, &info->last_pos,
44
 
                             offsetof(TREE_ELEMENT, left),
45
 
                             offsetof(TREE_ELEMENT, right));
46
 
    }
47
 
    else if (!info->lastkey_len)
48
 
    {
49
 
      /*
50
 
        We enter this branch only for DELETE queries after heap_rfirst(). E.g.
51
 
        DELETE FROM t1 WHERE a<10. As last key position is not available
52
 
        (last key is removed by heap_delete()), we must restart search as it
53
 
        is done in heap_rfirst().
54
 
 
55
 
        It should be safe to handle this situation without this branch. That is
56
 
        branch below should find smallest element in a tree as lastkey_len is
57
 
        zero. tree_search_edge() is a kind of optimisation here as it should be
58
 
        faster than tree_search_key().
59
 
      */
60
 
      pos= tree_search_edge(&keyinfo->rb_tree, info->parents,
61
 
                            &info->last_pos, offsetof(TREE_ELEMENT, left));
62
 
    }
63
 
    else
64
 
    {
65
 
      /*
66
 
        We enter this branch only for DELETE queries after heap_rkey(). E.g.
67
 
        DELETE FROM t1 WHERE a=10. As last key position is not available
68
 
        (last key is removed by heap_delete()), we must restart search as it
69
 
        is done in heap_rkey().
70
 
      */
71
 
      custom_arg.keyseg = keyinfo->seg;
72
 
      custom_arg.key_length = info->lastkey_len;
73
 
      custom_arg.search_flag = SEARCH_SAME | SEARCH_FIND;
74
 
      pos = tree_search_key(&keyinfo->rb_tree, info->lastkey, info->parents, 
75
 
                           &info->last_pos, info->last_find_flag, &custom_arg);
76
 
    }
77
 
    if (pos)
78
 
    {
79
 
      memcpy(&pos, pos + (*keyinfo->get_key_length)(keyinfo, pos), 
80
 
             sizeof(unsigned char*));
81
 
      info->current_ptr = pos;
82
 
    }
83
 
    else
84
 
    {
85
 
      my_errno = HA_ERR_KEY_NOT_FOUND;
86
 
    }
87
 
  }
88
 
  else
89
35
  {
90
36
    if (info->current_hash_ptr)
91
 
      pos= hp_search_next(info, keyinfo, info->lastkey,
 
37
      pos= hp_search_next(info, keyinfo, &info->lastkey[0],
92
38
                           info->current_hash_ptr);
93
39
    else
94
40
    {
95
41
      if (!info->current_ptr && (info->update & HA_STATE_NEXT_FOUND))
96
42
      {
97
43
        pos=0;                                  /* Read next after last */
98
 
        my_errno=HA_ERR_KEY_NOT_FOUND;
 
44
        errno=HA_ERR_KEY_NOT_FOUND;
99
45
      }
100
46
      else if (!info->current_ptr)              /* Deleted or first call */
101
 
        pos= hp_search(info, keyinfo, info->lastkey, 0);
 
47
        pos= hp_search(info, keyinfo, &info->lastkey[0], 0);
102
48
      else
103
 
        pos= hp_search(info, keyinfo, info->lastkey, 1);
 
49
        pos= hp_search(info, keyinfo, &info->lastkey[0], 1);
104
50
    }
105
51
  }
106
52
  if (!pos)
107
53
  {
108
54
    info->update=HA_STATE_NEXT_FOUND;           /* For heap_rprev */
109
 
    if (my_errno == HA_ERR_KEY_NOT_FOUND)
110
 
      my_errno=HA_ERR_END_OF_FILE;
111
 
    return(my_errno);
 
55
    if (errno == HA_ERR_KEY_NOT_FOUND)
 
56
      errno=HA_ERR_END_OF_FILE;
 
57
    return(errno);
112
58
  }
113
59
  hp_extract_record(share, record, pos);
114
60
  info->update=HA_STATE_AKTIV | HA_STATE_NEXT_FOUND;