mirror of
https://github.com/MariaDB/server.git
synced 2025-01-19 13:32:33 +01:00
a8ea31fae6
Renamed HA_VAR_LENGTH to HA_VAR_LENGTH_PART Renamed in all files FIELD_TYPE_STRING and FIELD_TYPE_VAR_STRING to MYSQL_TYPE_STRING and MYSQL_TYPE_VAR_STRING to make it easy to catch all possible errors Added support for VARCHAR KEYS to heap Removed support for ISAM Now only long VARCHAR columns are changed to TEXT on demand (not CHAR) Internal temporary files can now use fixed length tables if the used VARCHAR columns are short BitKeeper/deleted/.del-ha_isam.cc~4dce65904db2675e: Delete: sql/ha_isam.cc BitKeeper/deleted/.del-_cache.c~b5d80b5c3ae233b1: Delete: isam/_cache.c BitKeeper/deleted/.del-_dbug.c~88d7964ae5e3c9bd: Delete: isam/_dbug.c BitKeeper/deleted/.del-_dynrec.c~48dd758f5a5450df: Delete: isam/_dynrec.c BitKeeper/deleted/.del-_key.c~ce62d47a6c681084: Delete: isam/_key.c BitKeeper/deleted/.del-_locking.c~dea4cdc6ea425c67: Delete: isam/_locking.c BitKeeper/deleted/.del-_packrec.c~47ae1b16c007e9be: Delete: isam/_packrec.c BitKeeper/deleted/.del-_page.c~148b1a613d052ee8: Delete: isam/_page.c BitKeeper/deleted/.del-_search.c~f509292aa1ff18ff: Delete: isam/_search.c BitKeeper/deleted/.del-_statrec.c~58d9263b3475d58b: Delete: isam/_statrec.c BitKeeper/deleted/.del-changed.c~d075de80a314b02d: Delete: isam/changed.c BitKeeper/deleted/.del-close.c~fd62629496ee5bcc: Delete: isam/close.c BitKeeper/deleted/.del-create.c~96cecc433c0c2242: Delete: isam/create.c BitKeeper/deleted/.del-delete.c~65ee8daaa75a14b6: Delete: isam/delete.c BitKeeper/deleted/.del-extra.c~706f29d72beb2565: Delete: isam/extra.c BitKeeper/deleted/.del-info.c~96cfb747af8da0d: Delete: isam/info.c BitKeeper/deleted/.del-isamchk.c~c0f59c2687d2248f: Delete: isam/isamchk.c BitKeeper/deleted/.del-isamlog.c~85b6b31c6e2b8519: Delete: isam/isamlog.c BitKeeper/deleted/.del-log.c~55a973013d55cade: Delete: isam/log.c BitKeeper/deleted/.del-open.c~95b3b75042fae00a: Delete: isam/open.c BitKeeper/deleted/.del-pack_isam.c~43801f0df7504834: Delete: isam/pack_isam.c BitKeeper/deleted/.del-panic.c~f7fd71605324f8f3: Delete: isam/panic.c BitKeeper/deleted/.del-range.c~142f1f8ac4948082: Delete: isam/range.c BitKeeper/deleted/.del-rfirst.c~66f494291dc005d3: Delete: isam/rfirst.c BitKeeper/deleted/.del-rkey.c~cc54c6498352f999: Delete: isam/rkey.c BitKeeper/deleted/.del-rlast.c~d1fe1866139e9866: Delete: isam/rlast.c BitKeeper/deleted/.del-rnext.c~b308eaa1e11ea7de: Delete: isam/rnext.c BitKeeper/deleted/.del-rprev.c~b359f71fdea4bbce: Delete: isam/rprev.c BitKeeper/deleted/.del-rrnd.c~7fcfcce88d4a5200: Delete: isam/rrnd.c BitKeeper/deleted/.del-rsame.c~75a62d5548103a15: Delete: isam/rsame.c BitKeeper/deleted/.del-rsamepos.c~5b5652dd2cda6d5d: Delete: isam/rsamepos.c BitKeeper/deleted/.del-sort.c~e2e56b5a37ce86f4: Delete: isam/sort.c BitKeeper/deleted/.del-static.c~3a1354b84f4a9cc7: Delete: isam/static.c BitKeeper/deleted/.del-test1.c~64d52e9412d457ed: Delete: isam/test1.c BitKeeper/deleted/.del-test2.c~2f9a632cab572958: Delete: isam/test2.c BitKeeper/deleted/.del-test3.c~e8a7a4afe8a087: Delete: isam/test3.c BitKeeper/deleted/.del-isamdef.h~ac8d49e7e2201c66: Delete: isam/isamdef.h BitKeeper/deleted/.del-update.c~670264f51dc44934: Delete: isam/update.c BitKeeper/deleted/.del-write.c~8f1918b1f6770e54: Delete: isam/write.c BitKeeper/deleted/.del-Makefile.am~6cfa0db5e7778d09: Delete: isam/Makefile.am BitKeeper/deleted/.del-make-ccc~3ee55391eda0b0ab: Delete: isam/make-ccc BitKeeper/deleted/.del-ChangeLog~208984fb7a51e568: Delete: isam/ChangeLog BitKeeper/deleted/.del-test_all.res~c2aafb49a3a77db7: Delete: isam/test_all.res BitKeeper/deleted/.del-test_all~93c701e44a9c5b65: Delete: isam/test_all BitKeeper/deleted/.del-.cvsignore~54f6f0f2d5012561: Delete: isam/.cvsignore BitKeeper/deleted/.del-ha_isammrg.cc~dc682e4755d77a2e: Delete: sql/ha_isammrg.cc BitKeeper/deleted/.del-ha_isam.h~bf53d533be3d3927: Delete: sql/ha_isam.h BitKeeper/deleted/.del-ha_isammrg.h~66fd2e5bfe7207dc: Delete: sql/ha_isammrg.h acinclude.m4: Remove ISAM client/mysqldump.c: FIELD_TYPE -> MYSQL_TYPE client/mysqltest.c: Add missing DBUG_RETURN configure.in: Remove ISAM heap/heapdef.h: Add support for VARCHAR heap/hp_create.c: Add support for VARCHAR heap/hp_delete.c: Add support for VARCHAR heap/hp_hash.c: Add support for VARCHAR (VARCHAR keys was not supported before) heap/hp_rkey.c: Add support for VARCHAR heap/hp_update.c: Add support for VARCHAR heap/hp_write.c: Add support for VARCHAR (Added flag SEARCH_UPDATE to mark that this is an update) include/decimal.h: Remove not needed my_global.h include/m_ctype.h: Add support for VARCHAR include/my_base.h: Add support for VARCHAR include/my_handler.h: Moved general purpose macro from MyISAM code include/mysql_com.h: Add support for VARCHAR libmysql/libmysql.c: Add support for VARCHAR libmysqld/Makefile.am: Removed ISAM myisam/ft_static.c: Add support for VARCHAR myisam/ft_test1.c: Add support for VARCHAR myisam/ft_update.c: Add support for VARCHAR myisam/mi_check.c: Add support for VARCHAR myisam/mi_create.c: Add support for VARCHAR - VARCHAR key segments are marked with HA_VAR_LENGTH_PART myisam/mi_key.c: Add support for VARCHAR Fixed bug in old VARCHAR code when reading index-only myisam/mi_range.c: Fixed comment style myisam/mi_rnext_same.c: Handle case where equal keys can be of different length myisam/mi_search.c: Add support for VARCHAR myisam/mi_test1.c: Add support for VARCHAR myisam/mi_unique.c: Add support for VARCHAR (Some new code to handle keys that are equal but have different lengths) myisam/mi_write.c: Fixed comment myisam/myisamchk.c: Better infotext if wrong type mysql-test/r/bdb.result: Updated old result and new results for VARCHAR mysql-test/r/create.result: Updated old result and new results for VARCHAR mysql-test/r/ctype_tis620.result: Updated old result and new results for VARCHAR (Old code sorted tis620 wrong) mysql-test/r/ctype_ucs.result: Updated old result and new results for VARCHAR mysql-test/r/endspace.result: Updated old result and new results for VARCHAR mysql-test/r/func_like.result: Updated old result and new results for VARCHAR mysql-test/r/heap.result: Updated old result and new results for VARCHAR mysql-test/r/innodb.result: Updated old result. This will change a bit when also InnoDB supports VARCHAR mysql-test/r/merge.result: Updated old result and new results for VARCHAR mysql-test/r/myisam.result: Updated old result and new results for VARCHAR mysql-test/r/mysqldump.result: Updated old result and new results for VARCHAR mysql-test/r/order_by.result: Updated old result and new results for VARCHAR (Key length is different for VARCHAR) mysql-test/r/ps.result: Updated old result and new results for VARCHAR mysql-test/r/ps_1general.result: Updated results for new .frm version Don't print seconds in show full process list as this may change mysql-test/r/ps_2myisam.result: Updated old result and new results for VARCHAR mysql-test/r/ps_3innodb.result: Updated old result and new results for VARCHAR mysql-test/r/ps_4heap.result: Updated old result and new results for VARCHAR mysql-test/r/ps_5merge.result: Updated old result and new results for VARCHAR mysql-test/r/ps_6bdb.result: Updated old result and new results for VARCHAR mysql-test/r/select.result.es: Updated results by hand mysql-test/r/select.result: Updated old result and new results for VARCHAR mysql-test/r/select_found.result: Updated old result and new results for VARCHAR mysql-test/r/show_check.result: Updated old result and new results for VARCHAR mysql-test/r/strict.result: Updated old result and new results for VARCHAR mysql-test/r/subselect.result: Updated old result and new results for VARCHAR mysql-test/r/system_mysql_db.result: Updated old result and new results for VARCHAR mysql-test/r/type_blob.result: Updated old result and new results for VARCHAR mysql-test/r/type_ranges.result: Updated old result and new results for VARCHAR mysql-test/r/type_ranges.result.es: Updated some results by hand mysql-test/t/bdb.test: Test VARCHAR mysql-test/t/ctype_ucs.test: Some fixes related to VARCHAR mysql-test/t/endspace.test: Fixes to make it easier to compare columns with end space mysql-test/t/heap.test: Test VARCHAR mysql-test/t/innodb.test: Prepare for testing VARCHAR mysql-test/t/myisam.test: Test VARCHAR mysql-test/t/ps_1general.test: Don't show seconds for show processlist mysql-test/t/ps_4heap.test: Update for VARCHAR mysql-test/t/strict.test: Fix test for VARCHAR mysql-test/t/type_blob.test: Update test for VARCHAR Note that now you can't store 'a' and 'a ' in an unique varchar/text index if the column is not binary mysys/my_handler.c: Add support for VARCHAR ndb/src/common/util/NdbSqlUtil.cpp: Fix for usage of strnncollsp scripts/mysql_fix_privilege_tables.sh: Simple fix so that my_print_defaults works sql/Makefile.am: Remove ISAM sql/field.cc: Add support for VARCHAR Fixed the keys for blob's are compared with strnncollsp Ensure that old tables from MySQL 4.0 works as they did before. (Old VARCHAR will be converted to new VARCHAR on ALTER TABLE) sql/field.h: Add support for VARCHAR sql/field_conv.cc: Change FIELD_TYPE_VAR_STRING -> MYSQL_TYPE_VARCHAR Added usage of HA_KEY_BLOB_LENGTH sql/ha_berkeley.cc: Add support for VARCHAR Added usage of table->insert_or_update if we would ever want to know in key_cmp if we are changing keys sql/ha_heap.cc: Add support for VARCHAR sql/ha_innodb.cc: Changed MYSQL_TYPE_VAR_STRING to MYSQL_TYPE_VARCHAR. Waiting for Heikki to add full VARCHAR support sql/ha_innodb.h: InnoDB doesn't support full VARCHAR yet sql/ha_myisam.cc: Add support for VARCHAR sql/ha_ndbcluster.cc: Add support for VARCHAR sql/handler.h: Added HA_NO_VARCHAR for table handler that doesn't support VARCHAR. In this case MySQL will create a normal CHAR instead sql/item.cc: Fixed access of already freed memory Added support of VARCHAR - varchar length is now checked in mysql_prepare sql/item_cmpfunc.cc: Added new parameter to strncollsp sql/item_sum.cc: Added new parameter to strncollsp FIELD_TYPE -> MYSQL_TYPE sql/key.cc: Add support for VARCHAR sql/opt_range.cc: Remove character set parameter from set_key_image() sql/opt_sum.cc: Remove character set parameter from set_key_image() sql/protocol.cc: Return MYSQL_TYPE_VAR_STRING instead of MYSQL_TYPE_VARCHAR to clients (to not cause compatiblity problems) sql/sql_acl.cc: Change key handling code so that we can use CHAR or VARCHAR for the user table columns sql/sql_base.cc: Remove old, not used code sql/sql_help.cc: Remove charset from get_key_image sql/sql_parse.cc: Ensure that OPTION_TABLE_LOCK is cleared ASAP; This fixed a problem in BDB transaction code when one used LOCK TABLES on a BDB table Added support for VARCHAR Moved field length checking and VARCHAR -> TEXT convert to mysql_prepare (as we need the know the character set for the column) sql/sql_select.cc: Added support of VARCHAR Added heuristic to use fixed size rows for tmp tables if we are using only a few short VARCHAR's sql/sql_string.cc: Added extra argument to strnncollsp sql/sql_table.cc: Add support for VARCHAR Automaticly convert (with warning) big VARCHAR (but not CHAR) to TEXT If handler doesn't support VARCHAR convert VARCHAR to CHAR sql/sql_update.cc: Fixed compiler warning sql/sql_yacc.yy: Add support for VARCHAR sql/strfunc.cc: Fixed valgrind warning sql/structs.h: Added 'table' to KEY structure to make life easier for some handler functions sql/table.cc: Add support for VARCHAR - New .frm version - FIELD_TYPE -> MYSQL_TYPE sql/table.h: Added insert_or_update; A bool flag a handler can set/reset if needed (for handler internal usage) sql/unireg.h: Add support for VARCHAR strings/ctype-big5.c: Added new argument to strnncollsp() to allow one to define if end space are significant or not Changed my_like_range... to correctly calculate min_length & max_length strings/ctype-bin.c: Added new argument to strnncollsp() to allow one to define if end space are significant or not strings/ctype-czech.c: Changed my_like_range... to correctly calculate min_length & max_length strings/ctype-gbk.c: Added new argument to strnncollsp() to allow one to define if end space are significant or not Changed my_like_range... to correctly calculate min_length & max_length strings/ctype-latin1.c: Added new argument to strnncollsp() to allow one to define if end space are significant or not strings/ctype-mb.c: Added new argument to strnncollsp() to allow one to define if end space are significant or not Changed my_like_range... to correctly calculate min_length & max_length strings/ctype-simple.c: Added new argument to strnncollsp() to allow one to define if end space are significant or not Changed my_like_range... to correctly calculate min_length & max_length strings/ctype-sjis.c: Added new argument to strnncollsp() to allow one to define if end space are significant or not Changed my_like_range... to correctly calculate min_length & max_length strings/ctype-tis620.c: Added new argument to strnncollsp() to allow one to define if end space are significant or not Changed my_like_range... to correctly calculate min_length & max_length strings/ctype-uca.c: Added new argument to strnncollsp() to allow one to define if end space are significant or not strings/ctype-ucs2.c: Changed my_like_range... to correctly calculate min_length & max_length strings/ctype-utf8.c: Added new argument to strnncollsp() to allow one to define if end space are significant or not strings/ctype-win1250ch.c: Changed my_like_range... to correctly calculate min_length & max_length strings/decimal.c: Fixed include files usage Fixed some compiler warnings tests/client_test.c: Ensure tests works with VARCHAR
935 lines
24 KiB
C
935 lines
24 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 */
|
|
|
|
/* The hash functions used for saveing keys */
|
|
|
|
#include "heapdef.h"
|
|
#include <m_ctype.h>
|
|
|
|
|
|
|
|
/*
|
|
Find out how many rows there is in the given range
|
|
|
|
SYNOPSIS
|
|
hp_rb_records_in_range()
|
|
info HEAP handler
|
|
inx Index to use
|
|
min_key Min key. Is = 0 if no min range
|
|
max_key Max key. Is = 0 if no max range
|
|
|
|
NOTES
|
|
min_key.flag can have one of the following values:
|
|
HA_READ_KEY_EXACT Include the key in the range
|
|
HA_READ_AFTER_KEY Don't include key in range
|
|
|
|
max_key.flag can have one of the following values:
|
|
HA_READ_BEFORE_KEY Don't include key in range
|
|
HA_READ_AFTER_KEY Include all 'end_key' values in the range
|
|
|
|
RETURN
|
|
HA_POS_ERROR Something is wrong with the index tree.
|
|
0 There is no matching keys in the given range
|
|
number > 0 There is approximately 'number' matching rows in
|
|
the range.
|
|
*/
|
|
|
|
ha_rows hp_rb_records_in_range(HP_INFO *info, int inx, key_range *min_key,
|
|
key_range *max_key)
|
|
{
|
|
ha_rows start_pos, end_pos;
|
|
HP_KEYDEF *keyinfo= info->s->keydef + inx;
|
|
TREE *rb_tree = &keyinfo->rb_tree;
|
|
heap_rb_param custom_arg;
|
|
DBUG_ENTER("hp_rb_records_in_range");
|
|
|
|
info->lastinx= inx;
|
|
custom_arg.keyseg= keyinfo->seg;
|
|
custom_arg.search_flag= SEARCH_FIND | SEARCH_SAME;
|
|
if (min_key)
|
|
{
|
|
custom_arg.key_length= hp_rb_pack_key(keyinfo, (uchar*) info->recbuf,
|
|
(uchar*) min_key->key,
|
|
min_key->length);
|
|
start_pos= tree_record_pos(rb_tree, info->recbuf, min_key->flag,
|
|
&custom_arg);
|
|
}
|
|
else
|
|
{
|
|
start_pos= 0;
|
|
}
|
|
|
|
if (max_key)
|
|
{
|
|
custom_arg.key_length= hp_rb_pack_key(keyinfo, (uchar*) info->recbuf,
|
|
(uchar*) max_key->key,
|
|
max_key->length);
|
|
end_pos= tree_record_pos(rb_tree, info->recbuf, max_key->flag,
|
|
&custom_arg);
|
|
}
|
|
else
|
|
{
|
|
end_pos= rb_tree->elements_in_tree + (ha_rows)1;
|
|
}
|
|
|
|
DBUG_PRINT("info",("start_pos: %lu end_pos: %lu", (ulong) start_pos,
|
|
(ulong) end_pos));
|
|
if (start_pos == HA_POS_ERROR || end_pos == HA_POS_ERROR)
|
|
DBUG_RETURN(HA_POS_ERROR);
|
|
DBUG_RETURN(end_pos < start_pos ? (ha_rows) 0 :
|
|
(end_pos == start_pos ? (ha_rows) 1 : end_pos - start_pos));
|
|
}
|
|
|
|
|
|
/* Search after a record based on a key */
|
|
/* Sets info->current_ptr to found record */
|
|
/* next_flag: Search=0, next=1, prev =2, same =3 */
|
|
|
|
byte *hp_search(HP_INFO *info, HP_KEYDEF *keyinfo, const byte *key,
|
|
uint nextflag)
|
|
{
|
|
reg1 HASH_INFO *pos,*prev_ptr;
|
|
int flag;
|
|
uint old_nextflag;
|
|
HP_SHARE *share=info->s;
|
|
DBUG_ENTER("hp_search");
|
|
old_nextflag=nextflag;
|
|
flag=1;
|
|
prev_ptr=0;
|
|
|
|
if (share->records)
|
|
{
|
|
pos=hp_find_hash(&keyinfo->block, hp_mask(hp_hashnr(keyinfo, key),
|
|
share->blength, share->records));
|
|
do
|
|
{
|
|
if (!hp_key_cmp(keyinfo, pos->ptr_to_rec, key))
|
|
{
|
|
switch (nextflag) {
|
|
case 0: /* Search after key */
|
|
DBUG_PRINT("exit",("found key at %d",pos->ptr_to_rec));
|
|
info->current_hash_ptr=pos;
|
|
DBUG_RETURN(info->current_ptr= pos->ptr_to_rec);
|
|
case 1: /* Search next */
|
|
if (pos->ptr_to_rec == info->current_ptr)
|
|
nextflag=0;
|
|
break;
|
|
case 2: /* Search previous */
|
|
if (pos->ptr_to_rec == info->current_ptr)
|
|
{
|
|
my_errno=HA_ERR_KEY_NOT_FOUND; /* If gpos == 0 */
|
|
info->current_hash_ptr=prev_ptr;
|
|
DBUG_RETURN(info->current_ptr=prev_ptr ? prev_ptr->ptr_to_rec : 0);
|
|
}
|
|
prev_ptr=pos; /* Prev. record found */
|
|
break;
|
|
case 3: /* Search same */
|
|
if (pos->ptr_to_rec == info->current_ptr)
|
|
{
|
|
info->current_hash_ptr=pos;
|
|
DBUG_RETURN(info->current_ptr);
|
|
}
|
|
}
|
|
}
|
|
if (flag)
|
|
{
|
|
flag=0; /* Reset flag */
|
|
if (hp_find_hash(&keyinfo->block,
|
|
hp_mask(hp_rec_hashnr(keyinfo, pos->ptr_to_rec),
|
|
share->blength, share->records)) != pos)
|
|
break; /* Wrong link */
|
|
}
|
|
}
|
|
while ((pos=pos->next_key));
|
|
}
|
|
my_errno=HA_ERR_KEY_NOT_FOUND;
|
|
if (nextflag == 2 && ! info->current_ptr)
|
|
{
|
|
/* Do a previous from end */
|
|
info->current_hash_ptr=prev_ptr;
|
|
DBUG_RETURN(info->current_ptr=prev_ptr ? prev_ptr->ptr_to_rec : 0);
|
|
}
|
|
|
|
if (old_nextflag && nextflag)
|
|
my_errno=HA_ERR_RECORD_CHANGED; /* Didn't find old record */
|
|
DBUG_PRINT("exit",("Error: %d",my_errno));
|
|
info->current_hash_ptr=0;
|
|
DBUG_RETURN((info->current_ptr= 0));
|
|
}
|
|
|
|
|
|
/*
|
|
Search next after last read; Assumes that the table hasn't changed
|
|
since last read !
|
|
*/
|
|
|
|
byte *hp_search_next(HP_INFO *info, HP_KEYDEF *keyinfo, const byte *key,
|
|
HASH_INFO *pos)
|
|
{
|
|
DBUG_ENTER("hp_search_next");
|
|
|
|
while ((pos= pos->next_key))
|
|
{
|
|
if (! hp_key_cmp(keyinfo, pos->ptr_to_rec, key))
|
|
{
|
|
info->current_hash_ptr=pos;
|
|
DBUG_RETURN (info->current_ptr= pos->ptr_to_rec);
|
|
}
|
|
}
|
|
my_errno=HA_ERR_KEY_NOT_FOUND;
|
|
DBUG_PRINT("exit",("Error: %d",my_errno));
|
|
info->current_hash_ptr=0;
|
|
DBUG_RETURN ((info->current_ptr= 0));
|
|
}
|
|
|
|
|
|
/* Calculate pos according to keys */
|
|
|
|
ulong hp_mask(ulong hashnr, ulong buffmax, ulong maxlength)
|
|
{
|
|
if ((hashnr & (buffmax-1)) < maxlength) return (hashnr & (buffmax-1));
|
|
return (hashnr & ((buffmax >> 1) -1));
|
|
}
|
|
|
|
|
|
/* Change link from pos to new_link */
|
|
|
|
void hp_movelink(HASH_INFO *pos, HASH_INFO *next_link, HASH_INFO *newlink)
|
|
{
|
|
HASH_INFO *old_link;
|
|
do
|
|
{
|
|
old_link=next_link;
|
|
}
|
|
while ((next_link=next_link->next_key) != pos);
|
|
old_link->next_key=newlink;
|
|
return;
|
|
}
|
|
|
|
#ifndef NEW_HASH_FUNCTION
|
|
|
|
/* Calc hashvalue for a key */
|
|
|
|
ulong hp_hashnr(register HP_KEYDEF *keydef, register const byte *key)
|
|
{
|
|
/*register*/
|
|
ulong nr=1, nr2=4;
|
|
HA_KEYSEG *seg,*endseg;
|
|
|
|
for (seg=keydef->seg,endseg=seg+keydef->keysegs ; seg < endseg ; seg++)
|
|
{
|
|
uchar *pos=(uchar*) key;
|
|
key+=seg->length;
|
|
if (seg->null_bit)
|
|
{
|
|
key++; /* Skip null byte */
|
|
if (*pos) /* Found null */
|
|
{
|
|
nr^= (nr << 1) | 1;
|
|
continue;
|
|
}
|
|
pos++;
|
|
}
|
|
if (seg->type == HA_KEYTYPE_TEXT)
|
|
{
|
|
CHARSET_INFO *cs= seg->charset;
|
|
uint length= seg->length;
|
|
if (cs->mbmaxlen > 1)
|
|
{
|
|
uint char_length;
|
|
char_length= my_charpos(cs, pos, pos + length, length/cs->mbmaxlen);
|
|
set_if_smaller(length, char_length);
|
|
}
|
|
cs->coll->hash_sort(cs, pos, length, &nr, &nr2);
|
|
}
|
|
else if (seg->type == HA_KEYTYPE_VARTEXT)
|
|
{
|
|
CHARSET_INFO *cs= seg->charset;
|
|
uint length= uint2korr(pos);
|
|
if (cs->mbmaxlen > 1)
|
|
{
|
|
uint char_length;
|
|
char_length= my_charpos(cs, pos +2, pos +2 + length,
|
|
seg->length/cs->mbmaxlen);
|
|
set_if_smaller(length, char_length);
|
|
}
|
|
cs->coll->hash_sort(cs, pos+2, length, &nr, &nr2);
|
|
}
|
|
else
|
|
{
|
|
for (; pos < (uchar*) key ; pos++)
|
|
{
|
|
nr^=(ulong) ((((uint) nr & 63)+nr2)*((uint) *pos)) + (nr << 8);
|
|
nr2+=3;
|
|
}
|
|
}
|
|
}
|
|
return((ulong) nr);
|
|
}
|
|
|
|
/* Calc hashvalue for a key in a record */
|
|
|
|
ulong hp_rec_hashnr(register HP_KEYDEF *keydef, register const byte *rec)
|
|
{
|
|
/*register*/
|
|
ulong nr=1, nr2=4;
|
|
HA_KEYSEG *seg,*endseg;
|
|
|
|
for (seg=keydef->seg,endseg=seg+keydef->keysegs ; seg < endseg ; seg++)
|
|
{
|
|
uchar *pos=(uchar*) rec+seg->start,*end=pos+seg->length;
|
|
if (seg->null_bit)
|
|
{
|
|
if (rec[seg->null_pos] & seg->null_bit)
|
|
{
|
|
nr^= (nr << 1) | 1;
|
|
continue;
|
|
}
|
|
}
|
|
if (seg->type == HA_KEYTYPE_TEXT)
|
|
{
|
|
CHARSET_INFO *cs= seg->charset;
|
|
uint char_length= seg->length;
|
|
if (cs->mbmaxlen > 1)
|
|
{
|
|
char_length= my_charpos(cs, pos, pos + char_length,
|
|
char_length / cs->mbmaxlen);
|
|
set_if_smaller(char_length, seg->length); /* QQ: ok to remove? */
|
|
}
|
|
cs->coll->hash_sort(cs, pos, char_length, &nr, &nr2);
|
|
}
|
|
else if (seg->type == HA_KEYTYPE_VARTEXT)
|
|
{
|
|
CHARSET_INFO *cs= seg->charset;
|
|
uint length= uint2korr(pos);
|
|
if (cs->mbmaxlen > 1)
|
|
{
|
|
uint char_length;
|
|
char_length= my_charpos(cs, pos + 2 , pos + 2 + length,
|
|
seg->length/cs->mbmaxlen);
|
|
set_if_smaller(length, char_length);
|
|
}
|
|
cs->coll->hash_sort(cs, pos+2, length, &nr, &nr2);
|
|
}
|
|
else
|
|
{
|
|
for (; pos < end ; pos++)
|
|
{
|
|
nr^=(ulong) ((((uint) nr & 63)+nr2)*((uint) *pos))+ (nr << 8);
|
|
nr2+=3;
|
|
}
|
|
}
|
|
}
|
|
return((ulong) nr);
|
|
}
|
|
|
|
#else
|
|
|
|
/*
|
|
* Fowler/Noll/Vo hash
|
|
*
|
|
* The basis of the hash algorithm was taken from an idea sent by email to the
|
|
* IEEE Posix P1003.2 mailing list from Phong Vo (kpv@research.att.com) and
|
|
* Glenn Fowler (gsf@research.att.com). Landon Curt Noll (chongo@toad.com)
|
|
* later improved on their algorithm.
|
|
*
|
|
* The magic is in the interesting relationship between the special prime
|
|
* 16777619 (2^24 + 403) and 2^32 and 2^8.
|
|
*
|
|
* This hash produces the fewest collisions of any function that we've seen so
|
|
* far, and works well on both numbers and strings.
|
|
*/
|
|
|
|
ulong hp_hashnr(register HP_KEYDEF *keydef, register const byte *key)
|
|
{
|
|
register ulong nr=0;
|
|
HA_KEYSEG *seg,*endseg;
|
|
|
|
for (seg=keydef->seg,endseg=seg+keydef->keysegs ; seg < endseg ; seg++)
|
|
{
|
|
uchar *pos=(uchar*) key;
|
|
key+=seg->length;
|
|
if (seg->null_bit)
|
|
{
|
|
key++;
|
|
if (*pos)
|
|
{
|
|
nr^= (nr << 1) | 1;
|
|
continue;
|
|
}
|
|
pos++;
|
|
}
|
|
if (seg->type == HA_KEYTYPE_TEXT)
|
|
{
|
|
seg->charset->hash_sort(seg->charset,pos,((uchar*)key)-pos,&nr,NULL);
|
|
}
|
|
else if (seg->type == HA_KEYTYPE_VARTEXT)
|
|
{
|
|
uint length= uint2korr(pos);
|
|
seg->charset->hash_sort(seg->charset, pos+2, length, &nr, NULL);
|
|
}
|
|
else
|
|
{
|
|
for ( ; pos < (uchar*) key ; pos++)
|
|
{
|
|
nr *=16777619;
|
|
nr ^=(uint) *pos;
|
|
}
|
|
}
|
|
}
|
|
return((ulong) nr);
|
|
}
|
|
|
|
/* Calc hashvalue for a key in a record */
|
|
|
|
ulong hp_rec_hashnr(register HP_KEYDEF *keydef, register const byte *rec)
|
|
{
|
|
register ulong nr=0;
|
|
HA_KEYSEG *seg,*endseg;
|
|
|
|
for (seg=keydef->seg,endseg=seg+keydef->keysegs ; seg < endseg ; seg++)
|
|
{
|
|
uchar *pos=(uchar*) rec+seg->start,*end=pos+seg->length;
|
|
if (seg->null_bit)
|
|
{
|
|
if (rec[seg->null_pos] & seg->null_bit)
|
|
{
|
|
nr^= (nr << 1) | 1;
|
|
continue;
|
|
}
|
|
}
|
|
if (seg->type == HA_KEYTYPE_TEXT)
|
|
{
|
|
seg->charset->hash_sort(seg->charset,pos,((uchar*)key)-pos,&nr,NULL);
|
|
}
|
|
else if (seg->type == HA_KEYTYPE_VARTEXT)
|
|
{
|
|
uint length= uint2korr(pos);
|
|
seg->charset->hash_sort(seg->charset, pos+2, length, &nr, NULL);
|
|
}
|
|
else
|
|
{
|
|
for ( ; pos < end ; pos++)
|
|
{
|
|
nr *=16777619;
|
|
nr ^=(uint) *pos;
|
|
}
|
|
}
|
|
}
|
|
return((ulong) nr);
|
|
}
|
|
|
|
#endif
|
|
|
|
|
|
/*
|
|
Compare keys for two records. Returns 0 if they are identical
|
|
|
|
SYNOPSIS
|
|
hp_rec_key_cmp()
|
|
keydef Key definition
|
|
rec1 Record to compare
|
|
rec2 Other record to compare
|
|
diff_if_only_endspace_difference
|
|
Different number of end space is significant
|
|
|
|
NOTES
|
|
diff_if_only_endspace_difference is used to allow us to insert
|
|
'a' and 'a ' when there is an an unique key.
|
|
|
|
RETURN
|
|
0 Key is identical
|
|
<> 0 Key differes
|
|
*/
|
|
|
|
int hp_rec_key_cmp(HP_KEYDEF *keydef, const byte *rec1, const byte *rec2,
|
|
my_bool diff_if_only_endspace_difference)
|
|
{
|
|
HA_KEYSEG *seg,*endseg;
|
|
|
|
for (seg=keydef->seg,endseg=seg+keydef->keysegs ; seg < endseg ; seg++)
|
|
{
|
|
if (seg->null_bit)
|
|
{
|
|
if ((rec1[seg->null_pos] & seg->null_bit) !=
|
|
(rec2[seg->null_pos] & seg->null_bit))
|
|
return 1;
|
|
if (rec1[seg->null_pos] & seg->null_bit)
|
|
continue;
|
|
}
|
|
if (seg->type == HA_KEYTYPE_TEXT)
|
|
{
|
|
CHARSET_INFO *cs= seg->charset;
|
|
uint char_length1;
|
|
uint char_length2;
|
|
uchar *pos1= (uchar*)rec1 + seg->start;
|
|
uchar *pos2= (uchar*)rec2 + seg->start;
|
|
if (cs->mbmaxlen > 1)
|
|
{
|
|
uint char_length= seg->length / cs->mbmaxlen;
|
|
char_length1= my_charpos(cs, pos1, pos1 + seg->length, char_length);
|
|
set_if_smaller(char_length1, seg->length);
|
|
char_length2= my_charpos(cs, pos2, pos2 + seg->length, char_length);
|
|
set_if_smaller(char_length2, seg->length);
|
|
}
|
|
else
|
|
{
|
|
char_length1= char_length2= seg->length;
|
|
}
|
|
if (seg->charset->coll->strnncollsp(seg->charset,
|
|
pos1,char_length1,
|
|
pos2,char_length2, 0))
|
|
return 1;
|
|
}
|
|
else if (seg->type == HA_KEYTYPE_VARTEXT)
|
|
{
|
|
uchar *pos1= (uchar*)rec1 + seg->start;
|
|
uchar *pos2= (uchar*)rec2 + seg->start;
|
|
uint char_length1= uint2korr(pos1);
|
|
uint char_length2= uint2korr(pos2);
|
|
CHARSET_INFO *cs= seg->charset;
|
|
if (cs->mbmaxlen > 1)
|
|
{
|
|
uint char_length= seg->length / cs->mbmaxlen;
|
|
char_length1= my_charpos(cs, pos1, pos1 + char_length1, char_length);
|
|
set_if_smaller(char_length1, seg->length);
|
|
char_length2= my_charpos(cs, pos2, pos2 + char_length2, char_length);
|
|
set_if_smaller(char_length2, seg->length);
|
|
}
|
|
|
|
if (cs->coll->strnncollsp(seg->charset,
|
|
pos1+2, char_length1,
|
|
pos2+2, char_length2,
|
|
seg->flag & HA_END_SPACE_ARE_EQUAL ?
|
|
0 : diff_if_only_endspace_difference))
|
|
return 1;
|
|
}
|
|
else
|
|
{
|
|
if (bcmp(rec1+seg->start,rec2+seg->start,seg->length))
|
|
return 1;
|
|
}
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
/* Compare a key in a record to a whole key */
|
|
|
|
int hp_key_cmp(HP_KEYDEF *keydef, const byte *rec, const byte *key)
|
|
{
|
|
HA_KEYSEG *seg,*endseg;
|
|
|
|
for (seg=keydef->seg,endseg=seg+keydef->keysegs ;
|
|
seg < endseg ;
|
|
key+= (seg++)->length)
|
|
{
|
|
if (seg->null_bit)
|
|
{
|
|
int found_null=test(rec[seg->null_pos] & seg->null_bit);
|
|
if (found_null != (int) *key++)
|
|
return 1;
|
|
if (found_null)
|
|
continue;
|
|
}
|
|
if (seg->type == HA_KEYTYPE_TEXT)
|
|
{
|
|
CHARSET_INFO *cs= seg->charset;
|
|
uint char_length_key;
|
|
uint char_length_rec;
|
|
uchar *pos= (uchar*) rec + seg->start;
|
|
if (cs->mbmaxlen > 1)
|
|
{
|
|
uint char_length= seg->length / cs->mbmaxlen;
|
|
char_length_key= my_charpos(cs, key, key + seg->length, char_length);
|
|
set_if_smaller(char_length_key, seg->length);
|
|
char_length_rec= my_charpos(cs, pos, pos + seg->length, char_length);
|
|
set_if_smaller(char_length_rec, seg->length);
|
|
}
|
|
else
|
|
{
|
|
char_length_key= seg->length;
|
|
char_length_rec= seg->length;
|
|
}
|
|
|
|
if (seg->charset->coll->strnncollsp(seg->charset,
|
|
(uchar*) pos, char_length_rec,
|
|
(uchar*) key, char_length_key, 0))
|
|
return 1;
|
|
}
|
|
else if (seg->type == HA_KEYTYPE_VARTEXT)
|
|
{
|
|
uchar *pos= (uchar*) rec + seg->start;
|
|
CHARSET_INFO *cs= seg->charset;
|
|
uint char_length_rec= uint2korr(pos);
|
|
uint char_length_key= uint2korr(key);
|
|
|
|
if (cs->mbmaxlen > 1)
|
|
{
|
|
uint char_length= seg->length / cs->mbmaxlen;
|
|
char_length_key= my_charpos(cs, key+2, key +2 + char_length_key,
|
|
char_length);
|
|
set_if_smaller(char_length_key, seg->length);
|
|
char_length_rec= my_charpos(cs, pos +2 , pos + 2 + char_length_rec,
|
|
char_length);
|
|
set_if_smaller(char_length_rec, seg->length);
|
|
}
|
|
|
|
|
|
if (cs->coll->strnncollsp(seg->charset,
|
|
(uchar*) pos+2, char_length_rec,
|
|
(uchar*) key+2, char_length_key, 0))
|
|
return 1;
|
|
}
|
|
else
|
|
{
|
|
if (bcmp(rec+seg->start,key,seg->length))
|
|
return 1;
|
|
}
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
|
|
/* Copy a key from a record to a keybuffer */
|
|
|
|
void hp_make_key(HP_KEYDEF *keydef, byte *key, const byte *rec)
|
|
{
|
|
HA_KEYSEG *seg,*endseg;
|
|
|
|
for (seg=keydef->seg,endseg=seg+keydef->keysegs ; seg < endseg ; seg++)
|
|
{
|
|
CHARSET_INFO *cs= seg->charset;
|
|
uint char_length= seg->length;
|
|
uchar *pos= (uchar*) rec + seg->start;
|
|
if (seg->null_bit)
|
|
*key++= test(rec[seg->null_pos] & seg->null_bit);
|
|
if (cs->mbmaxlen > 1)
|
|
{
|
|
char_length= my_charpos(cs, pos, pos + seg->length,
|
|
char_length / cs->mbmaxlen);
|
|
set_if_smaller(char_length, seg->length); /* QQ: ok to remove? */
|
|
}
|
|
memcpy(key,rec+seg->start,(size_t) char_length);
|
|
key+= char_length;
|
|
}
|
|
}
|
|
|
|
#define FIX_LENGTH(cs, pos, length, char_length) \
|
|
do { \
|
|
if (length > char_length) \
|
|
char_length= my_charpos(cs, pos, pos+length, char_length); \
|
|
set_if_smaller(char_length,length); \
|
|
} while(0)
|
|
|
|
|
|
uint hp_rb_make_key(HP_KEYDEF *keydef, byte *key,
|
|
const byte *rec, byte *recpos)
|
|
{
|
|
byte *start_key= key;
|
|
HA_KEYSEG *seg, *endseg;
|
|
|
|
for (seg= keydef->seg, endseg= seg + keydef->keysegs; seg < endseg; seg++)
|
|
{
|
|
uint char_length;
|
|
if (seg->null_bit)
|
|
{
|
|
if (!(*key++= 1 - test(rec[seg->null_pos] & seg->null_bit)))
|
|
continue;
|
|
}
|
|
if (seg->flag & HA_SWAP_KEY)
|
|
{
|
|
uint length= seg->length;
|
|
byte *pos= (byte*) rec + seg->start;
|
|
|
|
#ifdef HAVE_ISNAN
|
|
if (seg->type == HA_KEYTYPE_FLOAT)
|
|
{
|
|
float nr;
|
|
float4get(nr, pos);
|
|
if (isnan(nr))
|
|
{
|
|
/* Replace NAN with zero */
|
|
bzero(key, length);
|
|
key+= length;
|
|
continue;
|
|
}
|
|
}
|
|
else if (seg->type == HA_KEYTYPE_DOUBLE)
|
|
{
|
|
double nr;
|
|
float8get(nr, pos);
|
|
if (isnan(nr))
|
|
{
|
|
bzero(key, length);
|
|
key+= length;
|
|
continue;
|
|
}
|
|
}
|
|
#endif
|
|
pos+= length;
|
|
while (length--)
|
|
{
|
|
*key++= *--pos;
|
|
}
|
|
continue;
|
|
}
|
|
|
|
if (seg->flag & HA_VAR_LENGTH_PART)
|
|
{
|
|
uchar *pos= (uchar*) rec + seg->start;
|
|
uint length= seg->length;
|
|
uint tmp_length= uint2korr(pos);
|
|
CHARSET_INFO *cs= seg->charset;
|
|
char_length= length/cs->mbmaxlen;
|
|
|
|
pos+=2; /* Skip VARCHAR length */
|
|
set_if_smaller(length,tmp_length);
|
|
FIX_LENGTH(cs, pos, length, char_length);
|
|
store_key_length_inc(key,char_length);
|
|
memcpy((byte*) key,(byte*) pos,(size_t) char_length);
|
|
key+= char_length;
|
|
continue;
|
|
}
|
|
|
|
char_length= seg->length;
|
|
if (seg->charset->mbmaxlen > 1)
|
|
{
|
|
char_length= my_charpos(seg->charset,
|
|
rec + seg->start, rec + seg->start + char_length,
|
|
char_length / seg->charset->mbmaxlen);
|
|
set_if_smaller(char_length, seg->length); /* QQ: ok to remove? */
|
|
if (char_length < seg->length)
|
|
seg->charset->cset->fill(seg->charset, (char*) key + char_length,
|
|
seg->length - char_length, ' ');
|
|
}
|
|
memcpy(key, rec + seg->start, (size_t) char_length);
|
|
key+= seg->length;
|
|
}
|
|
memcpy(key, &recpos, sizeof(byte*));
|
|
return key - start_key;
|
|
}
|
|
|
|
|
|
uint hp_rb_pack_key(HP_KEYDEF *keydef, uchar *key, const uchar *old,
|
|
uint k_len)
|
|
{
|
|
HA_KEYSEG *seg, *endseg;
|
|
uchar *start_key= key;
|
|
|
|
for (seg= keydef->seg, endseg= seg + keydef->keysegs;
|
|
seg < endseg && (int) k_len > 0; old+= seg->length, seg++)
|
|
{
|
|
uint char_length;
|
|
if (seg->null_bit)
|
|
{
|
|
k_len--;
|
|
if (!(*key++= (char) 1 - *old++))
|
|
{
|
|
k_len-= seg->length;
|
|
continue;
|
|
}
|
|
}
|
|
if (seg->flag & HA_SWAP_KEY)
|
|
{
|
|
uint length= seg->length;
|
|
byte *pos= (byte*) old + length;
|
|
|
|
k_len-= length;
|
|
while (length--)
|
|
{
|
|
*key++= *--pos;
|
|
}
|
|
continue;
|
|
}
|
|
if (seg->flag & (HA_VAR_LENGTH_PART | HA_BLOB_PART))
|
|
{
|
|
/* Length of key-part used with heap_rkey() always 2 */
|
|
uint tmp_length=uint2korr(old);
|
|
uint length= seg->length;
|
|
CHARSET_INFO *cs= seg->charset;
|
|
char_length= length/cs->mbmaxlen;
|
|
|
|
k_len-= 2+length;
|
|
old+= 2;
|
|
set_if_smaller(length,tmp_length); /* Safety */
|
|
FIX_LENGTH(cs, old, length, char_length);
|
|
store_key_length_inc(key,char_length);
|
|
memcpy((byte*) key, old,(size_t) char_length);
|
|
key+= char_length;
|
|
continue;
|
|
}
|
|
char_length= seg->length;
|
|
if (seg->charset->mbmaxlen > 1)
|
|
{
|
|
char_length= my_charpos(seg->charset, old, old+char_length,
|
|
char_length / seg->charset->mbmaxlen);
|
|
set_if_smaller(char_length, seg->length); /* QQ: ok to remove? */
|
|
if (char_length < seg->length)
|
|
seg->charset->cset->fill(seg->charset, (char*) key + char_length,
|
|
seg->length - char_length, ' ');
|
|
}
|
|
memcpy(key, old, (size_t) char_length);
|
|
key+= seg->length;
|
|
k_len-= seg->length;
|
|
}
|
|
return key - start_key;
|
|
}
|
|
|
|
|
|
uint hp_rb_key_length(HP_KEYDEF *keydef,
|
|
const byte *key __attribute__((unused)))
|
|
{
|
|
return keydef->length;
|
|
}
|
|
|
|
|
|
uint hp_rb_null_key_length(HP_KEYDEF *keydef, const byte *key)
|
|
{
|
|
const byte *start_key= key;
|
|
HA_KEYSEG *seg, *endseg;
|
|
|
|
for (seg= keydef->seg, endseg= seg + keydef->keysegs; seg < endseg; seg++)
|
|
{
|
|
if (seg->null_bit && !*key++)
|
|
continue;
|
|
key+= seg->length;
|
|
}
|
|
return key - start_key;
|
|
}
|
|
|
|
|
|
uint hp_rb_var_key_length(HP_KEYDEF *keydef, const byte *key)
|
|
{
|
|
const byte *start_key= key;
|
|
HA_KEYSEG *seg, *endseg;
|
|
|
|
for (seg= keydef->seg, endseg= seg + keydef->keysegs; seg < endseg; seg++)
|
|
{
|
|
uint length= seg->length;
|
|
if (seg->null_bit && !*key++)
|
|
continue;
|
|
if (seg->flag & (HA_VAR_LENGTH_PART | HA_BLOB_PART))
|
|
{
|
|
get_key_length(length, key);
|
|
}
|
|
key+= length;
|
|
}
|
|
return key - start_key;
|
|
}
|
|
|
|
|
|
/*
|
|
Test if any of the key parts are NULL.
|
|
Return:
|
|
1 if any of the key parts was NULL
|
|
0 otherwise
|
|
*/
|
|
|
|
my_bool hp_if_null_in_key(HP_KEYDEF *keydef, const byte *record)
|
|
{
|
|
HA_KEYSEG *seg,*endseg;
|
|
for (seg=keydef->seg,endseg=seg+keydef->keysegs ; seg < endseg ; seg++)
|
|
{
|
|
if (seg->null_bit && (record[seg->null_pos] & seg->null_bit))
|
|
return 1;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
|
|
/*
|
|
Update auto_increment info
|
|
|
|
SYNOPSIS
|
|
update_auto_increment()
|
|
info MyISAM handler
|
|
record Row to update
|
|
|
|
IMPLEMENTATION
|
|
Only replace the auto_increment value if it is higher than the previous
|
|
one. For signed columns we don't update the auto increment value if it's
|
|
less than zero.
|
|
*/
|
|
|
|
void heap_update_auto_increment(HP_INFO *info, const byte *record)
|
|
{
|
|
ulonglong value= 0; /* Store unsigned values here */
|
|
longlong s_value= 0; /* Store signed values here */
|
|
|
|
HA_KEYSEG *keyseg= info->s->keydef[info->s->auto_key - 1].seg;
|
|
const uchar *key= (uchar*) record + keyseg->start;
|
|
|
|
switch (info->s->auto_key_type) {
|
|
case HA_KEYTYPE_INT8:
|
|
s_value= (longlong) *(char*)key;
|
|
break;
|
|
case HA_KEYTYPE_BINARY:
|
|
value=(ulonglong) *(uchar*) key;
|
|
break;
|
|
case HA_KEYTYPE_SHORT_INT:
|
|
s_value= (longlong) sint2korr(key);
|
|
break;
|
|
case HA_KEYTYPE_USHORT_INT:
|
|
value=(ulonglong) uint2korr(key);
|
|
break;
|
|
case HA_KEYTYPE_LONG_INT:
|
|
s_value= (longlong) sint4korr(key);
|
|
break;
|
|
case HA_KEYTYPE_ULONG_INT:
|
|
value=(ulonglong) uint4korr(key);
|
|
break;
|
|
case HA_KEYTYPE_INT24:
|
|
s_value= (longlong) sint3korr(key);
|
|
break;
|
|
case HA_KEYTYPE_UINT24:
|
|
value=(ulonglong) uint3korr(key);
|
|
break;
|
|
case HA_KEYTYPE_FLOAT: /* This shouldn't be used */
|
|
{
|
|
float f_1;
|
|
float4get(f_1,key);
|
|
/* Ignore negative values */
|
|
value = (f_1 < (float) 0.0) ? 0 : (ulonglong) f_1;
|
|
break;
|
|
}
|
|
case HA_KEYTYPE_DOUBLE: /* This shouldn't be used */
|
|
{
|
|
double f_1;
|
|
float8get(f_1,key);
|
|
/* Ignore negative values */
|
|
value = (f_1 < 0.0) ? 0 : (ulonglong) f_1;
|
|
break;
|
|
}
|
|
case HA_KEYTYPE_LONGLONG:
|
|
s_value= sint8korr(key);
|
|
break;
|
|
case HA_KEYTYPE_ULONGLONG:
|
|
value= uint8korr(key);
|
|
break;
|
|
default:
|
|
DBUG_ASSERT(0);
|
|
value=0; /* Error */
|
|
break;
|
|
}
|
|
|
|
/*
|
|
The following code works becasue if s_value < 0 then value is 0
|
|
and if s_value == 0 then value will contain either s_value or the
|
|
correct value.
|
|
*/
|
|
set_if_bigger(info->s->auto_increment,
|
|
(s_value > 0) ? (ulonglong) s_value : value);
|
|
}
|