mirror of
https://github.com/MariaDB/server.git
synced 2025-01-18 13:02:28 +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
1350 lines
28 KiB
C++
1350 lines
28 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 */
|
|
|
|
|
|
/* This file defines all compare functions */
|
|
|
|
#ifdef __GNUC__
|
|
#pragma implementation // gcc: Class implementation
|
|
#endif
|
|
|
|
#include "mysql_priv.h"
|
|
#include <m_ctype.h>
|
|
|
|
/*
|
|
** Test functions
|
|
** These returns 0LL if false and 1LL if true and null if some arg is null
|
|
** 'AND' and 'OR' never return null
|
|
*/
|
|
|
|
longlong Item_func_not::val_int()
|
|
{
|
|
double value=args[0]->val();
|
|
null_value=args[0]->null_value;
|
|
return !null_value && value == 0 ? 1 : 0;
|
|
}
|
|
|
|
|
|
static bool convert_constant_item(Field *field, Item **item)
|
|
{
|
|
if ((*item)->const_item())
|
|
{
|
|
(*item)->save_in_field(field);
|
|
if (!((*item)->null_value))
|
|
{
|
|
Item *tmp=new Item_int(field->val_int());
|
|
if ((tmp))
|
|
*item=tmp;
|
|
return 1;
|
|
}
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
|
|
void Item_bool_func2::fix_length_and_dec()
|
|
{
|
|
max_length=1;
|
|
|
|
/* As some compare functions are generated after sql_yacc,
|
|
we have to check for out of memory conditons here */
|
|
if (!args[0] || !args[1])
|
|
return;
|
|
// Make a special case of compare with fields to get nicer DATE comparisons
|
|
if (args[0]->type() == FIELD_ITEM)
|
|
{
|
|
Field *field=((Item_field*) args[0])->field;
|
|
if (field->store_for_compare())
|
|
{
|
|
if (convert_constant_item(field,&args[1]))
|
|
{
|
|
cmp_func= &Item_bool_func2::compare_int; // Works for all types.
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
if (args[1]->type() == FIELD_ITEM)
|
|
{
|
|
Field *field=((Item_field*) args[1])->field;
|
|
if (field->store_for_compare())
|
|
{
|
|
if (convert_constant_item(field,&args[0]))
|
|
{
|
|
cmp_func= &Item_bool_func2::compare_int; // Works for all types.
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
set_cmp_func(item_cmp_type(args[0]->result_type(),args[1]->result_type()));
|
|
}
|
|
|
|
|
|
void Item_bool_func2::set_cmp_func(Item_result type)
|
|
{
|
|
switch (type) {
|
|
case STRING_RESULT:
|
|
cmp_func=&Item_bool_func2::compare_string;
|
|
break;
|
|
case REAL_RESULT:
|
|
cmp_func=&Item_bool_func2::compare_real;
|
|
break;
|
|
case INT_RESULT:
|
|
cmp_func=&Item_bool_func2::compare_int;
|
|
break;
|
|
}
|
|
}
|
|
|
|
|
|
int Item_bool_func2::compare_string()
|
|
{
|
|
String *res1,*res2;
|
|
if ((res1=args[0]->val_str(&tmp_value1)))
|
|
{
|
|
if ((res2=args[1]->val_str(&tmp_value2)))
|
|
{
|
|
null_value=0;
|
|
return binary ? stringcmp(res1,res2) : sortcmp(res1,res2);
|
|
}
|
|
}
|
|
null_value=1;
|
|
return -1;
|
|
}
|
|
|
|
int Item_bool_func2::compare_real()
|
|
{
|
|
double val1=args[0]->val();
|
|
if (!args[0]->null_value)
|
|
{
|
|
double val2=args[1]->val();
|
|
if (!args[1]->null_value)
|
|
{
|
|
null_value=0;
|
|
if (val1 < val2) return -1;
|
|
if (val1 == val2) return 0;
|
|
return 1;
|
|
}
|
|
}
|
|
null_value=1;
|
|
return -1;
|
|
}
|
|
|
|
|
|
int Item_bool_func2::compare_int()
|
|
{
|
|
longlong val1=args[0]->val_int();
|
|
if (!args[0]->null_value)
|
|
{
|
|
longlong val2=args[1]->val_int();
|
|
if (!args[1]->null_value)
|
|
{
|
|
null_value=0;
|
|
if (val1 < val2) return -1;
|
|
if (val1 == val2) return 0;
|
|
return 1;
|
|
}
|
|
}
|
|
null_value=1;
|
|
return -1;
|
|
}
|
|
|
|
|
|
|
|
longlong Item_func_eq::val_int()
|
|
{
|
|
int value=(this->*cmp_func)();
|
|
return value == 0 ? 1 : 0;
|
|
}
|
|
|
|
/* Same as Item_func_eq, but NULL = NULL */
|
|
|
|
void Item_func_equal::fix_length_and_dec()
|
|
{
|
|
Item_bool_func2::fix_length_and_dec();
|
|
cmp_result_type=item_cmp_type(args[0]->result_type(),args[1]->result_type());
|
|
maybe_null=null_value=0;
|
|
}
|
|
|
|
longlong Item_func_equal::val_int()
|
|
{
|
|
switch (cmp_result_type) {
|
|
case STRING_RESULT:
|
|
{
|
|
String *res1,*res2;
|
|
res1=args[0]->val_str(&tmp_value1);
|
|
res2=args[1]->val_str(&tmp_value2);
|
|
if (!res1 || !res2)
|
|
return test(res1 == res2);
|
|
return (binary ? test(stringcmp(res1,res2) == 0) :
|
|
test(sortcmp(res1,res2) == 0));
|
|
}
|
|
case REAL_RESULT:
|
|
{
|
|
double val1=args[0]->val();
|
|
double val2=args[1]->val();
|
|
if (args[0]->null_value || args[1]->null_value)
|
|
return test(args[0]->null_value && args[1]->null_value);
|
|
return test(val1 == val2);
|
|
}
|
|
case INT_RESULT:
|
|
{
|
|
longlong val1=args[0]->val_int();
|
|
longlong val2=args[1]->val_int();
|
|
if (args[0]->null_value || args[1]->null_value)
|
|
return test(args[0]->null_value && args[1]->null_value);
|
|
return test(val1 == val2);
|
|
}
|
|
}
|
|
return 0; // Impossible
|
|
}
|
|
|
|
|
|
longlong Item_func_ne::val_int()
|
|
{
|
|
int value=(this->*cmp_func)();
|
|
return value != 0 && !null_value ? 1 : 0;
|
|
}
|
|
|
|
|
|
longlong Item_func_ge::val_int()
|
|
{
|
|
int value=(this->*cmp_func)();
|
|
return value >= 0 ? 1 : 0;
|
|
}
|
|
|
|
|
|
longlong Item_func_gt::val_int()
|
|
{
|
|
int value=(this->*cmp_func)();
|
|
return value > 0 ? 1 : 0;
|
|
}
|
|
|
|
longlong Item_func_le::val_int()
|
|
{
|
|
int value=(this->*cmp_func)();
|
|
return value <= 0 && !null_value ? 1 : 0;
|
|
}
|
|
|
|
|
|
longlong Item_func_lt::val_int()
|
|
{
|
|
int value=(this->*cmp_func)();
|
|
return value < 0 && !null_value ? 1 : 0;
|
|
}
|
|
|
|
|
|
longlong Item_func_strcmp::val_int()
|
|
{
|
|
String *a=args[0]->val_str(&tmp_value1);
|
|
String *b=args[1]->val_str(&tmp_value2);
|
|
if (!a || !b)
|
|
{
|
|
null_value=1;
|
|
return 0;
|
|
}
|
|
int value= binary ? stringcmp(a,b) : sortcmp(a,b);
|
|
null_value=0;
|
|
return !value ? 0 : (value < 0 ? (longlong) -1 : (longlong) 1);
|
|
}
|
|
|
|
|
|
void Item_func_interval::fix_length_and_dec()
|
|
{
|
|
bool nums=1;
|
|
uint i;
|
|
for (i=0 ; i < arg_count ; i++)
|
|
{
|
|
if (!args[i])
|
|
return; // End of memory
|
|
if (args[i]->type() != Item::INT_ITEM &&
|
|
args[i]->type() != Item::REAL_ITEM)
|
|
{
|
|
nums=0;
|
|
break;
|
|
}
|
|
}
|
|
if (nums && arg_count >= 8)
|
|
{
|
|
if ((intervals=(double*) sql_alloc(sizeof(double)*arg_count)))
|
|
{
|
|
for (i=0 ; i < arg_count ; i++)
|
|
intervals[i]=args[i]->val();
|
|
}
|
|
}
|
|
maybe_null=0; max_length=2;
|
|
used_tables_cache|=item->used_tables();
|
|
}
|
|
|
|
/*
|
|
return -1 if null value,
|
|
0 if lower than lowest
|
|
1 - arg_count if between args[n] and args[n+1]
|
|
arg_count+1 if higher than biggest argument
|
|
*/
|
|
|
|
longlong Item_func_interval::val_int()
|
|
{
|
|
double value=item->val();
|
|
if (item->null_value)
|
|
return -1; // -1 if null /* purecov: inspected */
|
|
if (intervals)
|
|
{ // Use binary search to find interval
|
|
uint start,end;
|
|
start=0; end=arg_count-1;
|
|
while (start != end)
|
|
{
|
|
uint mid=(start+end+1)/2;
|
|
if (intervals[mid] <= value)
|
|
start=mid;
|
|
else
|
|
end=mid-1;
|
|
}
|
|
return (value < intervals[start]) ? 0 : start+1;
|
|
}
|
|
if (args[0]->val() > value)
|
|
return 0;
|
|
for (uint i=1 ; i < arg_count ; i++)
|
|
{
|
|
if (args[i]->val() > value)
|
|
return i;
|
|
}
|
|
return (longlong) arg_count;
|
|
}
|
|
|
|
|
|
void Item_func_interval::update_used_tables()
|
|
{
|
|
Item_func::update_used_tables();
|
|
item->update_used_tables();
|
|
used_tables_cache|=item->used_tables();
|
|
const_item_cache&=item->const_item();
|
|
}
|
|
|
|
void Item_func_between::fix_length_and_dec()
|
|
{
|
|
max_length=1;
|
|
|
|
/* As some compare functions are generated after sql_yacc,
|
|
we have to check for out of memory conditons here */
|
|
if (!args[0] || !args[1] || !args[2])
|
|
return;
|
|
cmp_type=args[0]->result_type();
|
|
if (args[0]->binary)
|
|
string_compare=stringcmp;
|
|
else
|
|
string_compare=sortcmp;
|
|
|
|
// Make a special case of compare with fields to get nicer DATE comparisons
|
|
if (args[0]->type() == FIELD_ITEM)
|
|
{
|
|
Field *field=((Item_field*) args[0])->field;
|
|
if (field->store_for_compare())
|
|
{
|
|
if (convert_constant_item(field,&args[1]))
|
|
cmp_type=INT_RESULT; // Works for all types.
|
|
if (convert_constant_item(field,&args[2]))
|
|
cmp_type=INT_RESULT; // Works for all types.
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
longlong Item_func_between::val_int()
|
|
{ // ANSI BETWEEN
|
|
if (cmp_type == STRING_RESULT)
|
|
{
|
|
String *value,*a,*b;
|
|
value=args[0]->val_str(&value0);
|
|
if ((null_value=args[0]->null_value))
|
|
return 0;
|
|
a=args[1]->val_str(&value1);
|
|
b=args[2]->val_str(&value2);
|
|
if (!args[1]->null_value && !args[2]->null_value)
|
|
return (string_compare(value,a) >= 0 && string_compare(value,b) <= 0) ?
|
|
1 : 0;
|
|
if (args[1]->null_value && args[2]->null_value)
|
|
null_value=1;
|
|
else if (args[1]->null_value)
|
|
{
|
|
null_value= string_compare(value,b) <= 0; // not null if false range.
|
|
}
|
|
else
|
|
{
|
|
null_value= string_compare(value,a) >= 0; // not null if false range.
|
|
}
|
|
}
|
|
else if (cmp_type == INT_RESULT)
|
|
{
|
|
longlong value=args[0]->val_int(),a,b;
|
|
if ((null_value=args[0]->null_value))
|
|
return 0; /* purecov: inspected */
|
|
a=args[1]->val_int();
|
|
b=args[2]->val_int();
|
|
if (!args[1]->null_value && !args[2]->null_value)
|
|
return (value >= a && value <= b) ? 1 : 0;
|
|
if (args[1]->null_value && args[2]->null_value)
|
|
null_value=1;
|
|
else if (args[1]->null_value)
|
|
{
|
|
null_value= value <= b; // not null if false range.
|
|
}
|
|
else
|
|
{
|
|
null_value= value >= a;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
double value=args[0]->val(),a,b;
|
|
if ((null_value=args[0]->null_value))
|
|
return 0; /* purecov: inspected */
|
|
a=args[1]->val();
|
|
b=args[2]->val();
|
|
if (!args[1]->null_value && !args[2]->null_value)
|
|
return (value >= a && value <= b) ? 1 : 0;
|
|
if (args[1]->null_value && args[2]->null_value)
|
|
null_value=1;
|
|
else if (args[1]->null_value)
|
|
{
|
|
null_value= value <= b; // not null if false range.
|
|
}
|
|
else
|
|
{
|
|
null_value= value >= a;
|
|
}
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
void
|
|
Item_func_ifnull::fix_length_and_dec()
|
|
{
|
|
maybe_null=args[1]->maybe_null;
|
|
max_length=max(args[0]->max_length,args[1]->max_length);
|
|
decimals=max(args[0]->decimals,args[1]->decimals);
|
|
cached_result_type=args[0]->result_type();
|
|
}
|
|
|
|
double
|
|
Item_func_ifnull::val()
|
|
{
|
|
double value=args[0]->val();
|
|
if (!args[0]->null_value)
|
|
{
|
|
null_value=0;
|
|
return value;
|
|
}
|
|
value=args[1]->val();
|
|
if ((null_value=args[1]->null_value))
|
|
return 0.0;
|
|
return value;
|
|
}
|
|
|
|
longlong
|
|
Item_func_ifnull::val_int()
|
|
{
|
|
longlong value=args[0]->val_int();
|
|
if (!args[0]->null_value)
|
|
{
|
|
null_value=0;
|
|
return value;
|
|
}
|
|
value=args[1]->val_int();
|
|
if ((null_value=args[1]->null_value))
|
|
return 0;
|
|
return value;
|
|
}
|
|
|
|
String *
|
|
Item_func_ifnull::val_str(String *str)
|
|
{
|
|
String *res =args[0]->val_str(str);
|
|
if (!args[0]->null_value)
|
|
{
|
|
null_value=0;
|
|
return res;
|
|
}
|
|
res=args[1]->val_str(str);
|
|
if ((null_value=args[1]->null_value))
|
|
return 0;
|
|
return res;
|
|
}
|
|
|
|
void
|
|
Item_func_if::fix_length_and_dec()
|
|
{
|
|
maybe_null=args[1]->maybe_null || args[2]->maybe_null;
|
|
max_length=max(args[1]->max_length,args[2]->max_length);
|
|
decimals=max(args[1]->decimals,args[2]->decimals);
|
|
enum Item_result arg1_type=args[1]->result_type();
|
|
enum Item_result arg2_type=args[2]->result_type();
|
|
if (arg1_type == STRING_RESULT || arg2_type == STRING_RESULT)
|
|
cached_result_type = STRING_RESULT;
|
|
else if (arg1_type == REAL_RESULT || arg2_type == REAL_RESULT)
|
|
cached_result_type = REAL_RESULT;
|
|
else
|
|
cached_result_type=arg1_type; // Should be INT_RESULT
|
|
}
|
|
|
|
|
|
double
|
|
Item_func_if::val()
|
|
{
|
|
Item *arg= args[0]->val_int() ? args[1] : args[2];
|
|
double value=arg->val();
|
|
null_value=arg->null_value;
|
|
return value;
|
|
}
|
|
|
|
longlong
|
|
Item_func_if::val_int()
|
|
{
|
|
Item *arg= args[0]->val_int() ? args[1] : args[2];
|
|
longlong value=arg->val_int();
|
|
null_value=arg->null_value;
|
|
return value;
|
|
}
|
|
|
|
String *
|
|
Item_func_if::val_str(String *str)
|
|
{
|
|
Item *arg= args[0]->val_int() ? args[1] : args[2];
|
|
String *res=arg->val_str(str);
|
|
null_value=arg->null_value;
|
|
return res;
|
|
}
|
|
|
|
|
|
void
|
|
Item_func_nullif::fix_length_and_dec()
|
|
{
|
|
Item_bool_func2::fix_length_and_dec();
|
|
maybe_null=1;
|
|
if (args[0]) // Only false if EOM
|
|
{
|
|
max_length=args[0]->max_length;
|
|
decimals=args[0]->decimals;
|
|
cached_result_type=args[0]->result_type();
|
|
}
|
|
}
|
|
|
|
/*
|
|
nullif() returns NULL if arguments are different, else it returns the
|
|
first argument.
|
|
Note that we have to evaluate the first argument twice as the compare
|
|
may have been done with a different type than return value
|
|
*/
|
|
|
|
double
|
|
Item_func_nullif::val()
|
|
{
|
|
double value;
|
|
if (!(this->*cmp_func)() || null_value)
|
|
{
|
|
null_value=1;
|
|
return 0.0;
|
|
}
|
|
value=args[0]->val();
|
|
null_value=args[0]->null_value;
|
|
return value;
|
|
}
|
|
|
|
longlong
|
|
Item_func_nullif::val_int()
|
|
{
|
|
longlong value;
|
|
if (!(this->*cmp_func)() || null_value)
|
|
{
|
|
null_value=1;
|
|
return 0;
|
|
}
|
|
value=args[0]->val_int();
|
|
null_value=args[0]->null_value;
|
|
return value;
|
|
}
|
|
|
|
String *
|
|
Item_func_nullif::val_str(String *str)
|
|
{
|
|
String *res;
|
|
if (!(this->*cmp_func)() || null_value)
|
|
{
|
|
null_value=1;
|
|
return 0;
|
|
}
|
|
res=args[0]->val_str(str);
|
|
null_value=args[0]->null_value;
|
|
return res;
|
|
}
|
|
|
|
/*
|
|
** CASE expression
|
|
*/
|
|
|
|
/* Return the matching ITEM or NULL if all compares (including else) failed */
|
|
|
|
Item *Item_func_case::find_item(String *str)
|
|
{
|
|
String *first_expr_str,*tmp;
|
|
longlong first_expr_int;
|
|
double first_expr_real;
|
|
bool int_used, real_used,str_used;
|
|
int_used=real_used=str_used=0;
|
|
|
|
/* These will be initialized later */
|
|
LINT_INIT(first_expr_str);
|
|
LINT_INIT(first_expr_int);
|
|
LINT_INIT(first_expr_real);
|
|
|
|
// Compare every WHEN argument with it and return the first match
|
|
for (uint i=0 ; i < arg_count ; i+=2)
|
|
{
|
|
if (!first_expr)
|
|
{
|
|
// No expression between CASE and first WHEN
|
|
if (args[i]->val_int())
|
|
return args[i+1];
|
|
continue;
|
|
}
|
|
switch (args[i]->result_type()) {
|
|
case STRING_RESULT:
|
|
if (!str_used)
|
|
{
|
|
str_used=1;
|
|
// We can't use 'str' here as this may be overwritten
|
|
if (!(first_expr_str= first_expr->val_str(&str_value)))
|
|
return else_expr; // Impossible
|
|
}
|
|
if ((tmp=args[i]->val_str(str))) // If not null
|
|
{
|
|
if (first_expr->binary || args[i]->binary)
|
|
{
|
|
if (stringcmp(tmp,first_expr_str)==0)
|
|
return args[i+1];
|
|
}
|
|
else if (sortcmp(tmp,first_expr_str)==0)
|
|
return args[i+1];
|
|
}
|
|
break;
|
|
case INT_RESULT:
|
|
if (!int_used)
|
|
{
|
|
int_used=1;
|
|
first_expr_int= first_expr->val_int();
|
|
if (first_expr->null_value)
|
|
return else_expr;
|
|
}
|
|
if (args[i]->val_int()==first_expr_int && !args[i]->null_value)
|
|
return args[i+1];
|
|
break;
|
|
case REAL_RESULT:
|
|
if (!real_used)
|
|
{
|
|
real_used=1;
|
|
first_expr_real= first_expr->val();
|
|
if (first_expr->null_value)
|
|
return else_expr;
|
|
}
|
|
if (args[i]->val()==first_expr_real && !args[i]->null_value)
|
|
return args[i+1];
|
|
}
|
|
}
|
|
// No, WHEN clauses all missed, return ELSE expression
|
|
return else_expr;
|
|
}
|
|
|
|
|
|
|
|
String *Item_func_case::val_str(String *str)
|
|
{
|
|
String *res;
|
|
Item *item=find_item(str);
|
|
|
|
if (!item)
|
|
{
|
|
null_value=1;
|
|
return 0;
|
|
}
|
|
if (!(res=item->val_str(str)))
|
|
null_value=1;
|
|
return res;
|
|
}
|
|
|
|
|
|
longlong Item_func_case::val_int()
|
|
{
|
|
char buff[MAX_FIELD_WIDTH];
|
|
String dummy_str(buff,sizeof(buff));
|
|
Item *item=find_item(&dummy_str);
|
|
longlong res;
|
|
|
|
if (!item)
|
|
{
|
|
null_value=1;
|
|
return 0;
|
|
}
|
|
res=item->val_int();
|
|
null_value=item->null_value;
|
|
return res;
|
|
}
|
|
|
|
double Item_func_case::val()
|
|
{
|
|
char buff[MAX_FIELD_WIDTH];
|
|
String dummy_str(buff,sizeof(buff));
|
|
Item *item=find_item(&dummy_str);
|
|
double res;
|
|
|
|
if (!item)
|
|
{
|
|
null_value=1;
|
|
return 0;
|
|
}
|
|
res=item->val();
|
|
null_value=item->null_value;
|
|
return res;
|
|
}
|
|
|
|
|
|
bool
|
|
Item_func_case::fix_fields(THD *thd,TABLE_LIST *tables)
|
|
{
|
|
if (first_expr && first_expr->fix_fields(thd,tables) ||
|
|
else_expr && else_expr->fix_fields(thd,tables))
|
|
return 1;
|
|
if (Item_func::fix_fields(thd,tables))
|
|
return 1;
|
|
if (first_expr)
|
|
{
|
|
used_tables_cache|=(first_expr)->used_tables();
|
|
const_item_cache&= (first_expr)->const_item();
|
|
}
|
|
if (else_expr)
|
|
{
|
|
used_tables_cache|=(else_expr)->used_tables();
|
|
const_item_cache&= (else_expr)->const_item();
|
|
}
|
|
if (!else_expr || else_expr->maybe_null)
|
|
maybe_null=1; // The result may be NULL
|
|
return 0;
|
|
}
|
|
|
|
void Item_func_case::update_used_tables()
|
|
{
|
|
Item_func::update_used_tables();
|
|
if (first_expr)
|
|
{
|
|
used_tables_cache|=(first_expr)->used_tables();
|
|
const_item_cache&= (first_expr)->const_item();
|
|
}
|
|
if (else_expr)
|
|
{
|
|
used_tables_cache|=(else_expr)->used_tables();
|
|
const_item_cache&= (else_expr)->const_item();
|
|
}
|
|
}
|
|
|
|
|
|
void Item_func_case::fix_length_and_dec()
|
|
{
|
|
max_length=0;
|
|
decimals=0;
|
|
cached_result_type = args[1]->result_type();
|
|
for (uint i=0 ; i < arg_count ; i+=2)
|
|
{
|
|
set_if_bigger(max_length,args[i+1]->max_length);
|
|
set_if_bigger(decimals,args[i+1]->decimals);
|
|
}
|
|
if (else_expr != NULL)
|
|
{
|
|
set_if_bigger(max_length,else_expr->max_length);
|
|
set_if_bigger(decimals,else_expr->decimals);
|
|
}
|
|
}
|
|
|
|
/* TODO: Fix this so that it prints the whole CASE expression */
|
|
|
|
void Item_func_case::print(String *str)
|
|
{
|
|
str->append("case "); // Not yet complete
|
|
}
|
|
|
|
/*
|
|
** Coalesce - return first not NULL argument.
|
|
*/
|
|
|
|
String *Item_func_coalesce::val_str(String *str)
|
|
{
|
|
null_value=0;
|
|
for (uint i=0 ; i < arg_count ; i++)
|
|
{
|
|
if (args[i]->val_str(str) != NULL)
|
|
return args[i]->val_str(str);
|
|
}
|
|
null_value=1;
|
|
return 0;
|
|
}
|
|
|
|
longlong Item_func_coalesce::val_int()
|
|
{
|
|
null_value=0;
|
|
for (uint i=0 ; i < arg_count ; i++)
|
|
{
|
|
longlong res=args[i]->val_int();
|
|
if (!args[i]->null_value)
|
|
return res;
|
|
}
|
|
null_value=1;
|
|
return 0;
|
|
}
|
|
|
|
double Item_func_coalesce::val()
|
|
{
|
|
null_value=0;
|
|
for (uint i=0 ; i < arg_count ; i++)
|
|
{
|
|
double res=args[i]->val();
|
|
if (!args[i]->null_value)
|
|
return res;
|
|
}
|
|
null_value=1;
|
|
return 0;
|
|
}
|
|
|
|
|
|
void Item_func_coalesce::fix_length_and_dec()
|
|
{
|
|
max_length=0;
|
|
decimals=0;
|
|
cached_result_type = args[0]->result_type();
|
|
for (uint i=0 ; i < arg_count ; i++)
|
|
{
|
|
set_if_bigger(max_length,args[i]->max_length);
|
|
set_if_bigger(decimals,args[i]->decimals);
|
|
}
|
|
}
|
|
|
|
/****************************************************************************
|
|
** classes and function for the IN operator
|
|
****************************************************************************/
|
|
|
|
static int cmp_longlong(longlong *a,longlong *b)
|
|
{
|
|
return *a < *b ? -1 : *a == *b ? 0 : 1;
|
|
}
|
|
|
|
static int cmp_double(double *a,double *b)
|
|
{
|
|
return *a < *b ? -1 : *a == *b ? 0 : 1;
|
|
}
|
|
|
|
int in_vector::find(Item *item)
|
|
{
|
|
byte *result=get_value(item);
|
|
if (!result || !used_count)
|
|
return 0; // Null value
|
|
|
|
uint start,end;
|
|
start=0; end=used_count-1;
|
|
while (start != end)
|
|
{
|
|
uint mid=(start+end+1)/2;
|
|
int res;
|
|
if ((res=(*compare)(base+mid*size,result)) == 0)
|
|
return 1;
|
|
if (res < 0)
|
|
start=mid;
|
|
else
|
|
end=mid-1;
|
|
}
|
|
return (int) ((*compare)(base+start*size,result) == 0);
|
|
}
|
|
|
|
|
|
in_string::in_string(uint elements,qsort_cmp cmp_func)
|
|
:in_vector(elements,sizeof(String),cmp_func),tmp(buff,sizeof(buff))
|
|
{}
|
|
|
|
in_string::~in_string()
|
|
{
|
|
for (uint i=0 ; i < count ; i++)
|
|
((String*) base)[i].free();
|
|
}
|
|
|
|
void in_string::set(uint pos,Item *item)
|
|
{
|
|
String *str=((String*) base)+pos;
|
|
String *res=item->val_str(str);
|
|
if (res && res != str)
|
|
*str= *res;
|
|
}
|
|
|
|
byte *in_string::get_value(Item *item)
|
|
{
|
|
return (byte*) item->val_str(&tmp);
|
|
}
|
|
|
|
|
|
in_longlong::in_longlong(uint elements)
|
|
:in_vector(elements,sizeof(longlong),(qsort_cmp) cmp_longlong)
|
|
{}
|
|
|
|
void in_longlong::set(uint pos,Item *item)
|
|
{
|
|
((longlong*) base)[pos]=item->val_int();
|
|
}
|
|
|
|
byte *in_longlong::get_value(Item *item)
|
|
{
|
|
tmp=item->val_int();
|
|
if (item->null_value)
|
|
return 0; /* purecov: inspected */
|
|
return (byte*) &tmp;
|
|
}
|
|
|
|
|
|
in_double::in_double(uint elements)
|
|
:in_vector(elements,sizeof(double),(qsort_cmp) cmp_double)
|
|
{}
|
|
|
|
void in_double::set(uint pos,Item *item)
|
|
{
|
|
((double*) base)[pos]=item->val();
|
|
}
|
|
|
|
byte *in_double::get_value(Item *item)
|
|
{
|
|
tmp=item->val();
|
|
if (item->null_value)
|
|
return 0; /* purecov: inspected */
|
|
return (byte*) &tmp;
|
|
}
|
|
|
|
|
|
void Item_func_in::fix_length_and_dec()
|
|
{
|
|
if (const_item())
|
|
{
|
|
switch (item->result_type()) {
|
|
case STRING_RESULT:
|
|
if (item->binary)
|
|
array=new in_string(arg_count,(qsort_cmp) stringcmp); /* purecov: inspected */
|
|
else
|
|
array=new in_string(arg_count,(qsort_cmp) sortcmp);
|
|
break;
|
|
case INT_RESULT:
|
|
array= new in_longlong(arg_count);
|
|
break;
|
|
case REAL_RESULT:
|
|
array= new in_double(arg_count);
|
|
break;
|
|
}
|
|
uint j=0;
|
|
for (uint i=0 ; i < arg_count ; i++)
|
|
{
|
|
array->set(j,args[i]);
|
|
if (!args[i]->null_value) // Skip NULL values
|
|
j++;
|
|
}
|
|
if ((array->used_count=j))
|
|
array->sort();
|
|
}
|
|
else
|
|
{
|
|
switch (item->result_type()) {
|
|
case STRING_RESULT:
|
|
if (item->binary)
|
|
in_item= new cmp_item_binary_string;
|
|
else
|
|
in_item= new cmp_item_sort_string;
|
|
break;
|
|
case INT_RESULT:
|
|
in_item= new cmp_item_int;
|
|
break;
|
|
case REAL_RESULT:
|
|
in_item= new cmp_item_real;
|
|
break;
|
|
}
|
|
}
|
|
maybe_null= item->maybe_null;
|
|
max_length=2;
|
|
used_tables_cache|=item->used_tables();
|
|
const_item_cache&=item->const_item();
|
|
}
|
|
|
|
|
|
void Item_func_in::print(String *str)
|
|
{
|
|
str->append('(');
|
|
item->print(str);
|
|
Item_func::print(str);
|
|
str->append(')');
|
|
}
|
|
|
|
|
|
longlong Item_func_in::val_int()
|
|
{
|
|
if (array)
|
|
{
|
|
int tmp=array->find(item);
|
|
null_value=item->null_value;
|
|
return tmp;
|
|
}
|
|
in_item->store_value(item);
|
|
if ((null_value=item->null_value))
|
|
return 0;
|
|
for (uint i=0 ; i < arg_count ; i++)
|
|
{
|
|
if (!in_item->cmp(args[i]) && !args[i]->null_value)
|
|
return 1; // Would maybe be nice with i ?
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
|
|
void Item_func_in::update_used_tables()
|
|
{
|
|
Item_func::update_used_tables();
|
|
item->update_used_tables();
|
|
used_tables_cache|=item->used_tables();
|
|
const_item_cache&=item->const_item();
|
|
}
|
|
|
|
|
|
longlong Item_func_bit_or::val_int()
|
|
{
|
|
ulonglong arg1= (ulonglong) args[0]->val_int();
|
|
if (args[0]->null_value)
|
|
{
|
|
null_value=1; /* purecov: inspected */
|
|
return 0; /* purecov: inspected */
|
|
}
|
|
ulonglong arg2= (ulonglong) args[1]->val_int();
|
|
if (args[1]->null_value)
|
|
{
|
|
null_value=1;
|
|
return 0;
|
|
}
|
|
null_value=0;
|
|
return (longlong) (arg1 | arg2);
|
|
}
|
|
|
|
|
|
longlong Item_func_bit_and::val_int()
|
|
{
|
|
ulonglong arg1= (ulonglong) args[0]->val_int();
|
|
if (args[0]->null_value)
|
|
{
|
|
null_value=1; /* purecov: inspected */
|
|
return 0; /* purecov: inspected */
|
|
}
|
|
ulonglong arg2= (ulonglong) args[1]->val_int();
|
|
if (args[1]->null_value)
|
|
{
|
|
null_value=1; /* purecov: inspected */
|
|
return 0; /* purecov: inspected */
|
|
}
|
|
null_value=0;
|
|
return (longlong) (arg1 & arg2);
|
|
}
|
|
|
|
|
|
bool
|
|
Item_cond::fix_fields(THD *thd,TABLE_LIST *tables)
|
|
{
|
|
List_iterator<Item> li(list);
|
|
Item *item;
|
|
char buff[sizeof(char*)]; // Max local vars in function
|
|
used_tables_cache=0;
|
|
const_item_cache=0;
|
|
|
|
if (thd && check_stack_overrun(thd,buff))
|
|
return 0; // Fatal error flag is set!
|
|
while ((item=li++))
|
|
{
|
|
while (item->type() == Item::COND_ITEM &&
|
|
((Item_cond*) item)->functype() == functype())
|
|
{ // Identical function
|
|
li.replace(((Item_cond*) item)->list);
|
|
((Item_cond*) item)->list.empty();
|
|
#ifdef DELETE_ITEMS
|
|
delete (Item_cond*) item;
|
|
#endif
|
|
item= *li.ref(); // new current item
|
|
}
|
|
if (item->fix_fields(thd,tables))
|
|
return 1; /* purecov: inspected */
|
|
used_tables_cache|=item->used_tables();
|
|
with_sum_func= with_sum_func || item->with_sum_func;
|
|
const_item_cache&=item->const_item();
|
|
}
|
|
if (thd)
|
|
thd->cond_count+=list.elements;
|
|
fix_length_and_dec();
|
|
return 0;
|
|
}
|
|
|
|
|
|
void Item_cond::split_sum_func(List<Item> &fields)
|
|
{
|
|
List_iterator<Item> li(list);
|
|
Item *item;
|
|
used_tables_cache=0;
|
|
const_item_cache=0;
|
|
while ((item=li++))
|
|
{
|
|
if (item->with_sum_func && item->type() != SUM_FUNC_ITEM)
|
|
item->split_sum_func(fields);
|
|
else if (item->used_tables() || item->type() == SUM_FUNC_ITEM)
|
|
{
|
|
fields.push_front(item);
|
|
li.replace(new Item_ref((Item**) fields.head_ref(),0,item->name));
|
|
}
|
|
item->update_used_tables();
|
|
used_tables_cache|=item->used_tables();
|
|
const_item_cache&=item->const_item();
|
|
}
|
|
}
|
|
|
|
|
|
table_map
|
|
Item_cond::used_tables() const
|
|
{ // This caches used_tables
|
|
return used_tables_cache;
|
|
}
|
|
|
|
void Item_cond::update_used_tables()
|
|
{
|
|
used_tables_cache=0;
|
|
const_item_cache=1;
|
|
List_iterator_fast<Item> li(list);
|
|
Item *item;
|
|
while ((item=li++))
|
|
{
|
|
item->update_used_tables();
|
|
used_tables_cache|=item->used_tables();
|
|
const_item_cache&= item->const_item();
|
|
}
|
|
}
|
|
|
|
|
|
void Item_cond::print(String *str)
|
|
{
|
|
str->append('(');
|
|
List_iterator_fast<Item> li(list);
|
|
Item *item;
|
|
if ((item=li++))
|
|
item->print(str);
|
|
while ((item=li++))
|
|
{
|
|
str->append(' ');
|
|
str->append(func_name());
|
|
str->append(' ');
|
|
item->print(str);
|
|
}
|
|
str->append(')');
|
|
}
|
|
|
|
|
|
longlong Item_cond_and::val_int()
|
|
{
|
|
List_iterator_fast<Item> li(list);
|
|
Item *item;
|
|
while ((item=li++))
|
|
{
|
|
if (item->val_int() == 0)
|
|
{
|
|
/* TODO: In case of NULL, ANSI would require us to continue evaluation
|
|
until we get a FALSE value or run out of values; This would
|
|
require a lot of unnecessary evaluation, which we skip for now */
|
|
null_value=item->null_value;
|
|
return 0;
|
|
}
|
|
}
|
|
null_value=0;
|
|
return 1;
|
|
}
|
|
|
|
longlong Item_cond_or::val_int()
|
|
{
|
|
List_iterator_fast<Item> li(list);
|
|
Item *item;
|
|
null_value=0;
|
|
while ((item=li++))
|
|
{
|
|
if (item->val_int() != 0)
|
|
{
|
|
null_value=0;
|
|
return 1;
|
|
}
|
|
if (item->null_value)
|
|
null_value=1;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
longlong Item_func_isnull::val_int()
|
|
{
|
|
return args[0]->is_null() ? 1: 0;
|
|
}
|
|
|
|
longlong Item_func_isnotnull::val_int()
|
|
{
|
|
return args[0]->is_null() ? 0 : 1;
|
|
}
|
|
|
|
|
|
void Item_func_like::fix_length_and_dec()
|
|
{
|
|
decimals=0; max_length=1;
|
|
// cmp_type=STRING_RESULT; // For quick select
|
|
}
|
|
|
|
|
|
longlong Item_func_like::val_int()
|
|
{
|
|
String *res,*res2;
|
|
res=args[0]->val_str(&tmp_value1);
|
|
if (args[0]->null_value)
|
|
{
|
|
null_value=1;
|
|
return 0;
|
|
}
|
|
res2=args[1]->val_str(&tmp_value2);
|
|
if (args[1]->null_value)
|
|
{
|
|
null_value=1;
|
|
return 0;
|
|
}
|
|
null_value=0;
|
|
if (binary)
|
|
return wild_compare(*res,*res2,escape) ? 0 : 1;
|
|
else
|
|
return wild_case_compare(*res,*res2,escape) ? 0 : 1;
|
|
}
|
|
|
|
|
|
/* We can optimize a where if first character isn't a wildcard */
|
|
|
|
Item_func::optimize_type Item_func_like::select_optimize() const
|
|
{
|
|
if (args[1]->type() == STRING_ITEM)
|
|
{
|
|
if (((Item_string *) args[1])->str_value[0] != wild_many)
|
|
{
|
|
if ((args[0]->result_type() != STRING_RESULT) ||
|
|
((Item_string *) args[1])->str_value[0] != wild_one)
|
|
return OPTIMIZE_OP;
|
|
}
|
|
}
|
|
return OPTIMIZE_NONE;
|
|
}
|
|
|
|
#ifdef USE_REGEX
|
|
|
|
bool
|
|
Item_func_regex::fix_fields(THD *thd,TABLE_LIST *tables)
|
|
{
|
|
if (args[0]->fix_fields(thd,tables) || args[1]->fix_fields(thd,tables))
|
|
return 1; /* purecov: inspected */
|
|
with_sum_func=args[0]->with_sum_func || args[1]->with_sum_func;
|
|
max_length=1; decimals=0;
|
|
binary=args[0]->binary || args[1]->binary;
|
|
used_tables_cache=args[0]->used_tables() | args[1]->used_tables();
|
|
const_item_cache=args[0]->const_item() && args[1]->const_item();
|
|
if (!regex_compiled && args[1]->const_item())
|
|
{
|
|
char buff[MAX_FIELD_WIDTH];
|
|
String tmp(buff,sizeof(buff));
|
|
String *res=args[1]->val_str(&tmp);
|
|
if (args[1]->null_value)
|
|
{ // Will always return NULL
|
|
maybe_null=1;
|
|
return 0;
|
|
}
|
|
int error;
|
|
if ((error=regcomp(&preg,res->c_ptr(),
|
|
binary ? REG_EXTENDED | REG_NOSUB :
|
|
REG_EXTENDED | REG_NOSUB | REG_ICASE)))
|
|
{
|
|
(void) regerror(error,&preg,buff,sizeof(buff));
|
|
my_printf_error(ER_REGEXP_ERROR,ER(ER_REGEXP_ERROR),MYF(0),buff);
|
|
return 1;
|
|
}
|
|
regex_compiled=regex_is_const=1;
|
|
maybe_null=args[0]->maybe_null;
|
|
}
|
|
else
|
|
maybe_null=1;
|
|
return 0;
|
|
}
|
|
|
|
|
|
longlong Item_func_regex::val_int()
|
|
{
|
|
char buff[MAX_FIELD_WIDTH];
|
|
String *res, tmp(buff,sizeof(buff));
|
|
|
|
res=args[0]->val_str(&tmp);
|
|
if (args[0]->null_value)
|
|
{
|
|
null_value=1;
|
|
return 0;
|
|
}
|
|
if (!regex_is_const)
|
|
{
|
|
char buff2[MAX_FIELD_WIDTH];
|
|
String *res2, tmp2(buff2,sizeof(buff2));
|
|
|
|
res2= args[1]->val_str(&tmp2);
|
|
if (args[1]->null_value)
|
|
{
|
|
null_value=1;
|
|
return 0;
|
|
}
|
|
if (!regex_compiled || stringcmp(res2,&prev_regexp))
|
|
{
|
|
prev_regexp.copy(*res2);
|
|
if (regex_compiled)
|
|
{
|
|
regfree(&preg);
|
|
regex_compiled=0;
|
|
}
|
|
if (regcomp(&preg,res2->c_ptr(),
|
|
binary ? REG_EXTENDED | REG_NOSUB :
|
|
REG_EXTENDED | REG_NOSUB | REG_ICASE))
|
|
|
|
{
|
|
null_value=1;
|
|
return 0;
|
|
}
|
|
regex_compiled=1;
|
|
}
|
|
}
|
|
null_value=0;
|
|
return regexec(&preg,res->c_ptr(),0,(regmatch_t*) 0,0) ? 0 : 1;
|
|
}
|
|
|
|
|
|
Item_func_regex::~Item_func_regex()
|
|
{
|
|
if (regex_compiled)
|
|
{
|
|
regfree(&preg);
|
|
regex_compiled=0;
|
|
}
|
|
}
|
|
|
|
#endif /* USE_REGEX */
|