18
18
#include "heapdef.h"
20
int heap_update(HP_INFO *info, const unsigned char *old_record, const unsigned char *new_record)
20
int heap_update(HP_INFO *info, const uchar *old, const uchar *heap_new)
22
22
HP_KEYDEF *keydef, *end, *p_lastinx;
24
bool auto_key_changed= 0;
24
my_bool auto_key_changed= 0;
25
25
HP_SHARE *share= info->s;
26
uint32_t old_length, new_length;
27
uint32_t old_chunk_count, new_chunk_count;
26
DBUG_ENTER("heap_update");
30
29
pos=info->current_ptr;
32
if (info->opt_flag & READ_CHECK_USED && hp_rectest(info,old_record))
33
return(my_errno); /* Record changed */
35
old_length = hp_get_encoded_data_length(share, old_record, &old_chunk_count);
36
new_length = hp_get_encoded_data_length(share, new_record, &new_chunk_count);
38
if (new_chunk_count > old_chunk_count) {
39
/* extend the old chunkset size as necessary, but do not shrink yet */
40
if (hp_reallocate_chunkset(&share->recordspace, new_chunk_count, pos)) {
41
return(my_errno); /* Out of memory or table space */
31
if (info->opt_flag & READ_CHECK_USED && hp_rectest(info,old))
32
DBUG_RETURN(my_errno); /* Record changed */
45
33
if (--(share->records) < share->blength >> 1) share->blength>>= 1;
48
36
p_lastinx= share->keydef + info->lastinx;
49
37
for (keydef= share->keydef, end= keydef + share->keys; keydef < end; keydef++)
51
if (hp_rec_key_cmp(keydef, old_record, new_record, 0))
39
if (hp_rec_key_cmp(keydef, old, heap_new, 0))
53
if ((*keydef->delete_key)(info, keydef, old_record, pos, keydef == p_lastinx) ||
54
(*keydef->write_key)(info, keydef, new_record, pos))
41
if ((*keydef->delete_key)(info, keydef, old, pos, keydef == p_lastinx) ||
42
(*keydef->write_key)(info, keydef, heap_new, pos))
56
44
if (share->auto_key == (uint) (keydef - share->keydef + 1))
57
45
auto_key_changed= 1;
60
hp_copy_record_data_to_chunkset(share, new_record, pos);
49
memcpy(pos,heap_new,(size_t) share->reclength);
61
50
if (++(share->records) == share->blength) share->blength+= share->blength;
63
if (new_chunk_count < old_chunk_count) {
64
/* Shrink the chunkset to its new size */
65
hp_reallocate_chunkset(&share->recordspace, new_chunk_count, pos);
52
#if !defined(DBUG_OFF) && defined(EXTRA_HEAP_DEBUG)
53
DBUG_EXECUTE("check_heap",heap_check_heap(info, 0););
68
55
if (auto_key_changed)
69
heap_update_auto_increment(info, new_record);
56
heap_update_auto_increment(info, heap_new);
73
60
if (my_errno == HA_ERR_FOUND_DUPP_KEY)
76
63
if (keydef->algorithm == HA_KEY_ALG_BTREE)
78
65
/* we don't need to delete non-inserted key from rb-tree */
79
if ((*keydef->write_key)(info, keydef, old_record, pos))
66
if ((*keydef->write_key)(info, keydef, old, pos))
81
68
if (++(share->records) == share->blength)
82
69
share->blength+= share->blength;
70
DBUG_RETURN(my_errno);
87
74
while (keydef >= share->keydef)
89
if (hp_rec_key_cmp(keydef, old_record, new_record, 0))
76
if (hp_rec_key_cmp(keydef, old, heap_new, 0))
91
if ((*keydef->delete_key)(info, keydef, new_record, pos, 0) ||
92
(*keydef->write_key)(info, keydef, old_record, pos))
78
if ((*keydef->delete_key)(info, keydef, heap_new, pos, 0) ||
79
(*keydef->write_key)(info, keydef, old, pos))
99
85
if (++(share->records) == share->blength)
100
86
share->blength+= share->blength;
102
if (new_chunk_count > old_chunk_count) {
103
/* Shrink the chunkset to its original size */
104
hp_reallocate_chunkset(&share->recordspace, old_chunk_count, pos);
87
DBUG_RETURN(my_errno);
108
88
} /* heap_update */