mirror of
https://github.com/MariaDB/server.git
synced 2025-01-16 20:12:31 +01:00
cfab46f546
Fixed memory leak on shutdown (Affects the embedded version & MyODBC) client/client_priv.h: Update copyright client/completion_hash.cc: Update copyright client/completion_hash.h: Update copyright client/connect_test.c: Update copyright client/errmsg.c: Update copyright client/get_password.c: Update copyright client/insert_test.c: Update copyright client/list_test.c: Update copyright client/my_readline.h: Update copyright client/mysql.cc: Update copyright client/mysqladmin.c: Update copyright client/mysqlbinlog.cc: Update copyright client/mysqlcheck.c: Update copyright client/mysqldump.c: Update copyright client/mysqlimport.c: Update copyright client/mysqlmanager-pwgen.c: Update copyright client/mysqlmanagerc.c: Update copyright client/mysqlshow.c: Update copyright client/mysqltest.c: Update copyright client/password.c: Update copyright client/readline.cc: Update copyright client/select_test.c: Update copyright client/showdb_test.c: Update copyright client/sql_string.cc: Update copyright client/sql_string.h: Update copyright client/ssl_test.c: Update copyright client/thimble.cc: Update copyright client/thread_test.c: Update copyright div/deadlock_test.c: Update copyright extra/comp_err.c: Update copyright extra/my_print_defaults.c: Update copyright extra/perror.c: Update copyright extra/replace.c: Update copyright extra/resolve_stack_dump.c: Update copyright extra/resolveip.c: Update copyright fs/database.c: Update copyright fs/libmysqlfs.c: Update copyright fs/mysqlcorbafs.c: Update copyright fs/mysqlcorbafs.h: Update copyright fs/mysqlcorbafs_test.c: Update copyright heap/_check.c: Update copyright heap/_rectest.c: Update copyright heap/heapdef.h: Update copyright heap/hp_block.c: Update copyright heap/hp_clear.c: Update copyright heap/hp_close.c: Update copyright heap/hp_create.c: Update copyright heap/hp_delete.c: Update copyright heap/hp_extra.c: Update copyright heap/hp_hash.c: Update copyright heap/hp_info.c: Update copyright heap/hp_open.c: Update copyright heap/hp_panic.c: Update copyright heap/hp_rename.c: Update copyright heap/hp_rfirst.c: Update copyright heap/hp_rkey.c: Update copyright heap/hp_rlast.c: Update copyright heap/hp_rnext.c: Update copyright heap/hp_rprev.c: Update copyright heap/hp_rrnd.c: Update copyright heap/hp_rsame.c: Update copyright heap/hp_scan.c: Update copyright heap/hp_static.c: Update copyright heap/hp_test1.c: Update copyright heap/hp_test2.c: Update copyright heap/hp_update.c: Update copyright heap/hp_write.c: Update copyright include/config-win.h: Update copyright include/dbug.h: Update copyright include/errmsg.h: Update copyright include/ft_global.h: Update copyright include/getopt.h: Update copyright include/hash.h: Update copyright include/heap.h: Update copyright include/m_ctype.h: Update copyright include/m_string.h: Update copyright include/md5.h: Update copyright include/merge.h: Update copyright include/my_alarm.h: Update copyright include/my_base.h: Update copyright include/my_bitmap.h: Update copyright include/my_dir.h: Update copyright include/my_global.h: Update copyright include/my_list.h: Update copyright include/my_net.h: Update copyright include/my_no_pthread.h: Update copyright include/my_nosys.h: Update copyright include/my_pthread.h: Update copyright include/my_sys.h: Update copyright include/my_tree.h: Update copyright include/myisam.h: Update copyright include/myisammrg.h: Update copyright include/myisampack.h: Update copyright include/mysql.h: Update copyright include/mysql_com.h: Update copyright include/mysql_embed.h: Update copyright include/mysqld_error.h: Update copyright include/mysys_err.h: Update copyright include/nisam.h: Update copyright include/queues.h: Update copyright include/raid.h: Update copyright include/sslopt-case.h: Update copyright include/sslopt-longopts.h: Update copyright include/sslopt-usage.h: Update copyright include/sslopt-vars.h: Update copyright include/t_ctype.h: Update copyright include/thr_alarm.h: Update copyright include/thr_lock.h: Update copyright include/violite.h: Update copyright isam/_cache.c: Update copyright isam/_dbug.c: Update copyright isam/_key.c: Update copyright isam/_locking.c: Update copyright isam/_packrec.c: Update copyright isam/_page.c: Update copyright isam/_search.c: Update copyright isam/_statrec.c: Update copyright isam/changed.c: Update copyright isam/close.c: Update copyright isam/create.c: Update copyright isam/delete.c: Update copyright isam/extra.c: Update copyright isam/info.c: Update copyright isam/isamchk.c: Update copyright isam/isamdef.h: Update copyright isam/log.c: Update copyright isam/open.c: Update copyright isam/panic.c: Update copyright isam/range.c: Update copyright isam/rfirst.c: Update copyright isam/rkey.c: Update copyright isam/rlast.c: Update copyright isam/rnext.c: Update copyright isam/rprev.c: Update copyright isam/rrnd.c: Update copyright isam/rsame.c: Update copyright isam/rsamepos.c: Update copyright isam/sort.c: Update copyright isam/static.c: Update copyright isam/test1.c: Update copyright isam/test2.c: Update copyright isam/test3.c: Update copyright isam/update.c: Update copyright isam/write.c: Update copyright libmysql/conf_to_src.c: Update copyright libmysql/dll.c: Update copyright libmysql/errmsg.c: Update copyright libmysql/get_password.c: Update copyright libmysql/libmysql.c: Update copyright libmysql/manager.c: Update copyright libmysql/net.c: Update copyright libmysql/password.c: Update copyright libmysqld/lib_sql.cc: Update copyright libmysqld/lib_vio.c: Update copyright libmysqld/libmysqld.c: Update copyright merge/mrg_close.c: Update copyright merge/mrg_create.c: Update copyright merge/mrg_def.h: Update copyright merge/mrg_delete.c: Update copyright merge/mrg_extra.c: Update copyright merge/mrg_info.c: Update copyright merge/mrg_locking.c: Update copyright merge/mrg_open.c: Update copyright merge/mrg_panic.c: Update copyright merge/mrg_rrnd.c: Update copyright merge/mrg_rsame.c: Update copyright merge/mrg_static.c: Update copyright merge/mrg_update.c: Update copyright myisam/ft_boolean_search.c: Update copyright myisam/ft_dump.c: Update copyright myisam/ft_eval.h: Update copyright myisam/ft_static.c: Update copyright myisam/ft_stem.c: Update copyright myisam/ft_stopwords.c: Update copyright myisam/ft_test1.h: Update copyright myisam/mi_cache.c: Update copyright myisam/mi_changed.c: Update copyright myisam/mi_check.c: Update copyright myisam/mi_checksum.c: Update copyright myisam/mi_close.c: Update copyright myisam/mi_create.c: Update copyright myisam/mi_dbug.c: Update copyright myisam/mi_delete.c: Update copyright myisam/mi_delete_all.c: Update copyright myisam/mi_delete_table.c: Update copyright myisam/mi_dynrec.c: Update copyright myisam/mi_extra.c: Update copyright myisam/mi_info.c: Update copyright myisam/mi_key.c: Update copyright myisam/mi_locking.c: Update copyright myisam/mi_log.c: Update copyright myisam/mi_open.c: Update copyright myisam/mi_packrec.c: Update copyright myisam/mi_page.c: Update copyright myisam/mi_panic.c: Update copyright myisam/mi_range.c: Update copyright myisam/mi_rename.c: Update copyright myisam/mi_rfirst.c: Update copyright myisam/mi_rlast.c: Update copyright myisam/mi_rnext_same.c: Update copyright myisam/mi_rrnd.c: Update copyright myisam/mi_rsame.c: Update copyright myisam/mi_rsamepos.c: Update copyright myisam/mi_scan.c: Update copyright myisam/mi_search.c: Update copyright myisam/mi_static.c: Update copyright myisam/mi_statrec.c: Update copyright myisam/mi_test1.c: Update copyright myisam/mi_test2.c: Update copyright myisam/mi_test3.c: Update copyright myisam/mi_unique.c: Update copyright myisam/mi_update.c: Update copyright myisam/mi_write.c: Update copyright myisam/myisamchk.c: Update copyright myisam/myisampack.c: Update copyright myisammrg/myrg_close.c: Update copyright myisammrg/myrg_create.c: Update copyright myisammrg/myrg_def.h: Update copyright myisammrg/myrg_delete.c: Update copyright myisammrg/myrg_locking.c: Update copyright myisammrg/myrg_open.c: Update copyright myisammrg/myrg_panic.c: Update copyright myisammrg/myrg_rsame.c: Update copyright myisammrg/myrg_static.c: Update copyright myisammrg/myrg_update.c: Update copyright myisammrg/myrg_write.c: Update copyright mysql-test/r/gcc296.result: Update of benchmark results mysql-test/r/innodb.result: Update of benchmark results mysql-test/r/join_outer.result: Update of benchmark results mysql-test/r/myisam.result: Update of benchmark results mysys/array.c: Update copyright mysys/charset.c: Fix for restart of character sets mysys/checksum.c: Update copyright mysys/default.c: Update copyright mysys/errors.c: Update copyright mysys/getopt.c: Cleanup mysys/getvar.c: Update copyright mysys/hash.c: Update copyright mysys/list.c: Update copyright mysys/make-conf.c: Update copyright mysys/md5.c: Update copyright mysys/mf_brkhant.c: Update copyright mysys/mf_cache.c: Update copyright mysys/mf_casecnv.c: Update copyright mysys/mf_dirname.c: Update copyright mysys/mf_fn_ext.c: Update copyright mysys/mf_format.c: Update copyright mysys/mf_getdate.c: Update copyright mysys/mf_iocache.c: Update copyright mysys/mf_iocache2.c: Update copyright mysys/mf_keycache.c: Update copyright mysys/mf_loadpath.c: Update copyright mysys/mf_pack.c: Update copyright mysys/mf_path.c: Update copyright mysys/mf_qsort.c: Update copyright mysys/mf_qsort2.c: Update copyright mysys/mf_radix.c: Update copyright mysys/mf_same.c: Update copyright mysys/mf_sleep.c: Update copyright mysys/mf_sort.c: Update copyright mysys/mf_soundex.c: Update copyright mysys/mf_stripp.c: Update copyright mysys/mf_tempfile.c: Update copyright mysys/mf_unixpath.c: Update copyright mysys/mf_util.c: Update copyright mysys/mf_wcomp.c: Update copyright mysys/mf_wfile.c: Update copyright mysys/mulalloc.c: Update copyright mysys/my_alarm.c: Update copyright mysys/my_alloc.c: Update copyright mysys/my_append.c: Update copyright mysys/my_bit.c: Update copyright mysys/my_bitmap.c: Update copyright mysys/my_chsize.c: Update copyright mysys/my_clock.c: Update copyright mysys/my_compress.c: Update copyright mysys/my_copy.c: Update copyright mysys/my_create.c: Update copyright mysys/my_delete.c: Update copyright mysys/my_div.c: Update copyright mysys/my_dup.c: Update copyright mysys/my_error.c: Update copyright mysys/my_fopen.c: Update copyright mysys/my_fstream.c: Update copyright mysys/my_getwd.c: Update copyright mysys/my_init.c: Free 'once_alloc' memory at shutdown. mysys/my_lib.c: Update copyright mysys/my_lock.c: Update copyright mysys/my_lockmem.c: Update copyright mysys/my_lread.c: Update copyright mysys/my_lwrite.c: Update copyright mysys/my_malloc.c: Update copyright mysys/my_messnc.c: Update copyright mysys/my_mkdir.c: Update copyright mysys/my_net.c: Update copyright mysys/my_once.c: Update copyright mysys/my_open.c: Update copyright mysys/my_pread.c: Update copyright mysys/my_pthread.c: Update copyright mysys/my_quick.c: Update copyright mysys/my_read.c: Update copyright mysys/my_realloc.c: Update copyright mysys/my_redel.c: Update copyright mysys/my_rename.c: Update copyright mysys/my_seek.c: Update copyright mysys/my_static.c: Update copyright mysys/my_static.h: Update copyright mysys/my_symlink.c: Update copyright mysys/my_symlink2.c: Update copyright mysys/my_tempnam.c: Update copyright mysys/my_thr_init.c: Update copyright mysys/my_vsnprintf.c: Update copyright mysys/my_wincond.c: Update copyright mysys/my_winthread.c: Update copyright mysys/my_write.c: Update copyright mysys/mysys_priv.h: Update copyright mysys/ptr_cmp.c: Update copyright mysys/queues.c: Update copyright mysys/raid.cc: Update copyright mysys/safemalloc.c: Update copyright mysys/string.c: Update copyright mysys/test_charset.c: Update copyright mysys/test_dir.c: Update copyright mysys/test_fn.c: Update copyright mysys/testhash.c: Update copyright mysys/thr_alarm.c: Update copyright mysys/thr_lock.c: Update copyright mysys/thr_mutex.c: Update copyright mysys/thr_rwlock.c: Update copyright mysys/tree.c: Update copyright mysys/typelib.c: Update copyright pstack/debug.c: Update copyright pstack/debug.h: Update copyright pstack/demangle.h: Update copyright pstack/ieee.c: Update copyright pstack/ieee.h: Update copyright pstack/pstack.c: Update copyright readline/bind.c: Cleanup empty lines readline/complete.c: Cleanup empty lines readline/display.c: Cleanup empty lines readline/funmap.c: Cleanup empty lines readline/histexpand.c: Cleanup empty lines readline/histfile.c: Cleanup empty lines readline/history.c: Cleanup empty lines readline/history.h: Cleanup empty lines readline/input.c: Cleanup empty lines readline/kill.c: Cleanup empty lines readline/readline.c: Cleanup empty lines readline/readline.h: Cleanup empty lines readline/vi_mode.c: Cleanup empty lines sql/cache_manager.cc: Update copyright sql/cache_manager.h: Update copyright sql/convert.cc: Update copyright sql/custom_conf.h: Update copyright sql/derror.cc: Update copyright sql/field.cc: Update copyright sql/field.h: Update copyright sql/field_conv.cc: Update copyright sql/filesort.cc: Update copyright sql/frm_crypt.cc: Update copyright sql/ha_berkeley.cc: Update copyright sql/ha_heap.cc: Update copyright sql/ha_heap.h: Update copyright sql/ha_innobase.cc: Update copyright sql/ha_isam.cc: Update copyright sql/ha_isam.h: Update copyright sql/ha_isammrg.cc: Update copyright sql/ha_isammrg.h: Update copyright sql/ha_myisam.cc: Update copyright sql/handler.cc: Update copyright sql/hash_filo.cc: Update copyright sql/hash_filo.h: Update copyright sql/hostname.cc: Update copyright sql/init.cc: Update copyright sql/item.cc: Update copyright sql/item.h: Update copyright sql/item_buff.cc: Update copyright sql/item_cmpfunc.cc: Update copyright sql/item_cmpfunc.h: Update copyright sql/item_create.cc: Update copyright sql/item_create.h: Update copyright sql/item_func.cc: Update copyright sql/item_strfunc.cc: Update copyright sql/item_sum.cc: Update copyright sql/item_sum.h: Update copyright sql/item_timefunc.cc: Update copyright sql/item_timefunc.h: Update copyright sql/item_uniq.cc: Update copyright sql/item_uniq.h: Update copyright sql/key.cc: Update copyright sql/lex_symbol.h: Update copyright sql/lock.cc: Update copyright sql/log.cc: Update copyright sql/log_event.cc: Update copyright sql/log_event.h: Update copyright sql/matherr.c: Update copyright sql/mf_iocache.cc: Update copyright sql/mini_client.cc: Update copyright sql/mini_client.h: Update copyright sql/my_lock.c: Update copyright sql/mysqld.cc: Update copyright sql/net_pkg.cc: Update copyright sql/net_serv.cc: Update copyright sql/opt_sum.cc: Update copyright sql/password.c: Update copyright sql/procedure.cc: Update copyright sql/procedure.h: Update copyright sql/records.cc: Update copyright sql/repl_failsafe.cc: Update copyright sql/slave.cc: Update copyright sql/slave.h: Update copyright sql/sql_acl.cc: Update copyright sql/sql_acl.h: Update copyright sql/sql_analyse.cc: Update copyright sql/sql_analyse.h: Update copyright sql/sql_base.cc: Update copyright sql/sql_cache.cc: Update copyright sql/sql_class.cc: Update copyright sql/sql_class.h: Update copyright sql/sql_crypt.cc: Update copyright sql/sql_crypt.h: Update copyright sql/sql_db.cc: Update copyright sql/sql_delete.cc: Update copyright sql/sql_handler.cc: Update copyright sql/sql_insert.cc: Update copyright sql/sql_lex.cc: Update copyright sql/sql_lex.h: Update copyright sql/sql_list.cc: Update copyright sql/sql_list.h: Update copyright sql/sql_load.cc: Update copyright sql/sql_map.cc: Update copyright sql/sql_map.h: Update copyright sql/sql_parse.cc: Update copyright sql/sql_rename.cc: Update copyright sql/sql_repl.cc: Update copyright sql/sql_select.h: Update copyright sql/sql_string.cc: Update copyright sql/sql_string.h: Update copyright sql/sql_table.cc: Update copyright sql/sql_test.cc: Update copyright sql/sql_udf.cc: Update copyright sql/sql_udf.h: Update copyright sql/stacktrace.c: Update copyright sql/structs.h: Update copyright sql/table.cc: Update copyright sql/table.h: Update copyright sql/thr_malloc.cc: Update copyright sql/time.cc: Update copyright sql/udf_example.cc: Update copyright sql/uniques.cc: Update copyright sql/unireg.cc: Update copyright sql/unireg.h: Update copyright strings/atof.c: Update copyright strings/bchange.c: Update copyright strings/bcmp.c: Update copyright strings/bcopy-duff.c: Update copyright strings/bfill.c: Update copyright strings/bmove.c: Update copyright strings/bmove512.c: Update copyright strings/bmove_upp.c: Update copyright strings/bzero.c: Update copyright strings/conf_to_src.c: Update copyright strings/ctype-big5.c: Update copyright strings/ctype-czech.c: Update copyright strings/ctype-euc_kr.c: Update copyright strings/ctype-gb2312.c: Update copyright strings/ctype-gbk.c: Update copyright strings/ctype-latin1_de.c: Update copyright strings/ctype-sjis.c: Update copyright strings/ctype-tis620.c: Update copyright strings/ctype-ujis.c: Update copyright strings/ctype.c: Update copyright strings/do_ctype.c: Update copyright strings/int2str.c: Update copyright strings/is_prefix.c: Update copyright strings/llstr.c: Update copyright strings/longlong2str.c: Update copyright strings/memcmp.c: Update copyright strings/memcpy.c: Update copyright strings/memset.c: Update copyright strings/r_strinstr.c: Update copyright strings/str2int.c: Update copyright strings/str_test.c: Update copyright strings/strappend.c: Update copyright strings/strcat.c: Update copyright strings/strcend.c: Update copyright strings/strchr.c: Update copyright strings/strcmp.c: Update copyright strings/strcont.c: Update copyright strings/strend.c: Update copyright strings/strfill.c: Update copyright strings/strings-not-used.h: Update copyright strings/strinstr.c: Update copyright strings/strlen.c: Update copyright strings/strmake.c: Update copyright strings/strmov.c: Update copyright strings/strnlen.c: Update copyright strings/strnmov.c: Update copyright strings/strrchr.c: Update copyright strings/strstr.c: Update copyright strings/strto.c: Update copyright strings/strtol.c: Update copyright strings/strtoll.c: Update copyright strings/strtoul.c: Update copyright strings/strtoull.c: Update copyright strings/strxmov.c: Update copyright strings/strxnmov.c: Update copyright strings/t_ctype.h: Update copyright strings/udiv.c: Update copyright tools/mysqlmanager.c: Update copyright vio/test-ssl.c: Update copyright vio/test-sslclient.c: Update copyright vio/test-sslserver.c: Update copyright vio/vio.c: Update copyright vio/viosocket.c: Update copyright vio/viossl.c: Update copyright vio/viosslfactories.c: Update copyright vio/viotest-ssl.c: Update copyright
889 lines
25 KiB
C
889 lines
25 KiB
C
/* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
|
|
|
|
This program is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation; either version 2 of the License, or
|
|
(at your option) any later version.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
|
|
|
|
/* S|ker efter positionen f|r en nyckel samt d{rmedh|rande funktioner */
|
|
|
|
#include "isamdef.h"
|
|
#include "m_ctype.h"
|
|
|
|
#define CMP(a,b) (a<b ? -1 : a == b ? 0 : 1)
|
|
|
|
/* Check index */
|
|
|
|
int _nisam_check_index(N_INFO *info, int inx)
|
|
{
|
|
if (inx == -1) /* Use last index */
|
|
inx=info->lastinx;
|
|
if (inx >= (int) info->s->state.keys || inx < 0)
|
|
{
|
|
my_errno=HA_ERR_WRONG_INDEX;
|
|
return -1;
|
|
}
|
|
if (info->lastinx != inx) /* Index changed */
|
|
{
|
|
info->lastinx = inx;
|
|
info->lastpos = NI_POS_ERROR;
|
|
info->update= ((info->update & (HA_STATE_CHANGED | HA_STATE_ROW_CHANGED)) |
|
|
HA_STATE_NEXT_FOUND | HA_STATE_PREV_FOUND);
|
|
}
|
|
if (info->opt_flag & WRITE_CACHE_USED && flush_io_cache(&info->rec_cache))
|
|
return(-1);
|
|
return(inx);
|
|
} /* ni_check_index */
|
|
|
|
|
|
/* S|ker reda p} positionen f|r ett record p} basen av en nyckel */
|
|
/* Positionen l{ggs i info->lastpos */
|
|
/* Returns -1 if not found and 1 if search at upper levels */
|
|
|
|
int _nisam_search(register N_INFO *info, register N_KEYDEF *keyinfo, uchar *key, uint key_len, uint nextflag, register ulong pos)
|
|
{
|
|
int error,flag;
|
|
uint nod_flag;
|
|
uchar *keypos,*maxpos;
|
|
uchar lastkey[N_MAX_KEY_BUFF],*buff;
|
|
DBUG_ENTER("_nisam_search");
|
|
DBUG_PRINT("enter",("pos: %ld nextflag: %d lastpos: %ld",
|
|
pos,nextflag,info->lastpos));
|
|
|
|
if (pos == NI_POS_ERROR)
|
|
{
|
|
my_errno=HA_ERR_KEY_NOT_FOUND; /* Didn't find key */
|
|
info->lastpos= NI_POS_ERROR;
|
|
if (!(nextflag & (SEARCH_SMALLER | SEARCH_BIGGER | SEARCH_LAST)))
|
|
DBUG_RETURN(-1); /* Not found ; return error */
|
|
DBUG_RETURN(1); /* Search at upper levels */
|
|
}
|
|
|
|
if (!(buff=_nisam_fetch_keypage(info,keyinfo,pos,info->buff,
|
|
test(!(nextflag & SEARCH_SAVE_BUFF)))))
|
|
goto err;
|
|
DBUG_DUMP("page",(byte*) buff,getint(buff));
|
|
|
|
flag=(*keyinfo->bin_search)(info,keyinfo,buff,key,key_len,nextflag,
|
|
&keypos,lastkey);
|
|
nod_flag=test_if_nod(buff);
|
|
maxpos=buff+getint(buff)-1;
|
|
|
|
if (flag)
|
|
{
|
|
if ((error=_nisam_search(info,keyinfo,key,key_len,nextflag,
|
|
_nisam_kpos(nod_flag,keypos))) <= 0)
|
|
DBUG_RETURN(error);
|
|
|
|
if (flag >0)
|
|
{
|
|
if ((nextflag & (SEARCH_SMALLER | SEARCH_LAST)) &&
|
|
keypos == buff+2+nod_flag)
|
|
DBUG_RETURN(1); /* Bigger than key */
|
|
}
|
|
else if (nextflag & SEARCH_BIGGER && keypos >= maxpos)
|
|
DBUG_RETURN(1); /* Smaller than key */
|
|
}
|
|
else
|
|
{
|
|
if (nextflag & SEARCH_FIND && (!(keyinfo->base.flag & HA_NOSAME)
|
|
|| key_len) && nod_flag)
|
|
{
|
|
if ((error=_nisam_search(info,keyinfo,key,key_len,SEARCH_FIND,
|
|
_nisam_kpos(nod_flag,keypos))) >= 0 ||
|
|
my_errno != HA_ERR_KEY_NOT_FOUND)
|
|
DBUG_RETURN(error);
|
|
info->int_pos= NI_POS_ERROR; /* Buffer not in memory */
|
|
}
|
|
}
|
|
if (pos != info->int_pos)
|
|
{
|
|
uchar *old_buff=buff;
|
|
if (!(buff=_nisam_fetch_keypage(info,keyinfo,pos,info->buff,
|
|
test(!(nextflag & SEARCH_SAVE_BUFF)))))
|
|
goto err;
|
|
keypos=buff+(keypos-old_buff);
|
|
maxpos=buff+(maxpos-old_buff);
|
|
}
|
|
|
|
if ((nextflag & (SEARCH_SMALLER | SEARCH_LAST)) && flag != 0)
|
|
{
|
|
keypos=_nisam_get_last_key(info,keyinfo,buff,lastkey,keypos);
|
|
if ((nextflag & SEARCH_LAST) &&
|
|
_nisam_key_cmp(keyinfo->seg, info->lastkey, key, key_len, SEARCH_FIND))
|
|
{
|
|
my_errno=HA_ERR_KEY_NOT_FOUND; /* Didn't find key */
|
|
goto err;
|
|
}
|
|
}
|
|
|
|
VOID((*keyinfo->get_key)(keyinfo,nod_flag,&keypos,lastkey));
|
|
VOID(_nisam_move_key(keyinfo,info->lastkey,lastkey));
|
|
info->lastpos=_nisam_dpos(info,nod_flag,keypos);
|
|
info->int_keypos=info->buff+ (keypos-buff);
|
|
info->int_maxpos=info->buff+ (maxpos-buff);
|
|
info->page_changed=0;
|
|
info->buff_used= (info->buff != buff);
|
|
info->last_search_keypage=info->int_pos;
|
|
|
|
DBUG_PRINT("exit",("found key at %ld",info->lastpos));
|
|
DBUG_RETURN(0);
|
|
err:
|
|
DBUG_PRINT("exit",("Error: %d",my_errno));
|
|
info->lastpos= NI_POS_ERROR;
|
|
DBUG_RETURN (-1);
|
|
} /* _nisam_search */
|
|
|
|
|
|
/* Search after key in page-block */
|
|
/* If packed key puts smaller or identical key in buff */
|
|
/* ret_pos point to where find or bigger key starts */
|
|
/* ARGSUSED */
|
|
|
|
int _nisam_bin_search(N_INFO *info, register N_KEYDEF *keyinfo, uchar *page,
|
|
uchar *key, uint key_len, uint comp_flag, uchar **ret_pos,
|
|
uchar *buff __attribute__((unused)))
|
|
{
|
|
reg4 int start,mid,end;
|
|
int flag;
|
|
uint totlength,nod_flag;
|
|
DBUG_ENTER("_nisam_bin_search");
|
|
|
|
LINT_INIT(flag);
|
|
totlength=keyinfo->base.keylength+(nod_flag=test_if_nod(page));
|
|
start=0; mid=1;
|
|
end= (int) ((getint(page)-2-nod_flag)/totlength-1);
|
|
DBUG_PRINT("test",("getint: %d end: %d",getint(page),end));
|
|
page+=2+nod_flag;
|
|
|
|
while (start != end)
|
|
{
|
|
mid= (start+end)/2;
|
|
if ((flag=_nisam_key_cmp(keyinfo->seg,page+(uint) mid*totlength,key,key_len,
|
|
comp_flag))
|
|
>= 0)
|
|
end=mid;
|
|
else
|
|
start=mid+1;
|
|
}
|
|
if (mid != start)
|
|
flag=_nisam_key_cmp(keyinfo->seg,page+(uint) start*totlength,key,key_len,
|
|
comp_flag);
|
|
if (flag < 0)
|
|
start++; /* point at next, bigger key */
|
|
*ret_pos=page+(uint) start*totlength;
|
|
DBUG_PRINT("exit",("flag: %d keypos: %d",flag,start));
|
|
DBUG_RETURN(flag);
|
|
} /* _nisam_bin_search */
|
|
|
|
|
|
/* Used instead of _nisam_bin_search() when key is packed */
|
|
/* Puts smaller or identical key in buff */
|
|
/* Key is searched sequentially */
|
|
|
|
int _nisam_seq_search(N_INFO *info, register N_KEYDEF *keyinfo, uchar *page, uchar *key, uint key_len, uint comp_flag, uchar **ret_pos, uchar *buff)
|
|
{
|
|
int flag;
|
|
uint nod_flag,length;
|
|
uchar t_buff[N_MAX_KEY_BUFF],*end;
|
|
DBUG_ENTER("_nisam_seq_search");
|
|
|
|
LINT_INIT(flag); LINT_INIT(length);
|
|
end= page+getint(page);
|
|
nod_flag=test_if_nod(page);
|
|
page+=2+nod_flag;
|
|
*ret_pos=page;
|
|
while (page < end)
|
|
{
|
|
length=(*keyinfo->get_key)(keyinfo,nod_flag,&page,t_buff);
|
|
if ((flag=_nisam_key_cmp(keyinfo->seg,t_buff,key,key_len,comp_flag)) >= 0)
|
|
break;
|
|
#ifdef EXTRA_DEBUG
|
|
DBUG_PRINT("loop",("page: %lx key: '%s' flag: %d",page,t_buff,flag));
|
|
#endif
|
|
memcpy(buff,t_buff,length);
|
|
*ret_pos=page;
|
|
}
|
|
if (flag == 0)
|
|
memcpy(buff,t_buff,length); /* Result is first key */
|
|
DBUG_PRINT("exit",("flag: %d ret_pos: %lx",flag,*ret_pos));
|
|
DBUG_RETURN(flag);
|
|
} /* _nisam_seq_search */
|
|
|
|
|
|
/* Get pos to a key_block */
|
|
|
|
ulong _nisam_kpos(uint nod_flag, uchar *after_key)
|
|
{
|
|
after_key-=nod_flag;
|
|
switch (nod_flag) {
|
|
case 3:
|
|
return uint3korr(after_key)*512L;
|
|
case 2:
|
|
return uint2korr(after_key)*512L;
|
|
case 1:
|
|
return (uint) (*after_key)*512L;
|
|
case 0: /* At leaf page */
|
|
default: /* Impossible */
|
|
return(NI_POS_ERROR);
|
|
}
|
|
} /* _kpos */
|
|
|
|
|
|
/* Save pos to a key_block */
|
|
|
|
void _nisam_kpointer(register N_INFO *info, register uchar *buff, ulong pos)
|
|
{
|
|
pos/=512L;
|
|
switch (info->s->base.key_reflength) {
|
|
case 3: int3store(buff,pos); break;
|
|
case 2: int2store(buff,(uint) pos); break;
|
|
case 1: buff[0]= (uchar) pos; break;
|
|
default: abort(); /* impossible */
|
|
}
|
|
} /* _nisam_kpointer */
|
|
|
|
|
|
/* Calc pos to a data-record */
|
|
|
|
ulong _nisam_dpos(N_INFO *info, uint nod_flag, uchar *after_key)
|
|
{
|
|
ulong pos;
|
|
after_key-=(nod_flag + info->s->rec_reflength);
|
|
switch (info->s->rec_reflength) {
|
|
case 4:
|
|
pos= (ulong) uint4korr(after_key);
|
|
break;
|
|
case 3:
|
|
pos= (ulong) uint3korr(after_key);
|
|
break;
|
|
case 2:
|
|
pos= (ulong) uint2korr(after_key);
|
|
break;
|
|
default:
|
|
pos=0L; /* Shut compiler up */
|
|
}
|
|
return (info->s->base.options &
|
|
(HA_OPTION_PACK_RECORD | HA_OPTION_COMPRESS_RECORD)) ? pos :
|
|
pos*info->s->base.reclength;
|
|
}
|
|
|
|
/* save pos to record */
|
|
|
|
void _nisam_dpointer(N_INFO *info, uchar *buff, ulong pos)
|
|
{
|
|
if (!(info->s->base.options &
|
|
(HA_OPTION_PACK_RECORD | HA_OPTION_COMPRESS_RECORD)))
|
|
pos/=info->s->base.reclength;
|
|
|
|
switch (info->s->rec_reflength) {
|
|
case 4: int4store(buff,pos); break;
|
|
case 3: int3store(buff,pos); break;
|
|
case 2: int2store(buff,(uint) pos); break;
|
|
default: abort(); /* Impossible */
|
|
}
|
|
} /* _nisam_dpointer */
|
|
|
|
|
|
/*
|
|
** Compare two keys with is bigger
|
|
** Returns <0, 0, >0 acording to with is bigger
|
|
** Key_length specifies length of key to use. Number-keys can't
|
|
** be splitted
|
|
** If flag <> SEARCH_FIND compare also position
|
|
*/
|
|
int _nisam_key_cmp(register N_KEYSEG *keyseg, register uchar *a, register uchar *b, uint key_length, uint nextflag)
|
|
{
|
|
reg4 int flag,length_diff;
|
|
int16 s_1,s_2;
|
|
int32 l_1,l_2;
|
|
uint32 u_1,u_2;
|
|
float f_1,f_2;
|
|
double d_1,d_2;
|
|
reg5 uchar *end;
|
|
|
|
if (!(nextflag & (SEARCH_FIND | SEARCH_NO_FIND | SEARCH_LAST))
|
|
|| key_length == 0)
|
|
key_length=N_MAX_KEY_BUFF*2;
|
|
|
|
for ( ; (int) key_length >0 ; key_length-= (keyseg++)->base.length)
|
|
{
|
|
end= a+ min(keyseg->base.length,key_length);
|
|
switch ((enum ha_base_keytype) keyseg->base.type) {
|
|
case HA_KEYTYPE_TEXT: /* Ascii; Key is converted */
|
|
case HA_KEYTYPE_BINARY:
|
|
if (keyseg->base.flag & HA_SPACE_PACK)
|
|
{
|
|
uchar *as, *bs;
|
|
int length,b_length;
|
|
|
|
as=a++; bs=b++;
|
|
length= (length_diff= ((int) *as - (b_length= (int) *bs))) < 0 ?
|
|
(int) *as : b_length;
|
|
end= a+ min(key_length,(uint) length);
|
|
|
|
#ifdef USE_STRCOLL
|
|
if (use_strcoll(default_charset_info)) {
|
|
if (((enum ha_base_keytype) keyseg->base.type) == HA_KEYTYPE_BINARY)
|
|
{
|
|
while (a < end)
|
|
if ((flag= (int) *a++ - (int) *b++))
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag);
|
|
}
|
|
else
|
|
{
|
|
if ((flag = my_strnncoll(default_charset_info,
|
|
a, (int) (end-a), b, b_length)))
|
|
return (keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag;
|
|
b+= (uint) (end-a);
|
|
a=end;
|
|
}
|
|
}
|
|
else
|
|
#endif
|
|
{
|
|
while (a < end)
|
|
if ((flag= (int) *a++ - (int) *b++))
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag);
|
|
}
|
|
if (key_length < (uint) keyseg->base.length)
|
|
{ /* key_part */
|
|
if (length_diff)
|
|
{
|
|
if (length_diff < 0 || (uint) *as <= key_length)
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ?
|
|
-length_diff : length_diff);
|
|
for (length= (int) key_length-b_length; length-- > 0 ;)
|
|
{
|
|
if (*a++ != ' ')
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -1 : 1);
|
|
}
|
|
}
|
|
if (nextflag & SEARCH_NO_FIND) /* Find record after key */
|
|
return (nextflag & SEARCH_BIGGER) ? -1 : 1;
|
|
return 0;
|
|
}
|
|
else
|
|
{
|
|
if (length_diff)
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ?
|
|
-length_diff : length_diff);
|
|
}
|
|
a=as+ (uint) *as+1 ; b= bs+ b_length+1; /* to next key */
|
|
}
|
|
else
|
|
{
|
|
#ifdef USE_STRCOLL
|
|
if (use_strcoll(default_charset_info)) {
|
|
if (((enum ha_base_keytype) keyseg->base.type) == HA_KEYTYPE_BINARY)
|
|
{
|
|
while (a < end)
|
|
if ((flag= (int) *a++ - (int) *b++))
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag);
|
|
}
|
|
else
|
|
{
|
|
if ((flag = my_strnncoll(default_charset_info,
|
|
a, (int) (end-a), b, (int) (end-a))))
|
|
return (keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag;
|
|
b+= (uint) (end-a);
|
|
a=end;
|
|
}
|
|
}
|
|
else
|
|
#endif
|
|
{
|
|
while (a < end)
|
|
if ((flag= (int) *a++ - (int) *b++))
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag);
|
|
}
|
|
}
|
|
break;
|
|
case HA_KEYTYPE_INT8:
|
|
{
|
|
int i_1= (int) *((signed char*) a);
|
|
int i_2= (int) *((signed char*) b);
|
|
if ((flag = CMP(i_1,i_2)))
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag);
|
|
a= end;
|
|
b++;
|
|
break;
|
|
}
|
|
case HA_KEYTYPE_SHORT_INT:
|
|
shortget(s_1,a);
|
|
shortget(s_2,b);
|
|
if ((flag = CMP(s_1,s_2)))
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag);
|
|
a= end;
|
|
b+= 2; /* sizeof(short int); */
|
|
break;
|
|
case HA_KEYTYPE_USHORT_INT:
|
|
{
|
|
uint16 us_1,us_2;
|
|
ushortget(us_1,a);
|
|
ushortget(us_2,b);
|
|
if ((flag = CMP(us_1,us_2)))
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag);
|
|
a= end;
|
|
b+=2; /* sizeof(short int); */
|
|
break;
|
|
}
|
|
case HA_KEYTYPE_LONG_INT:
|
|
longget(l_1,a);
|
|
longget(l_2,b);
|
|
if ((flag = CMP(l_1,l_2)))
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag);
|
|
a= end;
|
|
b+= 4; /* sizeof(long int); */
|
|
break;
|
|
case HA_KEYTYPE_ULONG_INT:
|
|
ulongget(u_1,a);
|
|
ulongget(u_2,b);
|
|
if ((flag = CMP(u_1,u_2)))
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag);
|
|
a= end;
|
|
b+= 4; /* sizeof(long int); */
|
|
break;
|
|
case HA_KEYTYPE_INT24:
|
|
l_1=sint3korr(a);
|
|
l_2=sint3korr(b);
|
|
if ((flag = CMP(l_1,l_2)))
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag);
|
|
a= end;
|
|
b+= 3;
|
|
break;
|
|
case HA_KEYTYPE_UINT24:
|
|
l_1=(long) uint3korr(a);
|
|
l_2=(long) uint3korr(b);
|
|
if ((flag = CMP(l_1,l_2)))
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag);
|
|
a= end;
|
|
b+= 3;
|
|
break;
|
|
case HA_KEYTYPE_FLOAT:
|
|
bmove((byte*) &f_1,(byte*) a,(int) sizeof(float));
|
|
bmove((byte*) &f_2,(byte*) b,(int) sizeof(float));
|
|
if ((flag = CMP(f_1,f_2)))
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag);
|
|
a= end;
|
|
b+= sizeof(float);
|
|
break;
|
|
case HA_KEYTYPE_DOUBLE:
|
|
doubleget(d_1,a);
|
|
doubleget(d_2,b);
|
|
if ((flag = CMP(d_1,d_2)))
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag);
|
|
a= end;
|
|
b+= sizeof(double);
|
|
break;
|
|
case HA_KEYTYPE_NUM: /* Numeric key */
|
|
{
|
|
int swap_flag=keyseg->base.flag & HA_REVERSE_SORT;
|
|
if (keyseg->base.flag & HA_SPACE_PACK)
|
|
{
|
|
int alength,blength;
|
|
|
|
if (swap_flag)
|
|
swap(uchar*,a,b);
|
|
alength= *a++; blength= *b++;
|
|
if ((flag=(int) (keyseg->base.length-key_length)) < 0)
|
|
flag=0;
|
|
if (alength != blength+flag)
|
|
{
|
|
if ((alength > blength+flag && *a != '-') ||
|
|
(alength < blength+flag && *b == '-'))
|
|
return 1;
|
|
else
|
|
return -1;
|
|
}
|
|
if (*a == '-' && *b == '-')
|
|
{
|
|
swap_flag=1;
|
|
swap(uchar*,a,b);
|
|
}
|
|
end=a+alength;
|
|
while (a < end)
|
|
if (*a++ != *b++)
|
|
{
|
|
a--; b--;
|
|
if (isdigit((char) *a) && isdigit((char) *b))
|
|
return ((int) *a - (int) *b);
|
|
if (*a == '-' || isdigit((char) *b))
|
|
return (-1);
|
|
if (*b == '-' || *b++ == ' ' || isdigit((char) *a))
|
|
return (1);
|
|
if (*a++ == ' ')
|
|
return (-1);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
for ( ; a < end && *a == ' ' && *b == ' ' ; a++, b++) ;
|
|
if (*a == '-' && *b == '-')
|
|
swap_flag=1;
|
|
if (swap_flag)
|
|
{
|
|
end=b+(int) (end-a);
|
|
swap(uchar*,a,b);
|
|
}
|
|
while (a < end)
|
|
if (*a++ != *b++)
|
|
{
|
|
a--; b--;
|
|
if (isdigit((char) *a) && isdigit((char) *b))
|
|
return ((int) *a - (int) *b);
|
|
if (*a == '-' || isdigit((char) *b))
|
|
return (-1);
|
|
if (*b == '-' || *b++ == ' ' || isdigit((char) *a))
|
|
return (1);
|
|
if (*a++ == ' ')
|
|
return -1;
|
|
}
|
|
}
|
|
if (swap_flag)
|
|
swap(uchar*,a,b);
|
|
break;
|
|
}
|
|
#ifdef HAVE_LONG_LONG
|
|
case HA_KEYTYPE_LONGLONG:
|
|
{
|
|
longlong ll_a,ll_b;
|
|
longlongget(ll_a,a);
|
|
longlongget(ll_b,b);
|
|
if ((flag = CMP(ll_a,ll_b)))
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag);
|
|
a= end;
|
|
b+= sizeof(longlong);
|
|
break;
|
|
}
|
|
case HA_KEYTYPE_ULONGLONG:
|
|
{
|
|
ulonglong ll_a,ll_b;
|
|
longlongget(ll_a,a);
|
|
longlongget(ll_b,b);
|
|
if ((flag = CMP(ll_a,ll_b)))
|
|
return ((keyseg->base.flag & HA_REVERSE_SORT) ? -flag : flag);
|
|
a= end;
|
|
b+= sizeof(ulonglong);
|
|
break;
|
|
}
|
|
#endif
|
|
case HA_KEYTYPE_END: /* Ready */
|
|
case HA_KEYTYPE_VARTEXT: /* Impossible */
|
|
case HA_KEYTYPE_VARBINARY: /* Impossible */
|
|
goto end;
|
|
}
|
|
}
|
|
end:
|
|
if (!(nextflag & SEARCH_FIND))
|
|
{
|
|
if (nextflag & (SEARCH_NO_FIND | SEARCH_LAST)) /* Find record after key */
|
|
return (nextflag & (SEARCH_BIGGER | SEARCH_LAST)) ? -1 : 1;
|
|
LINT_INIT(l_1); LINT_INIT(l_2);
|
|
switch (keyseg->base.length) {
|
|
case 4:
|
|
u_1= (ulong) uint4korr(a);
|
|
u_2= (ulong) uint4korr(b);
|
|
break;
|
|
case 3:
|
|
u_1= (ulong) uint3korr(a);
|
|
u_2= (ulong) uint3korr(b);
|
|
break;
|
|
case 2:
|
|
u_1= (ulong) uint2korr(a);
|
|
u_2= (ulong) uint2korr(b);
|
|
break;
|
|
default: abort(); /* Impossible */
|
|
}
|
|
flag = CMP(u_1,u_2);
|
|
|
|
if (nextflag & SEARCH_SAME)
|
|
return (flag); /* read same */
|
|
if (nextflag & SEARCH_BIGGER)
|
|
return (flag <= 0 ? -1 : 1); /* read next */
|
|
return (flag < 0 ? -1 : 1); /* read previous */
|
|
}
|
|
return 0;
|
|
} /* _nisam_key_cmp */
|
|
|
|
|
|
/* Get key from key-block */
|
|
/* page points at previous key; its advanced to point at next key */
|
|
/* key should contain previous key */
|
|
/* Returns length of found key + pointers */
|
|
/* nod_flag is a flag if we are on nod */
|
|
|
|
uint _nisam_get_key(register N_KEYDEF *keyinfo, uint nod_flag,
|
|
register uchar **page, register uchar *key)
|
|
{
|
|
reg1 N_KEYSEG *keyseg;
|
|
uchar *start,*start_key;
|
|
uint length,c_length;
|
|
|
|
LINT_INIT(start);
|
|
start_key=key; c_length=0;
|
|
for (keyseg=keyinfo->seg ; keyseg->base.type ;keyseg++)
|
|
{
|
|
if (keyseg->base.flag & (HA_SPACE_PACK | HA_PACK_KEY))
|
|
{
|
|
start=key;
|
|
if (keyseg->base.flag & HA_SPACE_PACK)
|
|
key++;
|
|
if ((length= *(*page)++) & 128)
|
|
{
|
|
key+= (c_length=(length & 127));
|
|
if (c_length == 0) /* Same key */
|
|
{
|
|
key+= *start; /* Same diff_key as prev */
|
|
length=0;
|
|
}
|
|
else
|
|
{
|
|
if (keyseg->base.flag & HA_SPACE_PACK)
|
|
length= *(*page)++;
|
|
else
|
|
length=keyseg->base.length-length+128; /* Rest of key */
|
|
/* Prevent core dumps if wrong data formats */
|
|
if (length > keyseg->base.length)
|
|
length=0;
|
|
}
|
|
}
|
|
}
|
|
else
|
|
length=keyseg->base.length;
|
|
memcpy((byte*) key,(byte*) *page,(size_t) length); key+=length;
|
|
if (keyseg->base.flag & HA_SPACE_PACK)
|
|
*start= (uchar) ((key-start)-1);
|
|
*page+=length;
|
|
}
|
|
length=keyseg->base.length+nod_flag;
|
|
bmove((byte*) key,(byte*) *page,length);
|
|
*page+=length;
|
|
return((uint) (key-start_key)+keyseg->base.length);
|
|
} /* _nisam_get_key */
|
|
|
|
|
|
/* same as _nisam_get_key but used with fixed length keys */
|
|
|
|
uint _nisam_get_static_key(register N_KEYDEF *keyinfo, uint nod_flag, register uchar **page, register uchar *key)
|
|
{
|
|
memcpy((byte*) key,(byte*) *page,
|
|
(size_t) (keyinfo->base.keylength+nod_flag));
|
|
*page+=keyinfo->base.keylength+nod_flag;
|
|
return(keyinfo->base.keylength);
|
|
} /* _nisam_get_static_key */
|
|
|
|
|
|
/* Get last key from key-block, starting from keypos */
|
|
/* Return pointer to where keystarts */
|
|
|
|
uchar *_nisam_get_last_key(N_INFO *info, N_KEYDEF *keyinfo, uchar *keypos, uchar *lastkey, uchar *endpos)
|
|
{
|
|
uint nod_flag;
|
|
uchar *lastpos;
|
|
|
|
nod_flag=test_if_nod(keypos);
|
|
if (! (keyinfo->base.flag & (HA_PACK_KEY | HA_SPACE_PACK_USED)))
|
|
{
|
|
lastpos=endpos-keyinfo->base.keylength-nod_flag;
|
|
if (lastpos > keypos)
|
|
bmove((byte*) lastkey,(byte*) lastpos,keyinfo->base.keylength+nod_flag);
|
|
}
|
|
else
|
|
{
|
|
lastpos=0 ; keypos+=2+nod_flag;
|
|
lastkey[0]=0;
|
|
while (keypos < endpos)
|
|
{
|
|
lastpos=keypos;
|
|
VOID(_nisam_get_key(keyinfo,nod_flag,&keypos,lastkey));
|
|
}
|
|
}
|
|
return lastpos;
|
|
} /* _nisam_get_last_key */
|
|
|
|
|
|
/* Calculate length of key */
|
|
|
|
uint _nisam_keylength(N_KEYDEF *keyinfo, register uchar *key)
|
|
{
|
|
reg1 N_KEYSEG *keyseg;
|
|
uchar *start;
|
|
|
|
if (! (keyinfo->base.flag & HA_SPACE_PACK_USED))
|
|
return (keyinfo->base.keylength);
|
|
|
|
start=key;
|
|
for (keyseg=keyinfo->seg ; keyseg->base.type ; keyseg++)
|
|
{
|
|
if (keyseg->base.flag & HA_SPACE_PACK)
|
|
key+= *key+1;
|
|
else
|
|
key+= keyseg->base.length;
|
|
}
|
|
return((uint) (key-start)+keyseg->base.length);
|
|
} /* _nisam_keylength */
|
|
|
|
|
|
/* Move a key */
|
|
|
|
uchar *_nisam_move_key(N_KEYDEF *keyinfo, uchar *to, uchar *from)
|
|
{
|
|
reg1 uint length;
|
|
memcpy((byte*) to, (byte*) from,
|
|
(size_t) (length=_nisam_keylength(keyinfo,from)));
|
|
return to+length;
|
|
}
|
|
|
|
/* Find next/previous record with same key */
|
|
/* This can't be used when database is touched after last read */
|
|
|
|
int _nisam_search_next(register N_INFO *info, register N_KEYDEF *keyinfo,
|
|
uchar *key, uint nextflag, ulong pos)
|
|
{
|
|
int error;
|
|
uint nod_flag;
|
|
uchar lastkey[N_MAX_KEY_BUFF];
|
|
DBUG_ENTER("_nisam_search_next");
|
|
DBUG_PRINT("enter",("nextflag: %d lastpos: %d int_keypos: %lx",
|
|
nextflag,info->lastpos,info->int_keypos));
|
|
DBUG_EXECUTE("key",_nisam_print_key(DBUG_FILE,keyinfo->seg,key););
|
|
|
|
if ((nextflag & SEARCH_BIGGER && info->int_keypos >= info->int_maxpos) ||
|
|
info->int_pos == NI_POS_ERROR || info->page_changed)
|
|
DBUG_RETURN(_nisam_search(info,keyinfo,key,0,nextflag | SEARCH_SAVE_BUFF,
|
|
pos));
|
|
|
|
if (info->buff_used)
|
|
{
|
|
if (!_nisam_fetch_keypage(info,keyinfo,info->last_search_keypage,
|
|
info->buff,0))
|
|
{
|
|
info->lastpos= NI_POS_ERROR;
|
|
DBUG_RETURN(-1);
|
|
}
|
|
info->buff_used=0;
|
|
}
|
|
|
|
/* Last used buffer is in info->buff */
|
|
|
|
nod_flag=test_if_nod(info->buff);
|
|
VOID(_nisam_move_key(keyinfo,lastkey,key));
|
|
|
|
if (nextflag & SEARCH_BIGGER) /* Next key */
|
|
{
|
|
ulong tmp_pos=_nisam_kpos(nod_flag,info->int_keypos);
|
|
if (tmp_pos != NI_POS_ERROR)
|
|
{
|
|
if ((error=_nisam_search(info,keyinfo,key,0,nextflag | SEARCH_SAVE_BUFF,
|
|
tmp_pos)) <=0)
|
|
DBUG_RETURN(error);
|
|
}
|
|
VOID((*keyinfo->get_key)(keyinfo,nod_flag,&info->int_keypos,lastkey));
|
|
}
|
|
else /* Previous key */
|
|
{
|
|
info->int_keypos=_nisam_get_last_key(info,keyinfo,info->buff,lastkey,
|
|
info->int_keypos);
|
|
if (info->int_keypos == info->buff+2)
|
|
DBUG_RETURN(_nisam_search(info,keyinfo,key,0,nextflag | SEARCH_SAVE_BUFF,
|
|
pos));
|
|
if ((error=_nisam_search(info,keyinfo,key,0,nextflag | SEARCH_SAVE_BUFF,
|
|
_nisam_kpos(nod_flag,info->int_keypos))) <= 0)
|
|
DBUG_RETURN(error);
|
|
}
|
|
|
|
info->int_keypos=_nisam_get_last_key(info,keyinfo,info->buff,lastkey,
|
|
info->int_keypos);
|
|
VOID(_nisam_move_key(keyinfo,info->lastkey,lastkey));
|
|
VOID((*keyinfo->get_key)(keyinfo,nod_flag,&info->int_keypos,info->lastkey));
|
|
info->lastpos=_nisam_dpos(info,nod_flag,info->int_keypos);
|
|
DBUG_PRINT("exit",("found key at %d",info->lastpos));
|
|
DBUG_RETURN(0);
|
|
} /* _nisam_search_next */
|
|
|
|
|
|
/* S|ker reda p} positionen f|r f|rsta recordet i ett index */
|
|
/* Positionen l{ggs i info->lastpos */
|
|
|
|
int _nisam_search_first(register N_INFO *info, register N_KEYDEF *keyinfo, register ulong pos)
|
|
{
|
|
uint nod_flag;
|
|
uchar *page;
|
|
DBUG_ENTER("_nisam_search_first");
|
|
|
|
if (pos == NI_POS_ERROR)
|
|
{
|
|
my_errno=HA_ERR_KEY_NOT_FOUND;
|
|
info->lastpos= NI_POS_ERROR;
|
|
DBUG_RETURN(-1);
|
|
}
|
|
|
|
do
|
|
{
|
|
if (!_nisam_fetch_keypage(info,keyinfo,pos,info->buff,0))
|
|
{
|
|
info->lastpos= NI_POS_ERROR;
|
|
DBUG_RETURN(-1);
|
|
}
|
|
nod_flag=test_if_nod(info->buff);
|
|
page=info->buff+2+nod_flag;
|
|
} while ((pos=_nisam_kpos(nod_flag,page)) != NI_POS_ERROR);
|
|
|
|
VOID((*keyinfo->get_key)(keyinfo,nod_flag,&page,info->lastkey));
|
|
info->int_keypos=page; info->int_maxpos=info->buff+getint(info->buff)-1;
|
|
info->lastpos=_nisam_dpos(info,nod_flag,page);
|
|
info->page_changed=info->buff_used=0;
|
|
info->last_search_keypage=info->int_pos;
|
|
|
|
DBUG_PRINT("exit",("found key at %d",info->lastpos));
|
|
DBUG_RETURN(0);
|
|
} /* _nisam_search_first */
|
|
|
|
|
|
/* S|ker reda p} positionen f|r sista recordet i ett index */
|
|
/* Positionen l{ggs i info->lastpos */
|
|
|
|
int _nisam_search_last(register N_INFO *info, register N_KEYDEF *keyinfo, register ulong pos)
|
|
{
|
|
uint nod_flag;
|
|
uchar *buff,*page;
|
|
DBUG_ENTER("_nisam_search_last");
|
|
|
|
if (pos == NI_POS_ERROR)
|
|
{
|
|
my_errno=HA_ERR_KEY_NOT_FOUND; /* Didn't find key */
|
|
info->lastpos= NI_POS_ERROR;
|
|
DBUG_RETURN(-1);
|
|
}
|
|
|
|
buff=info->buff;
|
|
do
|
|
{
|
|
if (!_nisam_fetch_keypage(info,keyinfo,pos,buff,0))
|
|
{
|
|
info->lastpos= NI_POS_ERROR;
|
|
DBUG_RETURN(-1);
|
|
}
|
|
page= buff+getint(buff);
|
|
nod_flag=test_if_nod(buff);
|
|
} while ((pos=_nisam_kpos(nod_flag,page)) != NI_POS_ERROR);
|
|
|
|
VOID(_nisam_get_last_key(info,keyinfo,buff,info->lastkey,page));
|
|
info->lastpos=_nisam_dpos(info,nod_flag,page);
|
|
info->int_keypos=info->int_maxpos=page;
|
|
info->page_changed=info->buff_used=0;
|
|
info->last_search_keypage=info->int_pos;
|
|
|
|
DBUG_PRINT("exit",("found key at %d",info->lastpos));
|
|
DBUG_RETURN(0);
|
|
} /* _nisam_search_last */
|