summaryrefslogtreecommitdiffstats
path: root/sql/item_func.h
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-05-04 18:00:34 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-05-04 18:00:34 +0000
commit3f619478f796eddbba6e39502fe941b285dd97b1 (patch)
treee2c7b5777f728320e5b5542b6213fd3591ba51e2 /sql/item_func.h
parentInitial commit. (diff)
downloadmariadb-3f619478f796eddbba6e39502fe941b285dd97b1.tar.xz
mariadb-3f619478f796eddbba6e39502fe941b285dd97b1.zip
Adding upstream version 1:10.11.6.upstream/1%10.11.6upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to '')
-rw-r--r--sql/item_func.h4240
1 files changed, 4240 insertions, 0 deletions
diff --git a/sql/item_func.h b/sql/item_func.h
new file mode 100644
index 00000000..435875bd
--- /dev/null
+++ b/sql/item_func.h
@@ -0,0 +1,4240 @@
+#ifndef ITEM_FUNC_INCLUDED
+#define ITEM_FUNC_INCLUDED
+/* Copyright (c) 2000, 2016, Oracle and/or its affiliates.
+ Copyright (c) 2009, 2021, MariaDB
+
+ 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; version 2 of the License.
+
+ 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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1335 USA */
+
+
+/* Function items used by mysql */
+
+#ifdef USE_PRAGMA_INTERFACE
+#pragma interface /* gcc class implementation */
+#endif
+
+#ifdef HAVE_IEEEFP_H
+extern "C" /* Bug in BSDI include file */
+{
+#include <ieeefp.h>
+}
+#endif
+
+#include "sql_udf.h" // udf_handler
+#include "my_decimal.h" // string2my_decimal
+#include <cmath>
+
+
+class Item_func :public Item_func_or_sum
+{
+ void sync_with_sum_func_and_with_field(List<Item> &list);
+protected:
+ virtual bool check_arguments() const
+ {
+ return check_argument_types_scalar(0, arg_count);
+ }
+ bool check_argument_types_like_args0() const;
+ bool check_argument_types_scalar(uint start, uint end) const;
+ bool check_argument_types_traditional_scalar(uint start, uint end) const;
+ bool check_argument_types_or_binary(const Type_handler *handler,
+ uint start, uint end) const;
+ bool check_argument_types_can_return_int(uint start, uint end) const;
+ bool check_argument_types_can_return_real(uint start, uint end) const;
+ bool check_argument_types_can_return_str(uint start, uint end) const;
+ bool check_argument_types_can_return_text(uint start, uint end) const;
+ bool check_argument_types_can_return_date(uint start, uint end) const;
+ bool check_argument_types_can_return_time(uint start, uint end) const;
+ void print_cast_temporal(String *str, enum_query_type query_type);
+public:
+
+ table_map not_null_tables_cache;
+
+ enum Functype { UNKNOWN_FUNC,EQ_FUNC,EQUAL_FUNC,NE_FUNC,LT_FUNC,LE_FUNC,
+ GE_FUNC,GT_FUNC,FT_FUNC,
+ LIKE_FUNC,ISNULL_FUNC,ISNOTNULL_FUNC,
+ COND_AND_FUNC, COND_OR_FUNC, XOR_FUNC,
+ BETWEEN, IN_FUNC, MULT_EQUAL_FUNC,
+ INTERVAL_FUNC, ISNOTNULLTEST_FUNC,
+ SP_EQUALS_FUNC, SP_DISJOINT_FUNC,SP_INTERSECTS_FUNC,
+ SP_TOUCHES_FUNC,SP_CROSSES_FUNC,SP_WITHIN_FUNC,
+ SP_CONTAINS_FUNC,SP_OVERLAPS_FUNC,
+ SP_STARTPOINT,SP_ENDPOINT,SP_EXTERIORRING,
+ SP_POINTN,SP_GEOMETRYN,SP_INTERIORRINGN, SP_RELATE_FUNC,
+ NOT_FUNC, NOT_ALL_FUNC, TEMPTABLE_ROWID,
+ NOW_FUNC, NOW_UTC_FUNC, SYSDATE_FUNC, TRIG_COND_FUNC,
+ SUSERVAR_FUNC, GUSERVAR_FUNC, COLLATE_FUNC,
+ EXTRACT_FUNC, CHAR_TYPECAST_FUNC, FUNC_SP, UDF_FUNC,
+ NEG_FUNC, GSYSVAR_FUNC, IN_OPTIMIZER_FUNC, DYNCOL_FUNC,
+ JSON_EXTRACT_FUNC, JSON_VALID_FUNC, ROWNUM_FUNC,
+ CASE_SEARCHED_FUNC, // Used by ColumnStore/Spider
+ CASE_SIMPLE_FUNC, // Used by ColumnStore/spider,
+ };
+ static scalar_comparison_op functype_to_scalar_comparison_op(Functype type)
+ {
+ switch (type) {
+ case EQ_FUNC: return SCALAR_CMP_EQ;
+ case EQUAL_FUNC: return SCALAR_CMP_EQUAL;
+ case LT_FUNC: return SCALAR_CMP_LT;
+ case LE_FUNC: return SCALAR_CMP_LE;
+ case GE_FUNC: return SCALAR_CMP_GE;
+ case GT_FUNC: return SCALAR_CMP_GT;
+ default: break;
+ }
+ DBUG_ASSERT(0);
+ return SCALAR_CMP_EQ;
+ }
+ enum Type type() const override { return FUNC_ITEM; }
+ virtual enum Functype functype() const { return UNKNOWN_FUNC; }
+ Item_func(THD *thd): Item_func_or_sum(thd)
+ {
+ DBUG_ASSERT(with_flags == item_with_t::NONE);
+ with_flags= item_with_t::NONE;
+ }
+ Item_func(THD *thd, Item *a): Item_func_or_sum(thd, a)
+ {
+ with_flags= a->with_flags;
+ }
+ Item_func(THD *thd, Item *a, Item *b):
+ Item_func_or_sum(thd, a, b)
+ {
+ with_flags= a->with_flags | b->with_flags;
+ }
+ Item_func(THD *thd, Item *a, Item *b, Item *c):
+ Item_func_or_sum(thd, a, b, c)
+ {
+ with_flags|= a->with_flags | b->with_flags | c->with_flags;
+ }
+ Item_func(THD *thd, Item *a, Item *b, Item *c, Item *d):
+ Item_func_or_sum(thd, a, b, c, d)
+ {
+ with_flags= a->with_flags | b->with_flags | c->with_flags | d->with_flags;
+ }
+ Item_func(THD *thd, Item *a, Item *b, Item *c, Item *d, Item* e):
+ Item_func_or_sum(thd, a, b, c, d, e)
+ {
+ with_flags= (a->with_flags | b->with_flags | c->with_flags | d->with_flags |
+ e->with_flags);
+ }
+ Item_func(THD *thd, List<Item> &list):
+ Item_func_or_sum(thd, list)
+ {
+ set_arguments(thd, list);
+ }
+ // Constructor used for Item_cond_and/or (see Item comment)
+ Item_func(THD *thd, Item_func *item):
+ Item_func_or_sum(thd, item),
+ not_null_tables_cache(item->not_null_tables_cache)
+ { }
+ bool fix_fields(THD *, Item **ref) override;
+ void cleanup() override
+ {
+ Item_func_or_sum::cleanup();
+ used_tables_and_const_cache_init();
+ }
+ void fix_after_pullout(st_select_lex *new_parent, Item **ref, bool merge)
+ override;
+ void quick_fix_field() override;
+ table_map not_null_tables() const override;
+ void update_used_tables() override
+ {
+ used_tables_and_const_cache_init();
+ used_tables_and_const_cache_update_and_join(arg_count, args);
+ }
+ COND *build_equal_items(THD *thd, COND_EQUAL *inherited,
+ bool link_item_fields,
+ COND_EQUAL **cond_equal_ref) override;
+ SEL_TREE *get_mm_tree(RANGE_OPT_PARAM *param, Item **cond_ptr) override
+ {
+ DBUG_ENTER("Item_func::get_mm_tree");
+ DBUG_RETURN(const_item() ? get_mm_tree_for_const(param) : NULL);
+ }
+ bool eq(const Item *item, bool binary_cmp) const override;
+ virtual Item *key_item() const { return args[0]; }
+ void set_arguments(THD *thd, List<Item> &list)
+ {
+ Item_args::set_arguments(thd, list);
+ sync_with_sum_func_and_with_field(list);
+ list.empty(); // Fields are used
+ }
+ void split_sum_func(THD *thd, Ref_ptr_array ref_pointer_array,
+ List<Item> &fields, uint flags) override;
+ void print(String *str, enum_query_type query_type) override;
+ void print_op(String *str, enum_query_type query_type);
+ void print_args(String *str, uint from, enum_query_type query_type);
+ bool is_null() override
+ {
+ update_null_value();
+ return null_value;
+ }
+ String *val_str_from_val_str_ascii(String *str, String *str2);
+
+ void signal_divide_by_null();
+ friend class udf_handler;
+ Field *create_field_for_create_select(MEM_ROOT *root, TABLE *table) override
+ { return tmp_table_field_from_field_type(root, table); }
+ Item *get_tmp_table_item(THD *thd) override;
+
+ void fix_char_length_ulonglong(ulonglong max_char_length_arg)
+ {
+ ulonglong max_result_length= max_char_length_arg *
+ collation.collation->mbmaxlen;
+ if (max_result_length >= MAX_BLOB_WIDTH)
+ {
+ max_length= MAX_BLOB_WIDTH;
+ set_maybe_null();
+ }
+ else
+ max_length= (uint32) max_result_length;
+ }
+ Item *transform(THD *thd, Item_transformer transformer, uchar *arg) override;
+ Item* compile(THD *thd, Item_analyzer analyzer, uchar **arg_p,
+ Item_transformer transformer, uchar *arg_t) override;
+ void traverse_cond(Cond_traverser traverser,
+ void * arg, traverse_order order) override;
+ bool eval_not_null_tables(void *opt_arg) override;
+ bool find_not_null_fields(table_map allowed) override;
+ // bool is_expensive_processor(void *arg);
+ // virtual bool is_expensive() { return 0; }
+ inline void raise_numeric_overflow(const char *type_name)
+ {
+ char buf[256];
+ String str(buf, sizeof(buf), system_charset_info);
+ str.length(0);
+ print(&str, QT_NO_DATA_EXPANSION);
+ my_error(ER_DATA_OUT_OF_RANGE, MYF(0), type_name, str.c_ptr_safe());
+ }
+ inline double raise_float_overflow()
+ {
+ raise_numeric_overflow("DOUBLE");
+ return 0.0;
+ }
+ inline longlong raise_integer_overflow()
+ {
+ raise_numeric_overflow(unsigned_flag ? "BIGINT UNSIGNED": "BIGINT");
+ return 0;
+ }
+ inline int raise_decimal_overflow()
+ {
+ raise_numeric_overflow("DECIMAL");
+ return E_DEC_OVERFLOW;
+ }
+ /**
+ Throw an error if the input double number is not finite, i.e. is either
+ +/-INF or NAN.
+ */
+ inline double check_float_overflow(double value)
+ {
+ return std::isfinite(value) ? value : raise_float_overflow();
+ }
+ /**
+ Throw an error if the input BIGINT value represented by the
+ (longlong value, bool unsigned flag) pair cannot be returned by the
+ function, i.e. is not compatible with this Item's unsigned_flag.
+ */
+ inline longlong check_integer_overflow(longlong value, bool val_unsigned)
+ {
+ return check_integer_overflow(Longlong_hybrid(value, val_unsigned));
+ }
+
+ // Check if the value is compatible with Item::unsigned_flag.
+ inline longlong check_integer_overflow(const Longlong_hybrid &sval)
+ {
+ Longlong_null res= sval.val_int(unsigned_flag);
+ return res.is_null() ? raise_integer_overflow() : res.value();
+ }
+
+ // Check if the value is compatible with Item::unsigned_flag.
+ longlong check_integer_overflow(const ULonglong_hybrid &uval)
+ {
+ Longlong_null res= uval.val_int(unsigned_flag);
+ return res.is_null() ? raise_integer_overflow() : res.value();
+ }
+
+ /**
+ Throw an error if the error code of a DECIMAL operation is E_DEC_OVERFLOW.
+ */
+ inline int check_decimal_overflow(int error)
+ {
+ return (error == E_DEC_OVERFLOW) ? raise_decimal_overflow() : error;
+ }
+
+ bool has_timestamp_args()
+ {
+ DBUG_ASSERT(fixed());
+ for (uint i= 0; i < arg_count; i++)
+ {
+ if (args[i]->type() == Item::FIELD_ITEM &&
+ args[i]->field_type() == MYSQL_TYPE_TIMESTAMP)
+ return TRUE;
+ }
+ return FALSE;
+ }
+
+ bool has_date_args()
+ {
+ DBUG_ASSERT(fixed());
+ for (uint i= 0; i < arg_count; i++)
+ {
+ if (args[i]->type() == Item::FIELD_ITEM &&
+ (args[i]->field_type() == MYSQL_TYPE_DATE ||
+ args[i]->field_type() == MYSQL_TYPE_DATETIME))
+ return TRUE;
+ }
+ return FALSE;
+ }
+
+ bool has_time_args()
+ {
+ DBUG_ASSERT(fixed());
+ for (uint i= 0; i < arg_count; i++)
+ {
+ if (args[i]->type() == Item::FIELD_ITEM &&
+ (args[i]->field_type() == MYSQL_TYPE_TIME ||
+ args[i]->field_type() == MYSQL_TYPE_DATETIME))
+ return TRUE;
+ }
+ return FALSE;
+ }
+
+ bool has_datetime_args()
+ {
+ DBUG_ASSERT(fixed());
+ for (uint i= 0; i < arg_count; i++)
+ {
+ if (args[i]->type() == Item::FIELD_ITEM &&
+ args[i]->field_type() == MYSQL_TYPE_DATETIME)
+ return TRUE;
+ }
+ return FALSE;
+ }
+
+ Item* propagate_equal_fields(THD *thd, const Context &ctx, COND_EQUAL *cond)
+ override
+ {
+ /*
+ By default only substitution for a field whose two different values
+ are never equal is allowed in the arguments of a function.
+ This is overruled for the direct arguments of comparison functions.
+ */
+ Item_args::propagate_equal_fields(thd, Context_identity(), cond);
+ return this;
+ }
+
+ bool has_rand_bit()
+ {
+ return used_tables() & RAND_TABLE_BIT;
+ }
+
+ bool excl_dep_on_table(table_map tab_map) override
+ {
+ if (used_tables() & (OUTER_REF_TABLE_BIT | RAND_TABLE_BIT))
+ return false;
+ return !(used_tables() & ~tab_map) ||
+ Item_args::excl_dep_on_table(tab_map);
+ }
+
+ bool excl_dep_on_grouping_fields(st_select_lex *sel) override
+ {
+ if (has_rand_bit() || with_subquery())
+ return false;
+ return Item_args::excl_dep_on_grouping_fields(sel);
+ }
+
+ bool excl_dep_on_in_subq_left_part(Item_in_subselect *subq_pred) override
+ {
+ return Item_args::excl_dep_on_in_subq_left_part(subq_pred);
+ }
+
+ /*
+ We assume the result of any function that has a TIMESTAMP argument to be
+ timezone-dependent, since a TIMESTAMP value in both numeric and string
+ contexts is interpreted according to the current timezone.
+ The only exception is UNIX_TIMESTAMP() which returns the internal
+ representation of a TIMESTAMP argument verbatim, and thus does not depend on
+ the timezone.
+ */
+ bool check_valid_arguments_processor(void *bool_arg) override
+ {
+ return has_timestamp_args();
+ }
+
+ bool find_function_processor (void *arg) override
+ {
+ return functype() == *(Functype *) arg;
+ }
+
+ void no_rows_in_result() override
+ {
+ for (uint i= 0; i < arg_count; i++)
+ {
+ args[i]->no_rows_in_result();
+ }
+ }
+ void restore_to_before_no_rows_in_result() override
+ {
+ for (uint i= 0; i < arg_count; i++)
+ {
+ args[i]->restore_to_before_no_rows_in_result();
+ }
+ }
+ void convert_const_compared_to_int_field(THD *thd);
+ /**
+ Prepare arguments and setup a comparator.
+ Used in Item_func_xxx with two arguments and a comparator,
+ e.g. Item_bool_func2 and Item_func_nullif.
+ args[0] or args[1] can be modified:
+ - converted to character set and collation of the operation
+ - or replaced to an Item_int_with_ref
+ */
+ bool setup_args_and_comparator(THD *thd, Arg_comparator *cmp);
+ Item_func *get_item_func() override { return this; }
+ bool is_simplified_cond_processor(void *arg) override
+ { return const_item() && !val_int(); }
+};
+
+
+class Item_real_func :public Item_func
+{
+public:
+ Item_real_func(THD *thd): Item_func(thd) { collation= DTCollation_numeric(); }
+ Item_real_func(THD *thd, Item *a): Item_func(thd, a)
+ { collation= DTCollation_numeric(); }
+ Item_real_func(THD *thd, Item *a, Item *b): Item_func(thd, a, b)
+ { collation= DTCollation_numeric(); }
+ Item_real_func(THD *thd, List<Item> &list): Item_func(thd, list)
+ { collation= DTCollation_numeric(); }
+ String *val_str(String*str) override;
+ my_decimal *val_decimal(my_decimal *decimal_value) override;
+ longlong val_int() override
+ {
+ DBUG_ASSERT(fixed());
+ return Converter_double_to_longlong(val_real(), unsigned_flag).result();
+ }
+ bool get_date(THD *thd, MYSQL_TIME *ltime, date_mode_t fuzzydate) override
+ { return get_date_from_real(thd, ltime, fuzzydate); }
+ const Type_handler *type_handler() const override
+ { return &type_handler_double; }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ decimals= NOT_FIXED_DEC;
+ max_length= float_length(decimals);
+ return FALSE;
+ }
+};
+
+
+/**
+ Functions whose returned field type is determined at fix_fields() time.
+*/
+class Item_hybrid_func: public Item_func,
+ public Type_handler_hybrid_field_type
+{
+protected:
+ bool fix_attributes(Item **item, uint nitems);
+public:
+ Item_hybrid_func(THD *thd): Item_func(thd) { }
+ Item_hybrid_func(THD *thd, Item *a): Item_func(thd, a) { }
+ Item_hybrid_func(THD *thd, Item *a, Item *b): Item_func(thd, a, b) { }
+ Item_hybrid_func(THD *thd, Item *a, Item *b, Item *c):
+ Item_func(thd, a, b, c) { }
+ Item_hybrid_func(THD *thd, List<Item> &list): Item_func(thd, list) { }
+ Item_hybrid_func(THD *thd, Item_hybrid_func *item)
+ :Item_func(thd, item), Type_handler_hybrid_field_type(item) { }
+ const Type_handler *type_handler() const override
+ { return Type_handler_hybrid_field_type::type_handler(); }
+ void fix_length_and_dec_long_or_longlong(uint char_length, bool unsigned_arg)
+ {
+ collation= DTCollation_numeric();
+ unsigned_flag= unsigned_arg;
+ max_length= char_length;
+ set_handler(Type_handler::type_handler_long_or_longlong(char_length,
+ unsigned_arg));
+ }
+ void fix_length_and_dec_ulong_or_ulonglong_by_nbits(uint nbits)
+ {
+ uint digits= Type_handler_bit::Bit_decimal_notation_int_digits_by_nbits(nbits);
+ collation= DTCollation_numeric();
+ unsigned_flag= true;
+ max_length= digits;
+ if (nbits > 32)
+ set_handler(&type_handler_ulonglong);
+ else
+ set_handler(&type_handler_ulong);
+ }
+};
+
+
+class Item_handled_func: public Item_func
+{
+public:
+ class Handler
+ {
+ public:
+ virtual ~Handler() = default;
+ virtual String *val_str(Item_handled_func *, String *) const= 0;
+ virtual String *val_str_ascii(Item_handled_func *, String *) const= 0;
+ virtual double val_real(Item_handled_func *) const= 0;
+ virtual longlong val_int(Item_handled_func *) const= 0;
+ virtual my_decimal *val_decimal(Item_handled_func *, my_decimal *) const= 0;
+ virtual bool get_date(THD *thd, Item_handled_func *, MYSQL_TIME *, date_mode_t fuzzydate) const= 0;
+ virtual bool val_native(THD *thd, Item_handled_func *, Native *to) const
+ {
+ DBUG_ASSERT(0);
+ to->length(0);
+ return true;
+ }
+ virtual const Type_handler *
+ return_type_handler(const Item_handled_func *item) const= 0;
+ virtual const Type_handler *
+ type_handler_for_create_select(const Item_handled_func *item) const
+ {
+ return return_type_handler(item);
+ }
+ virtual bool fix_length_and_dec(Item_handled_func *) const= 0;
+ };
+
+ class Handler_str: public Handler
+ {
+ public:
+ String *val_str_ascii(Item_handled_func *item, String *str) const
+ {
+ return item->Item::val_str_ascii(str);
+ }
+ double val_real(Item_handled_func *item) const
+ {
+ DBUG_ASSERT(item->fixed());
+ StringBuffer<64> tmp;
+ String *res= item->val_str(&tmp);
+ return res ? item->double_from_string_with_check(res) : 0.0;
+ }
+ longlong val_int(Item_handled_func *item) const
+ {
+ DBUG_ASSERT(item->fixed());
+ StringBuffer<22> tmp;
+ String *res= item->val_str(&tmp);
+ return res ? item->longlong_from_string_with_check(res) : 0;
+ }
+ my_decimal *val_decimal(Item_handled_func *item, my_decimal *to) const
+ {
+ return item->val_decimal_from_string(to);
+ }
+ bool get_date(THD *thd, Item_handled_func *item, MYSQL_TIME *to,
+ date_mode_t fuzzydate) const
+ {
+ return item->get_date_from_string(thd, to, fuzzydate);
+ }
+ };
+
+ /**
+ Abstract class for functions returning TIME, DATE, DATETIME or string values,
+ whose data type depends on parameters and is set at fix_fields time.
+ */
+ class Handler_temporal: public Handler
+ {
+ public:
+ String *val_str(Item_handled_func *item, String *to) const
+ {
+ StringBuffer<MAX_FIELD_WIDTH> ascii_buf;
+ return item->val_str_from_val_str_ascii(to, &ascii_buf);
+ }
+ };
+
+ /**
+ Abstract class for functions returning strings,
+ which are generated from get_date() results,
+ when get_date() can return different MYSQL_TIMESTAMP_XXX per row.
+ */
+ class Handler_temporal_string: public Handler_temporal
+ {
+ public:
+ const Type_handler *return_type_handler(const Item_handled_func *) const
+ {
+ return &type_handler_string;
+ }
+ const Type_handler *
+ type_handler_for_create_select(const Item_handled_func *item) const
+ {
+ return return_type_handler(item)->type_handler_for_tmp_table(item);
+ }
+ double val_real(Item_handled_func *item) const
+ {
+ return Temporal_hybrid(item).to_double();
+ }
+ longlong val_int(Item_handled_func *item) const
+ {
+ return Temporal_hybrid(item).to_longlong();
+ }
+ my_decimal *val_decimal(Item_handled_func *item, my_decimal *to) const
+ {
+ return Temporal_hybrid(item).to_decimal(to);
+ }
+ String *val_str_ascii(Item_handled_func *item, String *to) const
+ {
+ return Temporal_hybrid(item).to_string(to, item->decimals);
+ }
+ };
+
+
+ class Handler_date: public Handler_temporal
+ {
+ public:
+ const Type_handler *return_type_handler(const Item_handled_func *) const
+ {
+ return &type_handler_newdate;
+ }
+ bool fix_length_and_dec(Item_handled_func *item) const
+ {
+ item->fix_attributes_date();
+ return false;
+ }
+ double val_real(Item_handled_func *item) const
+ {
+ return Date(item).to_double();
+ }
+ longlong val_int(Item_handled_func *item) const
+ {
+ return Date(item).to_longlong();
+ }
+ my_decimal *val_decimal(Item_handled_func *item, my_decimal *to) const
+ {
+ return Date(item).to_decimal(to);
+ }
+ String *val_str_ascii(Item_handled_func *item, String *to) const
+ {
+ return Date(item).to_string(to);
+ }
+ };
+
+
+ class Handler_time: public Handler_temporal
+ {
+ public:
+ const Type_handler *return_type_handler(const Item_handled_func *) const
+ {
+ return &type_handler_time2;
+ }
+ double val_real(Item_handled_func *item) const
+ {
+ return Time(item).to_double();
+ }
+ longlong val_int(Item_handled_func *item) const
+ {
+ return Time(item).to_longlong();
+ }
+ my_decimal *val_decimal(Item_handled_func *item, my_decimal *to) const
+ {
+ return Time(item).to_decimal(to);
+ }
+ String *val_str_ascii(Item_handled_func *item, String *to) const
+ {
+ return Time(item).to_string(to, item->decimals);
+ }
+ bool val_native(THD *thd, Item_handled_func *item, Native *to) const
+ {
+ return Time(thd, item).to_native(to, item->decimals);
+ }
+ };
+
+
+ class Handler_datetime: public Handler_temporal
+ {
+ public:
+ const Type_handler *return_type_handler(const Item_handled_func *) const
+ {
+ return &type_handler_datetime2;
+ }
+ double val_real(Item_handled_func *item) const
+ {
+ return Datetime(item).to_double();
+ }
+ longlong val_int(Item_handled_func *item) const
+ {
+ return Datetime(item).to_longlong();
+ }
+ my_decimal *val_decimal(Item_handled_func *item, my_decimal *to) const
+ {
+ return Datetime(item).to_decimal(to);
+ }
+ String *val_str_ascii(Item_handled_func *item, String *to) const
+ {
+ return Datetime(item).to_string(to, item->decimals);
+ }
+ };
+
+
+ class Handler_int: public Handler
+ {
+ public:
+ String *val_str(Item_handled_func *item, String *to) const
+ {
+ longlong nr= val_int(item);
+ if (item->null_value)
+ return 0;
+ to->set_int(nr, item->unsigned_flag, item->collation.collation);
+ return to;
+ }
+ String *val_str_ascii(Item_handled_func *item, String *to) const
+ {
+ return item->Item::val_str_ascii(to);
+ }
+ double val_real(Item_handled_func *item) const
+ {
+ return item->unsigned_flag ? (double) ((ulonglong) val_int(item)) :
+ (double) val_int(item);
+ }
+ my_decimal *val_decimal(Item_handled_func *item, my_decimal *to) const
+ {
+ return item->val_decimal_from_int(to);
+ }
+ bool get_date(THD *thd, Item_handled_func *item,
+ MYSQL_TIME *to, date_mode_t fuzzydate) const
+ {
+ return item->get_date_from_int(thd, to, fuzzydate);
+ }
+ longlong val_int(Item_handled_func *item) const
+ {
+ Longlong_null tmp= to_longlong_null(item);
+ item->null_value= tmp.is_null();
+ return tmp.value();
+ }
+ virtual Longlong_null to_longlong_null(Item_handled_func *item) const= 0;
+ };
+
+ class Handler_slong: public Handler_int
+ {
+ public:
+ const Type_handler *return_type_handler(const Item_handled_func *item) const
+ {
+ return &type_handler_slong;
+ }
+ bool fix_length_and_dec(Item_handled_func *item) const
+ {
+ item->unsigned_flag= false;
+ item->collation= DTCollation_numeric();
+ item->fix_char_length(11);
+ return false;
+ }
+ };
+
+ class Handler_slong2: public Handler_slong
+ {
+ public:
+ bool fix_length_and_dec(Item_handled_func *func) const
+ {
+ bool rc= Handler_slong::fix_length_and_dec(func);
+ func->max_length= 2;
+ return rc;
+ }
+ };
+
+ class Handler_ulonglong: public Handler_int
+ {
+ public:
+ const Type_handler *return_type_handler(const Item_handled_func *item) const
+ {
+ return &type_handler_ulonglong;
+ }
+ bool fix_length_and_dec(Item_handled_func *item) const
+ {
+ item->unsigned_flag= true;
+ item->collation= DTCollation_numeric();
+ item->fix_char_length(21);
+ return false;
+ }
+ };
+
+protected:
+ const Handler *m_func_handler;
+public:
+ Item_handled_func(THD *thd, Item *a)
+ :Item_func(thd, a), m_func_handler(NULL) { }
+ Item_handled_func(THD *thd, Item *a, Item *b)
+ :Item_func(thd, a, b), m_func_handler(NULL) { }
+ void set_func_handler(const Handler *handler)
+ {
+ m_func_handler= handler;
+ }
+ const Type_handler *type_handler() const override
+ {
+ return m_func_handler->return_type_handler(this);
+ }
+ Field *create_field_for_create_select(MEM_ROOT *root, TABLE *table) override
+ {
+ DBUG_ASSERT(fixed());
+ const Type_handler *h= m_func_handler->type_handler_for_create_select(this);
+ return h->make_and_init_table_field(root, &name,
+ Record_addr(maybe_null()),
+ *this, table);
+ }
+ String *val_str(String *to) override
+ {
+ return m_func_handler->val_str(this, to);
+ }
+ String *val_str_ascii(String *to) override
+ {
+ return m_func_handler->val_str_ascii(this, to);
+ }
+ double val_real() override
+ {
+ return m_func_handler->val_real(this);
+ }
+ longlong val_int() override
+ {
+ return m_func_handler->val_int(this);
+ }
+ my_decimal *val_decimal(my_decimal *to) override
+ {
+ return m_func_handler->val_decimal(this, to);
+ }
+ bool get_date(THD *thd, MYSQL_TIME *to, date_mode_t fuzzydate) override
+ {
+ return m_func_handler->get_date(thd, this, to, fuzzydate);
+ }
+ bool val_native(THD *thd, Native *to) override
+ {
+ return m_func_handler->val_native(thd, this, to);
+ }
+};
+
+
+/**
+ Functions that at fix_fields() time determine the returned field type,
+ trying to preserve the exact data type of the arguments.
+
+ The descendants have to implement "native" value methods,
+ i.e. str_op(), date_op(), int_op(), real_op(), decimal_op().
+ fix_fields() chooses which of the above value methods will be
+ used during execution time, according to the returned field type.
+
+ For example, if fix_fields() determines that the returned value type
+ is MYSQL_TYPE_LONG, then:
+ - int_op() is chosen as the execution time native method.
+ - val_int() returns the result of int_op() as is.
+ - all other methods, i.e. val_real(), val_decimal(), val_str(), get_date(),
+ call int_op() first, then convert the result to the requested data type.
+*/
+class Item_func_hybrid_field_type: public Item_hybrid_func
+{
+ /*
+ Helper methods to make sure that the result of
+ decimal_op(), str_op() and date_op() is properly synched with null_value.
+ */
+ bool date_op_with_null_check(THD *thd, MYSQL_TIME *ltime)
+ {
+ bool rc= date_op(thd, ltime, date_mode_t(0));
+ DBUG_ASSERT(!rc ^ null_value);
+ return rc;
+ }
+ bool time_op_with_null_check(THD *thd, MYSQL_TIME *ltime)
+ {
+ bool rc= time_op(thd, ltime);
+ DBUG_ASSERT(!rc ^ null_value);
+ DBUG_ASSERT(rc || ltime->time_type == MYSQL_TIMESTAMP_TIME);
+ return rc;
+ }
+ String *str_op_with_null_check(String *str)
+ {
+ String *res= str_op(str);
+ DBUG_ASSERT((res != NULL) ^ null_value);
+ return res;
+ }
+
+public:
+ // Value methods that involve no conversion
+ String *val_str_from_str_op(String *str)
+ {
+ return str_op_with_null_check(&str_value);
+ }
+ longlong val_int_from_int_op()
+ {
+ return int_op();
+ }
+ double val_real_from_real_op()
+ {
+ return real_op();
+ }
+
+ // Value methods that involve conversion
+ String *val_str_from_real_op(String *str);
+ String *val_str_from_int_op(String *str);
+ String *val_str_from_date_op(String *str);
+ String *val_str_from_time_op(String *str);
+
+ my_decimal *val_decimal_from_str_op(my_decimal *dec);
+ my_decimal *val_decimal_from_real_op(my_decimal *dec);
+ my_decimal *val_decimal_from_int_op(my_decimal *dec);
+ my_decimal *val_decimal_from_date_op(my_decimal *dec);
+ my_decimal *val_decimal_from_time_op(my_decimal *dec);
+
+ longlong val_int_from_str_op();
+ longlong val_int_from_real_op();
+ longlong val_int_from_date_op();
+ longlong val_int_from_time_op();
+
+ double val_real_from_str_op();
+ double val_real_from_date_op();
+ double val_real_from_time_op();
+ double val_real_from_int_op();
+
+public:
+ Item_func_hybrid_field_type(THD *thd):
+ Item_hybrid_func(thd)
+ { collation= DTCollation_numeric(); }
+ Item_func_hybrid_field_type(THD *thd, Item *a):
+ Item_hybrid_func(thd, a)
+ { collation= DTCollation_numeric(); }
+ Item_func_hybrid_field_type(THD *thd, Item *a, Item *b):
+ Item_hybrid_func(thd, a, b)
+ { collation= DTCollation_numeric(); }
+ Item_func_hybrid_field_type(THD *thd, Item *a, Item *b, Item *c):
+ Item_hybrid_func(thd, a, b, c)
+ { collation= DTCollation_numeric(); }
+ Item_func_hybrid_field_type(THD *thd, List<Item> &list):
+ Item_hybrid_func(thd, list)
+ { collation= DTCollation_numeric(); }
+
+ double val_real() override
+ {
+ DBUG_ASSERT(fixed());
+ return Item_func_hybrid_field_type::type_handler()->
+ Item_func_hybrid_field_type_val_real(this);
+ }
+ longlong val_int() override
+ {
+ DBUG_ASSERT(fixed());
+ return Item_func_hybrid_field_type::type_handler()->
+ Item_func_hybrid_field_type_val_int(this);
+ }
+ my_decimal *val_decimal(my_decimal *dec) override
+ {
+ DBUG_ASSERT(fixed());
+ return Item_func_hybrid_field_type::type_handler()->
+ Item_func_hybrid_field_type_val_decimal(this, dec);
+ }
+ String *val_str(String*str) override
+ {
+ DBUG_ASSERT(fixed());
+ String *res= Item_func_hybrid_field_type::type_handler()->
+ Item_func_hybrid_field_type_val_str(this, str);
+ DBUG_ASSERT(null_value == (res == NULL));
+ return res;
+ }
+ bool get_date(THD *thd, MYSQL_TIME *to, date_mode_t mode) override
+ {
+ DBUG_ASSERT(fixed());
+ return Item_func_hybrid_field_type::type_handler()->
+ Item_func_hybrid_field_type_get_date_with_warn(thd, this, to, mode);
+ }
+
+ bool val_native(THD *thd, Native *to) override
+ {
+ DBUG_ASSERT(fixed());
+ return native_op(thd, to);
+ }
+
+ /**
+ @brief Performs the operation that this functions implements when the
+ result type is INT.
+
+ @return The result of the operation.
+ */
+ virtual longlong int_op()= 0;
+ Longlong_null to_longlong_null_op()
+ {
+ longlong nr= int_op();
+ /*
+ C++ does not guarantee the order of parameter evaluation,
+ so to make sure "null_value" is passed to the constructor
+ after the int_op() call, int_op() is caled on a separate line.
+ */
+ return Longlong_null(nr, null_value);
+ }
+ Longlong_hybrid_null to_longlong_hybrid_null_op()
+ {
+ return Longlong_hybrid_null(to_longlong_null_op(), unsigned_flag);
+ }
+
+ /**
+ @brief Performs the operation that this functions implements when the
+ result type is REAL.
+
+ @return The result of the operation.
+ */
+ virtual double real_op()= 0;
+ Double_null to_double_null_op()
+ {
+ // val_real() must be caleed on a separate line. See to_longlong_null()
+ double nr= real_op();
+ return Double_null(nr, null_value);
+ }
+
+ /**
+ @brief Performs the operation that this functions implements when the
+ result type is DECIMAL.
+
+ @param A pointer where the DECIMAL value will be allocated.
+ @return
+ - 0 If the result is NULL
+ - The same pointer it was given, with the area initialized to the
+ result of the operation.
+ */
+ virtual my_decimal *decimal_op(my_decimal *)= 0;
+
+ /**
+ @brief Performs the operation that this functions implements when the
+ result type is a string type.
+
+ @return The result of the operation.
+ */
+ virtual String *str_op(String *)= 0;
+
+ /**
+ @brief Performs the operation that this functions implements when
+ field type is DATETIME or DATE.
+ @return The result of the operation.
+ */
+ virtual bool date_op(THD *thd, MYSQL_TIME *res, date_mode_t fuzzydate)= 0;
+
+ /**
+ @brief Performs the operation that this functions implements when
+ field type is TIME.
+ @return The result of the operation.
+ */
+ virtual bool time_op(THD *thd, MYSQL_TIME *res)= 0;
+
+ virtual bool native_op(THD *thd, Native *native)= 0;
+};
+
+
+/*
+ This class resembles SQL standard CASE-alike expressions:
+ CASE and its abbreviations COALESCE, NULLIF, IFNULL, IF.
+
+ <case expression> ::= <case abbreviation>
+ | <case specification>
+*/
+class Item_func_case_expression: public Item_func_hybrid_field_type
+{
+public:
+ Item_func_case_expression(THD *thd)
+ :Item_func_hybrid_field_type(thd)
+ { }
+ Item_func_case_expression(THD *thd, Item *a)
+ :Item_func_hybrid_field_type(thd, a)
+ { }
+ Item_func_case_expression(THD *thd, Item *a, Item *b)
+ :Item_func_hybrid_field_type(thd, a, b)
+ { }
+ Item_func_case_expression(THD *thd, Item *a, Item *b, Item *c)
+ :Item_func_hybrid_field_type(thd, a, b, c)
+ { }
+ Item_func_case_expression(THD *thd, List<Item> &list):
+ Item_func_hybrid_field_type(thd, list)
+ { }
+ bool find_not_null_fields(table_map allowed) { return false; }
+};
+
+
+class Item_func_numhybrid: public Item_func_hybrid_field_type
+{
+protected:
+
+ inline void fix_decimals()
+ {
+ DBUG_ASSERT(result_type() == DECIMAL_RESULT);
+ if (decimals == NOT_FIXED_DEC)
+ set_if_smaller(decimals, max_length - 1);
+ }
+
+public:
+ Item_func_numhybrid(THD *thd): Item_func_hybrid_field_type(thd)
+ { }
+ Item_func_numhybrid(THD *thd, Item *a): Item_func_hybrid_field_type(thd, a)
+ { }
+ Item_func_numhybrid(THD *thd, Item *a, Item *b):
+ Item_func_hybrid_field_type(thd, a, b)
+ { }
+ Item_func_numhybrid(THD *thd, Item *a, Item *b, Item *c):
+ Item_func_hybrid_field_type(thd, a, b, c)
+ { }
+ Item_func_numhybrid(THD *thd, List<Item> &list):
+ Item_func_hybrid_field_type(thd, list)
+ { }
+ String *str_op(String *str) { DBUG_ASSERT(0); return 0; }
+ bool date_op(THD *thd, MYSQL_TIME *ltime, date_mode_t fuzzydate)
+ {
+ DBUG_ASSERT(0);
+ return true;
+ }
+ bool time_op(THD *thd, MYSQL_TIME *ltime)
+ {
+ DBUG_ASSERT(0);
+ return true;
+ }
+ bool native_op(THD *thd, Native *to)
+ {
+ DBUG_ASSERT(0);
+ return true;
+ }
+};
+
+
+/* function where type of result detected by first argument */
+class Item_func_num1: public Item_func_numhybrid
+{
+public:
+ Item_func_num1(THD *thd, Item *a): Item_func_numhybrid(thd, a) {}
+ Item_func_num1(THD *thd, Item *a, Item *b): Item_func_numhybrid(thd, a, b) {}
+ bool check_partition_func_processor(void *int_arg) { return FALSE; }
+ bool check_vcol_func_processor(void *arg) { return FALSE; }
+};
+
+
+/* Base class for operations like '+', '-', '*' */
+class Item_num_op :public Item_func_numhybrid
+{
+protected:
+ bool check_arguments() const override
+ {
+ return false; // Checked by aggregate_for_num_op()
+ }
+public:
+ Item_num_op(THD *thd, Item *a, Item *b): Item_func_numhybrid(thd, a, b) {}
+ virtual void result_precision()= 0;
+
+ void print(String *str, enum_query_type query_type) override
+ {
+ print_op(str, query_type);
+ }
+ bool fix_type_handler(const Type_aggregator *aggregator);
+ void fix_length_and_dec_double()
+ {
+ aggregate_numeric_attributes_real(args, arg_count);
+ max_length= float_length(decimals);
+ }
+ void fix_length_and_dec_decimal()
+ {
+ unsigned_flag= args[0]->unsigned_flag & args[1]->unsigned_flag;
+ result_precision();
+ fix_decimals();
+ }
+ void fix_length_and_dec_int()
+ {
+ unsigned_flag= args[0]->unsigned_flag | args[1]->unsigned_flag;
+ result_precision();
+ decimals= 0;
+ set_handler(type_handler_long_or_longlong());
+ }
+ void fix_length_and_dec_temporal(bool downcast_decimal_to_int)
+ {
+ set_handler(&type_handler_newdecimal);
+ fix_length_and_dec_decimal();
+ if (decimals == 0 && downcast_decimal_to_int)
+ set_handler(type_handler_long_or_longlong());
+ }
+ bool need_parentheses_in_default() override { return true; }
+};
+
+
+class Item_int_func :public Item_func
+{
+public:
+ /*
+ QQ: shouldn't 20 characters be enough:
+ Max unsigned = 18,446,744,073,709,551,615 = 20 digits, 20 characters
+ Max signed = 9,223,372,036,854,775,807 = 19 digits, 19 characters
+ Min signed = -9,223,372,036,854,775,808 = 19 digits, 20 characters
+ */
+ Item_int_func(THD *thd): Item_func(thd)
+ { collation= DTCollation_numeric(); fix_char_length(21); }
+ Item_int_func(THD *thd, Item *a): Item_func(thd, a)
+ { collation= DTCollation_numeric(); fix_char_length(21); }
+ Item_int_func(THD *thd, Item *a, Item *b): Item_func(thd, a, b)
+ { collation= DTCollation_numeric(); fix_char_length(21); }
+ Item_int_func(THD *thd, Item *a, Item *b, Item *c): Item_func(thd, a, b, c)
+ { collation= DTCollation_numeric(); fix_char_length(21); }
+ Item_int_func(THD *thd, Item *a, Item *b, Item *c, Item *d):
+ Item_func(thd, a, b, c, d)
+ { collation= DTCollation_numeric(); fix_char_length(21); }
+ Item_int_func(THD *thd, List<Item> &list): Item_func(thd, list)
+ { collation= DTCollation_numeric(); fix_char_length(21); }
+ Item_int_func(THD *thd, Item_int_func *item) :Item_func(thd, item)
+ { collation= DTCollation_numeric(); }
+ double val_real() override;
+ String *val_str(String*str) override;
+ my_decimal *val_decimal(my_decimal *decimal_value) override
+ {
+ return val_decimal_from_int(decimal_value);
+ }
+ bool get_date(THD *thd, MYSQL_TIME *ltime, date_mode_t fuzzydate) override
+ { return get_date_from_int(thd, ltime, fuzzydate); }
+ const Type_handler *type_handler() const override= 0;
+ bool fix_length_and_dec(THD *thd) override { return FALSE; }
+};
+
+
+class Item_long_func: public Item_int_func
+{
+public:
+ Item_long_func(THD *thd): Item_int_func(thd) { }
+ Item_long_func(THD *thd, Item *a): Item_int_func(thd, a) {}
+ Item_long_func(THD *thd, Item *a, Item *b): Item_int_func(thd, a, b) {}
+ Item_long_func(THD *thd, Item *a, Item *b, Item *c): Item_int_func(thd, a, b, c) {}
+ Item_long_func(THD *thd, List<Item> &list): Item_int_func(thd, list) { }
+ Item_long_func(THD *thd, Item_long_func *item) :Item_int_func(thd, item) {}
+ const Type_handler *type_handler() const override
+ {
+ if (unsigned_flag)
+ return &type_handler_ulong;
+ return &type_handler_slong;
+ }
+ bool fix_length_and_dec(THD *thd) override { max_length= 11; return FALSE; }
+};
+
+
+class Item_func_hash: public Item_int_func
+{
+public:
+ Item_func_hash(THD *thd, List<Item> &item): Item_int_func(thd, item)
+ {}
+ longlong val_int() override;
+ bool fix_length_and_dec(THD *thd) override;
+ const Type_handler *type_handler() const override
+ { return &type_handler_slong; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_hash>(thd, this); }
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("<hash>") };
+ return name;
+ }
+};
+
+class Item_func_hash_mariadb_100403: public Item_func_hash
+{
+public:
+ Item_func_hash_mariadb_100403(THD *thd, List<Item> &item)
+ :Item_func_hash(thd, item)
+ {}
+ longlong val_int();
+ Item *get_copy(THD *thd)
+ { return get_item_copy<Item_func_hash_mariadb_100403>(thd, this); }
+ const char *func_name() const { return "<hash_mariadb_100403>"; }
+};
+
+class Item_longlong_func: public Item_int_func
+{
+public:
+ Item_longlong_func(THD *thd): Item_int_func(thd) { }
+ Item_longlong_func(THD *thd, Item *a): Item_int_func(thd, a) {}
+ Item_longlong_func(THD *thd, Item *a, Item *b): Item_int_func(thd, a, b) {}
+ Item_longlong_func(THD *thd, Item *a, Item *b, Item *c): Item_int_func(thd, a, b, c) {}
+ Item_longlong_func(THD *thd, Item *a, Item *b, Item *c, Item *d):
+ Item_int_func(thd, a, b, c, d) {}
+ Item_longlong_func(THD *thd, List<Item> &list): Item_int_func(thd, list) { }
+ Item_longlong_func(THD *thd, Item_longlong_func *item) :Item_int_func(thd, item) {}
+ const Type_handler *type_handler() const override
+ {
+ if (unsigned_flag)
+ return &type_handler_ulonglong;
+ return &type_handler_slonglong;
+ }
+};
+
+
+class Cursor_ref
+{
+protected:
+ LEX_CSTRING m_cursor_name;
+ uint m_cursor_offset;
+ class sp_cursor *get_open_cursor_or_error();
+ Cursor_ref(const LEX_CSTRING *name, uint offset)
+ :m_cursor_name(*name), m_cursor_offset(offset)
+ { }
+ void print_func(String *str, const LEX_CSTRING &func_name);
+};
+
+
+
+class Item_func_cursor_rowcount: public Item_longlong_func,
+ public Cursor_ref
+{
+public:
+ Item_func_cursor_rowcount(THD *thd, const LEX_CSTRING *name, uint offset)
+ :Item_longlong_func(thd), Cursor_ref(name, offset)
+ {
+ set_maybe_null();
+ }
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("%ROWCOUNT") };
+ return name;
+ }
+ longlong val_int() override;
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), arg, VCOL_SESSION_FUNC);
+ }
+ void print(String *str, enum_query_type query_type) override
+ {
+ return Cursor_ref::print_func(str, func_name_cstring());
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_cursor_rowcount>(thd, this); }
+};
+
+
+
+class Item_func_connection_id :public Item_long_func
+{
+ longlong value;
+
+public:
+ Item_func_connection_id(THD *thd): Item_long_func(thd) { unsigned_flag=1; }
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("connection_id") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override;
+ bool fix_fields(THD *thd, Item **ref) override;
+ longlong val_int() override { DBUG_ASSERT(fixed()); return value; }
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg,
+ VCOL_SESSION_FUNC);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_connection_id>(thd, this); }
+};
+
+
+class Item_func_signed :public Item_int_func
+{
+public:
+ Item_func_signed(THD *thd, Item *a): Item_int_func(thd, a)
+ {
+ unsigned_flag= 0;
+ }
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("cast_as_signed") };
+ return name;
+ }
+ const Type_handler *type_handler() const override
+ {
+ return Type_handler::type_handler_long_or_longlong(max_char_length(),
+ false);
+ }
+ longlong val_int() override
+ {
+ longlong value= args[0]->val_int_signed_typecast();
+ null_value= args[0]->null_value;
+ return value;
+ }
+ void fix_length_and_dec_double()
+ {
+ fix_char_length(MAX_BIGINT_WIDTH);
+ }
+ void fix_length_and_dec_generic()
+ {
+ uint32 char_length= MY_MIN(args[0]->max_char_length(),
+ MY_INT64_NUM_DECIMAL_DIGITS);
+ /*
+ args[0]->max_char_length() can return 0.
+ Reserve max_length to fit at least one character for one digit,
+ plus one character for the sign (if signed).
+ */
+ set_if_bigger(char_length, 1U + (unsigned_flag ? 0 : 1));
+ fix_char_length(char_length);
+ }
+ void fix_length_and_dec_string()
+ {
+ /*
+ For strings, use decimal_int_part() instead of max_char_length().
+ This is important for Item_hex_hybrid:
+ SELECT CAST(0x1FFFFFFFF AS SIGNED);
+ Length is 5, decimal_int_part() is 13.
+ */
+ uint32 char_length= MY_MIN(args[0]->decimal_int_part(),
+ MY_INT64_NUM_DECIMAL_DIGITS);
+ set_if_bigger(char_length, 1U + (unsigned_flag ? 0 : 1));
+ fix_char_length(char_length);
+ }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ return args[0]->type_handler()->Item_func_signed_fix_length_and_dec(this);
+ }
+ void print(String *str, enum_query_type query_type) override;
+ decimal_digits_t decimal_precision() const override
+ { return args[0]->decimal_precision(); }
+ bool need_parentheses_in_default() override { return true; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_signed>(thd, this); }
+};
+
+
+class Item_func_unsigned :public Item_func_signed
+{
+public:
+ Item_func_unsigned(THD *thd, Item *a): Item_func_signed(thd, a)
+ {
+ unsigned_flag= 1;
+ }
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("cast_as_unsigned") };
+ return name;
+ }
+ const Type_handler *type_handler() const override
+ {
+ if (max_char_length() <= MY_INT32_NUM_DECIMAL_DIGITS - 1)
+ return &type_handler_ulong;
+ return &type_handler_ulonglong;
+ }
+ longlong val_int() override
+ {
+ longlong value= args[0]->val_int_unsigned_typecast();
+ null_value= args[0]->null_value;
+ return value;
+ }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ return args[0]->type_handler()->Item_func_unsigned_fix_length_and_dec(this);
+ }
+ decimal_digits_t decimal_precision() const override { return max_length; }
+ void print(String *str, enum_query_type query_type) override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_unsigned>(thd, this); }
+};
+
+
+class Item_decimal_typecast :public Item_func
+{
+ my_decimal decimal_value;
+public:
+ Item_decimal_typecast(THD *thd, Item *a, uint len, decimal_digits_t dec)
+ :Item_func(thd, a)
+ {
+ decimals= dec;
+ collation= DTCollation_numeric();
+ fix_char_length(my_decimal_precision_to_length_no_truncation(len, dec,
+ unsigned_flag));
+ }
+ String *val_str(String *str) override { return VDec(this).to_string(str); }
+ double val_real() override { return VDec(this).to_double(); }
+ longlong val_int() override { return VDec(this).to_longlong(unsigned_flag); }
+ my_decimal *val_decimal(my_decimal*) override;
+ bool get_date(THD *thd, MYSQL_TIME *to, date_mode_t mode) override
+ {
+ return decimal_to_datetime_with_warn(thd, VDec(this).ptr(), to, mode,
+ NULL, NULL);
+ }
+ const Type_handler *type_handler() const override
+ { return &type_handler_newdecimal; }
+ void fix_length_and_dec_generic() {}
+ bool fix_length_and_dec(THD *thd) override
+ {
+ return
+ args[0]->type_handler()->Item_decimal_typecast_fix_length_and_dec(this);
+ }
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("decimal_typecast") };
+ return name;
+ }
+ void print(String *str, enum_query_type query_type) override;
+ bool need_parentheses_in_default() override { return true; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_decimal_typecast>(thd, this); }
+};
+
+
+class Item_real_typecast: public Item_real_func
+{
+protected:
+ double val_real_with_truncate(double max_value);
+public:
+ Item_real_typecast(THD *thd, Item *a, uint len, uint dec)
+ :Item_real_func(thd, a)
+ {
+ decimals= (uint8) dec;
+ max_length= (uint32) len;
+ }
+ bool need_parentheses_in_default() { return true; }
+ void print(String *str, enum_query_type query_type);
+ void fix_length_and_dec_generic()
+ {
+ set_maybe_null();
+ }
+};
+
+
+class Item_float_typecast :public Item_real_typecast
+{
+public:
+ Item_float_typecast(THD *thd, Item *a)
+ :Item_real_typecast(thd, a, MAX_FLOAT_STR_LENGTH, NOT_FIXED_DEC)
+ { }
+ const Type_handler *type_handler() const override
+ { return &type_handler_float; }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ return
+ args[0]->type_handler()->Item_float_typecast_fix_length_and_dec(this);
+ }
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("float_typecast") };
+ return name;
+ }
+ double val_real() override
+ {
+ return (double) (float) val_real_with_truncate(FLT_MAX);
+ }
+ String *val_str(String*str) override
+ {
+ Float nr(Item_float_typecast::val_real());
+ if (null_value)
+ return 0;
+ nr.to_string(str, decimals);
+ return str;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_float_typecast>(thd, this); }
+};
+
+
+class Item_double_typecast :public Item_real_typecast
+{
+public:
+ Item_double_typecast(THD *thd, Item *a, uint len, uint dec):
+ Item_real_typecast(thd, a, len, dec)
+ { }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ return
+ args[0]->type_handler()->Item_double_typecast_fix_length_and_dec(this);
+ }
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("double_typecast") };
+ return name;
+ }
+ double val_real() override { return val_real_with_truncate(DBL_MAX); }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_double_typecast>(thd, this); }
+};
+
+
+class Item_func_additive_op :public Item_num_op
+{
+public:
+ Item_func_additive_op(THD *thd, Item *a, Item *b): Item_num_op(thd, a, b) {}
+ void result_precision();
+ bool check_partition_func_processor(void *int_arg) {return FALSE;}
+ bool check_vcol_func_processor(void *arg) { return FALSE;}
+};
+
+
+class Item_func_plus :public Item_func_additive_op
+{
+public:
+ Item_func_plus(THD *thd, Item *a, Item *b):
+ Item_func_additive_op(thd, a, b) {}
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("+") };
+ return name;
+ }
+ enum precedence precedence() const override { return ADD_PRECEDENCE; }
+ bool fix_length_and_dec(THD *thd) override;
+ longlong int_op() override;
+ double real_op() override;
+ my_decimal *decimal_op(my_decimal *) override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_plus>(thd, this); }
+};
+
+class Item_func_minus :public Item_func_additive_op
+{
+ bool m_depends_on_sql_mode_no_unsigned_subtraction;
+public:
+ Item_func_minus(THD *thd, Item *a, Item *b):
+ Item_func_additive_op(thd, a, b),
+ m_depends_on_sql_mode_no_unsigned_subtraction(false)
+ { }
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("-") };
+ return name;
+ }
+ enum precedence precedence() const override { return ADD_PRECEDENCE; }
+ Sql_mode_dependency value_depends_on_sql_mode() const override;
+ longlong int_op() override;
+ double real_op() override;
+ my_decimal *decimal_op(my_decimal *) override;
+ bool fix_length_and_dec(THD *thd) override;
+ void fix_unsigned_flag();
+ void fix_length_and_dec_double()
+ {
+ Item_func_additive_op::fix_length_and_dec_double();
+ fix_unsigned_flag();
+ }
+ void fix_length_and_dec_decimal()
+ {
+ Item_func_additive_op::fix_length_and_dec_decimal();
+ fix_unsigned_flag();
+ }
+ void fix_length_and_dec_int()
+ {
+ Item_func_additive_op::fix_length_and_dec_int();
+ fix_unsigned_flag();
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_minus>(thd, this); }
+};
+
+
+class Item_func_mul :public Item_num_op
+{
+public:
+ Item_func_mul(THD *thd, Item *a, Item *b):
+ Item_num_op(thd, a, b) {}
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("*") };
+ return name;
+ }
+ enum precedence precedence() const override { return MUL_PRECEDENCE; }
+ longlong int_op() override;
+ double real_op() override;
+ my_decimal *decimal_op(my_decimal *) override;
+ void result_precision() override;
+ bool fix_length_and_dec(THD *thd) override;
+ bool check_partition_func_processor(void *int_arg) override {return FALSE;}
+ bool check_vcol_func_processor(void *arg) override { return FALSE;}
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_mul>(thd, this); }
+};
+
+
+class Item_func_div :public Item_num_op
+{
+public:
+ uint prec_increment;
+ Item_func_div(THD *thd, Item *a, Item *b): Item_num_op(thd, a, b) {}
+ longlong int_op() override { DBUG_ASSERT(0); return 0; }
+ double real_op() override;
+ my_decimal *decimal_op(my_decimal *) override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("/") };
+ return name;
+ }
+ enum precedence precedence() const override { return MUL_PRECEDENCE; }
+ bool fix_length_and_dec(THD *thd) override;
+ void fix_length_and_dec_double();
+ void fix_length_and_dec_int();
+ void result_precision() override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_div>(thd, this); }
+};
+
+
+class Item_func_int_div :public Item_int_func
+{
+public:
+ Item_func_int_div(THD *thd, Item *a, Item *b): Item_int_func(thd, a, b)
+ {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("DIV") };
+ return name;
+ }
+ enum precedence precedence() const override { return MUL_PRECEDENCE; }
+ const Type_handler *type_handler() const override
+ { return type_handler_long_or_longlong(); }
+ bool fix_length_and_dec(THD *thd) override;
+ void print(String *str, enum_query_type query_type) override
+ {
+ print_op(str, query_type);
+ }
+
+ bool check_partition_func_processor(void *int_arg) override {return FALSE;}
+ bool check_vcol_func_processor(void *arg) override { return FALSE;}
+ bool need_parentheses_in_default() override { return true; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_int_div>(thd, this); }
+};
+
+
+class Item_func_mod :public Item_num_op
+{
+public:
+ Item_func_mod(THD *thd, Item *a, Item *b): Item_num_op(thd, a, b) {}
+ longlong int_op() override;
+ double real_op() override;
+ my_decimal *decimal_op(my_decimal *) override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("MOD") };
+ return name;
+ }
+ enum precedence precedence() const override { return MUL_PRECEDENCE; }
+ void result_precision() override;
+ bool fix_length_and_dec(THD *thd) override;
+ void fix_length_and_dec_double()
+ {
+ Item_num_op::fix_length_and_dec_double();
+ unsigned_flag= args[0]->unsigned_flag;
+ }
+ void fix_length_and_dec_decimal()
+ {
+ result_precision();
+ fix_decimals();
+ }
+ void fix_length_and_dec_int()
+ {
+ result_precision();
+ DBUG_ASSERT(decimals == 0);
+ set_handler(type_handler_long_or_longlong());
+ }
+ bool check_partition_func_processor(void *int_arg) override {return FALSE;}
+ bool check_vcol_func_processor(void *arg) override { return FALSE;}
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_mod>(thd, this); }
+};
+
+
+class Item_func_neg :public Item_func_num1
+{
+public:
+ Item_func_neg(THD *thd, Item *a): Item_func_num1(thd, a) {}
+ double real_op() override;
+ longlong int_op() override;
+ my_decimal *decimal_op(my_decimal *) override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("-") };
+ return name;
+ }
+ enum Functype functype() const override { return NEG_FUNC; }
+ enum precedence precedence() const override { return NEG_PRECEDENCE; }
+ void print(String *str, enum_query_type query_type) override
+ {
+ str->append(func_name_cstring());
+ args[0]->print_parenthesised(str, query_type, precedence());
+ }
+ void fix_length_and_dec_int();
+ void fix_length_and_dec_double();
+ void fix_length_and_dec_decimal();
+ bool fix_length_and_dec(THD *thd) override;
+ decimal_digits_t decimal_precision() const override
+ { return args[0]->decimal_precision(); }
+ bool need_parentheses_in_default() override { return true; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_neg>(thd, this); }
+};
+
+
+class Item_func_abs :public Item_func_num1
+{
+public:
+ Item_func_abs(THD *thd, Item *a): Item_func_num1(thd, a) {}
+ double real_op() override;
+ longlong int_op() override;
+ my_decimal *decimal_op(my_decimal *) override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("abs") };
+ return name;
+ }
+ void fix_length_and_dec_int();
+ void fix_length_and_dec_double();
+ void fix_length_and_dec_decimal();
+ bool fix_length_and_dec(THD *thd) override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_abs>(thd, this); }
+};
+
+// A class to handle logarithmic and trigonometric functions
+
+class Item_dec_func :public Item_real_func
+{
+ bool check_arguments() const override
+ { return check_argument_types_can_return_real(0, arg_count); }
+ public:
+ Item_dec_func(THD *thd, Item *a): Item_real_func(thd, a) {}
+ Item_dec_func(THD *thd, Item *a, Item *b): Item_real_func(thd, a, b) {}
+ bool fix_length_and_dec(THD *thd) override
+ {
+ decimals= NOT_FIXED_DEC;
+ max_length= float_length(decimals);
+ set_maybe_null();
+ return FALSE;
+ }
+};
+
+class Item_func_exp :public Item_dec_func
+{
+public:
+ Item_func_exp(THD *thd, Item *a): Item_dec_func(thd, a) {}
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("exp") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_exp>(thd, this); }
+};
+
+
+class Item_func_ln :public Item_dec_func
+{
+public:
+ Item_func_ln(THD *thd, Item *a): Item_dec_func(thd, a) {}
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("ln") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_ln>(thd, this); }
+};
+
+
+class Item_func_log :public Item_dec_func
+{
+public:
+ Item_func_log(THD *thd, Item *a): Item_dec_func(thd, a) {}
+ Item_func_log(THD *thd, Item *a, Item *b): Item_dec_func(thd, a, b) {}
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("log") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_log>(thd, this); }
+};
+
+
+class Item_func_log2 :public Item_dec_func
+{
+public:
+ Item_func_log2(THD *thd, Item *a): Item_dec_func(thd, a) {}
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("log2") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_log2>(thd, this); }
+};
+
+
+class Item_func_log10 :public Item_dec_func
+{
+public:
+ Item_func_log10(THD *thd, Item *a): Item_dec_func(thd, a) {}
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("log10") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_log10>(thd, this); }
+};
+
+
+class Item_func_sqrt :public Item_dec_func
+{
+public:
+ Item_func_sqrt(THD *thd, Item *a): Item_dec_func(thd, a) {}
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("sqrt") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_sqrt>(thd, this); }
+};
+
+
+class Item_func_pow :public Item_dec_func
+{
+public:
+ Item_func_pow(THD *thd, Item *a, Item *b): Item_dec_func(thd, a, b) {}
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("pow") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_pow>(thd, this); }
+};
+
+
+class Item_func_acos :public Item_dec_func
+{
+public:
+ Item_func_acos(THD *thd, Item *a): Item_dec_func(thd, a) {}
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("acos") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_acos>(thd, this); }
+};
+
+class Item_func_asin :public Item_dec_func
+{
+public:
+ Item_func_asin(THD *thd, Item *a): Item_dec_func(thd, a) {}
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("asin") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_asin>(thd, this); }
+};
+
+class Item_func_atan :public Item_dec_func
+{
+public:
+ Item_func_atan(THD *thd, Item *a): Item_dec_func(thd, a) {}
+ Item_func_atan(THD *thd, Item *a, Item *b): Item_dec_func(thd, a, b) {}
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("atan") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_atan>(thd, this); }
+};
+
+class Item_func_cos :public Item_dec_func
+{
+public:
+ Item_func_cos(THD *thd, Item *a): Item_dec_func(thd, a) {}
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("cos") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_cos>(thd, this); }
+};
+
+class Item_func_sin :public Item_dec_func
+{
+public:
+ Item_func_sin(THD *thd, Item *a): Item_dec_func(thd, a) {}
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("sin") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_sin>(thd, this); }
+};
+
+class Item_func_tan :public Item_dec_func
+{
+public:
+ Item_func_tan(THD *thd, Item *a): Item_dec_func(thd, a) {}
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("tan") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_tan>(thd, this); }
+};
+
+class Item_func_cot :public Item_dec_func
+{
+public:
+ Item_func_cot(THD *thd, Item *a): Item_dec_func(thd, a) {}
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("cot") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_cot>(thd, this); }
+};
+
+
+class Item_func_int_val :public Item_func_hybrid_field_type
+{
+public:
+ Item_func_int_val(THD *thd, Item *a): Item_func_hybrid_field_type(thd, a) {}
+ bool check_partition_func_processor(void *int_arg) override { return FALSE; }
+ bool check_vcol_func_processor(void *arg) override { return FALSE; }
+ virtual decimal_round_mode round_mode() const= 0;
+ void fix_length_and_dec_double();
+ void fix_length_and_dec_int_or_decimal();
+ void fix_length_and_dec_time()
+ {
+ fix_attributes_time(0);
+ set_handler(&type_handler_time2);
+ }
+ void fix_length_and_dec_datetime()
+ {
+ fix_attributes_datetime(0);
+ set_handler(&type_handler_datetime2);
+ // Thinks like CEILING(TIMESTAMP'0000-01-01 23:59:59.9') returns NULL
+ set_maybe_null();
+ }
+ bool fix_length_and_dec(THD *thd) override;
+ String *str_op(String *str) override { DBUG_ASSERT(0); return 0; }
+ bool native_op(THD *thd, Native *to) override;
+};
+
+
+class Item_func_ceiling :public Item_func_int_val
+{
+public:
+ Item_func_ceiling(THD *thd, Item *a): Item_func_int_val(thd, a) {}
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("ceiling") };
+ return name;
+ }
+ decimal_round_mode round_mode() const override { return CEILING; }
+ longlong int_op() override;
+ double real_op() override;
+ my_decimal *decimal_op(my_decimal *) override;
+ bool date_op(THD *thd, MYSQL_TIME *ltime, date_mode_t fuzzydate) override;
+ bool time_op(THD *thd, MYSQL_TIME *ltime) override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_ceiling>(thd, this); }
+};
+
+
+class Item_func_floor :public Item_func_int_val
+{
+public:
+ Item_func_floor(THD *thd, Item *a): Item_func_int_val(thd, a) {}
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("floor") };
+ return name;
+ }
+ decimal_round_mode round_mode() const override { return FLOOR; }
+ longlong int_op() override;
+ double real_op() override;
+ my_decimal *decimal_op(my_decimal *) override;
+ bool date_op(THD *thd, MYSQL_TIME *ltime, date_mode_t fuzzydate) override;
+ bool time_op(THD *thd, MYSQL_TIME *ltime) override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_floor>(thd, this); }
+};
+
+/* This handles round and truncate */
+
+class Item_func_round :public Item_func_hybrid_field_type
+{
+ bool truncate;
+ void fix_length_and_dec_decimal(uint decimals_to_set);
+ void fix_length_and_dec_double(uint decimals_to_set);
+ bool test_if_length_can_increase();
+public:
+ Item_func_round(THD *thd, Item *a, Item *b, bool trunc_arg)
+ :Item_func_hybrid_field_type(thd, a, b), truncate(trunc_arg) {}
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING truncate_name= {STRING_WITH_LEN("truncate") };
+ static LEX_CSTRING round_name= {STRING_WITH_LEN("round") };
+ return truncate ? truncate_name : round_name;
+ }
+ double real_op() override;
+ longlong int_op() override;
+ my_decimal *decimal_op(my_decimal *) override;
+ bool date_op(THD *thd, MYSQL_TIME *ltime, date_mode_t fuzzydate) override;
+ bool time_op(THD *thd, MYSQL_TIME *ltime) override;
+ bool native_op(THD *thd, Native *to) override;
+ String *str_op(String *str) override
+ {
+ DBUG_ASSERT(0);
+ return NULL;
+ }
+ void fix_arg_decimal();
+ void fix_arg_int(const Type_handler *preferred,
+ const Type_std_attributes *preferred_attributes,
+ bool use_decimal_on_length_increase);
+ void fix_arg_hex_hybrid();
+ void fix_arg_double();
+ void fix_arg_time();
+ void fix_arg_datetime();
+ void fix_arg_temporal(const Type_handler *h, uint int_part_length);
+ bool fix_length_and_dec(THD *thd) override
+ {
+ /*
+ We don't want to translate ENUM/SET to CHAR here.
+ So let's real_type_handler(), not type_handler().
+ */
+ return args[0]->real_type_handler()->Item_func_round_fix_length_and_dec(this);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_round>(thd, this); }
+};
+
+
+class Item_func_rand :public Item_real_func
+{
+ struct my_rnd_struct *rand;
+ bool first_eval; // TRUE if val_real() is called 1st time
+ bool check_arguments() const override
+ { return check_argument_types_can_return_int(0, arg_count); }
+ void seed_random (Item * val);
+public:
+ Item_func_rand(THD *thd, Item *a):
+ Item_real_func(thd, a), rand(0), first_eval(TRUE) {}
+ Item_func_rand(THD *thd): Item_real_func(thd) {}
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("rand") };
+ return name;
+ }
+ bool const_item() const override { return 0; }
+ void update_used_tables() override;
+ bool fix_fields(THD *thd, Item **ref) override;
+ void cleanup() override { first_eval= TRUE; Item_real_func::cleanup(); }
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg, VCOL_SESSION_FUNC);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_rand>(thd, this); }
+};
+
+
+class Item_func_rownum final :public Item_longlong_func
+{
+ /*
+ This points to a variable that contains the number of rows
+ accpted so far in the result set
+ */
+ ha_rows *accepted_rows;
+ SELECT_LEX *select;
+public:
+ Item_func_rownum(THD *thd);
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("rownum") };
+ return name;
+ }
+ enum Functype functype() const override { return ROWNUM_FUNC; }
+ void update_used_tables() override {}
+ bool const_item() const override { return 0; }
+ void fix_after_optimize(THD *thd) override;
+ bool fix_length_and_dec(THD *thd) override
+ {
+ unsigned_flag= 1;
+ used_tables_cache= RAND_TABLE_BIT;
+ const_item_cache=0;
+ set_maybe_null();
+ return FALSE;
+ }
+ void cleanup() override
+ {
+ Item_longlong_func::cleanup();
+ /* Ensure we don't point to freed memory */
+ accepted_rows= 0;
+ }
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg,
+ VCOL_IMPOSSIBLE);
+ }
+ bool check_handler_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg,
+ VCOL_IMPOSSIBLE);
+ }
+ Item *get_copy(THD *thd) override { return 0; }
+ /* This function is used in insert, update and delete */
+ void store_pointer_to_row_counter(ha_rows *row_counter)
+ {
+ accepted_rows= row_counter;
+ }
+};
+
+void fix_rownum_pointers(THD *thd, SELECT_LEX *select_lex, ha_rows *ptr);
+
+
+class Item_func_sign :public Item_long_func
+{
+ bool check_arguments() const override
+ { return args[0]->check_type_can_return_real(func_name_cstring()); }
+public:
+ Item_func_sign(THD *thd, Item *a): Item_long_func(thd, a) {}
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("sign") };
+ return name;
+ }
+ decimal_digits_t decimal_precision() const override { return 1; }
+ bool fix_length_and_dec(THD *thd) override { fix_char_length(2); return FALSE; }
+ longlong val_int() override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_sign>(thd, this); }
+};
+
+
+class Item_func_units :public Item_real_func
+{
+ LEX_CSTRING name;
+ double mul,add;
+ bool check_arguments() const override
+ { return check_argument_types_can_return_real(0, arg_count); }
+public:
+ Item_func_units(THD *thd, char *name_arg, Item *a, double mul_arg,
+ double add_arg):
+ Item_real_func(thd, a), mul(mul_arg), add(add_arg)
+ {
+ name.str= name_arg;
+ name.length= strlen(name_arg);
+ }
+ double val_real() override;
+ LEX_CSTRING func_name_cstring() const override { return name; }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ decimals= NOT_FIXED_DEC;
+ max_length= float_length(decimals);
+ return FALSE;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_units>(thd, this); }
+};
+
+
+/**
+ Item_func_min_max does not derive from Item_func_hybrid_field_type
+ because the way how its methods val_xxx() and get_date() work depend
+ not only by its arguments, but also on the context in which
+ LEAST() and GREATEST() appear.
+ For example, using Item_func_min_max in a CAST like this:
+ CAST(LEAST('11','2') AS SIGNED)
+ forces Item_func_min_max to compare the arguments as numbers rather
+ than strings.
+ Perhaps this should be changed eventually (see MDEV-5893).
+*/
+class Item_func_min_max :public Item_hybrid_func
+{
+ String tmp_value;
+ int cmp_sign;
+protected:
+ bool check_arguments() const override
+ {
+ return false; // Checked by aggregate_for_min_max()
+ }
+ bool fix_attributes(Item **item, uint nitems);
+public:
+ Item_func_min_max(THD *thd, List<Item> &list, int cmp_sign_arg):
+ Item_hybrid_func(thd, list), cmp_sign(cmp_sign_arg)
+ {}
+ String *val_str_native(String *str);
+ double val_real_native();
+ longlong val_int_native();
+ my_decimal *val_decimal_native(my_decimal *);
+ bool get_date_native(THD *thd, MYSQL_TIME *res, date_mode_t fuzzydate);
+ bool get_time_native(THD *thd, MYSQL_TIME *res);
+
+ double val_real() override
+ {
+ DBUG_ASSERT(fixed());
+ return Item_func_min_max::type_handler()->
+ Item_func_min_max_val_real(this);
+ }
+ longlong val_int() override
+ {
+ DBUG_ASSERT(fixed());
+ return Item_func_min_max::type_handler()->
+ Item_func_min_max_val_int(this);
+ }
+ String *val_str(String *str) override
+ {
+ DBUG_ASSERT(fixed());
+ return Item_func_min_max::type_handler()->
+ Item_func_min_max_val_str(this, str);
+ }
+ my_decimal *val_decimal(my_decimal *dec) override
+ {
+ DBUG_ASSERT(fixed());
+ return Item_func_min_max::type_handler()->
+ Item_func_min_max_val_decimal(this, dec);
+ }
+ bool get_date(THD *thd, MYSQL_TIME *res, date_mode_t fuzzydate) override
+ {
+ DBUG_ASSERT(fixed());
+ return Item_func_min_max::type_handler()->
+ Item_func_min_max_get_date(thd, this, res, fuzzydate);
+ }
+ bool val_native(THD *thd, Native *to) override;
+ void aggregate_attributes_real(Item **items, uint nitems)
+ {
+ /*
+ Aggregating attributes for the double data type for LEAST/GREATEST
+ is almost the same with aggregating for CASE-alike hybrid functions,
+ (CASE..THEN, COALESCE, IF, etc).
+ There is one notable difference though, when a numeric argument is mixed
+ with a string argument:
+ - CASE-alike functions return a string data type in such cases
+ COALESCE(10,'x') -> VARCHAR(2) = '10'
+ - LEAST/GREATEST returns double:
+ GREATEST(10,'10e4') -> DOUBLE = 100000
+ As the string argument can represent a number in the scientific notation,
+ like in the example above, max_length of the result can be longer than
+ max_length of the arguments. To handle this properly, max_length is
+ additionally assigned to the result of float_length(decimals).
+ */
+ Item_func::aggregate_attributes_real(items, nitems);
+ max_length= float_length(decimals);
+ }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ if (aggregate_for_min_max(func_name_cstring(), args, arg_count))
+ return true;
+ fix_attributes(args, arg_count);
+ return false;
+ }
+};
+
+class Item_func_min :public Item_func_min_max
+{
+public:
+ Item_func_min(THD *thd, List<Item> &list): Item_func_min_max(thd, list, 1) {}
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("least") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_min>(thd, this); }
+};
+
+class Item_func_max :public Item_func_min_max
+{
+public:
+ Item_func_max(THD *thd, List<Item> &list): Item_func_min_max(thd, list, -1) {}
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("greatest") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_max>(thd, this); }
+};
+
+
+/*
+ Objects of this class are used for ROLLUP queries to wrap up
+ each constant item referred to in GROUP BY list.
+*/
+
+class Item_func_rollup_const :public Item_func
+{
+public:
+ Item_func_rollup_const(THD *thd, Item *a): Item_func(thd, a)
+ {
+ name= a->name;
+ }
+ double val_real() override { return val_real_from_item(args[0]); }
+ longlong val_int() override { return val_int_from_item(args[0]); }
+ String *val_str(String *str) override
+ { return val_str_from_item(args[0], str); }
+ bool val_native(THD *thd, Native *to) override
+ { return val_native_from_item(thd, args[0], to); }
+ my_decimal *val_decimal(my_decimal *dec) override
+ { return val_decimal_from_item(args[0], dec); }
+ bool get_date(THD *thd, MYSQL_TIME *ltime, date_mode_t fuzzydate) override
+ { return get_date_from_item(thd, args[0], ltime, fuzzydate); }
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("rollup_const") };
+ return name;
+ }
+ bool const_item() const override { return 0; }
+ const Type_handler *type_handler() const override
+ { return args[0]->type_handler(); }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ Type_std_attributes::set(*args[0]);
+ return FALSE;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_rollup_const>(thd, this); }
+};
+
+
+class Item_long_func_length: public Item_long_func
+{
+ bool check_arguments() const override
+ { return args[0]->check_type_can_return_str(func_name_cstring()); }
+public:
+ Item_long_func_length(THD *thd, Item *a): Item_long_func(thd, a) {}
+ bool fix_length_and_dec(THD *thd) override { max_length=10; return FALSE; }
+};
+
+
+class Item_func_octet_length :public Item_long_func_length
+{
+ String value;
+public:
+ Item_func_octet_length(THD *thd, Item *a): Item_long_func_length(thd, a) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("octet_length") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_octet_length>(thd, this); }
+};
+
+class Item_func_bit_length :public Item_longlong_func
+{
+ String value;
+public:
+ Item_func_bit_length(THD *thd, Item *a): Item_longlong_func(thd, a) {}
+ bool fix_length_and_dec(THD *thd) override
+ {
+ max_length= 11; // 0x100000000*8 = 34,359,738,368
+ return FALSE;
+ }
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("bit_length") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_bit_length>(thd, this); }
+};
+
+class Item_func_char_length :public Item_long_func_length
+{
+ String value;
+public:
+ Item_func_char_length(THD *thd, Item *a): Item_long_func_length(thd, a) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("char_length") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_char_length>(thd, this); }
+};
+
+class Item_func_coercibility :public Item_long_func
+{
+ bool check_arguments() const override
+ { return args[0]->check_type_can_return_str(func_name_cstring()); }
+public:
+ Item_func_coercibility(THD *thd, Item *a): Item_long_func(thd, a) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("coercibility") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ max_length=10;
+ base_flags&= ~item_base_t::MAYBE_NULL;
+ return FALSE;
+ }
+ bool eval_not_null_tables(void *) override
+ {
+ not_null_tables_cache= 0;
+ return false;
+ }
+ bool find_not_null_fields(table_map allowed) override
+ {
+ return false;
+ }
+ Item* propagate_equal_fields(THD *thd, const Context &ctx, COND_EQUAL *cond)
+ override
+ { return this; }
+ bool const_item() const override { return true; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_coercibility>(thd, this); }
+};
+
+
+/*
+ In the corner case LOCATE could return (4,294,967,296 + 1),
+ which would not fit into Item_long_func range.
+ But string lengths are limited with max_allowed_packet,
+ which cannot be bigger than 1024*1024*1024.
+*/
+class Item_func_locate :public Item_long_func
+{
+ bool check_arguments() const override
+ {
+ return check_argument_types_can_return_str(0, 2) ||
+ (arg_count > 2 && args[2]->check_type_can_return_int(func_name_cstring()));
+ }
+ String value1,value2;
+ DTCollation cmp_collation;
+public:
+ Item_func_locate(THD *thd, Item *a, Item *b)
+ :Item_long_func(thd, a, b) {}
+ Item_func_locate(THD *thd, Item *a, Item *b, Item *c)
+ :Item_long_func(thd, a, b, c) {}
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("locate") };
+ return name;
+ }
+ longlong val_int() override;
+ bool fix_length_and_dec(THD *thd) override
+ {
+ max_length= MY_INT32_NUM_DECIMAL_DIGITS;
+ return agg_arg_charsets_for_comparison(cmp_collation, args, 2);
+ }
+ void print(String *str, enum_query_type query_type) override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_locate>(thd, this); }
+};
+
+
+class Item_func_field :public Item_long_func
+{
+ String value,tmp;
+ Item_result cmp_type;
+ DTCollation cmp_collation;
+public:
+ Item_func_field(THD *thd, List<Item> &list): Item_long_func(thd, list) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("field") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_field>(thd, this); }
+};
+
+
+class Item_func_ascii :public Item_long_func
+{
+ bool check_arguments() const override
+ { return check_argument_types_can_return_str(0, arg_count); }
+ String value;
+public:
+ Item_func_ascii(THD *thd, Item *a): Item_long_func(thd, a) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("ascii") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override { max_length=3; return FALSE; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_ascii>(thd, this); }
+};
+
+class Item_func_ord :public Item_long_func
+{
+ bool check_arguments() const override
+ { return args[0]->check_type_can_return_str(func_name_cstring()); }
+ String value;
+public:
+ Item_func_ord(THD *thd, Item *a): Item_long_func(thd, a) {}
+ bool fix_length_and_dec(THD *thd) override { fix_char_length(7); return FALSE; }
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("ord") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_ord>(thd, this); }
+};
+
+class Item_func_find_in_set :public Item_long_func
+{
+ bool check_arguments() const override
+ { return check_argument_types_can_return_str(0, 2); }
+ String value,value2;
+ uint enum_value;
+ ulonglong enum_bit;
+ DTCollation cmp_collation;
+public:
+ Item_func_find_in_set(THD *thd, Item *a, Item *b):
+ Item_long_func(thd, a, b), enum_value(0) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("find_in_set") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_find_in_set>(thd, this); }
+};
+
+/* Base class for all bit functions: '~', '|', '^', '&', '>>', '<<' */
+
+class Item_func_bit_operator: public Item_handled_func
+{
+ bool check_arguments() const override
+ { return check_argument_types_can_return_int(0, arg_count); }
+protected:
+ bool fix_length_and_dec_op1_std(const Handler *ha_int, const Handler *ha_dec)
+ {
+ set_func_handler(args[0]->cmp_type() == INT_RESULT ? ha_int : ha_dec);
+ return m_func_handler->fix_length_and_dec(this);
+ }
+ bool fix_length_and_dec_op2_std(const Handler *ha_int, const Handler *ha_dec)
+ {
+ set_func_handler(args[0]->cmp_type() == INT_RESULT &&
+ args[1]->cmp_type() == INT_RESULT ? ha_int : ha_dec);
+ return m_func_handler->fix_length_and_dec(this);
+ }
+public:
+ Item_func_bit_operator(THD *thd, Item *a)
+ :Item_handled_func(thd, a) {}
+ Item_func_bit_operator(THD *thd, Item *a, Item *b)
+ :Item_handled_func(thd, a, b) {}
+ void print(String *str, enum_query_type query_type) override
+ {
+ print_op(str, query_type);
+ }
+ bool need_parentheses_in_default() override { return true; }
+};
+
+class Item_func_bit_or :public Item_func_bit_operator
+{
+public:
+ Item_func_bit_or(THD *thd, Item *a, Item *b)
+ :Item_func_bit_operator(thd, a, b) {}
+ bool fix_length_and_dec(THD *thd) override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("|") };
+ return name;
+ }
+ enum precedence precedence() const override { return BITOR_PRECEDENCE; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_bit_or>(thd, this); }
+};
+
+class Item_func_bit_and :public Item_func_bit_operator
+{
+public:
+ Item_func_bit_and(THD *thd, Item *a, Item *b)
+ :Item_func_bit_operator(thd, a, b) {}
+ bool fix_length_and_dec(THD *thd) override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("&") };
+ return name;
+ }
+ enum precedence precedence() const override { return BITAND_PRECEDENCE; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_bit_and>(thd, this); }
+};
+
+class Item_func_bit_count :public Item_handled_func
+{
+ bool check_arguments() const override
+ { return args[0]->check_type_can_return_int(func_name_cstring()); }
+public:
+ Item_func_bit_count(THD *thd, Item *a): Item_handled_func(thd, a) {}
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("bit_count") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_bit_count>(thd, this); }
+};
+
+class Item_func_shift_left :public Item_func_bit_operator
+{
+public:
+ Item_func_shift_left(THD *thd, Item *a, Item *b)
+ :Item_func_bit_operator(thd, a, b) {}
+ bool fix_length_and_dec(THD *thd) override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("<<") };
+ return name;
+ }
+ enum precedence precedence() const override { return SHIFT_PRECEDENCE; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_shift_left>(thd, this); }
+};
+
+class Item_func_shift_right :public Item_func_bit_operator
+{
+public:
+ Item_func_shift_right(THD *thd, Item *a, Item *b)
+ :Item_func_bit_operator(thd, a, b) {}
+ bool fix_length_and_dec(THD *thd) override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN(">>") };
+ return name;
+ }
+ enum precedence precedence() const override { return SHIFT_PRECEDENCE; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_shift_right>(thd, this); }
+};
+
+class Item_func_bit_neg :public Item_func_bit_operator
+{
+public:
+ Item_func_bit_neg(THD *thd, Item *a): Item_func_bit_operator(thd, a) {}
+ bool fix_length_and_dec(THD *thd) override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("~") };
+ return name;
+ }
+ enum precedence precedence() const override { return NEG_PRECEDENCE; }
+ void print(String *str, enum_query_type query_type) override
+ {
+ str->append(func_name_cstring());
+ args[0]->print_parenthesised(str, query_type, precedence());
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_bit_neg>(thd, this); }
+};
+
+
+class Item_func_last_insert_id :public Item_longlong_func
+{
+ bool check_arguments() const override
+ { return check_argument_types_can_return_int(0, arg_count); }
+public:
+ Item_func_last_insert_id(THD *thd): Item_longlong_func(thd) {}
+ Item_func_last_insert_id(THD *thd, Item *a): Item_longlong_func(thd, a) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("last_insert_id") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ unsigned_flag= true;
+ if (arg_count)
+ max_length= args[0]->max_length;
+ return FALSE;
+ }
+ bool fix_fields(THD *thd, Item **ref) override;
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg, VCOL_IMPOSSIBLE);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_last_insert_id>(thd, this); }
+};
+
+
+class Item_func_benchmark :public Item_long_func
+{
+ bool check_arguments() const override
+ {
+ return args[0]->check_type_can_return_int(func_name_cstring()) ||
+ args[1]->check_type_scalar(func_name_cstring());
+ }
+public:
+ Item_func_benchmark(THD *thd, Item *count_expr, Item *expr):
+ Item_long_func(thd, count_expr, expr)
+ {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("benchmark") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ max_length=1;
+ base_flags&= ~item_base_t::MAYBE_NULL;
+ return FALSE;
+ }
+ void print(String *str, enum_query_type query_type) override;
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg, VCOL_IMPOSSIBLE);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_benchmark>(thd, this); }
+};
+
+
+void item_func_sleep_init(void);
+void item_func_sleep_free(void);
+
+class Item_func_sleep :public Item_long_func
+{
+ bool check_arguments() const override
+ { return args[0]->check_type_can_return_real(func_name_cstring()); }
+public:
+ Item_func_sleep(THD *thd, Item *a): Item_long_func(thd, a) {}
+ bool fix_length_and_dec(THD *thd) override { fix_char_length(1); return FALSE; }
+ bool const_item() const override { return 0; }
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("sleep") };
+ return name;
+ }
+ table_map used_tables() const override
+ {
+ return used_tables_cache | RAND_TABLE_BIT;
+ }
+ bool is_expensive() override { return 1; }
+ longlong val_int() override;
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg, VCOL_IMPOSSIBLE);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_sleep>(thd, this); }
+};
+
+
+
+#ifdef HAVE_DLOPEN
+
+class Item_udf_func :public Item_func
+{
+ /**
+ Mark "this" as non-deterministic if it uses no tables
+ and is not a constant at the same time.
+ */
+ void set_non_deterministic_if_needed()
+ {
+ if (!const_item_cache && !used_tables_cache)
+ used_tables_cache= RAND_TABLE_BIT;
+ }
+protected:
+ udf_handler udf;
+ bool is_expensive_processor(void *arg) override { return TRUE; }
+
+ class VDec_udf: public Dec_ptr_and_buffer
+ {
+ public:
+ VDec_udf(Item_udf_func *func, udf_handler *udf)
+ {
+ my_bool tmp_null_value;
+ m_ptr= udf->val_decimal(&tmp_null_value, &m_buffer);
+ DBUG_ASSERT(is_null() == (tmp_null_value != 0));
+ func->null_value= is_null();
+ }
+ };
+
+public:
+ Item_udf_func(THD *thd, udf_func *udf_arg):
+ Item_func(thd), udf(udf_arg) {}
+ Item_udf_func(THD *thd, udf_func *udf_arg, List<Item> &list):
+ Item_func(thd, list), udf(udf_arg) {}
+ LEX_CSTRING func_name_cstring() const override
+ {
+ const char *tmp= udf.name();
+ return { tmp, strlen(tmp) };
+ }
+ enum Functype functype() const override { return UDF_FUNC; }
+ bool fix_fields(THD *thd, Item **ref) override
+ {
+ DBUG_ASSERT(fixed() == 0);
+ bool res= udf.fix_fields(thd, this, arg_count, args);
+ set_non_deterministic_if_needed();
+ base_flags|= item_base_t::FIXED;
+ return res;
+ }
+ void fix_num_length_and_dec();
+ void update_used_tables() override
+ {
+ /*
+ TODO: Make a member in UDF_INIT and return if a UDF is deterministic or
+ not.
+ Currently UDF_INIT has a member (const_item) that is an in/out
+ parameter to the init() call.
+ The code in udf_handler::fix_fields also duplicates the arguments
+ handling code in Item_func::fix_fields().
+
+ The lack of information if a UDF is deterministic makes writing
+ a correct update_used_tables() for UDFs impossible.
+ One solution to this would be :
+ - Add a is_deterministic member of UDF_INIT
+ - (optionally) deprecate the const_item member of UDF_INIT
+ - Take away the duplicate code from udf_handler::fix_fields() and
+ make Item_udf_func call Item_func::fix_fields() to process its
+ arguments as for any other function.
+ - Store the deterministic flag returned by <udf>_init into the
+ udf_handler.
+ - Don't implement Item_udf_func::fix_fields, implement
+ Item_udf_func::fix_length_and_dec() instead (similar to non-UDF
+ functions).
+ - Override Item_func::update_used_tables to call
+ Item_func::update_used_tables() and add a RAND_TABLE_BIT to the
+ result of Item_func::update_used_tables() if the UDF is
+ non-deterministic.
+ - (optionally) rename RAND_TABLE_BIT to NONDETERMINISTIC_BIT to
+ better describe its usage.
+
+ The above would require a change of the UDF API.
+ Until that change is done here's how the current code works:
+ We call Item_func::update_used_tables() only when we know that
+ the function depends on real non-const tables and is deterministic.
+ This can be done only because we know that the optimizer will
+ call update_used_tables() only when there's possibly a new const
+ table. So update_used_tables() can only make a Item_func more
+ constant than it is currently.
+ That's why we don't need to do anything if a function is guaranteed
+ to return non-constant (it's non-deterministic) or is already a
+ const.
+ */
+ if ((used_tables_cache & ~PSEUDO_TABLE_BITS) &&
+ !(used_tables_cache & RAND_TABLE_BIT))
+ {
+ Item_func::update_used_tables();
+ set_non_deterministic_if_needed();
+ }
+ }
+ void cleanup() override;
+ bool eval_not_null_tables(void *opt_arg) override
+ {
+ not_null_tables_cache= 0;
+ return 0;
+ }
+ bool find_not_null_fields(table_map allowed) override
+ {
+ return false;
+ }
+ bool is_expensive() override { return 1; }
+ void print(String *str, enum_query_type query_type) override;
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg,
+ VCOL_NON_DETERMINISTIC);
+ }
+ bool get_date(THD *thd, MYSQL_TIME *ltime, date_mode_t fuzzydate) override
+ {
+ return type_handler()->Item_get_date_with_warn(thd, this, ltime, fuzzydate);
+ }
+ bool excl_dep_on_grouping_fields(st_select_lex *sel) override
+ { return false; }
+};
+
+
+class Item_func_udf_float :public Item_udf_func
+{
+ public:
+ Item_func_udf_float(THD *thd, udf_func *udf_arg):
+ Item_udf_func(thd, udf_arg) {}
+ Item_func_udf_float(THD *thd, udf_func *udf_arg,
+ List<Item> &list):
+ Item_udf_func(thd, udf_arg, list) {}
+ longlong val_int() override
+ {
+ DBUG_ASSERT(fixed());
+ return Converter_double_to_longlong(Item_func_udf_float::val_real(),
+ unsigned_flag).result();
+ }
+ my_decimal *val_decimal(my_decimal *dec_buf) override
+ {
+ double res=val_real();
+ if (null_value)
+ return NULL;
+ double2my_decimal(E_DEC_FATAL_ERROR, res, dec_buf);
+ return dec_buf;
+ }
+ double val_real() override;
+ String *val_str(String *str) override;
+ const Type_handler *type_handler() const override
+ { return &type_handler_double; }
+ bool fix_length_and_dec(THD *thd) override { fix_num_length_and_dec(); return FALSE; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_udf_float>(thd, this); }
+};
+
+
+class Item_func_udf_int :public Item_udf_func
+{
+public:
+ Item_func_udf_int(THD *thd, udf_func *udf_arg):
+ Item_udf_func(thd, udf_arg) {}
+ Item_func_udf_int(THD *thd, udf_func *udf_arg,
+ List<Item> &list):
+ Item_udf_func(thd, udf_arg, list) {}
+ longlong val_int() override;
+ double val_real() override { return (double) Item_func_udf_int::val_int(); }
+ my_decimal *val_decimal(my_decimal *decimal_value) override
+ {
+ return val_decimal_from_int(decimal_value);
+ }
+ String *val_str(String *str) override;
+ const Type_handler *type_handler() const override
+ {
+ if (unsigned_flag)
+ return &type_handler_ulonglong;
+ return &type_handler_slonglong;
+ }
+ bool fix_length_and_dec(THD *thd) override { decimals= 0; max_length= 21; return FALSE; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_udf_int>(thd, this); }
+};
+
+
+class Item_func_udf_decimal :public Item_udf_func
+{
+public:
+ Item_func_udf_decimal(THD *thd, udf_func *udf_arg):
+ Item_udf_func(thd, udf_arg) {}
+ Item_func_udf_decimal(THD *thd, udf_func *udf_arg, List<Item> &list):
+ Item_udf_func(thd, udf_arg, list) {}
+ longlong val_int() override
+ {
+ return VDec_udf(this, &udf).to_longlong(unsigned_flag);
+ }
+ double val_real() override
+ {
+ return VDec_udf(this, &udf).to_double();
+ }
+ my_decimal *val_decimal(my_decimal *) override;
+ String *val_str(String *str) override
+ {
+ return VDec_udf(this, &udf).to_string_round(str, decimals);
+ }
+ const Type_handler *type_handler() const override
+ { return &type_handler_newdecimal; }
+ bool fix_length_and_dec(THD *thd) override { fix_num_length_and_dec(); return FALSE; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_udf_decimal>(thd, this); }
+};
+
+
+class Item_func_udf_str :public Item_udf_func
+{
+public:
+ Item_func_udf_str(THD *thd, udf_func *udf_arg):
+ Item_udf_func(thd, udf_arg) {}
+ Item_func_udf_str(THD *thd, udf_func *udf_arg, List<Item> &list):
+ Item_udf_func(thd, udf_arg, list) {}
+ String *val_str(String *) override;
+ double val_real() override
+ {
+ int err_not_used;
+ char *end_not_used;
+ String *res;
+ res= val_str(&str_value);
+ return res ? res->charset()->strntod((char*) res->ptr(), res->length(),
+ &end_not_used, &err_not_used) : 0.0;
+ }
+ longlong val_int() override
+ {
+ int err_not_used;
+ String *res; res=val_str(&str_value);
+ return res ? res->charset()->strntoll(res->ptr(),res->length(),10,
+ (char**) 0, &err_not_used) : (longlong) 0;
+ }
+ my_decimal *val_decimal(my_decimal *dec_buf) override
+ {
+ String *res=val_str(&str_value);
+ if (!res)
+ return NULL;
+ string2my_decimal(E_DEC_FATAL_ERROR, res, dec_buf);
+ return dec_buf;
+ }
+ const Type_handler *type_handler() const override
+ { return string_type_handler(); }
+ bool fix_length_and_dec(THD *thd) override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_udf_str>(thd, this); }
+};
+
+#else /* Dummy functions to get yy_*.cc files compiled */
+
+class Item_func_udf_float :public Item_real_func
+{
+ public:
+ Item_func_udf_float(THD *thd, udf_func *udf_arg):
+ Item_real_func(thd) {}
+ Item_func_udf_float(THD *thd, udf_func *udf_arg, List<Item> &list):
+ Item_real_func(thd, list) {}
+ double val_real() { DBUG_ASSERT(fixed()); return 0.0; }
+};
+
+
+class Item_func_udf_int :public Item_int_func
+{
+public:
+ Item_func_udf_int(THD *thd, udf_func *udf_arg):
+ Item_int_func(thd) {}
+ Item_func_udf_int(THD *thd, udf_func *udf_arg, List<Item> &list):
+ Item_int_func(thd, list) {}
+ const Type_handler *type_handler() const override
+ { return &type_handler_slonglong; }
+ longlong val_int() { DBUG_ASSERT(fixed()); return 0; }
+};
+
+
+class Item_func_udf_decimal :public Item_int_func
+{
+public:
+ Item_func_udf_decimal(THD *thd, udf_func *udf_arg):
+ Item_int_func(thd) {}
+ Item_func_udf_decimal(THD *thd, udf_func *udf_arg, List<Item> &list):
+ Item_int_func(thd, list) {}
+ const Type_handler *type_handler() const override
+ { return &type_handler_slonglong; }
+ my_decimal *val_decimal(my_decimal *) { DBUG_ASSERT(fixed()); return 0; }
+};
+
+
+class Item_func_udf_str :public Item_func
+{
+public:
+ Item_func_udf_str(THD *thd, udf_func *udf_arg):
+ Item_func(thd) {}
+ Item_func_udf_str(THD *thd, udf_func *udf_arg, List<Item> &list):
+ Item_func(thd, list) {}
+ String *val_str(String *)
+ { DBUG_ASSERT(fixed()); null_value=1; return 0; }
+ double val_real() { DBUG_ASSERT(fixed()); null_value= 1; return 0.0; }
+ longlong val_int() { DBUG_ASSERT(fixed()); null_value=1; return 0; }
+ bool fix_length_and_dec(THD *thd) override
+ { base_flags|= item_base_t::MAYBE_NULL; max_length=0; return FALSE; }
+};
+
+#endif /* HAVE_DLOPEN */
+
+void mysql_ull_cleanup(THD *thd);
+void mysql_ull_set_explicit_lock_duration(THD *thd);
+
+
+class Item_func_lock :public Item_long_func
+{
+ public:
+ Item_func_lock(THD *thd): Item_long_func(thd) { }
+ Item_func_lock(THD *thd, Item *a): Item_long_func(thd, a) {}
+ Item_func_lock(THD *thd, Item *a, Item *b): Item_long_func(thd, a, b) {}
+ table_map used_tables() const override
+ {
+ return used_tables_cache | RAND_TABLE_BIT;
+ }
+ bool const_item() const override { return 0; }
+ bool is_expensive() override { return 1; }
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg, VCOL_IMPOSSIBLE);
+ }
+};
+
+
+class Item_func_get_lock final :public Item_func_lock
+{
+ bool check_arguments() const override
+ {
+ return args[0]->check_type_general_purpose_string(func_name_cstring()) ||
+ args[1]->check_type_can_return_real(func_name_cstring());
+ }
+ String value;
+ public:
+ Item_func_get_lock(THD *thd, Item *a, Item *b) :Item_func_lock(thd, a, b) {}
+ longlong val_int() final;
+ LEX_CSTRING func_name_cstring() const override final
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("get_lock") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ max_length= 1;
+ set_maybe_null();
+ return FALSE;
+ }
+ Item *get_copy(THD *thd) final
+ { return get_item_copy<Item_func_get_lock>(thd, this); }
+};
+
+
+class Item_func_release_all_locks final :public Item_func_lock
+{
+public:
+ Item_func_release_all_locks(THD *thd): Item_func_lock(thd)
+ { unsigned_flag= 1; }
+ longlong val_int() final;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("release_all_locks") };
+ return name;
+ }
+ Item *get_copy(THD *thd) final
+ { return get_item_copy<Item_func_release_all_locks>(thd, this); }
+};
+
+
+class Item_func_release_lock final :public Item_func_lock
+{
+ bool check_arguments() const override
+ { return args[0]->check_type_general_purpose_string(func_name_cstring()); }
+ String value;
+public:
+ Item_func_release_lock(THD *thd, Item *a): Item_func_lock(thd, a) {}
+ longlong val_int() final;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("release_lock") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ max_length= 1;
+ set_maybe_null();
+ return FALSE;
+ }
+ Item *get_copy(THD *thd) final
+ { return get_item_copy<Item_func_release_lock>(thd, this); }
+};
+
+
+/* replication functions */
+
+class Item_master_pos_wait :public Item_longlong_func
+{
+ bool check_arguments() const override
+ {
+ return
+ args[0]->check_type_general_purpose_string(func_name_cstring()) ||
+ args[1]->check_type_can_return_int(func_name_cstring()) ||
+ (arg_count > 2 && args[2]->check_type_can_return_int(func_name_cstring())) ||
+ (arg_count > 3 && args[3]->check_type_general_purpose_string(func_name_cstring()));
+ }
+ String value;
+public:
+ Item_master_pos_wait(THD *thd, Item *a, Item *b)
+ :Item_longlong_func(thd, a, b) {}
+ Item_master_pos_wait(THD *thd, Item *a, Item *b, Item *c):
+ Item_longlong_func(thd, a, b, c) {}
+ Item_master_pos_wait(THD *thd, Item *a, Item *b, Item *c, Item *d):
+ Item_longlong_func(thd, a, b, c, d) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("master_pos_wait") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ max_length=21;
+ set_maybe_null();
+ return FALSE;
+ }
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg, VCOL_IMPOSSIBLE);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_master_pos_wait>(thd, this); }
+};
+
+
+class Item_master_gtid_wait :public Item_long_func
+{
+ bool check_arguments() const override
+ {
+ return args[0]->check_type_general_purpose_string(func_name_cstring()) ||
+ (arg_count > 1 && args[1]->check_type_can_return_real(func_name_cstring()));
+ }
+ String value;
+public:
+ Item_master_gtid_wait(THD *thd, Item *a)
+ :Item_long_func(thd, a) {}
+ Item_master_gtid_wait(THD *thd, Item *a, Item *b)
+ :Item_long_func(thd, a, b) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("master_gtid_wait") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override { max_length=2; return FALSE; }
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg, VCOL_IMPOSSIBLE);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_master_gtid_wait>(thd, this); }
+};
+
+
+/* Handling of user definable variables */
+
+class user_var_entry;
+
+
+/**
+ A class to set and get user variables
+*/
+class Item_func_user_var :public Item_hybrid_func
+{
+protected:
+ user_var_entry *m_var_entry;
+public:
+ LEX_CSTRING name; // keep it public
+ Item_func_user_var(THD *thd, const LEX_CSTRING *a)
+ :Item_hybrid_func(thd), m_var_entry(NULL), name(*a) { }
+ Item_func_user_var(THD *thd, const LEX_CSTRING *a, Item *b)
+ :Item_hybrid_func(thd, b), m_var_entry(NULL), name(*a) { }
+ Item_func_user_var(THD *thd, Item_func_user_var *item)
+ :Item_hybrid_func(thd, item),
+ m_var_entry(item->m_var_entry), name(item->name) { }
+ Field *create_tmp_field_ex(MEM_ROOT *root, TABLE *table, Tmp_field_src *src,
+ const Tmp_field_param *param)
+ {
+ DBUG_ASSERT(fixed());
+ return create_tmp_field_ex_from_handler(root, table, src, param,
+ type_handler());
+ }
+ Field *create_field_for_create_select(MEM_ROOT *root, TABLE *table)
+ { return create_table_field_from_handler(root, table); }
+ bool check_vcol_func_processor(void *arg);
+ bool get_date(THD *thd, MYSQL_TIME *ltime, date_mode_t fuzzydate)
+ {
+ return type_handler()->Item_get_date_with_warn(thd, this, ltime, fuzzydate);
+ }
+};
+
+
+class Item_func_set_user_var :public Item_func_user_var
+{
+ /*
+ The entry_thread_id variable is used:
+ 1) to skip unnecessary updates of the entry field (see above);
+ 2) to reset the entry field that was initialized in the other thread
+ (for example, an item tree of a trigger that updates user variables
+ may be shared between several connections, and the entry_thread_id field
+ prevents updates of one connection user variables from a concurrent
+ connection calling the same trigger that initially updated some
+ user variable it the first connection context).
+ */
+ my_thread_id entry_thread_id;
+ String value;
+ my_decimal decimal_buff;
+ bool null_item;
+ union
+ {
+ longlong vint;
+ double vreal;
+ String *vstr;
+ my_decimal *vdec;
+ } save_result;
+
+public:
+ Item_func_set_user_var(THD *thd, const LEX_CSTRING *a, Item *b):
+ Item_func_user_var(thd, a, b),
+ entry_thread_id(0)
+ {}
+ Item_func_set_user_var(THD *thd, Item_func_set_user_var *item)
+ :Item_func_user_var(thd, item),
+ entry_thread_id(item->entry_thread_id),
+ value(item->value), decimal_buff(item->decimal_buff),
+ null_item(item->null_item), save_result(item->save_result)
+ {}
+
+ enum Functype functype() const override { return SUSERVAR_FUNC; }
+ double val_real() override;
+ longlong val_int() override;
+ String *val_str(String *str) override;
+ my_decimal *val_decimal(my_decimal *) override;
+ double val_result() override;
+ longlong val_int_result() override;
+ bool val_bool_result() override;
+ String *str_result(String *str) override;
+ my_decimal *val_decimal_result(my_decimal *) override;
+ bool is_null_result() override;
+ bool update_hash(void *ptr, size_t length, enum Item_result type,
+ CHARSET_INFO *cs, bool unsigned_arg);
+ bool send(Protocol *protocol, st_value *buffer) override;
+ void make_send_field(THD *thd, Send_field *tmp_field) override;
+ bool check(bool use_result_field);
+ void save_item_result(Item *item);
+ bool update();
+ bool fix_fields(THD *thd, Item **ref) override;
+ bool fix_length_and_dec(THD *thd) override;
+ void print(String *str, enum_query_type query_type) override;
+ enum precedence precedence() const override { return ASSIGN_PRECEDENCE; }
+ void print_as_stmt(String *str, enum_query_type query_type);
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("set_user_var") };
+ return name;
+ }
+ int save_in_field(Field *field, bool no_conversions,
+ bool can_use_result_field);
+ int save_in_field(Field *field, bool no_conversions) override
+ {
+ return save_in_field(field, no_conversions, 1);
+ }
+ void save_org_in_field(Field *field,
+ fast_field_copier data __attribute__ ((__unused__)))
+ override
+ { (void) save_in_field(field, 1, 0); }
+ bool register_field_in_read_map(void *arg) override;
+ bool register_field_in_bitmap(void *arg) override;
+ bool set_entry(THD *thd, bool create_if_not_exists);
+ void cleanup() override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_set_user_var>(thd, this); }
+ bool excl_dep_on_table(table_map tab_map) override { return false; }
+};
+
+
+class Item_func_get_user_var :public Item_func_user_var,
+ private Settable_routine_parameter
+{
+public:
+ Item_func_get_user_var(THD *thd, const LEX_CSTRING *a):
+ Item_func_user_var(thd, a) {}
+ enum Functype functype() const override { return GUSERVAR_FUNC; }
+ LEX_CSTRING get_name() { return name; }
+ double val_real() override;
+ longlong val_int() override;
+ my_decimal *val_decimal(my_decimal*) override;
+ String *val_str(String* str) override;
+ bool fix_length_and_dec(THD *thd) override;
+ void print(String *str, enum_query_type query_type) override;
+ /*
+ We must always return variables as strings to guard against selects of type
+ select @t1:=1,@t1,@t:="hello",@t from foo where (@t1:= t2.b)
+ */
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("get_user_var") };
+ return name;
+ }
+ bool const_item() const override;
+ table_map used_tables() const override
+ { return const_item() ? 0 : RAND_TABLE_BIT; }
+ bool eq(const Item *item, bool binary_cmp) const override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_get_user_var>(thd, this); }
+private:
+ bool set_value(THD *thd, sp_rcontext *ctx, Item **it) override;
+
+public:
+ Settable_routine_parameter *get_settable_routine_parameter() override
+ {
+ return this;
+ }
+};
+
+
+/*
+ This item represents user variable used as out parameter (e.g in LOAD DATA),
+ and it is supposed to be used only for this purprose. So it is simplified
+ a lot. Actually you should never obtain its value.
+
+ The only two reasons for this thing being an Item is possibility to store it
+ in List<Item> and desire to place this code somewhere near other functions
+ working with user variables.
+*/
+class Item_user_var_as_out_param :public Item_fixed_hybrid,
+ public Load_data_outvar
+{
+ LEX_CSTRING org_name;
+ user_var_entry *entry;
+public:
+ Item_user_var_as_out_param(THD *thd, const LEX_CSTRING *a)
+ :Item_fixed_hybrid(thd)
+ {
+ DBUG_ASSERT(a->length < UINT_MAX32);
+ org_name= *a;
+ set_name(thd, a->str, a->length, system_charset_info);
+ }
+ Load_data_outvar *get_load_data_outvar() override
+ {
+ return this;
+ }
+ bool load_data_set_null(THD *thd, const Load_data_param *param) override
+ {
+ set_null_value(param->charset());
+ return false;
+ }
+ bool load_data_set_no_data(THD *thd, const Load_data_param *param) override
+ {
+ set_null_value(param->charset());
+ return false;
+ }
+ bool load_data_set_value(THD *thd, const char *pos, uint length,
+ const Load_data_param *param) override
+ {
+ set_value(pos, length, param->charset());
+ return false;
+ }
+ void load_data_print_for_log_event(THD *thd, String *to) const override;
+ bool load_data_add_outvar(THD *thd, Load_data_param *param) const override
+ {
+ return param->add_outvar_user_var(thd);
+ }
+ uint load_data_fixed_length() const override
+ {
+ return 0;
+ }
+ Field *create_tmp_field_ex(MEM_ROOT *root, TABLE *table, Tmp_field_src *src,
+ const Tmp_field_param *param) override
+ {
+ DBUG_ASSERT(0);
+ return NULL;
+ }
+ /* We should return something different from FIELD_ITEM here */
+ enum Type type() const override { return CONST_ITEM;}
+ double val_real() override;
+ longlong val_int() override;
+ String *val_str(String *str) override;
+ bool get_date(THD *thd, MYSQL_TIME *ltime, date_mode_t fuzzydate) override;
+ my_decimal *val_decimal(my_decimal *decimal_buffer) override;
+ /* fix_fields() binds variable name with its entry structure */
+ bool fix_fields(THD *thd, Item **ref) override;
+ void set_null_value(CHARSET_INFO* cs);
+ void set_value(const char *str, uint length, CHARSET_INFO* cs);
+ const Type_handler *type_handler() const override
+ { return &type_handler_double; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_user_var_as_out_param>(thd, this); }
+};
+
+
+/* A system variable */
+
+#define GET_SYS_VAR_CACHE_LONG 1
+#define GET_SYS_VAR_CACHE_DOUBLE 2
+#define GET_SYS_VAR_CACHE_STRING 4
+
+class Item_func_get_system_var :public Item_func
+{
+ sys_var *var;
+ enum_var_type var_type, orig_var_type;
+ LEX_CSTRING component;
+ longlong cached_llval;
+ double cached_dval;
+ String cached_strval;
+ bool cached_null_value;
+ query_id_t used_query_id;
+ uchar cache_present;
+
+public:
+ Item_func_get_system_var(THD *thd, sys_var *var_arg,
+ enum_var_type var_type_arg,
+ LEX_CSTRING *component_arg, const char *name_arg,
+ size_t name_len_arg);
+ enum Functype functype() const override { return GSYSVAR_FUNC; }
+ void update_null_value() override;
+ bool fix_length_and_dec(THD *thd) override;
+ void print(String *str, enum_query_type query_type) override;
+ bool const_item() const override { return true; }
+ table_map used_tables() const override { return 0; }
+ const Type_handler *type_handler() const override;
+ double val_real() override;
+ longlong val_int() override;
+ String* val_str(String*) override;
+ my_decimal *val_decimal(my_decimal *dec_buf) override
+ { return val_decimal_from_real(dec_buf); }
+ bool get_date(THD *thd, MYSQL_TIME *ltime, date_mode_t fuzzydate) override
+ {
+ return type_handler()->Item_get_date_with_warn(thd, this, ltime, fuzzydate);
+ }
+ /* TODO: fix to support views */
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("get_system_var") };
+ return name;
+ }
+ /**
+ Indicates whether this system variable is written to the binlog or not.
+
+ Variables are written to the binlog as part of "status_vars" in
+ Query_log_event, as an Intvar_log_event, or a Rand_log_event.
+
+ @return true if the variable is written to the binlog, false otherwise.
+ */
+ bool is_written_to_binlog();
+ bool eq(const Item *item, bool binary_cmp) const override;
+
+ void cleanup() override;
+ bool check_vcol_func_processor(void *arg) override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_get_system_var>(thd, this); }
+};
+
+
+/* for fulltext search */
+
+class Item_func_match :public Item_real_func
+{
+public:
+ uint key, match_flags;
+ bool join_key;
+ DTCollation cmp_collation;
+ FT_INFO *ft_handler;
+ TABLE *table;
+ Item_func_match *master; // for master-slave optimization
+ Item *concat_ws; // Item_func_concat_ws
+ String value; // value of concat_ws
+ String search_value; // key_item()'s value converted to cmp_collation
+
+ Item_func_match(THD *thd, List<Item> &a, uint b):
+ Item_real_func(thd, a), key(0), match_flags(b), join_key(0), ft_handler(0),
+ table(0), master(0), concat_ws(0) { }
+ void cleanup() override
+ {
+ DBUG_ENTER("Item_func_match::cleanup");
+ Item_real_func::cleanup();
+ if (!master && ft_handler)
+ ft_handler->please->close_search(ft_handler);
+ ft_handler= 0;
+ concat_ws= 0;
+ table= 0; // required by Item_func_match::eq()
+ DBUG_VOID_RETURN;
+ }
+ bool is_expensive_processor(void *arg) override { return TRUE; }
+ enum Functype functype() const override { return FT_FUNC; }
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("match") };
+ return name;
+ }
+ bool eval_not_null_tables(void *opt_arg) override
+ {
+ not_null_tables_cache= 0;
+ return 0;
+ }
+ bool find_not_null_fields(table_map allowed) override
+ {
+ return false;
+ }
+ bool fix_fields(THD *thd, Item **ref) override;
+ bool eq(const Item *, bool binary_cmp) const override;
+ /* The following should be safe, even if we compare doubles */
+ longlong val_int() override { DBUG_ASSERT(fixed()); return val_real() != 0.0; }
+ double val_real() override;
+ void print(String *str, enum_query_type query_type) override;
+
+ bool fix_index();
+ bool init_search(THD *thd, bool no_order);
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function("match ... against()", arg, VCOL_IMPOSSIBLE);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_match>(thd, this); }
+ Item *build_clone(THD *thd) override { return 0; }
+private:
+ /**
+ Check whether storage engine for given table,
+ allows FTS Boolean search on non-indexed columns.
+
+ @todo A flag should be added to the extended fulltext API so that
+ it may be checked whether search on non-indexed columns are
+ supported. Currently, it is not possible to check for such a
+ flag since @c this->ft_handler is not yet set when this function is
+ called. The current hack is to assume that search on non-indexed
+ columns are supported for engines that does not support the extended
+ fulltext API (e.g., MyISAM), while it is not supported for other
+ engines (e.g., InnoDB)
+
+ @param table_arg Table for which storage engine to check
+
+ @retval true if BOOLEAN search on non-indexed columns is supported
+ @retval false otherwise
+ */
+ bool allows_search_on_non_indexed_columns(TABLE* table_arg)
+ {
+ // Only Boolean search may support non_indexed columns
+ if (!(match_flags & FT_BOOL))
+ return false;
+
+ DBUG_ASSERT(table_arg && table_arg->file);
+
+ // Assume that if extended fulltext API is not supported,
+ // non-indexed columns are allowed. This will be true for MyISAM.
+ if ((table_arg->file->ha_table_flags() & HA_CAN_FULLTEXT_EXT) == 0)
+ return true;
+
+ return false;
+ }
+};
+
+
+class Item_func_bit_xor : public Item_func_bit_operator
+{
+public:
+ Item_func_bit_xor(THD *thd, Item *a, Item *b)
+ :Item_func_bit_operator(thd, a, b) {}
+ bool fix_length_and_dec(THD *thd) override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("^") };
+ return name;
+ }
+ enum precedence precedence() const override { return BITXOR_PRECEDENCE; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_bit_xor>(thd, this); }
+};
+
+class Item_func_is_free_lock :public Item_long_func
+{
+ bool check_arguments() const override
+ { return args[0]->check_type_general_purpose_string(func_name_cstring()); }
+ String value;
+public:
+ Item_func_is_free_lock(THD *thd, Item *a): Item_long_func(thd, a) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("is_free_lock") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ decimals=0;
+ max_length=1;
+ set_maybe_null();
+ return FALSE;
+ }
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg, VCOL_IMPOSSIBLE);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_is_free_lock>(thd, this); }
+};
+
+class Item_func_is_used_lock :public Item_long_func
+{
+ bool check_arguments() const override
+ { return args[0]->check_type_general_purpose_string(func_name_cstring()); }
+ String value;
+public:
+ Item_func_is_used_lock(THD *thd, Item *a): Item_long_func(thd, a) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("is_used_lock") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ decimals=0; max_length=10;
+ set_maybe_null();
+ return FALSE;
+ }
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg, VCOL_IMPOSSIBLE);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_is_used_lock>(thd, this); }
+};
+
+
+struct Lex_cast_type_st: public Lex_length_and_dec_st
+{
+private:
+ const Type_handler *m_type_handler;
+ CHARSET_INFO *m_charset;
+public:
+ void set(const Type_handler *handler,
+ Lex_length_and_dec_st length_and_dec,
+ CHARSET_INFO *cs= NULL)
+ {
+ m_type_handler= handler;
+ m_charset= cs;
+ Lex_length_and_dec_st::operator=(length_and_dec);
+ }
+ bool set(const Type_handler *handler,
+ const Lex_length_and_dec_st & length_and_dec,
+ const Lex_column_charset_collation_attrs_st &cscl,
+ CHARSET_INFO *defcs)
+ {
+ CHARSET_INFO *tmp= cscl.resolved_to_character_set(defcs);
+ if (!tmp)
+ return true;
+ set(handler, length_and_dec, tmp);
+ return false;
+ }
+ void set(const Type_handler *handler)
+ {
+ m_type_handler= handler;
+ m_charset= NULL;
+ Lex_length_and_dec_st::reset();
+ }
+ const Type_handler *type_handler() const { return m_type_handler; }
+ CHARSET_INFO *charset() const { return m_charset; }
+ Item *create_typecast_item(THD *thd, Item *item) const
+ {
+ return m_type_handler->
+ create_typecast_item(thd, item, Type_cast_attributes(*this, m_charset));
+ }
+ Item *create_typecast_item_or_error(THD *thd, Item *item) const;
+};
+
+
+class Item_func_row_count :public Item_longlong_func
+{
+public:
+ Item_func_row_count(THD *thd): Item_longlong_func(thd) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("row_count") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ decimals= 0;
+ base_flags&= ~item_base_t::MAYBE_NULL;
+ return FALSE;
+ }
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg, VCOL_IMPOSSIBLE);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_row_count>(thd, this); }
+};
+
+
+/*
+ *
+ * Stored FUNCTIONs
+ *
+ */
+
+class Item_func_sp :public Item_func,
+ public Item_sp
+{
+private:
+ const Sp_handler *m_handler;
+
+ bool execute();
+
+protected:
+ bool is_expensive_processor(void *arg) override
+ { return is_expensive(); }
+
+ bool check_arguments() const override
+ {
+ // sp_prepare_func_item() checks that the number of columns is correct
+ return false;
+ }
+public:
+
+ Item_func_sp(THD *thd, Name_resolution_context *context_arg,
+ sp_name *name, const Sp_handler *sph);
+
+ Item_func_sp(THD *thd, Name_resolution_context *context_arg,
+ sp_name *name, const Sp_handler *sph, List<Item> &list);
+
+ virtual ~Item_func_sp() = default;
+
+ void update_used_tables() override;
+
+ void cleanup() override;
+
+ LEX_CSTRING func_name_cstring() const override;
+
+ const Type_handler *type_handler() const override;
+
+ Field *create_tmp_field_ex(MEM_ROOT *root, TABLE *table, Tmp_field_src *src,
+ const Tmp_field_param *param) override;
+ Field *create_field_for_create_select(MEM_ROOT *root, TABLE *table) override
+ {
+ return result_type() != STRING_RESULT ?
+ sp_result_field :
+ create_table_field_from_handler(root, table);
+ }
+ void make_send_field(THD *thd, Send_field *tmp_field) override;
+
+ longlong val_int() override
+ {
+ if (execute())
+ return (longlong) 0;
+ return sp_result_field->val_int();
+ }
+
+ double val_real() override
+ {
+ if (execute())
+ return 0.0;
+ return sp_result_field->val_real();
+ }
+
+ my_decimal *val_decimal(my_decimal *dec_buf) override
+ {
+ if (execute())
+ return NULL;
+ return sp_result_field->val_decimal(dec_buf);
+ }
+
+ bool get_date(THD *thd, MYSQL_TIME *ltime, date_mode_t fuzzydate) override
+ {
+ if (execute())
+ return true;
+ return sp_result_field->get_date(ltime, fuzzydate);
+ }
+
+ String *val_str(String *str) override
+ {
+ String buf;
+ char buff[20];
+ buf.set(buff, 20, str->charset());
+ buf.length(0);
+ if (execute())
+ return NULL;
+ /*
+ result_field will set buf pointing to internal buffer
+ of the resul_field. Due to this it will change any time
+ when SP is executed. In order to prevent occasional
+ corruption of returned value, we make here a copy.
+ */
+ sp_result_field->val_str(&buf);
+ str->copy(buf);
+ return str;
+ }
+
+ bool val_native(THD *thd, Native *to) override
+ {
+ if (execute())
+ return true;
+ return (null_value= sp_result_field->val_native(to));
+ }
+
+ void update_null_value() override
+ {
+ execute();
+ }
+
+ bool change_context_processor(void *cntx) override
+ { context= (Name_resolution_context *)cntx; return FALSE; }
+
+ enum Functype functype() const override { return FUNC_SP; }
+
+ bool fix_fields(THD *thd, Item **ref) override;
+ bool fix_length_and_dec(THD *thd) override;
+ bool is_expensive() override;
+
+ inline Field *get_sp_result_field()
+ {
+ return sp_result_field;
+ }
+ const sp_name *get_sp_name() const
+ {
+ return m_name;
+ }
+
+ bool check_vcol_func_processor(void *arg) override;
+ bool limit_index_condition_pushdown_processor(void *opt_arg) override
+ {
+ return TRUE;
+ }
+ Item *get_copy(THD *) override { return 0; }
+ bool eval_not_null_tables(void *opt_arg) override
+ {
+ not_null_tables_cache= 0;
+ return 0;
+ }
+ bool excl_dep_on_grouping_fields(st_select_lex *sel) override
+ { return false; }
+ bool find_not_null_fields(table_map allowed) override
+ {
+ return false;
+ }
+};
+
+
+class Item_func_found_rows :public Item_longlong_func
+{
+public:
+ Item_func_found_rows(THD *thd): Item_longlong_func(thd) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("found_rows") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ decimals= 0;
+ base_flags&= ~item_base_t::MAYBE_NULL;
+ return FALSE;
+ }
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg, VCOL_IMPOSSIBLE);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_found_rows>(thd, this); }
+};
+
+
+class Item_func_oracle_sql_rowcount :public Item_longlong_func
+{
+public:
+ Item_func_oracle_sql_rowcount(THD *thd): Item_longlong_func(thd) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("SQL%ROWCOUNT") };
+ return name;
+ }
+ void print(String *str, enum_query_type query_type) override
+ {
+ str->append(func_name_cstring());
+ }
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg, VCOL_IMPOSSIBLE);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_oracle_sql_rowcount>(thd, this); }
+};
+
+
+class Item_func_sqlcode: public Item_long_func
+{
+public:
+ Item_func_sqlcode(THD *thd): Item_long_func(thd) { }
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("SQLCODE") };
+ return name;
+ }
+ void print(String *str, enum_query_type query_type) override
+ {
+ str->append(func_name_cstring());
+ }
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg, VCOL_IMPOSSIBLE);
+ }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ base_flags&= ~item_base_t::MAYBE_NULL;
+ null_value= false;
+ max_length= 11;
+ return FALSE;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_sqlcode>(thd, this); }
+};
+
+
+void uuid_short_init();
+ulonglong server_uuid_value();
+
+class Item_func_uuid_short :public Item_longlong_func
+{
+public:
+ Item_func_uuid_short(THD *thd): Item_longlong_func(thd) {}
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("uuid_short") };
+ return name;
+ }
+ longlong val_int() override;
+ bool const_item() const override { return false; }
+ bool fix_length_and_dec(THD *thd) override
+ { max_length= 21; unsigned_flag=1; return FALSE; }
+ table_map used_tables() const override { return RAND_TABLE_BIT; }
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg,
+ VCOL_NON_DETERMINISTIC);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_uuid_short>(thd, this); }
+};
+
+
+class Item_func_last_value :public Item_func
+{
+protected:
+ Item *last_value;
+public:
+ Item_func_last_value(THD *thd, List<Item> &list): Item_func(thd, list) {}
+ double val_real() override;
+ longlong val_int() override;
+ String *val_str(String *) override;
+ my_decimal *val_decimal(my_decimal *) override;
+ bool get_date(THD *thd, MYSQL_TIME *ltime, date_mode_t fuzzydate) override;
+ bool val_native(THD *thd, Native *) override;
+ bool fix_length_and_dec(THD *thd) override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("last_value") };
+ return name;
+ }
+ const Type_handler *type_handler() const override
+ { return last_value->type_handler(); }
+ bool eval_not_null_tables(void *) override
+ {
+ not_null_tables_cache= 0;
+ return 0;
+ }
+ bool find_not_null_fields(table_map allowed) override
+ {
+ return false;
+ }
+ bool const_item() const override { return 0; }
+ void evaluate_sideeffects();
+ void update_used_tables() override
+ {
+ Item_func::update_used_tables();
+ copy_flags(last_value, item_base_t::MAYBE_NULL);
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_last_value>(thd, this); }
+};
+
+
+/* Implementation for sequences: NEXT VALUE FOR sequence and NEXTVAL() */
+
+class Item_func_nextval :public Item_longlong_func
+{
+protected:
+ TABLE_LIST *table_list;
+ TABLE *table;
+public:
+ Item_func_nextval(THD *thd, TABLE_LIST *table_list_arg):
+ Item_longlong_func(thd), table_list(table_list_arg) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("nextval") };
+ return name;
+ }
+ bool fix_length_and_dec(THD *thd) override
+ {
+ unsigned_flag= 0;
+ max_length= MAX_BIGINT_WIDTH;
+ set_maybe_null(); /* In case of errors */
+ return FALSE;
+ }
+ /*
+ update_table() function must be called during the value function
+ as in case of DEFAULT the sequence table may not yet be open
+ while fix_fields() are called
+ */
+ void update_table()
+ {
+ if (!(table= table_list->table))
+ {
+ /*
+ If nextval was used in DEFAULT then next_local points to
+ the table_list used by to open the sequence table
+ */
+ table= table_list->next_local->table;
+ }
+ }
+ bool const_item() const override { return 0; }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_nextval>(thd, this); }
+ void print(String *str, enum_query_type query_type) override;
+ bool check_vcol_func_processor(void *arg) override
+ {
+ return mark_unsupported_function(func_name(), "()", arg, VCOL_NEXTVAL);
+ }
+};
+
+
+/* Implementation for sequences: LASTVAL(sequence), PostgreSQL style */
+
+class Item_func_lastval :public Item_func_nextval
+{
+public:
+ Item_func_lastval(THD *thd, TABLE_LIST *table_list_arg):
+ Item_func_nextval(thd, table_list_arg) {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("lastval") };
+ return name;
+ }
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_lastval>(thd, this); }
+};
+
+
+/* Implementation for sequences: SETVAL(sequence), PostgreSQL style */
+
+class Item_func_setval :public Item_func_nextval
+{
+ longlong nextval;
+ ulonglong round;
+ bool is_used;
+public:
+ Item_func_setval(THD *thd, TABLE_LIST *table_list_arg, longlong nextval_arg,
+ ulonglong round_arg, bool is_used_arg)
+ : Item_func_nextval(thd, table_list_arg),
+ nextval(nextval_arg), round(round_arg), is_used(is_used_arg)
+ {}
+ longlong val_int() override;
+ LEX_CSTRING func_name_cstring() const override
+ {
+ static LEX_CSTRING name= {STRING_WITH_LEN("setval") };
+ return name;
+ }
+ void print(String *str, enum_query_type query_type) override;
+ Item *get_copy(THD *thd) override
+ { return get_item_copy<Item_func_setval>(thd, this); }
+};
+
+
+Item *get_system_var(THD *thd, enum_var_type var_type,
+ const LEX_CSTRING *name, const LEX_CSTRING *component);
+extern bool check_reserved_words(const LEX_CSTRING *name);
+double my_double_round(double value, longlong dec, bool dec_unsigned,
+ bool truncate);
+
+extern bool volatile mqh_used;
+
+bool update_hash(user_var_entry *entry, bool set_null, void *ptr, size_t length,
+ Item_result type, CHARSET_INFO *cs,
+ bool unsigned_arg);
+
+#endif /* ITEM_FUNC_INCLUDED */