item_func.cc 137 KB
Newer Older
unknown's avatar
unknown committed
1
/* Copyright (C) 2000-2003 MySQL AB
unknown's avatar
unknown committed
2 3 4

   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
unknown's avatar
unknown committed
5
   the Free Software Foundation; version 2 of the License.
unknown's avatar
unknown committed
6 7 8 9 10 11 12 13 14 15 16 17 18

   This program is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   GNU General Public License for more details.

   You should have received a copy of the GNU General Public License
   along with this program; if not, write to the Free Software
   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */


/* This file defines all numerical functions */

19
#ifdef USE_PRAGMA_IMPLEMENTATION
unknown's avatar
unknown committed
20 21 22 23
#pragma implementation				// gcc: Class implementation
#endif

#include "mysql_priv.h"
unknown's avatar
unknown committed
24
#include "slave.h"				// for wait_for_master_pos
unknown's avatar
unknown committed
25 26 27 28 29
#include <m_ctype.h>
#include <hash.h>
#include <time.h>
#include <ft_global.h>

30 31 32
#include "sp_head.h"
#include "sp_rcontext.h"
#include "sp.h"
unknown's avatar
unknown committed
33

unknown's avatar
unknown committed
34 35 36 37 38
#ifdef NO_EMBEDDED_ACCESS_CHECKS
#define sp_restore_security_context(A,B) while (0) {}
#endif


39 40 41 42 43 44 45 46 47 48
bool check_reserved_words(LEX_STRING *name)
{
  if (!my_strcasecmp(system_charset_info, name->str, "GLOBAL") ||
      !my_strcasecmp(system_charset_info, name->str, "LOCAL") ||
      !my_strcasecmp(system_charset_info, name->str, "SESSION"))
    return TRUE;
  return FALSE;
}


unknown's avatar
unknown committed
49 50 51 52 53 54 55 56
/* return TRUE if item is a constant */

bool
eval_const_cond(COND *cond)
{
  return ((Item_func*) cond)->val_int() ? TRUE : FALSE;
}

unknown's avatar
unknown committed
57

58
void Item_func::set_arguments(List<Item> &list)
unknown's avatar
unknown committed
59
{
60
  allowed_arg_cols= 1;
unknown's avatar
unknown committed
61
  arg_count=list.elements;
unknown's avatar
unknown committed
62 63
  args= tmp_arg;                                // If 2 arguments
  if (arg_count <= 2 || (args=(Item**) sql_alloc(sizeof(Item*)*arg_count)))
unknown's avatar
unknown committed
64
  {
unknown's avatar
unknown committed
65
    List_iterator_fast<Item> li(list);
unknown's avatar
unknown committed
66
    Item *item;
unknown's avatar
unknown committed
67
    Item **save_args= args;
unknown's avatar
unknown committed
68 69 70

    while ((item=li++))
    {
unknown's avatar
unknown committed
71
      *(save_args++)= item;
unknown's avatar
unknown committed
72 73 74 75 76 77
      with_sum_func|=item->with_sum_func;
    }
  }
  list.empty();					// Fields are used
}

78 79 80 81 82 83
Item_func::Item_func(List<Item> &list)
  :allowed_arg_cols(1)
{
  set_arguments(list);
}

84
Item_func::Item_func(THD *thd, Item_func *item)
85
  :Item_result_field(thd, item),
86 87 88 89 90
   allowed_arg_cols(item->allowed_arg_cols),
   arg_count(item->arg_count),
   used_tables_cache(item->used_tables_cache),
   not_null_tables_cache(item->not_null_tables_cache),
   const_item_cache(item->const_item_cache)
91 92 93 94 95 96 97 98 99 100
{
  if (arg_count)
  {
    if (arg_count <=2)
      args= tmp_arg;
    else
    {
      if (!(args=(Item**) thd->alloc(sizeof(Item*)*arg_count)))
	return;
    }
101
    memcpy((char*) args, (char*) item->args, sizeof(Item*)*arg_count);
102 103 104
  }
}

unknown's avatar
unknown committed
105 106

/*
107
  Resolve references to table column for a function and its argument
unknown's avatar
unknown committed
108 109 110 111 112 113 114 115 116 117 118 119 120 121 122

  SYNOPSIS:
  fix_fields()
  thd		Thread object
  ref		Pointer to where this object is used.  This reference
		is used if we want to replace this object with another
		one (for example in the summary functions).

  DESCRIPTION
    Call fix_fields() for all arguments to the function.  The main intention
    is to allow all Item_field() objects to setup pointers to the table fields.

    Sets as a side effect the following class variables:
      maybe_null	Set if any argument may return NULL
      with_sum_func	Set if any of the arguments contains a sum function
unknown's avatar
unknown committed
123
      used_tables_cache Set to union of the tables used by arguments
unknown's avatar
unknown committed
124 125 126

      str_value.charset If this is a string function, set this to the
			character set for the first argument.
127
			If any argument is binary, this is set to binary
unknown's avatar
unknown committed
128 129 130 131 132 133 134

   If for any item any of the defaults are wrong, then this can
   be fixed in the fix_length_and_dec() function that is called
   after this one or by writing a specialized fix_fields() for the
   item.

  RETURN VALUES
unknown's avatar
unknown committed
135 136
  FALSE	ok
  TRUE	Got error.  Stored with my_error().
unknown's avatar
unknown committed
137 138
*/

unknown's avatar
unknown committed
139
bool
140
Item_func::fix_fields(THD *thd, Item **ref)
unknown's avatar
unknown committed
141
{
142
  DBUG_ASSERT(fixed == 0);
unknown's avatar
unknown committed
143
  Item **arg,**arg_end;
144 145 146
#ifndef EMBEDDED_LIBRARY			// Avoid compiler warning
  char buff[STACK_BUFF_ALLOC];			// Max argument in function
#endif
147

148
  used_tables_cache= not_null_tables_cache= 0;
unknown's avatar
unknown committed
149 150
  const_item_cache=1;

151
  if (check_stack_overrun(thd, STACK_MIN_SIZE, buff))
unknown's avatar
unknown committed
152
    return TRUE;				// Fatal error if flag is set!
unknown's avatar
unknown committed
153 154 155 156
  if (arg_count)
  {						// Print purify happy
    for (arg=args, arg_end=args+arg_count; arg != arg_end ; arg++)
    {
unknown's avatar
unknown committed
157
      Item *item;
unknown's avatar
merge  
unknown committed
158 159 160 161
      /*
	We can't yet set item to *arg as fix_fields may change *arg
	We shouldn't call fix_fields() twice, so check 'fixed' field first
      */
162
      if ((!(*arg)->fixed && (*arg)->fix_fields(thd, arg)))
unknown's avatar
unknown committed
163
	return TRUE;				/* purecov: inspected */
unknown's avatar
unknown committed
164
      item= *arg;
165 166 167 168 169 170 171 172 173 174 175 176 177 178

      if (allowed_arg_cols)
      {
        if (item->check_cols(allowed_arg_cols))
          return 1;
      }
      else
      {
        /*  we have to fetch allowed_arg_cols from first argument */
        DBUG_ASSERT(arg == args); // it is first argument
        allowed_arg_cols= item->cols();
        DBUG_ASSERT(allowed_arg_cols); // Can't be 0 any more
      }

unknown's avatar
unknown committed
179
      if (item->maybe_null)
unknown's avatar
unknown committed
180
	maybe_null=1;
181

unknown's avatar
unknown committed
182
      with_sum_func= with_sum_func || item->with_sum_func;
183 184 185
      used_tables_cache|=     item->used_tables();
      not_null_tables_cache|= item->not_null_tables();
      const_item_cache&=      item->const_item();
186
      with_subselect|=        item->with_subselect;
unknown's avatar
unknown committed
187 188 189
    }
  }
  fix_length_and_dec();
unknown's avatar
unknown committed
190 191
  if (thd->net.report_error) // An error inside fix_length_and_dec occured
    return TRUE;
192
  fixed= 1;
unknown's avatar
unknown committed
193
  return FALSE;
unknown's avatar
unknown committed
194 195
}

unknown's avatar
unknown committed
196 197 198 199 200 201 202 203 204 205 206 207 208
bool Item_func::walk (Item_processor processor, byte *argument)
{
  if (arg_count)
  {
    Item **arg,**arg_end;
    for (arg= args, arg_end= args+arg_count; arg != arg_end; arg++)
    {
      if ((*arg)->walk(processor, argument))
	return 1;
    }
  }
  return (this->*processor)(argument);
}
209

210 211
void Item_func::traverse_cond(Cond_traverser traverser,
                              void *argument, traverse_order order)
212 213 214 215
{
  if (arg_count)
  {
    Item **arg,**arg_end;
216 217 218

    switch (order) {
    case(PREFIX):
unknown's avatar
unknown committed
219
      (*traverser)(this, argument);
220 221 222 223 224 225 226 227 228 229
      for (arg= args, arg_end= args+arg_count; arg != arg_end; arg++)
      {
	(*arg)->traverse_cond(traverser, argument, order);
      }
      break;
    case (POSTFIX):
      for (arg= args, arg_end= args+arg_count; arg != arg_end; arg++)
      {
	(*arg)->traverse_cond(traverser, argument, order);
      }
unknown's avatar
unknown committed
230
      (*traverser)(this, argument);
231 232
    }
  }
233 234
  else
    (*traverser)(this, argument);
235 236
}

unknown's avatar
unknown committed
237 238 239 240 241 242

/*
  Transform an Item_func object with a transformer callback function
   
  SYNOPSIS
    transform()
243 244 245
      transformer   the transformer callback function to be applied to the nodes
                    of the tree of the object
      argument      parameter to be passed to the transformer
unknown's avatar
unknown committed
246 247
  
  DESCRIPTION
248 249 250
    The function recursively applies the transform method to each
    argument of the Item_func node.
    If the call of the method for an argument item returns a new item
unknown's avatar
unknown committed
251
    the old item is substituted for a new one.
252
    After this the transformer is applied to the root node
unknown's avatar
unknown committed
253 254 255 256 257 258 259
    of the Item_func object. 
     
  RETURN VALUES
    Item returned as the result of transformation of the root node 
*/

Item *Item_func::transform(Item_transformer transformer, byte *argument)
260
{
261 262
  DBUG_ASSERT(!current_thd->is_stmt_prepare());

263 264 265 266 267
  if (arg_count)
  {
    Item **arg,**arg_end;
    for (arg= args, arg_end= args+arg_count; arg != arg_end; arg++)
    {
unknown's avatar
unknown committed
268
      Item *new_item= (*arg)->transform(transformer, argument);
269 270
      if (!new_item)
	return 0;
271 272 273 274 275 276 277

      /*
        THD::change_item_tree() should be called only if the tree was
        really transformed, i.e. when a new item has been created.
        Otherwise we'll be allocating a lot of unnecessary memory for
        change records at each execution.
      */
unknown's avatar
unknown committed
278 279
      if (*arg != new_item)
        current_thd->change_item_tree(arg, new_item);
280 281
    }
  }
unknown's avatar
unknown committed
282
  return (this->*transformer)(argument);
283 284 285
}


286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325
/*
  Compile Item_func object with a processor and a transformer callback functions
   
  SYNOPSIS
    compile()
      analyzer      the analyzer callback function to be applied to the nodes
                    of the tree of the object
      arg_p         in/out parameter to be passed to the processor
      transformer   the transformer callback function to be applied to the nodes
                    of the tree of the object
      arg_t         parameter to be passed to the transformer
  
  DESCRIPTION
    First the function applies the analyzer to the root node of
    the Item_func object. Then if the analizer succeeeds (returns TRUE)
    the function recursively applies the compile method to each argument
    of the Item_func node.
    If the call of the method for an argument item returns a new item
    the old item is substituted for a new one.
    After this the transformer is applied to the root node
    of the Item_func object. 
     
  RETURN VALUES
    Item returned as the result of transformation of the root node 
*/

Item *Item_func::compile(Item_analyzer analyzer, byte **arg_p,
                         Item_transformer transformer, byte *arg_t)
{
  if (!(this->*analyzer)(arg_p))
    return 0;
  if (arg_count)
  {
    Item **arg,**arg_end;
    for (arg= args, arg_end= args+arg_count; arg != arg_end; arg++)
    {
      /* 
        The same parameter value of arg_p must be passed
        to analyze any argument of the condition formula.
      */   
326
      byte *arg_v= *arg_p;
327 328 329 330 331 332 333 334
      Item *new_item= (*arg)->compile(analyzer, &arg_v, transformer, arg_t);
      if (new_item && *arg != new_item)
        current_thd->change_item_tree(arg, new_item);
    }
  }
  return (this->*transformer)(arg_t);
}

335 336
/* See comments in Item_cmp_func::split_sum_func() */

337 338
void Item_func::split_sum_func(THD *thd, Item **ref_pointer_array,
                               List<Item> &fields)
unknown's avatar
unknown committed
339
{
340 341
  Item **arg, **arg_end;
  for (arg= args, arg_end= args+arg_count; arg != arg_end ; arg++)
unknown's avatar
unknown committed
342
    (*arg)->split_sum_func2(thd, ref_pointer_array, fields, arg, TRUE);
unknown's avatar
unknown committed
343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363
}


void Item_func::update_used_tables()
{
  used_tables_cache=0;
  const_item_cache=1;
  for (uint i=0 ; i < arg_count ; i++)
  {
    args[i]->update_used_tables();
    used_tables_cache|=args[i]->used_tables();
    const_item_cache&=args[i]->const_item();
  }
}


table_map Item_func::used_tables() const
{
  return used_tables_cache;
}

364 365 366 367 368 369 370

table_map Item_func::not_null_tables() const
{
  return not_null_tables_cache;
}


unknown's avatar
unknown committed
371 372 373 374
void Item_func::print(String *str)
{
  str->append(func_name());
  str->append('(');
unknown's avatar
unknown committed
375
  print_args(str, 0);
376 377 378 379
  str->append(')');
}


unknown's avatar
unknown committed
380
void Item_func::print_args(String *str, uint from)
381
{
unknown's avatar
unknown committed
382
  for (uint i=from ; i < arg_count ; i++)
unknown's avatar
unknown committed
383
  {
unknown's avatar
unknown committed
384
    if (i != from)
unknown's avatar
unknown committed
385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404
      str->append(',');
    args[i]->print(str);
  }
}


void Item_func::print_op(String *str)
{
  str->append('(');
  for (uint i=0 ; i < arg_count-1 ; i++)
  {
    args[i]->print(str);
    str->append(' ');
    str->append(func_name());
    str->append(' ');
  }
  args[arg_count-1]->print(str);
  str->append(')');
}

unknown's avatar
unknown committed
405

406
bool Item_func::eq(const Item *item, bool binary_cmp) const
unknown's avatar
unknown committed
407 408 409 410 411 412 413
{
  /* Assume we don't have rtti */
  if (this == item)
    return 1;
  if (item->type() != FUNC_ITEM)
    return 0;
  Item_func *item_func=(Item_func*) item;
414 415 416 417 418 419 420
  Item_func::Functype func_type;
  if ((func_type= functype()) != item_func->functype() ||
      arg_count != item_func->arg_count ||
      (func_type != Item_func::FUNC_SP &&
       func_name() != item_func->func_name()) ||
      (func_type == Item_func::FUNC_SP &&
       my_strcasecmp(system_charset_info, func_name(), item_func->func_name())))
unknown's avatar
unknown committed
421 422
    return 0;
  for (uint i=0; i < arg_count ; i++)
423
    if (!args[i]->eq(item_func->args[i], binary_cmp))
unknown's avatar
unknown committed
424 425 426 427
      return 0;
  return 1;
}

428

429 430 431 432 433
Field *Item_func::tmp_table_field(TABLE *t_arg)
{
  Field *res;
  LINT_INIT(res);

unknown's avatar
unknown committed
434
  switch (result_type()) {
435
  case INT_RESULT:
436
    if (max_length > MY_INT32_NUM_DECIMAL_DIGITS)
437 438 439 440 441 442 443 444 445 446
      res= new Field_longlong(max_length, maybe_null, name, t_arg,
			      unsigned_flag);
    else
      res= new Field_long(max_length, maybe_null, name, t_arg,
			  unsigned_flag);
    break;
  case REAL_RESULT:
    res= new Field_double(max_length, maybe_null, name, t_arg, decimals);
    break;
  case STRING_RESULT:
447
    res= make_string_field(t_arg);
448
    break;
unknown's avatar
unknown committed
449
  case DECIMAL_RESULT:
unknown's avatar
unknown committed
450 451 452 453
    res= new Field_new_decimal(my_decimal_precision_to_length(decimal_precision(),
                                                              decimals,
                                                              unsigned_flag),
                               maybe_null, name, t_arg, decimals, unsigned_flag);
unknown's avatar
unknown committed
454
    break;
455
  case ROW_RESULT:
unknown's avatar
unknown committed
456
  default:
unknown's avatar
unknown committed
457
    // This case should never be chosen
unknown's avatar
unknown committed
458 459
    DBUG_ASSERT(0);
    break;
460 461 462 463
  }
  return res;
}

464

465
bool Item_func::is_expensive_processor(byte *arg)
466
{
467
  return is_expensive();
468 469 470
}


unknown's avatar
unknown committed
471 472 473 474 475 476 477
my_decimal *Item_func::val_decimal(my_decimal *decimal_value)
{
  DBUG_ASSERT(fixed);
  int2my_decimal(E_DEC_FATAL_ERROR, val_int(), unsigned_flag, decimal_value);
  return decimal_value;
}

478

unknown's avatar
unknown committed
479 480
String *Item_real_func::val_str(String *str)
{
481
  DBUG_ASSERT(fixed == 1);
482
  double nr= val_real();
unknown's avatar
unknown committed
483 484
  if (null_value)
    return 0; /* purecov: inspected */
unknown's avatar
unknown committed
485
  str->set(nr,decimals, &my_charset_bin);
unknown's avatar
unknown committed
486 487 488 489
  return str;
}


490 491 492 493 494 495 496 497 498 499 500
my_decimal *Item_real_func::val_decimal(my_decimal *decimal_value)
{
  DBUG_ASSERT(fixed);
  double nr= val_real();
  if (null_value)
    return 0; /* purecov: inspected */
  double2my_decimal(E_DEC_FATAL_ERROR, nr, decimal_value);
  return decimal_value;
}


unknown's avatar
unknown committed
501
void Item_func::fix_num_length_and_dec()
unknown's avatar
unknown committed
502
{
503
  uint fl_length= 0;
unknown's avatar
unknown committed
504
  decimals=0;
unknown's avatar
unknown committed
505
  for (uint i=0 ; i < arg_count ; i++)
unknown's avatar
unknown committed
506 507
  {
    set_if_bigger(decimals,args[i]->decimals);
508 509
    set_if_bigger(fl_length, args[i]->max_length);
  }
unknown's avatar
unknown committed
510
  max_length=float_length(decimals);
511 512 513 514
  if (fl_length > max_length)
  {
    decimals= NOT_FIXED_DEC;
    max_length= float_length(NOT_FIXED_DEC);
unknown's avatar
unknown committed
515
  }
unknown's avatar
unknown committed
516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532
}


void Item_func_numhybrid::fix_num_length_and_dec()
{}


/*
  Set max_length/decimals of function if function is fixed point and
  result length/precision depends on argument ones

  SYNOPSIS
    Item_func::count_decimal_length()
*/

void Item_func::count_decimal_length()
{
unknown's avatar
unknown committed
533
  int max_int_part= 0;
unknown's avatar
unknown committed
534
  decimals= 0;
unknown's avatar
unknown committed
535
  unsigned_flag= 1;
unknown's avatar
unknown committed
536
  for (uint i=0 ; i < arg_count ; i++)
unknown's avatar
unknown committed
537
  {
unknown's avatar
unknown committed
538
    set_if_bigger(decimals, args[i]->decimals);
unknown's avatar
unknown committed
539 540
    set_if_bigger(max_int_part, args[i]->decimal_int_part());
    set_if_smaller(unsigned_flag, args[i]->unsigned_flag);
unknown's avatar
unknown committed
541
  }
unknown's avatar
unknown committed
542 543 544
  int precision= min(max_int_part + decimals, DECIMAL_MAX_PRECISION);
  max_length= my_decimal_precision_to_length(precision, decimals,
                                             unsigned_flag);
unknown's avatar
unknown committed
545 546 547
}


unknown's avatar
unknown committed
548 549 550 551 552 553 554 555
/*
  Set max_length of if it is maximum length of its arguments

  SYNOPSIS
    Item_func::count_only_length()
*/

void Item_func::count_only_length()
unknown's avatar
unknown committed
556
{
unknown's avatar
unknown committed
557
  max_length= 0;
unknown's avatar
unknown committed
558
  unsigned_flag= 0;
unknown's avatar
unknown committed
559
  for (uint i=0 ; i < arg_count ; i++)
unknown's avatar
unknown committed
560
  {
unknown's avatar
unknown committed
561
    set_if_bigger(max_length, args[i]->max_length);
unknown's avatar
unknown committed
562 563
    set_if_bigger(unsigned_flag, args[i]->unsigned_flag);
  }
unknown's avatar
unknown committed
564 565
}

unknown's avatar
unknown committed
566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601

/*
  Set max_length/decimals of function if function is floating point and
  result length/precision depends on argument ones

  SYNOPSIS
    Item_func::count_real_length()
*/

void Item_func::count_real_length()
{
  uint32 length= 0;
  decimals= 0;
  max_length= 0;
  for (uint i=0 ; i < arg_count ; i++)
  {
    if (decimals != NOT_FIXED_DEC)
    {
      set_if_bigger(decimals, args[i]->decimals);
      set_if_bigger(length, (args[i]->max_length - args[i]->decimals));
    }
    set_if_bigger(max_length, args[i]->max_length);
  }
  if (decimals != NOT_FIXED_DEC)
  {
    max_length= length;
    length+= decimals;
    if (length < max_length)  // If previous operation gave overflow
      max_length= UINT_MAX32;
    else
      max_length= length;
  }
}



unknown's avatar
unknown committed
602 603 604 605 606 607 608 609 610 611
void Item_func::signal_divide_by_null()
{
  THD *thd= current_thd;
  if (thd->variables.sql_mode & MODE_ERROR_FOR_DIVISION_BY_ZERO)
    push_warning(thd, MYSQL_ERROR::WARN_LEVEL_ERROR, ER_DIVISION_BY_ZERO,
                 ER(ER_DIVISION_BY_ZERO));
  null_value= 1;
}


612
Item *Item_func::get_tmp_table_item(THD *thd)
613
{
614
  if (!with_sum_func && !const_item() && functype() != SUSERVAR_FUNC)
615
    return new Item_field(result_field);
616
  return copy_or_same(thd);
617 618
}

619 620 621 622 623 624 625 626
double Item_int_func::val_real()
{
  DBUG_ASSERT(fixed == 1);

  return unsigned_flag ? (double) ((ulonglong) val_int()) : (double) val_int();
}


unknown's avatar
unknown committed
627 628
String *Item_int_func::val_str(String *str)
{
629
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
630 631 632
  longlong nr=val_int();
  if (null_value)
    return 0;
633
  if (!unsigned_flag)
unknown's avatar
unknown committed
634
    str->set(nr,&my_charset_bin);
635
  else
unknown's avatar
unknown committed
636
    str->set((ulonglong) nr,&my_charset_bin);
unknown's avatar
unknown committed
637 638 639
  return str;
}

unknown's avatar
unknown committed
640

641 642 643 644 645 646 647 648 649 650 651
void Item_func_connection_id::fix_length_and_dec()
{
  Item_int_func::fix_length_and_dec();
  max_length= 10;
}


bool Item_func_connection_id::fix_fields(THD *thd, Item **ref)
{
  if (Item_int_func::fix_fields(thd, ref))
    return TRUE;
652
  thd->thread_specific_used= TRUE;
653
  value= thd->variables.pseudo_thread_id;
654 655 656 657
  return FALSE;
}


658
/*
659 660
  Check arguments here to determine result's type for a numeric
  function of two arguments.
unknown's avatar
unknown committed
661 662 663

  SYNOPSIS
    Item_num_op::find_num_type()
664
*/
unknown's avatar
unknown committed
665 666 667

void Item_num_op::find_num_type(void)
{
unknown's avatar
unknown committed
668 669 670 671 672 673 674 675
  DBUG_ENTER("Item_num_op::find_num_type");
  DBUG_PRINT("info", ("name %s", func_name()));
  DBUG_ASSERT(arg_count == 2);
  Item_result r0= args[0]->result_type();
  Item_result r1= args[1]->result_type();

  if (r0 == REAL_RESULT || r1 == REAL_RESULT ||
      r0 == STRING_RESULT || r1 ==STRING_RESULT)
676
  {
unknown's avatar
unknown committed
677 678 679 680 681 682 683 684 685
    count_real_length();
    max_length= float_length(decimals);
    hybrid_type= REAL_RESULT;
  }
  else if (r0 == DECIMAL_RESULT || r1 == DECIMAL_RESULT)
  {
    hybrid_type= DECIMAL_RESULT;
    result_precision();
  }
686
  else
687
  {
688
    DBUG_ASSERT(r0 == INT_RESULT && r1 == INT_RESULT);
unknown's avatar
unknown committed
689
    decimals= 0;
unknown's avatar
unknown committed
690
    hybrid_type=INT_RESULT;
unknown's avatar
unknown committed
691
    result_precision();
692
  }
unknown's avatar
unknown committed
693 694 695 696 697 698
  DBUG_PRINT("info", ("Type: %s",
             (hybrid_type == REAL_RESULT ? "REAL_RESULT" :
              hybrid_type == DECIMAL_RESULT ? "DECIMAL_RESULT" :
              hybrid_type == INT_RESULT ? "INT_RESULT" :
              "--ILLEGAL!!!--")));
  DBUG_VOID_RETURN;
unknown's avatar
unknown committed
699 700
}

unknown's avatar
unknown committed
701 702

/*
703 704 705
  Set result type for a numeric function of one argument
  (can be also used by a numeric function of many arguments, if the result
  type depends only on the first argument)
unknown's avatar
unknown committed
706 707 708 709

  SYNOPSIS
    Item_func_num1::find_num_type()
*/
710

unknown's avatar
unknown committed
711 712 713 714
void Item_func_num1::find_num_type()
{
  DBUG_ENTER("Item_func_num1::find_num_type");
  DBUG_PRINT("info", ("name %s", func_name()));
715
  switch (hybrid_type= args[0]->result_type()) {
unknown's avatar
unknown committed
716
  case INT_RESULT:
717
    unsigned_flag= args[0]->unsigned_flag;
unknown's avatar
unknown committed
718 719 720 721 722 723 724 725 726 727
    break;
  case STRING_RESULT:
  case REAL_RESULT:
    hybrid_type= REAL_RESULT;
    max_length= float_length(decimals);
    break;
  case DECIMAL_RESULT:
    break;
  default:
    DBUG_ASSERT(0);
728
  }
unknown's avatar
unknown committed
729 730 731 732 733 734
  DBUG_PRINT("info", ("Type: %s",
                      (hybrid_type == REAL_RESULT ? "REAL_RESULT" :
                       hybrid_type == DECIMAL_RESULT ? "DECIMAL_RESULT" :
                       hybrid_type == INT_RESULT ? "INT_RESULT" :
                       "--ILLEGAL!!!--")));
  DBUG_VOID_RETURN;
unknown's avatar
unknown committed
735 736
}

unknown's avatar
unknown committed
737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752

void Item_func_num1::fix_num_length_and_dec()
{
  decimals= args[0]->decimals;
  max_length= args[0]->max_length;
}


void Item_func_numhybrid::fix_length_and_dec()
{
  fix_num_length_and_dec();
  find_num_type();
}


String *Item_func_numhybrid::val_str(String *str)
unknown's avatar
unknown committed
753
{
754
  DBUG_ASSERT(fixed == 1);
755
  switch (hybrid_type) {
unknown's avatar
unknown committed
756 757 758 759
  case DECIMAL_RESULT:
  {
    my_decimal decimal_value, *val;
    if (!(val= decimal_op(&decimal_value)))
760
      return 0;                                 // null is set
unknown's avatar
unknown committed
761 762 763 764 765 766 767
    my_decimal_round(E_DEC_FATAL_ERROR, val, decimals, FALSE, val);
    my_decimal2string(E_DEC_FATAL_ERROR, val, 0, 0, 0, str);
    break;
  }
  case INT_RESULT:
  {
    longlong nr= int_op();
unknown's avatar
unknown committed
768 769
    if (null_value)
      return 0; /* purecov: inspected */
770
    if (!unsigned_flag)
unknown's avatar
unknown committed
771
      str->set(nr,&my_charset_bin);
772
    else
unknown's avatar
unknown committed
773
      str->set((ulonglong) nr,&my_charset_bin);
unknown's avatar
unknown committed
774
    break;
unknown's avatar
unknown committed
775
  }
unknown's avatar
unknown committed
776
  case REAL_RESULT:
unknown's avatar
unknown committed
777
  {
778
    double nr= real_op();
unknown's avatar
unknown committed
779 780
    if (null_value)
      return 0; /* purecov: inspected */
unknown's avatar
unknown committed
781
    str->set(nr,decimals,&my_charset_bin);
unknown's avatar
unknown committed
782 783
    break;
  }
unknown's avatar
unknown committed
784 785
  case STRING_RESULT:
    return str_op(&str_value);
unknown's avatar
unknown committed
786 787
  default:
    DBUG_ASSERT(0);
unknown's avatar
unknown committed
788 789 790 791 792
  }
  return str;
}


unknown's avatar
unknown committed
793 794 795
double Item_func_numhybrid::val_real()
{
  DBUG_ASSERT(fixed == 1);
796
  switch (hybrid_type) {
unknown's avatar
unknown committed
797 798 799 800
  case DECIMAL_RESULT:
  {
    my_decimal decimal_value, *val;
    double result;
801 802
    if (!(val= decimal_op(&decimal_value)))
      return 0.0;                               // null is set
unknown's avatar
unknown committed
803 804 805 806
    my_decimal2double(E_DEC_FATAL_ERROR, val, &result);
    return result;
  }
  case INT_RESULT:
807 808 809 810
  {
    longlong result= int_op();
    return unsigned_flag ? (double) ((ulonglong) result) : (double) result;
  }
unknown's avatar
unknown committed
811 812
  case REAL_RESULT:
    return real_op();
unknown's avatar
unknown committed
813 814 815 816 817 818 819 820
  case STRING_RESULT:
  {
    char *end_not_used;
    int err_not_used;
    String *res= str_op(&str_value);
    return (res ? my_strntod(res->charset(), (char*) res->ptr(), res->length(),
			     &end_not_used, &err_not_used) : 0.0);
  }
unknown's avatar
unknown committed
821 822 823 824 825 826 827 828 829 830
  default:
    DBUG_ASSERT(0);
  }
  return 0.0;
}


longlong Item_func_numhybrid::val_int()
{
  DBUG_ASSERT(fixed == 1);
831
  switch (hybrid_type) {
unknown's avatar
unknown committed
832 833 834 835
  case DECIMAL_RESULT:
  {
    my_decimal decimal_value, *val;
    if (!(val= decimal_op(&decimal_value)))
836
      return 0;                                 // null is set
unknown's avatar
unknown committed
837 838 839 840 841 842 843
    longlong result;
    my_decimal2int(E_DEC_FATAL_ERROR, val, unsigned_flag, &result);
    return result;
  }
  case INT_RESULT:
    return int_op();
  case REAL_RESULT:
844
    return (longlong) rint(real_op());
unknown's avatar
unknown committed
845 846 847
  case STRING_RESULT:
  {
    int err_not_used;
unknown's avatar
unknown committed
848 849 850 851
    String *res;
    if (!(res= str_op(&str_value)))
      return 0;

852
    char *end= (char*) res->ptr() + res->length();
unknown's avatar
unknown committed
853
    CHARSET_INFO *cs= str_value.charset();
unknown's avatar
unknown committed
854
    return (*(cs->cset->strtoll10))(cs, res->ptr(), &end, &err_not_used);
unknown's avatar
unknown committed
855
  }
unknown's avatar
unknown committed
856 857 858 859 860 861 862 863 864 865 866
  default:
    DBUG_ASSERT(0);
  }
  return 0;
}


my_decimal *Item_func_numhybrid::val_decimal(my_decimal *decimal_value)
{
  my_decimal *val= decimal_value;
  DBUG_ASSERT(fixed == 1);
867
  switch (hybrid_type) {
unknown's avatar
unknown committed
868 869 870 871 872 873 874 875 876 877 878
  case DECIMAL_RESULT:
    val= decimal_op(decimal_value);
    break;
  case INT_RESULT:
  {
    longlong result= int_op();
    int2my_decimal(E_DEC_FATAL_ERROR, result, unsigned_flag, decimal_value);
    break;
  }
  case REAL_RESULT:
  {
879
    double result= (double)real_op();
unknown's avatar
unknown committed
880 881 882 883
    double2my_decimal(E_DEC_FATAL_ERROR, result, decimal_value);
    break;
  }
  case STRING_RESULT:
unknown's avatar
unknown committed
884
  {
unknown's avatar
unknown committed
885 886 887 888
    String *res;
    if (!(res= str_op(&str_value)))
      return NULL;

unknown's avatar
unknown committed
889 890 891 892
    str2my_decimal(E_DEC_FATAL_ERROR, (char*) res->ptr(),
                   res->length(), res->charset(), decimal_value);
    break;
  }  
unknown's avatar
unknown committed
893 894 895 896 897 898 899 900
  case ROW_RESULT:
  default:
    DBUG_ASSERT(0);
  }
  return val;
}


901 902
void Item_func_signed::print(String *str)
{
903
  str->append(STRING_WITH_LEN("cast("));
904
  args[0]->print(str);
905
  str->append(STRING_WITH_LEN(" as signed)"));
906 907 908 909

}


910 911
longlong Item_func_signed::val_int_from_str(int *error)
{
unknown's avatar
unknown committed
912 913
  char buff[MAX_FIELD_WIDTH], *end, *start;
  uint32 length;
914 915 916 917 918 919 920 921 922 923 924 925 926 927 928
  String tmp(buff,sizeof(buff), &my_charset_bin), *res;
  longlong value;

  /*
    For a string result, we must first get the string and then convert it
    to a longlong
  */

  if (!(res= args[0]->val_str(&tmp)))
  {
    null_value= 1;
    *error= 0;
    return 0;
  }
  null_value= 0;
unknown's avatar
unknown committed
929 930 931 932 933 934 935 936 937 938
  start= (char *)res->ptr();
  length= res->length();

  end= start + length;
  value= my_strtoll10(start, &end, error);
  if (*error > 0 || end != start+ length)
  {
    char err_buff[128];
    String err_tmp(err_buff,(uint32) sizeof(err_buff), system_charset_info);
    err_tmp.copy(start, length, system_charset_info);
939 940 941
    push_warning_printf(current_thd, MYSQL_ERROR::WARN_LEVEL_WARN,
                        ER_TRUNCATED_WRONG_VALUE,
                        ER(ER_TRUNCATED_WRONG_VALUE), "INTEGER",
unknown's avatar
unknown committed
942 943
                        err_tmp.c_ptr());
  }
944 945 946 947 948 949 950 951 952
  return value;
}


longlong Item_func_signed::val_int()
{
  longlong value;
  int error;

953 954
  if (args[0]->cast_to_int_type() != STRING_RESULT ||
      args[0]->result_as_longlong())
955 956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971
  {
    value= args[0]->val_int();
    null_value= args[0]->null_value; 
    return value;
  }

  value= val_int_from_str(&error);
  if (value < 0 && error == 0)
  {
    push_warning(current_thd, MYSQL_ERROR::WARN_LEVEL_WARN, ER_UNKNOWN_ERROR,
                 "Cast to signed converted positive out-of-range integer to "
                 "it's negative complement");
  }
  return value;
}


972 973
void Item_func_unsigned::print(String *str)
{
974
  str->append(STRING_WITH_LEN("cast("));
975
  args[0]->print(str);
976
  str->append(STRING_WITH_LEN(" as unsigned)"));
977 978 979 980

}


981 982 983 984 985
longlong Item_func_unsigned::val_int()
{
  longlong value;
  int error;

986 987 988 989 990
  if (args[0]->cast_to_int_type() == DECIMAL_RESULT)
  {
    my_decimal tmp, *dec= args[0]->val_decimal(&tmp);
    if (!(null_value= args[0]->null_value))
      my_decimal2int(E_DEC_FATAL_ERROR, dec, 1, &value);
991 992
    else
      value= 0;
993 994
    return value;
  }
995 996
  else if (args[0]->cast_to_int_type() != STRING_RESULT ||
           args[0]->result_as_longlong())
997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011
  {
    value= args[0]->val_int();
    null_value= args[0]->null_value; 
    return value;
  }

  value= val_int_from_str(&error);
  if (error < 0)
    push_warning(current_thd, MYSQL_ERROR::WARN_LEVEL_WARN, ER_UNKNOWN_ERROR,
                 "Cast to unsigned converted negative integer to it's "
                 "positive complement");
  return value;
}


unknown's avatar
unknown committed
1012 1013 1014
String *Item_decimal_typecast::val_str(String *str)
{
  my_decimal tmp_buf, *tmp= val_decimal(&tmp_buf);
1015 1016
  if (null_value)
    return NULL;
1017
  my_decimal2string(E_DEC_FATAL_ERROR, tmp, 0, 0, 0, str);
unknown's avatar
unknown committed
1018 1019 1020 1021 1022 1023 1024 1025
  return str;
}


double Item_decimal_typecast::val_real()
{
  my_decimal tmp_buf, *tmp= val_decimal(&tmp_buf);
  double res;
1026 1027
  if (null_value)
    return 0.0;
unknown's avatar
unknown committed
1028 1029 1030 1031 1032 1033 1034 1035 1036
  my_decimal2double(E_DEC_FATAL_ERROR, tmp, &res);
  return res;
}


longlong Item_decimal_typecast::val_int()
{
  my_decimal tmp_buf, *tmp= val_decimal(&tmp_buf);
  longlong res;
1037 1038
  if (null_value)
    return 0;
unknown's avatar
unknown committed
1039 1040 1041 1042 1043 1044 1045 1046
  my_decimal2int(E_DEC_FATAL_ERROR, tmp, unsigned_flag, &res);
  return res;
}


my_decimal *Item_decimal_typecast::val_decimal(my_decimal *dec)
{
  my_decimal tmp_buf, *tmp= args[0]->val_decimal(&tmp_buf);
1047
  bool sign;
unknown's avatar
unknown committed
1048 1049
  uint precision;

1050 1051
  if ((null_value= args[0]->null_value))
    return NULL;
unknown's avatar
unknown committed
1052
  my_decimal_round(E_DEC_FATAL_ERROR, tmp, decimals, FALSE, dec);
1053 1054 1055 1056 1057 1058 1059 1060 1061
  sign= dec->sign();
  if (unsigned_flag)
  {
    if (sign)
    {
      my_decimal_set_zero(dec);
      goto err;
    }
  }
unknown's avatar
unknown committed
1062 1063 1064
  precision= my_decimal_length_to_precision(max_length,
                                            decimals, unsigned_flag);
  if (precision - decimals < (uint) my_decimal_intg(dec))
1065
  {
unknown's avatar
unknown committed
1066
    max_my_decimal(dec, precision, decimals);
1067 1068 1069 1070 1071 1072 1073 1074 1075 1076
    dec->sign(sign);
    goto err;
  }
  return dec;

err:
  push_warning_printf(current_thd, MYSQL_ERROR::WARN_LEVEL_ERROR,
                      ER_WARN_DATA_OUT_OF_RANGE,
                      ER(ER_WARN_DATA_OUT_OF_RANGE),
                      name, 1);
unknown's avatar
unknown committed
1077 1078 1079 1080
  return dec;
}


1081 1082
void Item_decimal_typecast::print(String *str)
{
1083 1084 1085 1086 1087
  char len_buf[20*3 + 1];
  char *end;

  uint precision= my_decimal_length_to_precision(max_length, decimals,
                                                 unsigned_flag);
1088
  str->append(STRING_WITH_LEN("cast("));
1089
  args[0]->print(str);
1090 1091 1092 1093 1094 1095 1096 1097 1098 1099 1100 1101
  str->append(STRING_WITH_LEN(" as decimal("));

  end=int10_to_str(precision, len_buf,10);
  str->append(len_buf, (uint32) (end - len_buf));

  str->append(',');

  end=int10_to_str(decimals, len_buf,10);
  str->append(len_buf, (uint32) (end - len_buf));

  str->append(')');
  str->append(')');
1102 1103 1104
}


unknown's avatar
unknown committed
1105
double Item_func_plus::real_op()
unknown's avatar
unknown committed
1106
{
1107
  double value= args[0]->val_real() + args[1]->val_real();
unknown's avatar
unknown committed
1108 1109 1110 1111 1112
  if ((null_value=args[0]->null_value || args[1]->null_value))
    return 0.0;
  return value;
}

unknown's avatar
unknown committed
1113 1114

longlong Item_func_plus::int_op()
unknown's avatar
unknown committed
1115
{
unknown's avatar
unknown committed
1116 1117 1118 1119 1120 1121 1122
  longlong value=args[0]->val_int()+args[1]->val_int();
  if ((null_value=args[0]->null_value || args[1]->null_value))
    return 0;
  return value;
}


1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134
/*
  Calculate plus of two decimail's

  SYNOPSIS
    decimal_op()
    decimal_value	Buffer that can be used to store result

  RETURN
   0	Value was NULL;  In this case null_value is set
   #	Value of operation as a decimal
*/

unknown's avatar
unknown committed
1135 1136
my_decimal *Item_func_plus::decimal_op(my_decimal *decimal_value)
{
1137 1138 1139
  my_decimal value1, *val1;
  my_decimal value2, *val2;
  val1= args[0]->val_decimal(&value1);
unknown's avatar
unknown committed
1140 1141
  if ((null_value= args[0]->null_value))
    return 0;
1142
  val2= args[1]->val_decimal(&value2);
1143
  if (!(null_value= (args[1]->null_value ||
1144 1145
                     (my_decimal_add(E_DEC_FATAL_ERROR, decimal_value, val1,
                                     val2) > 3))))
1146 1147
    return decimal_value;
  return 0;
unknown's avatar
unknown committed
1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158
}

/*
  Set precision of results for additive operations (+ and -)

  SYNOPSIS
    Item_func_additive_op::result_precision()
*/
void Item_func_additive_op::result_precision()
{
  decimals= max(args[0]->decimals, args[1]->decimals);
unknown's avatar
unknown committed
1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169
  int max_int_part= max(args[0]->decimal_precision() - args[0]->decimals,
                        args[1]->decimal_precision() - args[1]->decimals);
  int precision= min(max_int_part + 1 + decimals, DECIMAL_MAX_PRECISION);

  /* Integer operations keep unsigned_flag if one of arguments is unsigned */
  if (result_type() == INT_RESULT)
    unsigned_flag= args[0]->unsigned_flag | args[1]->unsigned_flag;
  else
    unsigned_flag= args[0]->unsigned_flag & args[1]->unsigned_flag;
  max_length= my_decimal_precision_to_length(precision, decimals,
                                             unsigned_flag);
unknown's avatar
unknown committed
1170 1171
}

1172 1173 1174 1175 1176 1177 1178 1179 1180 1181

/*
  The following function is here to allow the user to force
  subtraction of UNSIGNED BIGINT to return negative values.
*/

void Item_func_minus::fix_length_and_dec()
{
  Item_num_op::fix_length_and_dec();
  if (unsigned_flag &&
1182
      (current_thd->variables.sql_mode & MODE_NO_UNSIGNED_SUBTRACTION))
1183 1184 1185 1186
    unsigned_flag=0;
}


unknown's avatar
unknown committed
1187
double Item_func_minus::real_op()
unknown's avatar
unknown committed
1188
{
1189
  double value= args[0]->val_real() - args[1]->val_real();
unknown's avatar
unknown committed
1190 1191 1192 1193 1194
  if ((null_value=args[0]->null_value || args[1]->null_value))
    return 0.0;
  return value;
}

unknown's avatar
unknown committed
1195 1196

longlong Item_func_minus::int_op()
unknown's avatar
unknown committed
1197
{
unknown's avatar
unknown committed
1198 1199 1200 1201
  longlong value=args[0]->val_int() - args[1]->val_int();
  if ((null_value=args[0]->null_value || args[1]->null_value))
    return 0;
  return value;
unknown's avatar
unknown committed
1202 1203
}

1204

1205 1206
/* See Item_func_plus::decimal_op for comments */

unknown's avatar
unknown committed
1207 1208
my_decimal *Item_func_minus::decimal_op(my_decimal *decimal_value)
{
1209 1210 1211 1212
  my_decimal value1, *val1;
  my_decimal value2, *val2= 

  val1= args[0]->val_decimal(&value1);
unknown's avatar
unknown committed
1213 1214
  if ((null_value= args[0]->null_value))
    return 0;
1215
  val2= args[1]->val_decimal(&value2);
1216
  if (!(null_value= (args[1]->null_value ||
1217 1218
                     (my_decimal_sub(E_DEC_FATAL_ERROR, decimal_value, val1,
                                     val2) > 3))))
1219 1220
    return decimal_value;
  return 0;
unknown's avatar
unknown committed
1221 1222
}

1223

unknown's avatar
unknown committed
1224
double Item_func_mul::real_op()
unknown's avatar
unknown committed
1225
{
1226
  DBUG_ASSERT(fixed == 1);
1227
  double value= args[0]->val_real() * args[1]->val_real();
unknown's avatar
unknown committed
1228
  if ((null_value=args[0]->null_value || args[1]->null_value))
unknown's avatar
unknown committed
1229
    return 0.0;
unknown's avatar
unknown committed
1230 1231 1232
  return value;
}

unknown's avatar
unknown committed
1233 1234

longlong Item_func_mul::int_op()
unknown's avatar
unknown committed
1235
{
1236
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
1237 1238 1239 1240
  longlong value=args[0]->val_int()*args[1]->val_int();
  if ((null_value=args[0]->null_value || args[1]->null_value))
    return 0;
  return value;
unknown's avatar
unknown committed
1241 1242 1243
}


1244 1245
/* See Item_func_plus::decimal_op for comments */

unknown's avatar
unknown committed
1246 1247
my_decimal *Item_func_mul::decimal_op(my_decimal *decimal_value)
{
1248 1249 1250
  my_decimal value1, *val1;
  my_decimal value2, *val2;
  val1= args[0]->val_decimal(&value1);
unknown's avatar
unknown committed
1251 1252
  if ((null_value= args[0]->null_value))
    return 0;
1253
  val2= args[1]->val_decimal(&value2);
1254
  if (!(null_value= (args[1]->null_value ||
1255 1256
                     (my_decimal_mul(E_DEC_FATAL_ERROR, decimal_value, val1,
                                    val2) > 3))))
1257 1258
    return decimal_value;
  return 0;
unknown's avatar
unknown committed
1259 1260 1261
}


unknown's avatar
unknown committed
1262 1263
void Item_func_mul::result_precision()
{
unknown's avatar
unknown committed
1264 1265 1266 1267 1268 1269 1270 1271 1272
  /* Integer operations keep unsigned_flag if one of arguments is unsigned */
  if (result_type() == INT_RESULT)
    unsigned_flag= args[0]->unsigned_flag | args[1]->unsigned_flag;
  else
    unsigned_flag= args[0]->unsigned_flag & args[1]->unsigned_flag;
  decimals= min(args[0]->decimals + args[1]->decimals, DECIMAL_MAX_SCALE);
  int precision= min(args[0]->decimal_precision() + args[1]->decimal_precision(),
                     DECIMAL_MAX_PRECISION);
  max_length= my_decimal_precision_to_length(precision, decimals,unsigned_flag);
unknown's avatar
unknown committed
1273 1274 1275 1276
}


double Item_func_div::real_op()
unknown's avatar
unknown committed
1277
{
1278
  DBUG_ASSERT(fixed == 1);
1279 1280
  double value= args[0]->val_real();
  double val2= args[1]->val_real();
unknown's avatar
unknown committed
1281 1282 1283 1284 1285
  if ((null_value= args[0]->null_value || args[1]->null_value))
    return 0.0;
  if (val2 == 0.0)
  {
    signal_divide_by_null();
unknown's avatar
unknown committed
1286
    return 0.0;
unknown's avatar
unknown committed
1287
  }
unknown's avatar
unknown committed
1288 1289 1290
  return value/val2;
}

unknown's avatar
unknown committed
1291

unknown's avatar
unknown committed
1292
my_decimal *Item_func_div::decimal_op(my_decimal *decimal_value)
unknown's avatar
unknown committed
1293
{
1294 1295
  my_decimal value1, *val1;
  my_decimal value2, *val2;
unknown's avatar
unknown committed
1296
  int err;
1297 1298

  val1= args[0]->val_decimal(&value1);
unknown's avatar
unknown committed
1299 1300
  if ((null_value= args[0]->null_value))
    return 0;
1301
  val2= args[1]->val_decimal(&value2);
unknown's avatar
unknown committed
1302 1303
  if ((null_value= args[1]->null_value))
    return 0;
unknown's avatar
unknown committed
1304 1305 1306 1307 1308 1309
  if ((err= my_decimal_div(E_DEC_FATAL_ERROR & ~E_DEC_DIV_ZERO, decimal_value,
                           val1, val2, prec_increment)) > 3)
  {
    if (err == E_DEC_DIV_ZERO)
      signal_divide_by_null();
    null_value= 1;
unknown's avatar
unknown committed
1310
    return 0;
1311
  }
unknown's avatar
unknown committed
1312
  return decimal_value;
unknown's avatar
unknown committed
1313 1314 1315 1316 1317
}


void Item_func_div::result_precision()
{
unknown's avatar
unknown committed
1318 1319 1320 1321 1322 1323 1324 1325 1326 1327
  uint precision=min(args[0]->decimal_precision() + prec_increment,
                     DECIMAL_MAX_PRECISION);
  /* Integer operations keep unsigned_flag if one of arguments is unsigned */
  if (result_type() == INT_RESULT)
    unsigned_flag= args[0]->unsigned_flag | args[1]->unsigned_flag;
  else
    unsigned_flag= args[0]->unsigned_flag & args[1]->unsigned_flag;
  decimals= min(args[0]->decimals + prec_increment, DECIMAL_MAX_SCALE);
  max_length= my_decimal_precision_to_length(precision, decimals,
                                             unsigned_flag);
unknown's avatar
unknown committed
1328 1329
}

unknown's avatar
unknown committed
1330

unknown's avatar
unknown committed
1331 1332
void Item_func_div::fix_length_and_dec()
{
unknown's avatar
unknown committed
1333
  DBUG_ENTER("Item_func_div::fix_length_and_dec");
unknown's avatar
unknown committed
1334
  prec_increment= current_thd->variables.div_precincrement;
1335
  Item_num_op::fix_length_and_dec();
1336
  switch(hybrid_type) {
unknown's avatar
unknown committed
1337 1338
  case REAL_RESULT:
  {
unknown's avatar
unknown committed
1339
    decimals=max(args[0]->decimals,args[1]->decimals)+prec_increment;
unknown's avatar
unknown committed
1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358
    set_if_smaller(decimals, NOT_FIXED_DEC);
    max_length=args[0]->max_length - args[0]->decimals + decimals;
    uint tmp=float_length(decimals);
    set_if_smaller(max_length,tmp);
    break;
  }
  case INT_RESULT:
    hybrid_type= DECIMAL_RESULT;
    DBUG_PRINT("info", ("Type changed: DECIMAL_RESULT"));
    result_precision();
    break;
  case DECIMAL_RESULT:
    result_precision();
    break;
  default:
    DBUG_ASSERT(0);
  }
  maybe_null= 1; // devision by zero
  DBUG_VOID_RETURN;
unknown's avatar
unknown committed
1359 1360
}

1361 1362 1363 1364

/* Integer division */
longlong Item_func_int_div::val_int()
{
1365
  DBUG_ASSERT(fixed == 1);
1366 1367
  longlong value=args[0]->val_int();
  longlong val2=args[1]->val_int();
1368
  if ((null_value= (args[0]->null_value || args[1]->null_value)))
unknown's avatar
unknown committed
1369 1370 1371 1372
    return 0;
  if (val2 == 0)
  {
    signal_divide_by_null();
1373
    return 0;
unknown's avatar
unknown committed
1374
  }
1375 1376 1377
  return (unsigned_flag ?
	  (ulonglong) value / (ulonglong) val2 :
	  value / val2);
1378 1379 1380 1381 1382 1383 1384
}


void Item_func_int_div::fix_length_and_dec()
{
  max_length=args[0]->max_length - args[0]->decimals;
  maybe_null=1;
unknown's avatar
unknown committed
1385
  unsigned_flag=args[0]->unsigned_flag | args[1]->unsigned_flag;
1386 1387 1388
}


unknown's avatar
unknown committed
1389 1390 1391 1392 1393
longlong Item_func_mod::int_op()
{
  DBUG_ASSERT(fixed == 1);
  longlong value=  args[0]->val_int();
  longlong val2= args[1]->val_int();
1394 1395
  longlong result;

unknown's avatar
unknown committed
1396 1397 1398 1399 1400 1401 1402
  if ((null_value= args[0]->null_value || args[1]->null_value))
    return 0; /* purecov: inspected */
  if (val2 == 0)
  {
    signal_divide_by_null();
    return 0;
  }
1403 1404

  if (args[0]->unsigned_flag)
1405 1406 1407 1408 1409
    result= args[1]->unsigned_flag ? 
      ((ulonglong) value) % ((ulonglong) val2) : ((ulonglong) value) % val2;
  else
    result= args[1]->unsigned_flag ?
      value % ((ulonglong) val2) : value % val2;
1410

1411
  return result;
unknown's avatar
unknown committed
1412 1413 1414
}

double Item_func_mod::real_op()
unknown's avatar
unknown committed
1415
{
1416
  DBUG_ASSERT(fixed == 1);
1417 1418
  double value= args[0]->val_real();
  double val2=  args[1]->val_real();
unknown's avatar
unknown committed
1419
  if ((null_value= args[0]->null_value || args[1]->null_value))
unknown's avatar
unknown committed
1420
    return 0.0; /* purecov: inspected */
unknown's avatar
unknown committed
1421 1422 1423 1424 1425
  if (val2 == 0.0)
  {
    signal_divide_by_null();
    return 0.0;
  }
unknown's avatar
unknown committed
1426 1427 1428
  return fmod(value,val2);
}

unknown's avatar
unknown committed
1429 1430

my_decimal *Item_func_mod::decimal_op(my_decimal *decimal_value)
unknown's avatar
unknown committed
1431
{
1432 1433 1434 1435
  my_decimal value1, *val1;
  my_decimal value2, *val2;

  val1= args[0]->val_decimal(&value1);
unknown's avatar
unknown committed
1436 1437
  if ((null_value= args[0]->null_value))
    return 0;
1438
  val2= args[1]->val_decimal(&value2);
unknown's avatar
unknown committed
1439 1440 1441
  if ((null_value= args[1]->null_value))
    return 0;
  switch (my_decimal_mod(E_DEC_FATAL_ERROR & ~E_DEC_DIV_ZERO, decimal_value,
1442
                         val1, val2)) {
unknown's avatar
unknown committed
1443 1444 1445 1446
  case E_DEC_TRUNCATED:
  case E_DEC_OK:
    return decimal_value;
  case E_DEC_DIV_ZERO:
unknown's avatar
unknown committed
1447
    signal_divide_by_null();
unknown's avatar
unknown committed
1448
  default:
1449
    null_value= 1;
unknown's avatar
unknown committed
1450 1451
    return 0;
  }
unknown's avatar
unknown committed
1452 1453
}

unknown's avatar
unknown committed
1454 1455

void Item_func_mod::result_precision()
unknown's avatar
unknown committed
1456
{
unknown's avatar
unknown committed
1457 1458
  decimals= max(args[0]->decimals, args[1]->decimals);
  max_length= max(args[0]->max_length, args[1]->max_length);
unknown's avatar
unknown committed
1459 1460 1461 1462 1463
}


void Item_func_mod::fix_length_and_dec()
{
1464
  Item_num_op::fix_length_and_dec();
1465
  maybe_null= 1;
1466
  unsigned_flag= args[0]->unsigned_flag;
unknown's avatar
unknown committed
1467 1468 1469
}


unknown's avatar
unknown committed
1470
double Item_func_neg::real_op()
unknown's avatar
unknown committed
1471
{
1472
  double value= args[0]->val_real();
unknown's avatar
unknown committed
1473
  null_value= args[0]->null_value;
unknown's avatar
unknown committed
1474 1475 1476
  return -value;
}

unknown's avatar
unknown committed
1477

unknown's avatar
unknown committed
1478
longlong Item_func_neg::int_op()
unknown's avatar
unknown committed
1479
{
unknown's avatar
unknown committed
1480 1481
  longlong value= args[0]->val_int();
  null_value= args[0]->null_value;
unknown's avatar
unknown committed
1482 1483 1484
  return -value;
}

unknown's avatar
unknown committed
1485

unknown's avatar
unknown committed
1486
my_decimal *Item_func_neg::decimal_op(my_decimal *decimal_value)
unknown's avatar
unknown committed
1487
{
unknown's avatar
unknown committed
1488 1489 1490 1491 1492
  my_decimal val, *value= args[0]->val_decimal(&val);
  if (!(null_value= args[0]->null_value))
  {
    my_decimal2decimal(value, decimal_value);
    my_decimal_neg(decimal_value);
1493
    return decimal_value;
unknown's avatar
unknown committed
1494
  }
1495
  return 0;
unknown's avatar
unknown committed
1496 1497
}

1498

unknown's avatar
unknown committed
1499
void Item_func_neg::fix_num_length_and_dec()
unknown's avatar
unknown committed
1500
{
unknown's avatar
unknown committed
1501 1502 1503
  decimals= args[0]->decimals;
  /* 1 add because sign can appear */
  max_length= args[0]->max_length + 1;
unknown's avatar
unknown committed
1504 1505
}

unknown's avatar
unknown committed
1506

1507
void Item_func_neg::fix_length_and_dec()
unknown's avatar
unknown committed
1508
{
1509
  DBUG_ENTER("Item_func_neg::fix_length_and_dec");
unknown's avatar
unknown committed
1510
  Item_func_num1::fix_length_and_dec();
1511 1512 1513 1514

  /*
    If this is in integer context keep the context as integer if possible
    (This is how multiplication and other integer functions works)
1515 1516
    Use val() to get value as arg_type doesn't mean that item is
    Item_int or Item_real due to existence of Item_param.
1517
  */
unknown's avatar
unknown committed
1518
  if (hybrid_type == INT_RESULT && args[0]->const_item())
unknown's avatar
unknown committed
1519
  {
unknown's avatar
unknown committed
1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531
    longlong val= args[0]->val_int();
    if ((ulonglong) val >= (ulonglong) LONGLONG_MIN &&
        ((ulonglong) val != (ulonglong) LONGLONG_MIN ||
          args[0]->type() != INT_ITEM))        
    {
      /*
        Ensure that result is converted to DECIMAL, as longlong can't hold
        the negated number
      */
      hybrid_type= DECIMAL_RESULT;
      DBUG_PRINT("info", ("Type changed: DECIMAL_RESULT"));
    }
unknown's avatar
unknown committed
1532
  }
unknown's avatar
unknown committed
1533
  unsigned_flag= 0;
unknown's avatar
unknown committed
1534
  DBUG_VOID_RETURN;
unknown's avatar
unknown committed
1535 1536
}

unknown's avatar
unknown committed
1537

unknown's avatar
unknown committed
1538
double Item_func_abs::real_op()
unknown's avatar
unknown committed
1539
{
1540
  double value= args[0]->val_real();
unknown's avatar
unknown committed
1541
  null_value= args[0]->null_value;
unknown's avatar
unknown committed
1542 1543 1544
  return fabs(value);
}

unknown's avatar
unknown committed
1545

unknown's avatar
unknown committed
1546
longlong Item_func_abs::int_op()
unknown's avatar
unknown committed
1547
{
unknown's avatar
unknown committed
1548
  longlong value= args[0]->val_int();
1549 1550 1551
  if ((null_value= args[0]->null_value))
    return 0;
  return (value >= 0) || unsigned_flag ? value : -value;
unknown's avatar
unknown committed
1552 1553
}

unknown's avatar
unknown committed
1554

unknown's avatar
unknown committed
1555
my_decimal *Item_func_abs::decimal_op(my_decimal *decimal_value)
unknown's avatar
unknown committed
1556
{
unknown's avatar
unknown committed
1557 1558
  my_decimal val, *value= args[0]->val_decimal(&val);
  if (!(null_value= args[0]->null_value))
unknown's avatar
unknown committed
1559
  {
unknown's avatar
unknown committed
1560 1561 1562
    my_decimal2decimal(value, decimal_value);
    if (decimal_value->sign())
      my_decimal_neg(decimal_value);
1563
    return decimal_value;
unknown's avatar
unknown committed
1564
  }
1565
  return 0;
unknown's avatar
unknown committed
1566 1567 1568 1569 1570 1571
}


void Item_func_abs::fix_length_and_dec()
{
  Item_func_num1::fix_length_and_dec();
1572
  unsigned_flag= args[0]->unsigned_flag;
unknown's avatar
unknown committed
1573 1574
}

unknown's avatar
unknown committed
1575

1576
/* Gateway to natural LOG function */
1577
double Item_func_ln::val_real()
1578
{
1579
  DBUG_ASSERT(fixed == 1);
1580
  double value= args[0]->val_real();
1581
  if ((null_value= args[0]->null_value))
1582
    return 0.0;
1583
  if (value <= 0.0)
1584 1585
  {
    signal_divide_by_null();
1586
    return 0.0;
1587
  }
1588 1589 1590 1591 1592 1593 1594 1595
  return log(value);
}

/* 
 Extended but so slower LOG function
 We have to check if all values are > zero and first one is not one
 as these are the cases then result is not a number.
*/ 
1596
double Item_func_log::val_real()
unknown's avatar
unknown committed
1597
{
1598
  DBUG_ASSERT(fixed == 1);
1599
  double value= args[0]->val_real();
1600
  if ((null_value= args[0]->null_value))
1601
    return 0.0;
1602
  if (value <= 0.0)
1603 1604 1605 1606
  {
    signal_divide_by_null();
    return 0.0;
  }
1607 1608
  if (arg_count == 2)
  {
1609
    double value2= args[1]->val_real();
1610
    if ((null_value= args[1]->null_value))
1611
      return 0.0;
1612
    if (value2 <= 0.0 || value == 1.0)
1613 1614 1615 1616
    {
      signal_divide_by_null();
      return 0.0;
    }
1617 1618
    return log(value2) / log(value);
  }
unknown's avatar
unknown committed
1619 1620 1621
  return log(value);
}

1622
double Item_func_log2::val_real()
1623
{
1624
  DBUG_ASSERT(fixed == 1);
1625
  double value= args[0]->val_real();
1626 1627

  if ((null_value=args[0]->null_value))
1628
    return 0.0;
1629
  if (value <= 0.0)
1630 1631 1632 1633
  {
    signal_divide_by_null();
    return 0.0;
  }
1634
  return log(value) / M_LN2;
1635 1636
}

1637
double Item_func_log10::val_real()
unknown's avatar
unknown committed
1638
{
1639
  DBUG_ASSERT(fixed == 1);
1640
  double value= args[0]->val_real();
1641
  if ((null_value= args[0]->null_value))
1642
    return 0.0;
1643
  if (value <= 0.0)
1644 1645 1646 1647
  {
    signal_divide_by_null();
    return 0.0;
  }
unknown's avatar
unknown committed
1648 1649 1650
  return log10(value);
}

1651
double Item_func_exp::val_real()
unknown's avatar
unknown committed
1652
{
1653
  DBUG_ASSERT(fixed == 1);
1654
  double value= args[0]->val_real();
unknown's avatar
unknown committed
1655 1656 1657 1658 1659
  if ((null_value=args[0]->null_value))
    return 0.0; /* purecov: inspected */
  return exp(value);
}

1660
double Item_func_sqrt::val_real()
unknown's avatar
unknown committed
1661
{
1662
  DBUG_ASSERT(fixed == 1);
1663
  double value= args[0]->val_real();
unknown's avatar
unknown committed
1664 1665 1666 1667 1668
  if ((null_value=(args[0]->null_value || value < 0)))
    return 0.0; /* purecov: inspected */
  return sqrt(value);
}

1669
double Item_func_pow::val_real()
unknown's avatar
unknown committed
1670
{
1671
  DBUG_ASSERT(fixed == 1);
1672 1673
  double value= args[0]->val_real();
  double val2= args[1]->val_real();
unknown's avatar
unknown committed
1674 1675 1676 1677 1678 1679 1680
  if ((null_value=(args[0]->null_value || args[1]->null_value)))
    return 0.0; /* purecov: inspected */
  return pow(value,val2);
}

// Trigonometric functions

1681
double Item_func_acos::val_real()
unknown's avatar
unknown committed
1682
{
1683
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
1684
  // the volatile's for BUG #2338 to calm optimizer down (because of gcc's bug)
1685
  volatile double value= args[0]->val_real();
unknown's avatar
unknown committed
1686 1687 1688 1689 1690
  if ((null_value=(args[0]->null_value || (value < -1.0 || value > 1.0))))
    return 0.0;
  return fix_result(acos(value));
}

1691
double Item_func_asin::val_real()
unknown's avatar
unknown committed
1692
{
1693
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
1694
  // the volatile's for BUG #2338 to calm optimizer down (because of gcc's bug)
1695
  volatile double value= args[0]->val_real();
unknown's avatar
unknown committed
1696 1697 1698 1699 1700
  if ((null_value=(args[0]->null_value || (value < -1.0 || value > 1.0))))
    return 0.0;
  return fix_result(asin(value));
}

1701
double Item_func_atan::val_real()
unknown's avatar
unknown committed
1702
{
1703
  DBUG_ASSERT(fixed == 1);
1704
  double value= args[0]->val_real();
unknown's avatar
unknown committed
1705 1706 1707 1708
  if ((null_value=args[0]->null_value))
    return 0.0;
  if (arg_count == 2)
  {
1709
    double val2= args[1]->val_real();
unknown's avatar
unknown committed
1710 1711 1712 1713 1714 1715 1716
    if ((null_value=args[1]->null_value))
      return 0.0;
    return fix_result(atan2(value,val2));
  }
  return fix_result(atan(value));
}

1717
double Item_func_cos::val_real()
unknown's avatar
unknown committed
1718
{
1719
  DBUG_ASSERT(fixed == 1);
1720
  double value= args[0]->val_real();
unknown's avatar
unknown committed
1721 1722 1723 1724 1725
  if ((null_value=args[0]->null_value))
    return 0.0;
  return fix_result(cos(value));
}

1726
double Item_func_sin::val_real()
unknown's avatar
unknown committed
1727
{
1728
  DBUG_ASSERT(fixed == 1);
1729
  double value= args[0]->val_real();
unknown's avatar
unknown committed
1730 1731 1732 1733 1734
  if ((null_value=args[0]->null_value))
    return 0.0;
  return fix_result(sin(value));
}

1735
double Item_func_tan::val_real()
unknown's avatar
unknown committed
1736
{
1737
  DBUG_ASSERT(fixed == 1);
1738
  double value= args[0]->val_real();
unknown's avatar
unknown committed
1739 1740 1741 1742 1743 1744 1745 1746 1747 1748 1749
  if ((null_value=args[0]->null_value))
    return 0.0;
  return fix_result(tan(value));
}


// Shift-functions, same as << and >> in C/C++


longlong Item_func_shift_left::val_int()
{
1750
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
1751 1752 1753 1754 1755 1756 1757 1758 1759 1760 1761 1762 1763 1764
  uint shift;
  ulonglong res= ((ulonglong) args[0]->val_int() <<
		  (shift=(uint) args[1]->val_int()));
  if (args[0]->null_value || args[1]->null_value)
  {
    null_value=1;
    return 0;
  }
  null_value=0;
  return (shift < sizeof(longlong)*8 ? (longlong) res : LL(0));
}

longlong Item_func_shift_right::val_int()
{
1765
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
1766 1767 1768 1769 1770 1771 1772 1773 1774 1775 1776 1777 1778 1779 1780
  uint shift;
  ulonglong res= (ulonglong) args[0]->val_int() >>
    (shift=(uint) args[1]->val_int());
  if (args[0]->null_value || args[1]->null_value)
  {
    null_value=1;
    return 0;
  }
  null_value=0;
  return (shift < sizeof(longlong)*8 ? (longlong) res : LL(0));
}


longlong Item_func_bit_neg::val_int()
{
1781
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
1782 1783 1784 1785 1786 1787 1788 1789 1790 1791 1792 1793 1794 1795 1796 1797 1798
  ulonglong res= (ulonglong) args[0]->val_int();
  if ((null_value=args[0]->null_value))
    return 0;
  return ~res;
}


// Conversion functions

void Item_func_integer::fix_length_and_dec()
{
  max_length=args[0]->max_length - args[0]->decimals+1;
  uint tmp=float_length(decimals);
  set_if_smaller(max_length,tmp);
  decimals=0;
}

unknown's avatar
unknown committed
1799
void Item_func_int_val::fix_num_length_and_dec()
unknown's avatar
unknown committed
1800
{
unknown's avatar
unknown committed
1801 1802 1803 1804 1805 1806 1807 1808 1809 1810 1811 1812 1813 1814 1815 1816 1817 1818 1819 1820 1821 1822 1823 1824 1825 1826 1827 1828 1829 1830 1831 1832 1833 1834 1835 1836 1837 1838 1839 1840 1841 1842 1843 1844 1845 1846 1847 1848 1849 1850 1851 1852
  max_length= args[0]->max_length - (args[0]->decimals ?
                                     args[0]->decimals + 1 :
                                     0) + 2;
  uint tmp= float_length(decimals);
  set_if_smaller(max_length,tmp);
  decimals= 0;
}


void Item_func_int_val::find_num_type()
{
  DBUG_ENTER("Item_func_int_val::find_num_type");
  DBUG_PRINT("info", ("name %s", func_name()));
  switch(hybrid_type= args[0]->result_type())
  {
  case STRING_RESULT:
  case REAL_RESULT:
    hybrid_type= REAL_RESULT;
    max_length= float_length(decimals);
    break;
  case INT_RESULT:
  case DECIMAL_RESULT:
    /*
      -2 because in most high position can't be used any digit for longlong
      and one position for increasing value during operation
    */
    if ((args[0]->max_length - args[0]->decimals) >=
        (DECIMAL_LONGLONG_DIGITS - 2))
    {
      hybrid_type= DECIMAL_RESULT;
    }
    else
    {
      unsigned_flag= args[0]->unsigned_flag;
      hybrid_type= INT_RESULT;
    }
    break;
  default:
    DBUG_ASSERT(0);
  }
  DBUG_PRINT("info", ("Type: %s",
                      (hybrid_type == REAL_RESULT ? "REAL_RESULT" :
                       hybrid_type == DECIMAL_RESULT ? "DECIMAL_RESULT" :
                       hybrid_type == INT_RESULT ? "INT_RESULT" :
                       "--ILLEGAL!!!--")));

  DBUG_VOID_RETURN;
}


longlong Item_func_ceiling::int_op()
{
1853 1854 1855 1856 1857 1858 1859 1860 1861
  longlong result;
  switch (args[0]->result_type()) {
  case INT_RESULT:
    result= args[0]->val_int();
    null_value= args[0]->null_value;
    break;
  case DECIMAL_RESULT:
  {
    my_decimal dec_buf, *dec;
1862
    if ((dec= Item_func_ceiling::decimal_op(&dec_buf)))
1863 1864 1865 1866 1867 1868
      my_decimal2int(E_DEC_FATAL_ERROR, dec, unsigned_flag, &result);
    else
      result= 0;
    break;
  }
  default:
1869
    result= (longlong)Item_func_ceiling::real_op();
1870 1871
  };
  return result;
unknown's avatar
unknown committed
1872 1873
}

unknown's avatar
unknown committed
1874 1875

double Item_func_ceiling::real_op()
unknown's avatar
unknown committed
1876
{
unknown's avatar
unknown committed
1877 1878 1879 1880
  /*
    the volatile's for BUG #3051 to calm optimizer down (because of gcc's
    bug)
  */
1881
  volatile double value= args[0]->val_real();
unknown's avatar
unknown committed
1882 1883 1884 1885 1886 1887
  null_value= args[0]->null_value;
  return ceil(value);
}


my_decimal *Item_func_ceiling::decimal_op(my_decimal *decimal_value)
unknown's avatar
unknown committed
1888
{
unknown's avatar
unknown committed
1889
  my_decimal val, *value= args[0]->val_decimal(&val);
1890 1891 1892 1893 1894
  if (!(null_value= (args[0]->null_value ||
                     my_decimal_ceiling(E_DEC_FATAL_ERROR, value,
                                        decimal_value) > 1)))
    return decimal_value;
  return 0;
unknown's avatar
unknown committed
1895 1896 1897 1898 1899
}


longlong Item_func_floor::int_op()
{
1900 1901 1902 1903 1904 1905 1906 1907 1908 1909 1910 1911 1912 1913 1914 1915 1916 1917 1918
  longlong result;
  switch (args[0]->result_type()) {
  case INT_RESULT:
    result= args[0]->val_int();
    null_value= args[0]->null_value;
    break;
  case DECIMAL_RESULT:
  {
    my_decimal dec_buf, *dec;
    if ((dec= Item_func_floor::decimal_op(&dec_buf)))
      my_decimal2int(E_DEC_FATAL_ERROR, dec, unsigned_flag, &result);
    else
      result= 0;
    break;
  }
  default:
    result= (longlong)Item_func_floor::real_op();
  };
  return result;
unknown's avatar
unknown committed
1919 1920
}

unknown's avatar
unknown committed
1921 1922

double Item_func_floor::real_op()
unknown's avatar
unknown committed
1923
{
unknown's avatar
unknown committed
1924 1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936
  /*
    the volatile's for BUG #3051 to calm optimizer down (because of gcc's
    bug)
  */
  volatile double value= args[0]->val_real();
  null_value= args[0]->null_value;
  return floor(value);
}


my_decimal *Item_func_floor::decimal_op(my_decimal *decimal_value)
{
  my_decimal val, *value= args[0]->val_decimal(&val);
1937 1938 1939 1940 1941
  if (!(null_value= (args[0]->null_value ||
                     my_decimal_floor(E_DEC_FATAL_ERROR, value,
                                      decimal_value) > 1)))
    return decimal_value;
  return 0;
unknown's avatar
unknown committed
1942 1943 1944
}


unknown's avatar
unknown committed
1945
void Item_func_round::fix_length_and_dec()
unknown's avatar
unknown committed
1946
{
1947 1948 1949 1950
  int      decimals_to_set;
  longlong val1;
  bool     val1_unsigned;
  
unknown's avatar
unknown committed
1951 1952
  unsigned_flag= args[0]->unsigned_flag;
  if (!args[1]->const_item())
unknown's avatar
unknown committed
1953
  {
unknown's avatar
unknown committed
1954 1955
    max_length= args[0]->max_length;
    decimals= args[0]->decimals;
1956 1957 1958 1959 1960 1961 1962
    if (args[0]->result_type() == DECIMAL_RESULT)
    {
      max_length++;
      hybrid_type= DECIMAL_RESULT;
    }
    else
      hybrid_type= REAL_RESULT;
unknown's avatar
unknown committed
1963 1964
    return;
  }
1965 1966 1967 1968 1969 1970 1971 1972

  val1= args[1]->val_int();
  val1_unsigned= args[1]->unsigned_flag;
  if (val1 < 0)
    decimals_to_set= val1_unsigned ? INT_MAX : 0;
  else
    decimals_to_set= (val1 > INT_MAX) ? INT_MAX : (int) val1;

unknown's avatar
unknown committed
1973 1974 1975 1976 1977 1978 1979 1980
  if (args[0]->decimals == NOT_FIXED_DEC)
  {
    max_length= args[0]->max_length;
    decimals= min(decimals_to_set, NOT_FIXED_DEC);
    hybrid_type= REAL_RESULT;
    return;
  }
  
unknown's avatar
unknown committed
1981
  switch (args[0]->result_type()) {
unknown's avatar
unknown committed
1982 1983 1984 1985 1986 1987 1988
  case REAL_RESULT:
  case STRING_RESULT:
    hybrid_type= REAL_RESULT;
    decimals= min(decimals_to_set, NOT_FIXED_DEC);
    max_length= float_length(decimals);
    break;
  case INT_RESULT:
1989
    if ((!decimals_to_set && truncate) || (args[0]->decimal_precision() < DECIMAL_LONGLONG_DIGITS))
unknown's avatar
unknown committed
1990
    {
1991
      int length_can_increase= test(!truncate && (val1 < 0) && !val1_unsigned);
unknown's avatar
unknown committed
1992
      max_length= args[0]->max_length + length_can_increase;
unknown's avatar
unknown committed
1993 1994 1995 1996 1997
      /* Here we can keep INT_RESULT */
      hybrid_type= INT_RESULT;
      decimals= 0;
      break;
    }
unknown's avatar
unknown committed
1998
    /* fall through */
unknown's avatar
unknown committed
1999 2000 2001 2002 2003
  case DECIMAL_RESULT:
  {
    hybrid_type= DECIMAL_RESULT;
    int decimals_delta= args[0]->decimals - decimals_to_set;
    int precision= args[0]->decimal_precision();
2004 2005 2006 2007
    int length_increase= ((decimals_delta <= 0) || truncate) ? 0:1;

    precision-= decimals_delta - length_increase;
    decimals= decimals_to_set;
unknown's avatar
unknown committed
2008
    max_length= my_decimal_precision_to_length(precision, decimals,
2009
                                               unsigned_flag);
unknown's avatar
unknown committed
2010 2011 2012 2013
    break;
  }
  default:
    DBUG_ASSERT(0); /* This result type isn't handled */
unknown's avatar
unknown committed
2014 2015 2016
  }
}

2017 2018
double my_double_round(double value, longlong dec, bool dec_unsigned,
                       bool truncate)
unknown's avatar
unknown committed
2019
{
2020
  double tmp;
2021 2022
  bool dec_negative= (dec < 0) && !dec_unsigned;
  ulonglong abs_dec= dec_negative ? -dec : dec;
2023 2024 2025 2026 2027
  /*
    tmp2 is here to avoid return the value with 80 bit precision
    This will fix that the test round(0.1,1) = round(0.1,1) is true
  */
  volatile double tmp2;
unknown's avatar
unknown committed
2028

2029 2030
  tmp=(abs_dec < array_elements(log_10) ?
       log_10[abs_dec] : pow(10.0,(double) abs_dec));
unknown's avatar
unknown committed
2031

2032
  if (dec_negative && my_isinf(tmp))
2033
    tmp2= 0;
2034
  else if (!dec_negative && my_isinf(value * tmp))
2035 2036
    tmp2= value;
  else if (truncate)
unknown's avatar
unknown committed
2037 2038
  {
    if (value >= 0)
2039
      tmp2= dec < 0 ? floor(value/tmp)*tmp : floor(value*tmp)/tmp;
unknown's avatar
unknown committed
2040
    else
2041
      tmp2= dec < 0 ? ceil(value/tmp)*tmp : ceil(value*tmp)/tmp;
unknown's avatar
unknown committed
2042
  }
2043 2044 2045
  else
    tmp2=dec < 0 ? rint(value/tmp)*tmp : rint(value*tmp)/tmp;
  return tmp2;
unknown's avatar
unknown committed
2046 2047 2048
}


2049 2050 2051 2052 2053
double Item_func_round::real_op()
{
  double value= args[0]->val_real();

  if (!(null_value= args[0]->null_value || args[1]->null_value))
2054 2055
    return my_double_round(value, args[1]->val_int(), args[1]->unsigned_flag,
                           truncate);
2056 2057 2058 2059

  return 0.0;
}

2060 2061 2062 2063 2064 2065 2066 2067 2068 2069 2070
/*
  Rounds a given value to a power of 10 specified as the 'to' argument,
  avoiding overflows when the value is close to the ulonglong range boundary.
*/

static inline ulonglong my_unsigned_round(ulonglong value, ulonglong to)
{
  ulonglong tmp= value / to * to;
  return (value - tmp < (to >> 1)) ? tmp : tmp + to;
}

2071

unknown's avatar
unknown committed
2072 2073 2074
longlong Item_func_round::int_op()
{
  longlong value= args[0]->val_int();
2075
  longlong dec= args[1]->val_int();
unknown's avatar
unknown committed
2076
  decimals= 0;
2077
  ulonglong abs_dec;
unknown's avatar
unknown committed
2078 2079
  if ((null_value= args[0]->null_value || args[1]->null_value))
    return 0;
2080
  if ((dec >= 0) || args[1]->unsigned_flag)
unknown's avatar
unknown committed
2081 2082 2083
    return value; // integer have not digits after point

  abs_dec= -dec;
unknown's avatar
unknown committed
2084 2085 2086 2087 2088 2089 2090
  longlong tmp;
  
  if(abs_dec >= array_elements(log_10_int))
    return 0;
  
  tmp= log_10_int[abs_dec];
  
unknown's avatar
unknown committed
2091
  if (truncate)
2092 2093
    value= (unsigned_flag) ?
      ((ulonglong) value / tmp) * tmp : (value / tmp) * tmp;
unknown's avatar
unknown committed
2094
  else
2095 2096
    value= (unsigned_flag || value >= 0) ?
      my_unsigned_round((ulonglong) value, tmp) :
2097
      -(longlong) my_unsigned_round((ulonglong) -value, tmp);
unknown's avatar
unknown committed
2098
  return value;
unknown's avatar
unknown committed
2099 2100 2101 2102 2103 2104
}


my_decimal *Item_func_round::decimal_op(my_decimal *decimal_value)
{
  my_decimal val, *value= args[0]->val_decimal(&val);
2105 2106
  longlong dec= args[1]->val_int();
  if (dec > 0 || (dec < 0 && args[1]->unsigned_flag))
unknown's avatar
unknown committed
2107
  {
2108
    dec= min((ulonglong) dec, DECIMAL_MAX_SCALE);
2109
    decimals= (uint8) dec; // to get correct output
unknown's avatar
unknown committed
2110
  }
2111 2112 2113
  else if (dec < INT_MIN)
    dec= INT_MIN;
    
2114
  if (!(null_value= (args[0]->null_value || args[1]->null_value ||
2115
                     my_decimal_round(E_DEC_FATAL_ERROR, value, (int) dec,
2116
                                      truncate, decimal_value) > 1)))
2117 2118
    return decimal_value;
  return 0;
unknown's avatar
unknown committed
2119 2120 2121
}


2122
bool Item_func_rand::fix_fields(THD *thd,Item **ref)
unknown's avatar
unknown committed
2123
{
2124
  if (Item_real_func::fix_fields(thd, ref))
2125
    return TRUE;
2126
  used_tables_cache|= RAND_TABLE_BIT;
unknown's avatar
unknown committed
2127 2128
  if (arg_count)
  {					// Only use argument once in query
2129 2130 2131 2132 2133
    if (!args[0]->const_during_execution())
    {
      my_error(ER_WRONG_ARGUMENTS, MYF(0), "RAND");
      return TRUE;
    }
2134
    /*
unknown's avatar
unknown committed
2135
      Allocate rand structure once: we must use thd->stmt_arena
2136 2137
      to create rand in proper mem_root if it's a prepared statement or
      stored procedure.
2138 2139 2140

      No need to send a Rand log event if seed was given eg: RAND(seed),
      as it will be replicated in the query as such.
2141 2142
    */
    if (!rand && !(rand= (struct rand_struct*)
unknown's avatar
unknown committed
2143
                   thd->stmt_arena->alloc(sizeof(*rand))))
2144 2145 2146 2147 2148 2149 2150 2151 2152 2153 2154 2155 2156 2157 2158
      return TRUE;
    /*
      PARAM_ITEM is returned if we're in statement prepare and consequently
      no placeholder value is set yet.
    */
    if (args[0]->type() != PARAM_ITEM)
    {
      /*
        TODO: do not do reinit 'rand' for every execute of PS/SP if
        args[0] is a constant.
      */
      uint32 tmp= (uint32) args[0]->val_int();
      randominit(rand, (uint32) (tmp*0x10001L+55555555L),
                 (uint32) (tmp*0x10000001L));
    }
unknown's avatar
unknown committed
2159
  }
2160
  else
unknown's avatar
unknown committed
2161
  {
2162 2163 2164 2165 2166
    /*
      Save the seed only the first time RAND() is used in the query
      Once events are forwarded rather than recreated,
      the following can be skipped if inside the slave thread
    */
2167 2168 2169 2170 2171 2172
    if (!thd->rand_used)
    {
      thd->rand_used= 1;
      thd->rand_saved_seed1= thd->rand.seed1;
      thd->rand_saved_seed2= thd->rand.seed2;
    }
2173
    rand= &thd->rand;
unknown's avatar
unknown committed
2174
  }
2175
  return FALSE;
2176 2177
}

unknown's avatar
unknown committed
2178 2179 2180 2181 2182 2183
void Item_func_rand::update_used_tables()
{
  Item_real_func::update_used_tables();
  used_tables_cache|= RAND_TABLE_BIT;
}

2184

2185
double Item_func_rand::val_real()
2186
{
2187
  DBUG_ASSERT(fixed == 1);
2188
  return my_rnd(rand);
unknown's avatar
unknown committed
2189 2190 2191 2192
}

longlong Item_func_sign::val_int()
{
2193
  DBUG_ASSERT(fixed == 1);
2194
  double value= args[0]->val_real();
unknown's avatar
unknown committed
2195 2196 2197 2198 2199
  null_value=args[0]->null_value;
  return value < 0.0 ? -1 : (value > 0 ? 1 : 0);
}


2200
double Item_func_units::val_real()
unknown's avatar
unknown committed
2201
{
2202
  DBUG_ASSERT(fixed == 1);
2203
  double value= args[0]->val_real();
unknown's avatar
unknown committed
2204 2205 2206 2207 2208 2209 2210 2211
  if ((null_value=args[0]->null_value))
    return 0;
  return value*mul+add;
}


void Item_func_min_max::fix_length_and_dec()
{
unknown's avatar
unknown committed
2212
  int max_int_part=0;
2213
  bool datetime_found= FALSE;
unknown's avatar
unknown committed
2214 2215
  decimals=0;
  max_length=0;
unknown's avatar
unknown committed
2216
  maybe_null=0;
unknown's avatar
unknown committed
2217
  cmp_type=args[0]->result_type();
2218

unknown's avatar
unknown committed
2219 2220
  for (uint i=0 ; i < arg_count ; i++)
  {
unknown's avatar
unknown committed
2221 2222
    set_if_bigger(max_length, args[i]->max_length);
    set_if_bigger(decimals, args[i]->decimals);
unknown's avatar
unknown committed
2223
    set_if_bigger(max_int_part, args[i]->decimal_int_part());
unknown's avatar
unknown committed
2224 2225
    if (args[i]->maybe_null)
      maybe_null=1;
unknown's avatar
unknown committed
2226
    cmp_type=item_cmp_type(cmp_type,args[i]->result_type());
2227 2228 2229 2230 2231 2232
    if (args[i]->result_type() != ROW_RESULT && args[i]->is_datetime())
    {
      datetime_found= TRUE;
      if (!datetime_item || args[i]->field_type() == MYSQL_TYPE_DATETIME)
        datetime_item= args[i];
    }
unknown's avatar
unknown committed
2233
  }
unknown's avatar
unknown committed
2234
  if (cmp_type == STRING_RESULT)
2235
  {
2236
    agg_arg_charsets(collation, args, arg_count, MY_COLL_CMP_CONV, 1);
2237 2238 2239 2240 2241 2242
    if (datetime_found)
    {
      thd= current_thd;
      compare_as_dates= TRUE;
    }
  }
unknown's avatar
unknown committed
2243 2244 2245
  else if ((cmp_type == DECIMAL_RESULT) || (cmp_type == INT_RESULT))
    max_length= my_decimal_precision_to_length(max_int_part+decimals, decimals,
                                            unsigned_flag);
unknown's avatar
unknown committed
2246 2247 2248
}


2249 2250 2251 2252 2253 2254 2255 2256 2257 2258 2259 2260 2261 2262 2263 2264 2265 2266 2267 2268 2269 2270 2271 2272 2273 2274 2275 2276 2277 2278 2279 2280 2281 2282 2283 2284 2285 2286 2287 2288 2289 2290 2291 2292 2293 2294 2295
/*
  Compare item arguments in the DATETIME context.

  SYNOPSIS
    cmp_datetimes()
    value [out]   found least/greatest DATE/DATETIME value

  DESCRIPTION
    Compare item arguments as DATETIME values and return the index of the
    least/greatest argument in the arguments array.
    The correct integer DATE/DATETIME value of the found argument is
    stored to the value pointer, if latter is provided.

  RETURN
   0	If one of arguments is NULL
   #	index of the least/greatest argument
*/

uint Item_func_min_max::cmp_datetimes(ulonglong *value)
{
  ulonglong min_max;
  uint min_max_idx= 0;
  LINT_INIT(min_max);

  for (uint i=0; i < arg_count ; i++)
  {
    Item **arg= args + i;
    bool is_null;
    ulonglong res= get_datetime_value(thd, &arg, 0, datetime_item, &is_null);
    if ((null_value= args[i]->null_value))
      return 0;
    if (i == 0 || (res < min_max ? cmp_sign : -cmp_sign) > 0)
    {
      min_max= res;
      min_max_idx= i;
    }
  }
  if (value)
  {
    *value= min_max;
    if (datetime_item->field_type() == MYSQL_TYPE_DATE)
      *value/= 1000000L;
  }
  return min_max_idx;
}


unknown's avatar
unknown committed
2296 2297
String *Item_func_min_max::val_str(String *str)
{
2298
  DBUG_ASSERT(fixed == 1);
2299 2300 2301 2302 2303 2304 2305 2306 2307 2308
  if (compare_as_dates)
  {
    String *str_res;
    uint min_max_idx= cmp_datetimes(NULL);
    if (null_value)
      return 0;
    str_res= args[min_max_idx]->val_str(str);
    str_res->set_charset(collation.collation);
    return str_res;
  }
unknown's avatar
unknown committed
2309 2310 2311 2312 2313 2314
  switch (cmp_type) {
  case INT_RESULT:
  {
    longlong nr=val_int();
    if (null_value)
      return 0;
2315
    if (!unsigned_flag)
unknown's avatar
unknown committed
2316
      str->set(nr,&my_charset_bin);
2317
    else
unknown's avatar
unknown committed
2318
      str->set((ulonglong) nr,&my_charset_bin);
unknown's avatar
unknown committed
2319 2320
    return str;
  }
unknown's avatar
unknown committed
2321 2322 2323 2324 2325 2326 2327 2328
  case DECIMAL_RESULT:
  {
    my_decimal dec_buf, *dec_val= val_decimal(&dec_buf);
    if (null_value)
      return 0;
    my_decimal2string(E_DEC_FATAL_ERROR, dec_val, 0, 0, 0, str);
    return str;
  }
unknown's avatar
unknown committed
2329 2330
  case REAL_RESULT:
  {
2331
    double nr= val_real();
unknown's avatar
unknown committed
2332 2333
    if (null_value)
      return 0; /* purecov: inspected */
unknown's avatar
unknown committed
2334
    str->set(nr,decimals,&my_charset_bin);
unknown's avatar
unknown committed
2335 2336 2337 2338 2339 2340 2341 2342
    return str;
  }
  case STRING_RESULT:
  {
    String *res;
    LINT_INIT(res);
    for (uint i=0; i < arg_count ; i++)
    {
unknown's avatar
unknown committed
2343
      if (i == 0)
unknown's avatar
unknown committed
2344 2345 2346 2347 2348 2349 2350
	res=args[i]->val_str(str);
      else
      {
	String *res2;
	res2= args[i]->val_str(res == str ? &tmp_value : str);
	if (res2)
	{
2351
	  int cmp= sortcmp(res,res2,collation.collation);
unknown's avatar
unknown committed
2352 2353 2354 2355
	  if ((cmp_sign < 0 ? cmp : -cmp) < 0)
	    res=res2;
	}
      }
unknown's avatar
unknown committed
2356
      if ((null_value= args[i]->null_value))
2357
        return 0;
unknown's avatar
unknown committed
2358
    }
2359
    res->set_charset(collation.collation);
unknown's avatar
unknown committed
2360 2361
    return res;
  }
2362
  case ROW_RESULT:
unknown's avatar
unknown committed
2363
  default:
unknown's avatar
unknown committed
2364
    // This case should never be chosen
unknown's avatar
unknown committed
2365 2366
    DBUG_ASSERT(0);
    return 0;
unknown's avatar
unknown committed
2367 2368 2369 2370 2371
  }
  return 0;					// Keep compiler happy
}


2372
double Item_func_min_max::val_real()
unknown's avatar
unknown committed
2373
{
2374
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
2375
  double value=0.0;
2376 2377
  if (compare_as_dates)
  {
unknown's avatar
unknown committed
2378
    ulonglong result= 0;
2379 2380 2381
    (void)cmp_datetimes(&result);
    return (double)result;
  }
unknown's avatar
unknown committed
2382 2383
  for (uint i=0; i < arg_count ; i++)
  {
unknown's avatar
unknown committed
2384
    if (i == 0)
2385
      value= args[i]->val_real();
unknown's avatar
unknown committed
2386 2387
    else
    {
2388
      double tmp= args[i]->val_real();
unknown's avatar
unknown committed
2389 2390 2391
      if (!args[i]->null_value && (tmp < value ? cmp_sign : -cmp_sign) > 0)
	value=tmp;
    }
unknown's avatar
unknown committed
2392 2393
    if ((null_value= args[i]->null_value))
      break;
unknown's avatar
unknown committed
2394 2395 2396 2397 2398 2399 2400
  }
  return value;
}


longlong Item_func_min_max::val_int()
{
2401
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
2402
  longlong value=0;
2403 2404
  if (compare_as_dates)
  {
unknown's avatar
unknown committed
2405
    ulonglong result= 0;
2406 2407 2408
    (void)cmp_datetimes(&result);
    return (longlong)result;
  }
unknown's avatar
unknown committed
2409 2410
  for (uint i=0; i < arg_count ; i++)
  {
unknown's avatar
unknown committed
2411
    if (i == 0)
2412
      value=args[i]->val_int();
unknown's avatar
unknown committed
2413 2414
    else
    {
2415 2416 2417
      longlong tmp=args[i]->val_int();
      if (!args[i]->null_value && (tmp < value ? cmp_sign : -cmp_sign) > 0)
	value=tmp;
unknown's avatar
unknown committed
2418
    }
2419 2420
    if ((null_value= args[i]->null_value))
      break;
unknown's avatar
unknown committed
2421 2422 2423 2424
  }
  return value;
}

unknown's avatar
unknown committed
2425 2426 2427 2428

my_decimal *Item_func_min_max::val_decimal(my_decimal *dec)
{
  DBUG_ASSERT(fixed == 1);
2429 2430 2431
  my_decimal tmp_buf, *tmp, *res;
  LINT_INIT(res);

2432 2433
  if (compare_as_dates)
  {
unknown's avatar
unknown committed
2434
    ulonglong value= 0;
2435 2436 2437 2438
    (void)cmp_datetimes(&value);
    ulonglong2decimal(value, dec);
    return dec;
  }
unknown's avatar
unknown committed
2439 2440
  for (uint i=0; i < arg_count ; i++)
  {
unknown's avatar
unknown committed
2441
    if (i == 0)
unknown's avatar
unknown committed
2442 2443 2444
      res= args[i]->val_decimal(dec);
    else
    {
2445 2446
      tmp= args[i]->val_decimal(&tmp_buf);      // Zero if NULL
      if (tmp && (my_decimal_cmp(tmp, res) * cmp_sign) < 0)
unknown's avatar
unknown committed
2447 2448 2449
      {
        if (tmp == &tmp_buf)
        {
2450
          /* Move value out of tmp_buf as this will be reused on next loop */
unknown's avatar
unknown committed
2451 2452 2453 2454 2455 2456 2457
          my_decimal2decimal(tmp, dec);
          res= dec;
        }
        else
          res= tmp;
      }
    }
unknown's avatar
unknown committed
2458
    if ((null_value= args[i]->null_value))
2459 2460
    {
      res= 0;
unknown's avatar
unknown committed
2461
      break;
2462
    }
unknown's avatar
unknown committed
2463 2464 2465 2466 2467
  }
  return res;
}


unknown's avatar
unknown committed
2468 2469
longlong Item_func_length::val_int()
{
2470
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
2471 2472 2473 2474 2475 2476 2477 2478 2479 2480
  String *res=args[0]->val_str(&value);
  if (!res)
  {
    null_value=1;
    return 0; /* purecov: inspected */
  }
  null_value=0;
  return (longlong) res->length();
}

unknown's avatar
unknown committed
2481

unknown's avatar
unknown committed
2482 2483
longlong Item_func_char_length::val_int()
{
2484
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
2485 2486 2487 2488 2489 2490 2491
  String *res=args[0]->val_str(&value);
  if (!res)
  {
    null_value=1;
    return 0; /* purecov: inspected */
  }
  null_value=0;
2492
  return (longlong) res->numchars();
unknown's avatar
unknown committed
2493 2494
}

unknown's avatar
unknown committed
2495

unknown's avatar
unknown committed
2496 2497
longlong Item_func_coercibility::val_int()
{
2498
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
2499
  null_value= 0;
2500
  return (longlong) args[0]->collation.derivation;
unknown's avatar
unknown committed
2501
}
unknown's avatar
unknown committed
2502

unknown's avatar
unknown committed
2503

2504 2505
void Item_func_locate::fix_length_and_dec()
{
2506
  max_length= MY_INT32_NUM_DECIMAL_DIGITS;
2507
  agg_arg_charsets(cmp_collation, args, 2, MY_COLL_CMP_CONV, 1);
2508 2509
}

unknown's avatar
unknown committed
2510

unknown's avatar
unknown committed
2511 2512
longlong Item_func_locate::val_int()
{
2513
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
2514 2515 2516 2517 2518 2519 2520 2521
  String *a=args[0]->val_str(&value1);
  String *b=args[1]->val_str(&value2);
  if (!a || !b)
  {
    null_value=1;
    return 0; /* purecov: inspected */
  }
  null_value=0;
2522 2523 2524
  /* must be longlong to avoid truncation */
  longlong start=  0; 
  longlong start0= 0;
2525
  my_match_t match;
2526

unknown's avatar
unknown committed
2527 2528
  if (arg_count == 3)
  {
2529 2530 2531 2532 2533 2534
    start0= start= args[2]->val_int() - 1;

    if ((start < 0) || (start > a->length()))
      return 0;

    /* start is now sufficiently valid to pass to charpos function */
2535
    start= a->charpos((int) start);
2536 2537

    if (start + b->length() > a->length())
unknown's avatar
unknown committed
2538 2539
      return 0;
  }
2540

unknown's avatar
unknown committed
2541
  if (!b->length())				// Found empty string at start
2542
    return start + 1;
2543
  
2544
  if (!cmp_collation.collation->coll->instr(cmp_collation.collation,
2545 2546
                                            a->ptr()+start,
                                            (uint) (a->length()-start),
2547 2548 2549
                                            b->ptr(), b->length(),
                                            &match, 1))
    return 0;
2550
  return (longlong) match.mb_len + start0 + 1;
unknown's avatar
unknown committed
2551 2552 2553
}


2554 2555
void Item_func_locate::print(String *str)
{
2556
  str->append(STRING_WITH_LEN("locate("));
2557 2558 2559 2560 2561 2562 2563 2564 2565 2566 2567 2568
  args[1]->print(str);
  str->append(',');
  args[0]->print(str);
  if (arg_count == 3)
  {
    str->append(',');
    args[2]->print(str);
  }
  str->append(')');
}


unknown's avatar
unknown committed
2569 2570
longlong Item_func_field::val_int()
{
2571
  DBUG_ASSERT(fixed == 1);
2572

2573 2574 2575
  if (cmp_type == STRING_RESULT)
  {
    String *field;
2576 2577
    if (!(field= args[0]->val_str(&value)))
      return 0;
2578
    for (uint i=1 ; i < arg_count ; i++)
2579 2580
    {
      String *tmp_value=args[i]->val_str(&tmp);
unknown's avatar
Fix:  
unknown committed
2581
      if (tmp_value && !sortcmp(field,tmp_value,cmp_collation.collation))
2582
        return (longlong) (i);
2583 2584 2585 2586
    }
  }
  else if (cmp_type == INT_RESULT)
  {
2587
    longlong val= args[0]->val_int();
unknown's avatar
unknown committed
2588 2589
    if (args[0]->null_value)
      return 0;
2590
    for (uint i=1; i < arg_count ; i++)
2591
    {
2592
      if (val == args[i]->val_int() && !args[i]->null_value)
2593
        return (longlong) (i);
2594 2595
    }
  }
unknown's avatar
unknown committed
2596 2597 2598 2599
  else if (cmp_type == DECIMAL_RESULT)
  {
    my_decimal dec_arg_buf, *dec_arg,
               dec_buf, *dec= args[0]->val_decimal(&dec_buf);
unknown's avatar
unknown committed
2600 2601
    if (args[0]->null_value)
      return 0;
unknown's avatar
unknown committed
2602 2603 2604
    for (uint i=1; i < arg_count; i++)
    {
      dec_arg= args[i]->val_decimal(&dec_arg_buf);
unknown's avatar
unknown committed
2605
      if (!args[i]->null_value && !my_decimal_cmp(dec_arg, dec))
unknown's avatar
unknown committed
2606 2607 2608
        return (longlong) (i);
    }
  }
2609
  else
unknown's avatar
unknown committed
2610
  {
2611
    double val= args[0]->val_real();
unknown's avatar
unknown committed
2612 2613
    if (args[0]->null_value)
      return 0;
2614
    for (uint i=1; i < arg_count ; i++)
2615
    {
unknown's avatar
unknown committed
2616
      if (val == args[i]->val_real() && !args[i]->null_value)
2617
        return (longlong) (i);
2618
    }
unknown's avatar
unknown committed
2619 2620 2621 2622
  }
  return 0;
}

unknown's avatar
unknown committed
2623

2624 2625 2626
void Item_func_field::fix_length_and_dec()
{
  maybe_null=0; max_length=3;
2627 2628
  cmp_type= args[0]->result_type();
  for (uint i=1; i < arg_count ; i++)
2629 2630
    cmp_type= item_cmp_type(cmp_type, args[i]->result_type());
  if (cmp_type == STRING_RESULT)
2631
    agg_arg_charsets(cmp_collation, args, arg_count, MY_COLL_CMP_CONV, 1);
2632
}
unknown's avatar
unknown committed
2633

2634

unknown's avatar
unknown committed
2635 2636
longlong Item_func_ascii::val_int()
{
2637
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
2638 2639 2640 2641 2642 2643 2644 2645 2646 2647 2648 2649
  String *res=args[0]->val_str(&value);
  if (!res)
  {
    null_value=1;
    return 0;
  }
  null_value=0;
  return (longlong) (res->length() ? (uchar) (*res)[0] : (uchar) 0);
}

longlong Item_func_ord::val_int()
{
2650
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
2651 2652 2653 2654 2655 2656 2657 2658 2659
  String *res=args[0]->val_str(&value);
  if (!res)
  {
    null_value=1;
    return 0;
  }
  null_value=0;
  if (!res->length()) return 0;
#ifdef USE_MB
2660
  if (use_mb(res->charset()))
unknown's avatar
unknown committed
2661 2662
  {
    register const char *str=res->ptr();
2663
    register uint32 n=0, l=my_ismbchar(res->charset(),str,str+res->length());
unknown's avatar
unknown committed
2664 2665
    if (!l)
      return (longlong)((uchar) *str);
unknown's avatar
unknown committed
2666 2667 2668 2669 2670 2671 2672 2673 2674 2675 2676 2677 2678 2679 2680 2681 2682 2683 2684 2685 2686 2687 2688 2689
    while (l--)
      n=(n<<8)|(uint32)((uchar) *str++);
    return (longlong) n;
  }
#endif
  return (longlong) ((uchar) (*res)[0]);
}

	/* Search after a string in a string of strings separated by ',' */
	/* Returns number of found type >= 1 or 0 if not found */
	/* This optimizes searching in enums to bit testing! */

void Item_func_find_in_set::fix_length_and_dec()
{
  decimals=0;
  max_length=3;					// 1-999
  if (args[0]->const_item() && args[1]->type() == FIELD_ITEM)
  {
    Field *field= ((Item_field*) args[1])->field;
    if (field->real_type() == FIELD_TYPE_SET)
    {
      String *find=args[0]->val_str(&value);
      if (find)
      {
2690 2691
	enum_value= find_type(((Field_enum*) field)->typelib,find->ptr(),
			      find->length(), 0);
unknown's avatar
unknown committed
2692 2693 2694 2695 2696 2697
	enum_bit=0;
	if (enum_value)
	  enum_bit=LL(1) << (enum_value-1);
      }
    }
  }
2698
  agg_arg_charsets(cmp_collation, args, 2, MY_COLL_CMP_CONV, 1);
unknown's avatar
unknown committed
2699 2700 2701 2702 2703 2704
}

static const char separator=',';

longlong Item_func_find_in_set::val_int()
{
2705
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
2706 2707 2708 2709 2710 2711 2712 2713 2714 2715 2716 2717 2718 2719 2720 2721 2722 2723 2724 2725 2726 2727 2728
  if (enum_value)
  {
    ulonglong tmp=(ulonglong) args[1]->val_int();
    if (!(null_value=args[1]->null_value || args[0]->null_value))
    {
      if (tmp & enum_bit)
	return enum_value;
    }
    return 0L;
  }

  String *find=args[0]->val_str(&value);
  String *buffer=args[1]->val_str(&value2);
  if (!find || !buffer)
  {
    null_value=1;
    return 0; /* purecov: inspected */
  }
  null_value=0;

  int diff;
  if ((diff=buffer->length() - find->length()) >= 0)
  {
2729 2730 2731 2732 2733 2734 2735 2736 2737
    my_wc_t wc;
    CHARSET_INFO *cs= cmp_collation.collation;
    const char *str_begin= buffer->ptr();
    const char *str_end= buffer->ptr();
    const char *real_end= str_end+buffer->length();
    const uchar *find_str= (const uchar *) find->ptr();
    uint find_str_len= find->length();
    int position= 0;
    while (1)
unknown's avatar
unknown committed
2738
    {
2739 2740 2741
      int symbol_len;
      if ((symbol_len= cs->cset->mb_wc(cs, &wc, (uchar*) str_end, 
                                       (uchar*) real_end)) > 0)
unknown's avatar
unknown committed
2742
      {
2743 2744
        const char *substr_end= str_end + symbol_len;
        bool is_last_item= (substr_end == real_end);
2745 2746
        bool is_separator= (wc == (my_wc_t) separator);
        if (is_separator || is_last_item)
2747 2748
        {
          position++;
2749
          if (is_last_item && !is_separator)
2750 2751 2752 2753 2754 2755 2756 2757 2758
            str_end= substr_end;
          if (!my_strnncoll(cs, (const uchar *) str_begin,
                            str_end - str_begin,
                            find_str, find_str_len))
            return (longlong) position;
          else
            str_begin= substr_end;
        }
        str_end= substr_end;
unknown's avatar
unknown committed
2759
      }
unknown's avatar
unknown committed
2760 2761
      else if (str_end - str_begin == 0 &&
               find_str_len == 0 &&
2762 2763 2764
               wc == (my_wc_t) separator)
        return (longlong) ++position;
      else
unknown's avatar
unknown committed
2765
        return LL(0);
2766
    }
unknown's avatar
unknown committed
2767 2768 2769 2770 2771 2772
  }
  return 0;
}

longlong Item_func_bit_count::val_int()
{
2773
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
2774
  ulonglong value= (ulonglong) args[0]->val_int();
2775
  if ((null_value= args[0]->null_value))
unknown's avatar
unknown committed
2776
    return 0; /* purecov: inspected */
unknown's avatar
unknown committed
2777
  return (longlong) my_count_bits(value);
unknown's avatar
unknown committed
2778 2779 2780 2781 2782 2783
}


/****************************************************************************
** Functions to handle dynamic loadable functions
** Original source by: Alexis Mikhailov <root@medinf.chuvashia.su>
2784
** Rewritten by monty.
unknown's avatar
unknown committed
2785 2786 2787 2788
****************************************************************************/

#ifdef HAVE_DLOPEN

2789
void udf_handler::cleanup()
unknown's avatar
unknown committed
2790
{
2791
  if (!not_original)
unknown's avatar
unknown committed
2792
  {
2793
    if (initialized)
unknown's avatar
unknown committed
2794
    {
2795 2796
      if (u_d->func_deinit != NULL)
      {
2797
        Udf_func_deinit deinit= u_d->func_deinit;
2798 2799 2800
        (*deinit)(&initid);
      }
      free_udf(u_d);
2801
      initialized= FALSE;
unknown's avatar
unknown committed
2802
    }
2803 2804
    if (buffers)				// Because of bug in ecc
      delete [] buffers;
2805
    buffers= 0;
unknown's avatar
unknown committed
2806 2807 2808 2809 2810
  }
}


bool
2811
udf_handler::fix_fields(THD *thd, Item_result_field *func,
unknown's avatar
unknown committed
2812 2813
			uint arg_count, Item **arguments)
{
2814 2815 2816
#ifndef EMBEDDED_LIBRARY			// Avoid compiler warning
  char buff[STACK_BUFF_ALLOC];			// Max argument in function
#endif
unknown's avatar
unknown committed
2817 2818
  DBUG_ENTER("Item_udf_func::fix_fields");

2819
  if (check_stack_overrun(thd, STACK_MIN_SIZE, buff))
unknown's avatar
unknown committed
2820
    DBUG_RETURN(TRUE);				// Fatal error flag is set!
unknown's avatar
unknown committed
2821

2822
  udf_func *tmp_udf=find_udf(u_d->name.str,(uint) u_d->name.length,1);
unknown's avatar
unknown committed
2823 2824 2825

  if (!tmp_udf)
  {
2826
    my_error(ER_CANT_FIND_UDF, MYF(0), u_d->name.str, errno);
unknown's avatar
unknown committed
2827
    DBUG_RETURN(TRUE);
unknown's avatar
unknown committed
2828 2829 2830 2831 2832
  }
  u_d=tmp_udf;
  args=arguments;

  /* Fix all arguments */
2833
  func->maybe_null=0;
unknown's avatar
unknown committed
2834 2835 2836 2837 2838 2839 2840 2841 2842 2843
  used_tables_cache=0;
  const_item_cache=1;

  if ((f_args.arg_count=arg_count))
  {
    if (!(f_args.arg_type= (Item_result*)
	  sql_alloc(f_args.arg_count*sizeof(Item_result))))

    {
      free_udf(u_d);
unknown's avatar
unknown committed
2844
      DBUG_RETURN(TRUE);
unknown's avatar
unknown committed
2845 2846 2847 2848 2849 2850 2851
    }
    uint i;
    Item **arg,**arg_end;
    for (i=0, arg=arguments, arg_end=arguments+arg_count;
	 arg != arg_end ;
	 arg++,i++)
    {
unknown's avatar
unknown committed
2852
      if (!(*arg)->fixed &&
2853
          (*arg)->fix_fields(thd, arg))
unknown's avatar
unknown committed
2854
	DBUG_RETURN(1);
2855
      // we can't assign 'item' before, because fix_fields() can change arg
unknown's avatar
unknown committed
2856
      Item *item= *arg;
2857
      if (item->check_cols(1))
unknown's avatar
unknown committed
2858
	DBUG_RETURN(TRUE);
2859 2860 2861 2862 2863 2864 2865 2866 2867
      /*
	TODO: We should think about this. It is not always
	right way just to set an UDF result to return my_charset_bin
	if one argument has binary sorting order.
	The result collation should be calculated according to arguments
	derivations in some cases and should not in other cases.
	Moreover, some arguments can represent a numeric input
	which doesn't effect the result character set and collation.
	There is no a general rule for UDF. Everything depends on
unknown's avatar
unknown committed
2868
        the particular user defined function.
2869
      */
2870 2871
      if (item->collation.collation->state & MY_CS_BINSORT)
	func->collation.set(&my_charset_bin);
unknown's avatar
unknown committed
2872
      if (item->maybe_null)
unknown's avatar
unknown committed
2873
	func->maybe_null=1;
unknown's avatar
unknown committed
2874 2875 2876 2877
      func->with_sum_func= func->with_sum_func || item->with_sum_func;
      used_tables_cache|=item->used_tables();
      const_item_cache&=item->const_item();
      f_args.arg_type[i]=item->result_type();
unknown's avatar
unknown committed
2878
    }
unknown's avatar
unknown committed
2879
    //TODO: why all following memory is not allocated with 1 call of sql_alloc?
unknown's avatar
unknown committed
2880 2881
    if (!(buffers=new String[arg_count]) ||
	!(f_args.args= (char**) sql_alloc(arg_count * sizeof(char *))) ||
2882 2883 2884 2885 2886 2887 2888
	!(f_args.lengths= (ulong*) sql_alloc(arg_count * sizeof(long))) ||
	!(f_args.maybe_null= (char*) sql_alloc(arg_count * sizeof(char))) ||
	!(num_buffer= (char*) sql_alloc(arg_count *
					ALIGN_SIZE(sizeof(double)))) ||
	!(f_args.attributes= (char**) sql_alloc(arg_count * sizeof(char *))) ||
	!(f_args.attribute_lengths= (ulong*) sql_alloc(arg_count *
						       sizeof(long))))
unknown's avatar
unknown committed
2889 2890
    {
      free_udf(u_d);
unknown's avatar
unknown committed
2891
      DBUG_RETURN(TRUE);
unknown's avatar
unknown committed
2892 2893 2894 2895 2896 2897 2898 2899 2900 2901 2902 2903 2904 2905
    }
  }
  func->fix_length_and_dec();
  initid.max_length=func->max_length;
  initid.maybe_null=func->maybe_null;
  initid.const_item=const_item_cache;
  initid.decimals=func->decimals;
  initid.ptr=0;

  if (u_d->func_init)
  {
    char *to=num_buffer;
    for (uint i=0; i < arg_count; i++)
    {
2906 2907 2908 2909 2910 2911
      /*
       For a constant argument i, args->args[i] points to the argument value. 
       For non-constant, args->args[i] is NULL.
      */
      f_args.args[i]= NULL;         /* Non-const unless updated below. */

2912 2913 2914 2915
      f_args.lengths[i]= arguments[i]->max_length;
      f_args.maybe_null[i]= (char) arguments[i]->maybe_null;
      f_args.attributes[i]= arguments[i]->name;
      f_args.attribute_lengths[i]= arguments[i]->name_length;
unknown's avatar
unknown committed
2916

2917
      if (arguments[i]->const_item())
unknown's avatar
unknown committed
2918
      {
2919 2920 2921 2922 2923 2924
        switch (arguments[i]->result_type()) 
        {
        case STRING_RESULT:
        case DECIMAL_RESULT:
        {
          String *res= arguments[i]->val_str(&buffers[i]);
2925 2926
          if (arguments[i]->null_value)
            continue;
2927 2928 2929 2930 2931
          f_args.args[i]= (char*) res->ptr();
          break;
        }
        case INT_RESULT:
          *((longlong*) to)= arguments[i]->val_int();
2932 2933
          if (arguments[i]->null_value)
            continue;
2934 2935 2936 2937 2938
          f_args.args[i]= to;
          to+= ALIGN_SIZE(sizeof(longlong));
          break;
        case REAL_RESULT:
          *((double*) to)= arguments[i]->val_real();
2939 2940
          if (arguments[i]->null_value)
            continue;
2941 2942 2943 2944 2945 2946 2947 2948 2949
          f_args.args[i]= to;
          to+= ALIGN_SIZE(sizeof(double));
          break;
        case ROW_RESULT:
        default:
          // This case should never be chosen
          DBUG_ASSERT(0);
          break;
        }
unknown's avatar
unknown committed
2950 2951
      }
    }
2952
    thd->net.last_error[0]=0;
2953
    Udf_func_init init= u_d->func_init;
unknown's avatar
unknown committed
2954 2955
    if ((error=(uchar) init(&initid, &f_args, thd->net.last_error)))
    {
2956 2957
      my_error(ER_CANT_INITIALIZE_UDF, MYF(0),
               u_d->name.str, thd->net.last_error);
unknown's avatar
unknown committed
2958
      free_udf(u_d);
unknown's avatar
unknown committed
2959
      DBUG_RETURN(TRUE);
unknown's avatar
unknown committed
2960 2961 2962 2963
    }
    func->max_length=min(initid.max_length,MAX_BLOB_WIDTH);
    func->maybe_null=initid.maybe_null;
    const_item_cache=initid.const_item;
2964
    func->decimals=min(initid.decimals,NOT_FIXED_DEC);
unknown's avatar
unknown committed
2965 2966 2967 2968
  }
  initialized=1;
  if (error)
  {
2969 2970
    my_error(ER_CANT_INITIALIZE_UDF, MYF(0),
             u_d->name.str, ER(ER_UNKNOWN_ERROR));
unknown's avatar
unknown committed
2971
    DBUG_RETURN(TRUE);
unknown's avatar
unknown committed
2972
  }
unknown's avatar
unknown committed
2973
  DBUG_RETURN(FALSE);
unknown's avatar
unknown committed
2974 2975 2976 2977 2978 2979 2980 2981 2982 2983 2984 2985 2986 2987
}


bool udf_handler::get_arguments()
{
  if (error)
    return 1;					// Got an error earlier
  char *to= num_buffer;
  uint str_count=0;
  for (uint i=0; i < f_args.arg_count; i++)
  {
    f_args.args[i]=0;
    switch (f_args.arg_type[i]) {
    case STRING_RESULT:
unknown's avatar
unknown committed
2988
    case DECIMAL_RESULT:
unknown's avatar
unknown committed
2989 2990 2991 2992 2993 2994 2995 2996 2997 2998 2999 3000 3001 3002 3003 3004 3005 3006
      {
	String *res=args[i]->val_str(&buffers[str_count++]);
	if (!(args[i]->null_value))
	{
	  f_args.args[i]=    (char*) res->ptr();
	  f_args.lengths[i]= res->length();
	  break;
	}
      }
    case INT_RESULT:
      *((longlong*) to) = args[i]->val_int();
      if (!args[i]->null_value)
      {
	f_args.args[i]=to;
	to+= ALIGN_SIZE(sizeof(longlong));
      }
      break;
    case REAL_RESULT:
3007
      *((double*) to)= args[i]->val_real();
unknown's avatar
unknown committed
3008 3009 3010 3011 3012 3013
      if (!args[i]->null_value)
      {
	f_args.args[i]=to;
	to+= ALIGN_SIZE(sizeof(double));
      }
      break;
3014
    case ROW_RESULT:
unknown's avatar
unknown committed
3015
    default:
unknown's avatar
unknown committed
3016
      // This case should never be chosen
unknown's avatar
unknown committed
3017
      DBUG_ASSERT(0);
3018
      break;
unknown's avatar
unknown committed
3019 3020 3021 3022 3023 3024 3025 3026 3027
    }
  }
  return 0;
}

/* This returns (String*) 0 in case of NULL values */

String *udf_handler::val_str(String *str,String *save_str)
{
3028
  uchar is_null_tmp=0;
unknown's avatar
unknown committed
3029
  ulong res_length;
3030
  DBUG_ENTER("udf_handler::val_str");
unknown's avatar
unknown committed
3031 3032

  if (get_arguments())
3033
    DBUG_RETURN(0);
unknown's avatar
unknown committed
3034 3035 3036 3037 3038 3039 3040 3041 3042
  char * (*func)(UDF_INIT *, UDF_ARGS *, char *, ulong *, uchar *, uchar *)=
    (char* (*)(UDF_INIT *, UDF_ARGS *, char *, ulong *, uchar *, uchar *))
    u_d->func;

  if ((res_length=str->alloced_length()) < MAX_FIELD_WIDTH)
  {						// This happens VERY seldom
    if (str->alloc(MAX_FIELD_WIDTH))
    {
      error=1;
3043
      DBUG_RETURN(0);
unknown's avatar
unknown committed
3044 3045
    }
  }
3046 3047
  char *res=func(&initid, &f_args, (char*) str->ptr(), &res_length,
		 &is_null_tmp, &error);
3048
  DBUG_PRINT("info", ("udf func returned, res_length: %lu", res_length));
3049
  if (is_null_tmp || !res || error)		// The !res is for safety
unknown's avatar
unknown committed
3050
  {
3051 3052
    DBUG_PRINT("info", ("Null or error"));
    DBUG_RETURN(0);
unknown's avatar
unknown committed
3053 3054 3055 3056
  }
  if (res == str->ptr())
  {
    str->length(res_length);
3057 3058
    DBUG_PRINT("exit", ("str: %s", str->ptr()));
    DBUG_RETURN(str);
unknown's avatar
unknown committed
3059
  }
3060
  save_str->set(res, res_length, str->charset());
3061 3062
  DBUG_PRINT("exit", ("save_str: %s", save_str->ptr()));
  DBUG_RETURN(save_str);
unknown's avatar
unknown committed
3063 3064 3065
}


3066 3067 3068 3069
/*
  For the moment, UDF functions are returning DECIMAL values as strings
*/

unknown's avatar
unknown committed
3070 3071 3072 3073 3074 3075 3076 3077 3078 3079 3080 3081 3082 3083 3084 3085 3086 3087 3088 3089
my_decimal *udf_handler::val_decimal(my_bool *null_value, my_decimal *dec_buf)
{
  char buf[DECIMAL_MAX_STR_LENGTH+1], *end;
  ulong res_length= DECIMAL_MAX_STR_LENGTH;

  if (get_arguments())
  {
    *null_value=1;
    return 0;
  }
  char *(*func)(UDF_INIT *, UDF_ARGS *, char *, ulong *, uchar *, uchar *)=
    (char* (*)(UDF_INIT *, UDF_ARGS *, char *, ulong *, uchar *, uchar *))
    u_d->func;

  char *res= func(&initid, &f_args, buf, &res_length, &is_null, &error);
  if (is_null || error)
  {
    *null_value= 1;
    return 0;
  }
3090 3091
  end= res+ res_length;
  str2my_decimal(E_DEC_FATAL_ERROR, res, dec_buf, &end);
unknown's avatar
unknown committed
3092 3093 3094
  return dec_buf;
}

unknown's avatar
unknown committed
3095

3096 3097 3098 3099 3100 3101
void Item_udf_func::cleanup()
{
  udf.cleanup();
  Item_func::cleanup();
}

unknown's avatar
unknown committed
3102

3103 3104 3105 3106 3107 3108 3109 3110 3111 3112 3113 3114 3115 3116
void Item_udf_func::print(String *str)
{
  str->append(func_name());
  str->append('(');
  for (uint i=0 ; i < arg_count ; i++)
  {
    if (i != 0)
      str->append(',');
    args[i]->print_item_w_name(str);
  }
  str->append(')');
}


3117
double Item_func_udf_float::val_real()
unknown's avatar
unknown committed
3118
{
3119
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
3120 3121 3122 3123 3124 3125 3126 3127 3128
  DBUG_ENTER("Item_func_udf_float::val");
  DBUG_PRINT("info",("result_type: %d  arg_count: %d",
		     args[0]->result_type(), arg_count));
  DBUG_RETURN(udf.val(&null_value));
}


String *Item_func_udf_float::val_str(String *str)
{
3129
  DBUG_ASSERT(fixed == 1);
3130
  double nr= val_real();
unknown's avatar
unknown committed
3131 3132
  if (null_value)
    return 0;					/* purecov: inspected */
unknown's avatar
unknown committed
3133
  str->set(nr,decimals,&my_charset_bin);
unknown's avatar
unknown committed
3134 3135 3136 3137 3138 3139
  return str;
}


longlong Item_func_udf_int::val_int()
{
3140
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
3141 3142 3143 3144 3145 3146 3147
  DBUG_ENTER("Item_func_udf_int::val_int");
  DBUG_RETURN(udf.val_int(&null_value));
}


String *Item_func_udf_int::val_str(String *str)
{
3148
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
3149 3150 3151
  longlong nr=val_int();
  if (null_value)
    return 0;
3152
  if (!unsigned_flag)
unknown's avatar
unknown committed
3153
    str->set(nr,&my_charset_bin);
3154
  else
unknown's avatar
unknown committed
3155
    str->set((ulonglong) nr,&my_charset_bin);
unknown's avatar
unknown committed
3156 3157 3158
  return str;
}

unknown's avatar
unknown committed
3159 3160 3161 3162

longlong Item_func_udf_decimal::val_int()
{
  my_decimal dec_buf, *dec= udf.val_decimal(&null_value, &dec_buf);
3163
  longlong result;
unknown's avatar
unknown committed
3164 3165 3166 3167 3168 3169 3170 3171 3172 3173
  if (null_value)
    return 0;
  my_decimal2int(E_DEC_FATAL_ERROR, dec, unsigned_flag, &result);
  return result;
}


double Item_func_udf_decimal::val_real()
{
  my_decimal dec_buf, *dec= udf.val_decimal(&null_value, &dec_buf);
3174
  double result;
unknown's avatar
unknown committed
3175 3176 3177 3178 3179 3180 3181 3182 3183 3184 3185 3186 3187 3188 3189 3190 3191 3192 3193 3194 3195 3196 3197 3198 3199 3200 3201 3202 3203 3204 3205 3206 3207 3208 3209 3210 3211
  if (null_value)
    return 0.0;
  my_decimal2double(E_DEC_FATAL_ERROR, dec, &result);
  return result;
}


my_decimal *Item_func_udf_decimal::val_decimal(my_decimal *dec_buf)
{
  DBUG_ASSERT(fixed == 1);
  DBUG_ENTER("Item_func_udf_decimal::val_decimal");
  DBUG_PRINT("info",("result_type: %d  arg_count: %d",
                     args[0]->result_type(), arg_count));

  DBUG_RETURN(udf.val_decimal(&null_value, dec_buf));
}


String *Item_func_udf_decimal::val_str(String *str)
{
  my_decimal dec_buf, *dec= udf.val_decimal(&null_value, &dec_buf);
  if (null_value)
    return 0;
  if (str->length() < DECIMAL_MAX_STR_LENGTH)
    str->length(DECIMAL_MAX_STR_LENGTH);
  my_decimal_round(E_DEC_FATAL_ERROR, dec, decimals, FALSE, &dec_buf);
  my_decimal2string(E_DEC_FATAL_ERROR, &dec_buf, 0, 0, '0', str);
  return str;
}


void Item_func_udf_decimal::fix_length_and_dec()
{
  fix_num_length_and_dec();
}


unknown's avatar
unknown committed
3212 3213 3214 3215 3216 3217 3218 3219 3220 3221 3222 3223 3224
/* Default max_length is max argument length */

void Item_func_udf_str::fix_length_and_dec()
{
  DBUG_ENTER("Item_func_udf_str::fix_length_and_dec");
  max_length=0;
  for (uint i = 0; i < arg_count; i++)
    set_if_bigger(max_length,args[i]->max_length);
  DBUG_VOID_RETURN;
}

String *Item_func_udf_str::val_str(String *str)
{
3225
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
3226 3227 3228 3229 3230
  String *res=udf.val_str(str,&str_value);
  null_value = !res;
  return res;
}

3231 3232

/*
3233 3234
   This has to come last in the udf_handler methods, or C for AIX
   version 6.0.0.0 fails to compile with debugging enabled. (Yes, really.)
3235 3236 3237 3238
 */

udf_handler::~udf_handler()
{
3239 3240
  /* Everything should be properly cleaned up by this moment. */
  DBUG_ASSERT(not_original || !(initialized || buffers));
3241 3242
}

unknown's avatar
unknown committed
3243 3244 3245 3246 3247 3248 3249 3250 3251 3252 3253
#else
bool udf_handler::get_arguments() { return 0; }
#endif /* HAVE_DLOPEN */

/*
** User level locks
*/

pthread_mutex_t LOCK_user_locks;
static HASH hash_user_locks;

3254
class User_level_lock
unknown's avatar
unknown committed
3255 3256 3257 3258 3259 3260 3261 3262 3263
{
  char *key;
  uint key_length;

public:
  int count;
  bool locked;
  pthread_cond_t cond;
  pthread_t thread;
unknown's avatar
SCRUM  
unknown committed
3264
  ulong thread_id;
unknown's avatar
unknown committed
3265

3266
  User_level_lock(const char *key_arg,uint length, ulong id) 
unknown's avatar
SCRUM  
unknown committed
3267
    :key_length(length),count(1),locked(1), thread_id(id)
unknown's avatar
unknown committed
3268 3269 3270 3271 3272
  {
    key=(char*) my_memdup((byte*) key_arg,length,MYF(0));
    pthread_cond_init(&cond,NULL);
    if (key)
    {
unknown's avatar
SCRUM  
unknown committed
3273
      if (my_hash_insert(&hash_user_locks,(byte*) this))
unknown's avatar
unknown committed
3274 3275 3276 3277 3278 3279
      {
	my_free((gptr) key,MYF(0));
	key=0;
      }
    }
  }
3280
  ~User_level_lock()
unknown's avatar
unknown committed
3281 3282 3283 3284 3285 3286 3287 3288 3289
  {
    if (key)
    {
      hash_delete(&hash_user_locks,(byte*) this);
      my_free((gptr) key,MYF(0));
    }
    pthread_cond_destroy(&cond);
  }
  inline bool initialized() { return key != 0; }
3290 3291 3292
  friend void item_user_lock_release(User_level_lock *ull);
  friend char *ull_get_key(const User_level_lock *ull, uint *length,
                           my_bool not_used);
unknown's avatar
unknown committed
3293 3294
};

3295
char *ull_get_key(const User_level_lock *ull, uint *length,
unknown's avatar
unknown committed
3296 3297 3298 3299 3300 3301
		  my_bool not_used __attribute__((unused)))
{
  *length=(uint) ull->key_length;
  return (char*) ull->key;
}

3302 3303 3304

static bool item_user_lock_inited= 0;

unknown's avatar
unknown committed
3305 3306
void item_user_lock_init(void)
{
3307
  pthread_mutex_init(&LOCK_user_locks,MY_MUTEX_INIT_SLOW);
unknown's avatar
unknown committed
3308 3309
  hash_init(&hash_user_locks,system_charset_info,
	    16,0,0,(hash_get_key) ull_get_key,NULL,0);
3310
  item_user_lock_inited= 1;
unknown's avatar
unknown committed
3311 3312 3313 3314
}

void item_user_lock_free(void)
{
3315 3316 3317 3318 3319 3320
  if (item_user_lock_inited)
  {
    item_user_lock_inited= 0;
    hash_free(&hash_user_locks);
    pthread_mutex_destroy(&LOCK_user_locks);
  }
unknown's avatar
unknown committed
3321 3322
}

3323
void item_user_lock_release(User_level_lock *ull)
unknown's avatar
unknown committed
3324 3325
{
  ull->locked=0;
3326
  ull->thread_id= 0;
unknown's avatar
unknown committed
3327 3328 3329 3330 3331 3332
  if (--ull->count)
    pthread_cond_signal(&ull->cond);
  else
    delete ull;
}

unknown's avatar
unknown committed
3333 3334 3335 3336 3337 3338 3339
/*
   Wait until we are at or past the given position in the master binlog
   on the slave
 */

longlong Item_master_pos_wait::val_int()
{
3340
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
3341 3342
  THD* thd = current_thd;
  String *log_name = args[0]->val_str(&value);
3343
  int event_count= 0;
unknown's avatar
unknown committed
3344

unknown's avatar
unknown committed
3345 3346 3347 3348 3349 3350
  null_value=0;
  if (thd->slave_thread || !log_name || !log_name->length())
  {
    null_value = 1;
    return 0;
  }
3351
#ifdef HAVE_REPLICATION
unknown's avatar
unknown committed
3352
  longlong pos = (ulong)args[1]->val_int();
3353 3354
  longlong timeout = (arg_count==3) ? args[2]->val_int() : 0 ;
  if ((event_count = active_mi->rli.wait_for_pos(thd, log_name, pos, timeout)) == -2)
unknown's avatar
unknown committed
3355 3356 3357 3358
  {
    null_value = 1;
    event_count=0;
  }
3359
#endif
unknown's avatar
unknown committed
3360 3361 3362
  return event_count;
}

3363 3364 3365 3366
#ifdef EXTRA_DEBUG
void debug_sync_point(const char* lock_name, uint lock_timeout)
{
  THD* thd=current_thd;
3367
  User_level_lock* ull;
3368
  struct timespec abstime;
3369
  int lock_name_len;
3370 3371 3372 3373 3374 3375 3376 3377 3378
  lock_name_len=strlen(lock_name);
  pthread_mutex_lock(&LOCK_user_locks);

  if (thd->ull)
  {
    item_user_lock_release(thd->ull);
    thd->ull=0;
  }

3379 3380 3381 3382 3383
  /*
    If the lock has not been aquired by some client, we do not want to
    create an entry for it, since we immediately release the lock. In
    this case, we will not be waiting, but rather, just waste CPU and
    memory on the whole deal
3384
  */
3385
  if (!(ull= ((User_level_lock*) hash_search(&hash_user_locks, lock_name,
3386 3387 3388 3389 3390 3391 3392
				 lock_name_len))))
  {
    pthread_mutex_unlock(&LOCK_user_locks);
    return;
  }
  ull->count++;

3393 3394 3395 3396
  /*
    Structure is now initialized.  Try to get the lock.
    Set up control struct to allow others to abort locks
  */
3397 3398 3399 3400
  thd->proc_info="User lock";
  thd->mysys_var->current_mutex= &LOCK_user_locks;
  thd->mysys_var->current_cond=  &ull->cond;

3401
  set_timespec(abstime,lock_timeout);
unknown's avatar
unknown committed
3402 3403 3404 3405 3406 3407 3408
  while (ull->locked && !thd->killed)
  {
    int error= pthread_cond_timedwait(&ull->cond, &LOCK_user_locks, &abstime);
    if (error == ETIMEDOUT || error == ETIME)
      break;
  }

3409 3410 3411 3412 3413 3414 3415 3416 3417 3418 3419 3420 3421 3422 3423 3424 3425 3426 3427 3428 3429 3430 3431 3432 3433 3434 3435 3436
  if (ull->locked)
  {
    if (!--ull->count)
      delete ull;				// Should never happen
  }
  else
  {
    ull->locked=1;
    ull->thread=thd->real_id;
    thd->ull=ull;
  }
  pthread_mutex_unlock(&LOCK_user_locks);
  pthread_mutex_lock(&thd->mysys_var->mutex);
  thd->proc_info=0;
  thd->mysys_var->current_mutex= 0;
  thd->mysys_var->current_cond=  0;
  pthread_mutex_unlock(&thd->mysys_var->mutex);
  pthread_mutex_lock(&LOCK_user_locks);
  if (thd->ull)
  {
    item_user_lock_release(thd->ull);
    thd->ull=0;
  }
  pthread_mutex_unlock(&LOCK_user_locks);
}

#endif

unknown's avatar
unknown committed
3437 3438 3439 3440 3441 3442 3443 3444 3445
/*
  Get a user level lock. If the thread has an old lock this is first released.
  Returns 1:  Got lock
  Returns 0:  Timeout
  Returns NULL: Error
*/

longlong Item_func_get_lock::val_int()
{
3446
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
3447 3448 3449 3450
  String *res=args[0]->val_str(&value);
  longlong timeout=args[1]->val_int();
  struct timespec abstime;
  THD *thd=current_thd;
3451
  User_level_lock *ull;
unknown's avatar
unknown committed
3452
  int error;
3453
  DBUG_ENTER("Item_func_get_lock::val_int");
unknown's avatar
unknown committed
3454

3455 3456 3457 3458 3459 3460 3461 3462
  /*
    In slave thread no need to get locks, everything is serialized. Anyway
    there is no way to make GET_LOCK() work on slave like it did on master
    (i.e. make it return exactly the same value) because we don't have the
    same other concurrent threads environment. No matter what we return here,
    it's not guaranteed to be same as on master.
  */
  if (thd->slave_thread)
3463
    DBUG_RETURN(1);
3464

unknown's avatar
unknown committed
3465 3466 3467 3468 3469 3470
  pthread_mutex_lock(&LOCK_user_locks);

  if (!res || !res->length())
  {
    pthread_mutex_unlock(&LOCK_user_locks);
    null_value=1;
3471
    DBUG_RETURN(0);
unknown's avatar
unknown committed
3472
  }
3473 3474
  DBUG_PRINT("info", ("lock %.*s, thd=%ld", res->length(), res->ptr(),
                      (long) thd->real_id));
unknown's avatar
unknown committed
3475 3476 3477 3478 3479 3480 3481 3482
  null_value=0;

  if (thd->ull)
  {
    item_user_lock_release(thd->ull);
    thd->ull=0;
  }

3483 3484 3485
  if (!(ull= ((User_level_lock *) hash_search(&hash_user_locks,
                                              (byte*) res->ptr(),
                                              res->length()))))
unknown's avatar
unknown committed
3486
  {
3487
    ull=new User_level_lock(res->ptr(),res->length(), thd->thread_id);
unknown's avatar
unknown committed
3488 3489 3490 3491 3492
    if (!ull || !ull->initialized())
    {
      delete ull;
      pthread_mutex_unlock(&LOCK_user_locks);
      null_value=1;				// Probably out of memory
3493
      DBUG_RETURN(0);
unknown's avatar
unknown committed
3494 3495
    }
    ull->thread=thd->real_id;
3496
    ull->thread_id=thd->thread_id;
unknown's avatar
unknown committed
3497 3498
    thd->ull=ull;
    pthread_mutex_unlock(&LOCK_user_locks);
3499 3500
    DBUG_PRINT("info", ("made new lock"));
    DBUG_RETURN(1);				// Got new lock
unknown's avatar
unknown committed
3501 3502
  }
  ull->count++;
3503
  DBUG_PRINT("info", ("ull->count=%d", ull->count));
unknown's avatar
unknown committed
3504

3505 3506 3507 3508
  /*
    Structure is now initialized.  Try to get the lock.
    Set up control struct to allow others to abort locks.
  */
unknown's avatar
unknown committed
3509 3510 3511 3512
  thd->proc_info="User lock";
  thd->mysys_var->current_mutex= &LOCK_user_locks;
  thd->mysys_var->current_cond=  &ull->cond;

3513
  set_timespec(abstime,timeout);
unknown's avatar
unknown committed
3514 3515 3516
  error= 0;
  while (ull->locked && !thd->killed)
  {
3517
    DBUG_PRINT("info", ("waiting on lock"));
unknown's avatar
unknown committed
3518 3519
    error= pthread_cond_timedwait(&ull->cond,&LOCK_user_locks,&abstime);
    if (error == ETIMEDOUT || error == ETIME)
3520 3521
    {
      DBUG_PRINT("info", ("lock wait timeout"));
unknown's avatar
unknown committed
3522
      break;
3523
    }
unknown's avatar
unknown committed
3524 3525 3526
    error= 0;
  }

unknown's avatar
unknown committed
3527 3528 3529
  if (ull->locked)
  {
    if (!--ull->count)
unknown's avatar
unknown committed
3530 3531
    {
      DBUG_ASSERT(0);
unknown's avatar
unknown committed
3532
      delete ull;				// Should never happen
unknown's avatar
unknown committed
3533 3534
    }
    if (!error)                                 // Killed (thd->killed != 0)
unknown's avatar
unknown committed
3535 3536 3537 3538 3539
    {
      error=1;
      null_value=1;				// Return NULL
    }
  }
unknown's avatar
unknown committed
3540
  else                                          // We got the lock
unknown's avatar
unknown committed
3541 3542 3543
  {
    ull->locked=1;
    ull->thread=thd->real_id;
3544
    ull->thread_id= thd->thread_id;
unknown's avatar
unknown committed
3545 3546
    thd->ull=ull;
    error=0;
3547
    DBUG_PRINT("info", ("got the lock"));
unknown's avatar
unknown committed
3548 3549 3550 3551 3552 3553 3554 3555 3556
  }
  pthread_mutex_unlock(&LOCK_user_locks);

  pthread_mutex_lock(&thd->mysys_var->mutex);
  thd->proc_info=0;
  thd->mysys_var->current_mutex= 0;
  thd->mysys_var->current_cond=  0;
  pthread_mutex_unlock(&thd->mysys_var->mutex);

3557
  DBUG_RETURN(!error ? 1 : 0);
unknown's avatar
unknown committed
3558 3559 3560 3561
}


/*
3562 3563 3564 3565 3566
  Release a user level lock.
  Return:
    1 if lock released
    0 if lock wasn't held
    (SQL) NULL if no such lock
unknown's avatar
unknown committed
3567 3568 3569 3570
*/

longlong Item_func_release_lock::val_int()
{
3571
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
3572
  String *res=args[0]->val_str(&value);
3573
  User_level_lock *ull;
unknown's avatar
unknown committed
3574
  longlong result;
3575 3576
  THD *thd=current_thd;
  DBUG_ENTER("Item_func_release_lock::val_int");
unknown's avatar
unknown committed
3577 3578 3579
  if (!res || !res->length())
  {
    null_value=1;
3580
    DBUG_RETURN(0);
unknown's avatar
unknown committed
3581
  }
3582
  DBUG_PRINT("info", ("lock %.*s", res->length(), res->ptr()));
unknown's avatar
unknown committed
3583 3584 3585 3586
  null_value=0;

  result=0;
  pthread_mutex_lock(&LOCK_user_locks);
3587 3588 3589
  if (!(ull= ((User_level_lock*) hash_search(&hash_user_locks,
                                             (const byte*) res->ptr(),
                                             res->length()))))
unknown's avatar
unknown committed
3590 3591 3592 3593 3594
  {
    null_value=1;
  }
  else
  {
3595 3596 3597 3598 3599
    DBUG_PRINT("info", ("ull->locked=%d ull->thread=%ld thd=%ld", 
                        (int) ull->locked,
                        (long)ull->thread,
                        (long)thd->real_id));
    if (ull->locked && pthread_equal(thd->real_id,ull->thread))
unknown's avatar
unknown committed
3600
    {
3601
      DBUG_PRINT("info", ("release lock"));
unknown's avatar
unknown committed
3602 3603
      result=1;					// Release is ok
      item_user_lock_release(ull);
3604
      thd->ull=0;
unknown's avatar
unknown committed
3605 3606 3607
    }
  }
  pthread_mutex_unlock(&LOCK_user_locks);
3608
  DBUG_RETURN(result);
unknown's avatar
unknown committed
3609 3610 3611
}


3612 3613 3614 3615 3616 3617 3618 3619 3620 3621 3622 3623 3624 3625 3626 3627 3628
bool Item_func_last_insert_id::fix_fields(THD *thd, Item **ref)
{
  DBUG_ASSERT(fixed == 0);

  if (Item_int_func::fix_fields(thd, ref))
    return TRUE;

  if (arg_count == 0)
  {
    if (!thd->last_insert_id_used)
    {
      /*
        As this statement calls LAST_INSERT_ID(), set
        THD::last_insert_id_used and remember first generated insert
        id of the previous statement in THD::current_insert_id.
      */
      thd->last_insert_id_used= TRUE;
3629
      thd->last_insert_id_used_bin_log= TRUE;
3630 3631 3632 3633 3634 3635 3636 3637 3638 3639 3640
      thd->current_insert_id= thd->last_insert_id;
    }
    null_value= FALSE;
  }

  thd->lex->uncacheable(UNCACHEABLE_SIDEEFFECT);

  return FALSE;
}


3641
longlong Item_func_last_insert_id::val_int()
unknown's avatar
unknown committed
3642
{
unknown's avatar
unknown committed
3643
  THD *thd= current_thd;
3644
  DBUG_ASSERT(fixed == 1);
3645 3646
  if (arg_count)
  {
unknown's avatar
unknown committed
3647 3648 3649
    longlong value= args[0]->val_int();
    thd->insert_id(value);
    null_value= args[0]->null_value;
3650
    return value;
3651
  }
3652 3653

  return thd->current_insert_id;
unknown's avatar
unknown committed
3654 3655
}

3656

unknown's avatar
unknown committed
3657 3658 3659 3660
/* This function is just used to test speed of different functions */

longlong Item_func_benchmark::val_int()
{
3661
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
3662
  char buff[MAX_FIELD_WIDTH];
unknown's avatar
unknown committed
3663
  String tmp(buff,sizeof(buff), &my_charset_bin);
3664
  my_decimal tmp_decimal;
unknown's avatar
unknown committed
3665 3666 3667 3668 3669 3670
  THD *thd=current_thd;

  for (ulong loop=0 ; loop < loop_count && !thd->killed; loop++)
  {
    switch (args[0]->result_type()) {
    case REAL_RESULT:
3671
      (void) args[0]->val_real();
unknown's avatar
unknown committed
3672 3673 3674 3675 3676 3677 3678
      break;
    case INT_RESULT:
      (void) args[0]->val_int();
      break;
    case STRING_RESULT:
      (void) args[0]->val_str(&tmp);
      break;
3679 3680 3681
    case DECIMAL_RESULT:
      (void) args[0]->val_decimal(&tmp_decimal);
      break;
3682
    case ROW_RESULT:
unknown's avatar
unknown committed
3683
    default:
unknown's avatar
unknown committed
3684
      // This case should never be chosen
unknown's avatar
unknown committed
3685 3686
      DBUG_ASSERT(0);
      return 0;
unknown's avatar
unknown committed
3687 3688 3689 3690 3691
    }
  }
  return 0;
}

3692

3693 3694
void Item_func_benchmark::print(String *str)
{
3695
  str->append(STRING_WITH_LEN("benchmark("));
3696
  char buffer[20];
unknown's avatar
unknown committed
3697 3698 3699
  // my_charset_bin is good enough for numbers
  String st(buffer, sizeof(buffer), &my_charset_bin);
  st.set((ulonglong)loop_count, &my_charset_bin);
3700 3701 3702 3703 3704 3705
  str->append(st);
  str->append(',');
  args[0]->print(str);
  str->append(')');
}

unknown's avatar
unknown committed
3706

3707 3708 3709 3710
/* This function is just used to create tests with time gaps */

longlong Item_func_sleep::val_int()
{
3711 3712 3713
  THD *thd= current_thd;
  struct timespec abstime;
  pthread_cond_t cond;
3714
  int error;
3715

3716
  DBUG_ASSERT(fixed == 1);
3717

3718
  double time= args[0]->val_real();
3719 3720 3721 3722 3723 3724 3725 3726
  set_timespec_nsec(abstime, (ulonglong)(time * ULL(1000000000)));

  pthread_cond_init(&cond, NULL);
  pthread_mutex_lock(&LOCK_user_locks);

  thd->mysys_var->current_mutex= &LOCK_user_locks;
  thd->mysys_var->current_cond=  &cond;

unknown's avatar
unknown committed
3727 3728 3729 3730 3731 3732 3733 3734
  error= 0;
  while (!thd->killed)
  {
    error= pthread_cond_timedwait(&cond, &LOCK_user_locks, &abstime);
    if (error == ETIMEDOUT || error == ETIME)
      break;
    error= 0;
  }
3735 3736 3737 3738 3739 3740 3741 3742 3743

  pthread_mutex_lock(&thd->mysys_var->mutex);
  thd->mysys_var->current_mutex= 0;
  thd->mysys_var->current_cond=  0;
  pthread_mutex_unlock(&thd->mysys_var->mutex);

  pthread_mutex_unlock(&LOCK_user_locks);
  pthread_cond_destroy(&cond);

unknown's avatar
unknown committed
3744
  return test(!error); 		// Return 1 killed
3745 3746 3747
}


unknown's avatar
unknown committed
3748 3749 3750 3751 3752 3753 3754 3755 3756 3757 3758 3759 3760 3761 3762 3763 3764 3765 3766 3767 3768
#define extra_size sizeof(double)

static user_var_entry *get_variable(HASH *hash, LEX_STRING &name,
				    bool create_if_not_exists)
{
  user_var_entry *entry;

  if (!(entry = (user_var_entry*) hash_search(hash, (byte*) name.str,
					      name.length)) &&
      create_if_not_exists)
  {
    uint size=ALIGN_SIZE(sizeof(user_var_entry))+name.length+1+extra_size;
    if (!hash_inited(hash))
      return 0;
    if (!(entry = (user_var_entry*) my_malloc(size,MYF(MY_WME))))
      return 0;
    entry->name.str=(char*) entry+ ALIGN_SIZE(sizeof(user_var_entry))+
      extra_size;
    entry->name.length=name.length;
    entry->value=0;
    entry->length=0;
3769
    entry->update_query_id=0;
3770
    entry->collation.set(NULL, DERIVATION_IMPLICIT);
unknown's avatar
unknown committed
3771
    entry->unsigned_flag= 0;
3772 3773 3774 3775 3776 3777 3778 3779 3780 3781
    /*
      If we are here, we were called from a SET or a query which sets a
      variable. Imagine it is this:
      INSERT INTO t SELECT @a:=10, @a:=@a+1.
      Then when we have a Item_func_get_user_var (because of the @a+1) so we
      think we have to write the value of @a to the binlog. But before that,
      we have a Item_func_set_user_var to create @a (@a:=10), in this we mark
      the variable as "already logged" (line below) so that it won't be logged
      by Item_func_get_user_var (because that's not necessary).
    */
unknown's avatar
unknown committed
3782
    entry->used_query_id=current_thd->query_id;
unknown's avatar
unknown committed
3783 3784
    entry->type=STRING_RESULT;
    memcpy(entry->name.str, name.str, name.length+1);
unknown's avatar
SCRUM  
unknown committed
3785
    if (my_hash_insert(hash,(byte*) entry))
unknown's avatar
unknown committed
3786 3787 3788 3789 3790 3791 3792 3793
    {
      my_free((char*) entry,MYF(0));
      return 0;
    }
  }
  return entry;
}

3794
/*
3795 3796
  When a user variable is updated (in a SET command or a query like
  SELECT @a:= ).
3797
*/
3798

3799
bool Item_func_set_user_var::fix_fields(THD *thd, Item **ref)
unknown's avatar
unknown committed
3800
{
3801
  DBUG_ASSERT(fixed == 0);
3802
  /* fix_fields will call Item_func_set_user_var::fix_length_and_dec */
3803
  if (Item_func::fix_fields(thd, ref) ||
unknown's avatar
unknown committed
3804
      !(entry= get_variable(&thd->user_vars, name, 1)))
unknown's avatar
unknown committed
3805
    return TRUE;
3806 3807 3808 3809 3810
  /* 
     Remember the last query which updated it, this way a query can later know
     if this variable is a constant item in the query (it is if update_query_id
     is different from query_id).
  */
3811
  entry->update_query_id= thd->query_id;
3812 3813 3814 3815 3816 3817 3818 3819 3820 3821 3822 3823 3824 3825 3826
  /*
    As it is wrong and confusing to associate any 
    character set with NULL, @a should be latin2
    after this query sequence:

      SET @a=_latin2'string';
      SET @a=NULL;

    I.e. the second query should not change the charset
    to the current default value, but should keep the 
    original value assigned during the first query.
    In order to do it, we don't copy charset
    from the argument if the argument is NULL
    and the variable has previously been initialized.
  */
3827 3828
  null_item= (args[0]->type() == NULL_ITEM);
  if (!entry->collation.collation || !null_item)
3829 3830
    entry->collation.set(args[0]->collation.collation, DERIVATION_IMPLICIT);
  collation.set(entry->collation.collation, DERIVATION_IMPLICIT);
3831
  cached_result_type= args[0]->result_type();
unknown's avatar
unknown committed
3832
  return FALSE;
unknown's avatar
unknown committed
3833 3834 3835 3836 3837 3838 3839 3840 3841
}


void
Item_func_set_user_var::fix_length_and_dec()
{
  maybe_null=args[0]->maybe_null;
  max_length=args[0]->max_length;
  decimals=args[0]->decimals;
3842
  collation.set(args[0]->collation.collation, DERIVATION_IMPLICIT);
unknown's avatar
unknown committed
3843 3844
}

3845

unknown's avatar
unknown committed
3846 3847 3848 3849 3850 3851 3852 3853 3854 3855 3856 3857
/*
  Set value to user variable.

  SYNOPSYS
    update_hash()
    entry    - pointer to structure representing variable
    set_null - should we set NULL value ?
    ptr      - pointer to buffer with new value
    length   - length of new value
    type     - type of new value
    cs       - charset info for new value
    dv       - derivation for new value
3858
    unsigned_arg - indiates if a value of type INT_RESULT is unsigned
unknown's avatar
unknown committed
3859 3860 3861 3862 3863 3864 3865

  RETURN VALUE
    False - success, True - failure
*/

static bool
update_hash(user_var_entry *entry, bool set_null, void *ptr, uint length,
3866 3867
            Item_result type, CHARSET_INFO *cs, Derivation dv,
            bool unsigned_arg)
unknown's avatar
unknown committed
3868
{
unknown's avatar
unknown committed
3869
  if (set_null)
unknown's avatar
unknown committed
3870 3871 3872 3873
  {
    char *pos= (char*) entry+ ALIGN_SIZE(sizeof(user_var_entry));
    if (entry->value && entry->value != pos)
      my_free(entry->value,MYF(0));
3874 3875
    entry->value= 0;
    entry->length= 0;
unknown's avatar
unknown committed
3876 3877 3878
  }
  else
  {
3879 3880
    if (type == STRING_RESULT)
      length++;					// Store strings with end \0
unknown's avatar
unknown committed
3881 3882 3883 3884 3885 3886 3887 3888 3889 3890 3891 3892 3893 3894 3895 3896 3897 3898 3899
    if (length <= extra_size)
    {
      /* Save value in value struct */
      char *pos= (char*) entry+ ALIGN_SIZE(sizeof(user_var_entry));
      if (entry->value != pos)
      {
	if (entry->value)
	  my_free(entry->value,MYF(0));
	entry->value=pos;
      }
    }
    else
    {
      /* Allocate variable */
      if (entry->length != length)
      {
	char *pos= (char*) entry+ ALIGN_SIZE(sizeof(user_var_entry));
	if (entry->value == pos)
	  entry->value=0;
3900 3901 3902
        entry->value= (char*) my_realloc(entry->value, length,
                                         MYF(MY_ALLOW_ZERO_PTR | MY_WME));
        if (!entry->value)
unknown's avatar
unknown committed
3903
	  return 1;
unknown's avatar
unknown committed
3904 3905
      }
    }
3906 3907 3908 3909 3910
    if (type == STRING_RESULT)
    {
      length--;					// Fix length change above
      entry->value[length]= 0;			// Store end \0
    }
unknown's avatar
unknown committed
3911
    memcpy(entry->value,ptr,length);
unknown's avatar
unknown committed
3912 3913
    if (type == DECIMAL_RESULT)
      ((my_decimal*)entry->value)->fix_buffer_pointer();
unknown's avatar
unknown committed
3914
    entry->length= length;
3915
    entry->collation.set(cs, dv);
unknown's avatar
unknown committed
3916
    entry->unsigned_flag= unsigned_arg;
unknown's avatar
unknown committed
3917
  }
3918
  entry->type=type;
3919
  return 0;
unknown's avatar
unknown committed
3920
}
unknown's avatar
unknown committed
3921

unknown's avatar
unknown committed
3922 3923

bool
3924 3925
Item_func_set_user_var::update_hash(void *ptr, uint length,
                                    Item_result res_type,
3926 3927
                                    CHARSET_INFO *cs, Derivation dv,
                                    bool unsigned_arg)
unknown's avatar
unknown committed
3928
{
3929 3930 3931 3932 3933
  /*
    If we set a variable explicitely to NULL then keep the old
    result type of the variable
  */
  if ((null_value= args[0]->null_value) && null_item)
3934
    res_type= entry->type;                      // Don't change type of item
unknown's avatar
unknown committed
3935
  if (::update_hash(entry, (null_value= args[0]->null_value),
3936
                    ptr, length, res_type, cs, dv, unsigned_arg))
unknown's avatar
unknown committed
3937 3938 3939 3940 3941 3942
  {
    current_thd->fatal_error();     // Probably end of memory
    null_value= 1;
    return 1;
  }
  return 0;
unknown's avatar
unknown committed
3943 3944 3945
}


3946 3947
/* Get the value of a variable as a double */

unknown's avatar
unknown committed
3948
double user_var_entry::val_real(my_bool *null_value)
unknown's avatar
unknown committed
3949
{
3950 3951 3952 3953 3954 3955 3956 3957
  if ((*null_value= (value == 0)))
    return 0.0;

  switch (type) {
  case REAL_RESULT:
    return *(double*) value;
  case INT_RESULT:
    return (double) *(longlong*) value;
unknown's avatar
unknown committed
3958 3959 3960 3961 3962 3963
  case DECIMAL_RESULT:
  {
    double result;
    my_decimal2double(E_DEC_FATAL_ERROR, (my_decimal *)value, &result);
    return result;
  }
3964
  case STRING_RESULT:
unknown's avatar
unknown committed
3965
    return my_atof(value);                      // This is null terminated
3966 3967 3968
  case ROW_RESULT:
    DBUG_ASSERT(1);				// Impossible
    break;
unknown's avatar
unknown committed
3969
  }
3970
  return 0.0;					// Impossible
unknown's avatar
unknown committed
3971 3972 3973
}


3974 3975 3976
/* Get the value of a variable as an integer */

longlong user_var_entry::val_int(my_bool *null_value)
unknown's avatar
unknown committed
3977
{
3978 3979 3980 3981 3982 3983 3984 3985
  if ((*null_value= (value == 0)))
    return LL(0);

  switch (type) {
  case REAL_RESULT:
    return (longlong) *(double*) value;
  case INT_RESULT:
    return *(longlong*) value;
unknown's avatar
unknown committed
3986 3987 3988
  case DECIMAL_RESULT:
  {
    longlong result;
3989
    my_decimal2int(E_DEC_FATAL_ERROR, (my_decimal *)value, 0, &result);
unknown's avatar
unknown committed
3990 3991
    return result;
  }
unknown's avatar
unknown committed
3992
  case STRING_RESULT:
unknown's avatar
unknown committed
3993 3994 3995 3996
  {
    int error;
    return my_strtoll10(value, (char**) 0, &error);// String is null terminated
  }
3997 3998 3999
  case ROW_RESULT:
    DBUG_ASSERT(1);				// Impossible
    break;
unknown's avatar
unknown committed
4000
  }
4001 4002 4003 4004 4005 4006 4007 4008 4009 4010 4011 4012 4013 4014
  return LL(0);					// Impossible
}


/* Get the value of a variable as a string */

String *user_var_entry::val_str(my_bool *null_value, String *str,
				uint decimals)
{
  if ((*null_value= (value == 0)))
    return (String*) 0;

  switch (type) {
  case REAL_RESULT:
unknown's avatar
unknown committed
4015
    str->set(*(double*) value, decimals, &my_charset_bin);
4016 4017
    break;
  case INT_RESULT:
4018 4019 4020 4021
    if (!unsigned_flag)
      str->set(*(longlong*) value, &my_charset_bin);
    else
      str->set(*(ulonglong*) value, &my_charset_bin);
4022
    break;
unknown's avatar
unknown committed
4023 4024 4025
  case DECIMAL_RESULT:
    my_decimal2string(E_DEC_FATAL_ERROR, (my_decimal *)value, 0, 0, 0, str);
    break;
4026
  case STRING_RESULT:
unknown's avatar
unknown committed
4027
    if (str->copy(value, length, collation.collation))
4028
      str= 0;					// EOM error
4029 4030 4031
  case ROW_RESULT:
    DBUG_ASSERT(1);				// Impossible
    break;
unknown's avatar
unknown committed
4032
  }
4033
  return(str);
unknown's avatar
unknown committed
4034 4035
}

unknown's avatar
unknown committed
4036 4037 4038 4039 4040 4041 4042 4043 4044 4045 4046 4047 4048 4049 4050 4051 4052 4053 4054 4055 4056 4057 4058 4059 4060 4061 4062
/* Get the value of a variable as a decimal */

my_decimal *user_var_entry::val_decimal(my_bool *null_value, my_decimal *val)
{
  if ((*null_value= (value == 0)))
    return 0;

  switch (type) {
  case REAL_RESULT:
    double2my_decimal(E_DEC_FATAL_ERROR, *(double*) value, val);
    break;
  case INT_RESULT:
    int2my_decimal(E_DEC_FATAL_ERROR, *(longlong*) value, 0, val);
    break;
  case DECIMAL_RESULT:
    val= (my_decimal *)value;
    break;
  case STRING_RESULT:
    str2my_decimal(E_DEC_FATAL_ERROR, value, length, collation.collation, val);
    break;
  case ROW_RESULT:
    DBUG_ASSERT(1);				// Impossible
    break;
  }
  return(val);
}

4063 4064
/*
  This functions is invoked on SET @variable or @variable:= expression.
unknown's avatar
unknown committed
4065
  Evaluate (and check expression), store results.
4066 4067 4068 4069 4070

  SYNOPSYS
    Item_func_set_user_var::check()

  NOTES
unknown's avatar
unknown committed
4071 4072
    For now it always return OK. All problem with value evaluating
    will be caught by thd->net.report_error check in sql_set_variables().
4073 4074

  RETURN
unknown's avatar
unknown committed
4075
    FALSE OK.
4076 4077 4078
*/

bool
4079
Item_func_set_user_var::check(bool use_result_field)
4080 4081
{
  DBUG_ENTER("Item_func_set_user_var::check");
unknown's avatar
unknown committed
4082 4083
  if (use_result_field && !result_field)
    use_result_field= FALSE;
4084 4085 4086 4087

  switch (cached_result_type) {
  case REAL_RESULT:
  {
4088 4089
    save_result.vreal= use_result_field ? result_field->val_real() :
                        args[0]->val_real();
4090 4091 4092 4093
    break;
  }
  case INT_RESULT:
  {
4094 4095 4096 4097
    save_result.vint= use_result_field ? result_field->val_int() :
                       args[0]->val_int();
    unsigned_flag= use_result_field ? ((Field_num*)result_field)->unsigned_flag:
                    args[0]->unsigned_flag;
4098 4099 4100 4101
    break;
  }
  case STRING_RESULT:
  {
4102 4103
    save_result.vstr= use_result_field ? result_field->val_str(&value) :
                       args[0]->val_str(&value);
4104 4105
    break;
  }
unknown's avatar
unknown committed
4106 4107
  case DECIMAL_RESULT:
  {
4108 4109 4110
    save_result.vdec= use_result_field ?
                       result_field->val_decimal(&decimal_buff) :
                       args[0]->val_decimal(&decimal_buff);
unknown's avatar
unknown committed
4111 4112
    break;
  }
4113 4114
  case ROW_RESULT:
  default:
unknown's avatar
unknown committed
4115
    // This case should never be chosen
4116 4117 4118
    DBUG_ASSERT(0);
    break;
  }
unknown's avatar
unknown committed
4119
  DBUG_RETURN(FALSE);
4120 4121
}

4122 4123 4124 4125 4126 4127 4128 4129 4130 4131 4132 4133

/*
  This functions is invoked on SET @variable or @variable:= expression.

  SYNOPSIS
    Item_func_set_user_var::update()

  NOTES
    We have to store the expression as such in the variable, independent of
    the value method used by the user

  RETURN
unknown's avatar
unknown committed
4134
    0	OK
4135 4136 4137 4138
    1	EOM Error

*/

unknown's avatar
unknown committed
4139 4140 4141
bool
Item_func_set_user_var::update()
{
4142 4143 4144 4145
  bool res;
  DBUG_ENTER("Item_func_set_user_var::update");
  LINT_INIT(res);

unknown's avatar
unknown committed
4146 4147
  switch (cached_result_type) {
  case REAL_RESULT:
unknown's avatar
unknown committed
4148
  {
4149
    res= update_hash((void*) &save_result.vreal,sizeof(save_result.vreal),
unknown's avatar
unknown committed
4150
		     REAL_RESULT, &my_charset_bin, DERIVATION_IMPLICIT, 0);
unknown's avatar
unknown committed
4151
    break;
unknown's avatar
unknown committed
4152
  }
unknown's avatar
unknown committed
4153
  case INT_RESULT:
4154
  {
4155
    res= update_hash((void*) &save_result.vint, sizeof(save_result.vint),
4156
                     INT_RESULT, &my_charset_bin, DERIVATION_IMPLICIT,
4157
                     unsigned_flag);
unknown's avatar
unknown committed
4158
    break;
unknown's avatar
unknown committed
4159
  }
unknown's avatar
unknown committed
4160
  case STRING_RESULT:
unknown's avatar
unknown committed
4161
  {
4162
    if (!save_result.vstr)					// Null value
unknown's avatar
unknown committed
4163
      res= update_hash((void*) 0, 0, STRING_RESULT, &my_charset_bin,
unknown's avatar
unknown committed
4164
		       DERIVATION_IMPLICIT, 0);
4165
    else
4166 4167 4168
      res= update_hash((void*) save_result.vstr->ptr(),
		       save_result.vstr->length(), STRING_RESULT,
		       save_result.vstr->charset(),
unknown's avatar
unknown committed
4169
		       DERIVATION_IMPLICIT, 0);
unknown's avatar
unknown committed
4170 4171
    break;
  }
unknown's avatar
unknown committed
4172 4173 4174 4175
  case DECIMAL_RESULT:
  {
    if (!save_result.vdec)					// Null value
      res= update_hash((void*) 0, 0, DECIMAL_RESULT, &my_charset_bin,
unknown's avatar
unknown committed
4176
                       DERIVATION_IMPLICIT, 0);
unknown's avatar
unknown committed
4177 4178 4179
    else
      res= update_hash((void*) save_result.vdec,
                       sizeof(my_decimal), DECIMAL_RESULT,
unknown's avatar
unknown committed
4180
                       &my_charset_bin, DERIVATION_IMPLICIT, 0);
unknown's avatar
unknown committed
4181 4182
    break;
  }
4183
  case ROW_RESULT:
unknown's avatar
unknown committed
4184
  default:
unknown's avatar
unknown committed
4185
    // This case should never be chosen
unknown's avatar
unknown committed
4186 4187 4188
    DBUG_ASSERT(0);
    break;
  }
4189
  DBUG_RETURN(res);
unknown's avatar
unknown committed
4190 4191 4192
}


4193
double Item_func_set_user_var::val_real()
unknown's avatar
unknown committed
4194
{
4195
  DBUG_ASSERT(fixed == 1);
4196
  check(0);
4197
  update();					// Store expression
unknown's avatar
unknown committed
4198
  return entry->val_real(&null_value);
unknown's avatar
unknown committed
4199 4200
}

4201
longlong Item_func_set_user_var::val_int()
unknown's avatar
unknown committed
4202
{
4203
  DBUG_ASSERT(fixed == 1);
4204
  check(0);
4205 4206
  update();					// Store expression
  return entry->val_int(&null_value);
unknown's avatar
unknown committed
4207 4208
}

4209
String *Item_func_set_user_var::val_str(String *str)
unknown's avatar
unknown committed
4210
{
4211
  DBUG_ASSERT(fixed == 1);
4212
  check(0);
4213 4214
  update();					// Store expression
  return entry->val_str(&null_value, str, decimals);
unknown's avatar
unknown committed
4215 4216 4217
}


unknown's avatar
unknown committed
4218 4219 4220
my_decimal *Item_func_set_user_var::val_decimal(my_decimal *val)
{
  DBUG_ASSERT(fixed == 1);
4221
  check(0);
unknown's avatar
unknown committed
4222 4223 4224 4225 4226
  update();					// Store expression
  return entry->val_decimal(&null_value, val);
}


unknown's avatar
unknown committed
4227
double Item_func_set_user_var::val_result()
4228 4229 4230 4231 4232 4233 4234 4235 4236 4237 4238 4239 4240 4241 4242
{
  DBUG_ASSERT(fixed == 1);
  check(TRUE);
  update();					// Store expression
  return entry->val_real(&null_value);
}

longlong Item_func_set_user_var::val_int_result()
{
  DBUG_ASSERT(fixed == 1);
  check(TRUE);
  update();					// Store expression
  return entry->val_int(&null_value);
}

unknown's avatar
unknown committed
4243
String *Item_func_set_user_var::str_result(String *str)
4244 4245 4246 4247 4248 4249 4250 4251 4252 4253 4254 4255 4256 4257 4258 4259 4260
{
  DBUG_ASSERT(fixed == 1);
  check(TRUE);
  update();					// Store expression
  return entry->val_str(&null_value, str, decimals);
}


my_decimal *Item_func_set_user_var::val_decimal_result(my_decimal *val)
{
  DBUG_ASSERT(fixed == 1);
  check(TRUE);
  update();					// Store expression
  return entry->val_decimal(&null_value, val);
}


unknown's avatar
unknown committed
4261 4262
void Item_func_set_user_var::print(String *str)
{
4263
  str->append(STRING_WITH_LEN("(@"));
4264
  str->append(name.str, name.length);
4265
  str->append(STRING_WITH_LEN(":="));
unknown's avatar
unknown committed
4266 4267 4268 4269 4270
  args[0]->print(str);
  str->append(')');
}


4271 4272
void Item_func_set_user_var::print_as_stmt(String *str)
{
4273
  str->append(STRING_WITH_LEN("set @"));
4274
  str->append(name.str, name.length);
4275
  str->append(STRING_WITH_LEN(":="));
4276 4277 4278 4279
  args[0]->print(str);
  str->append(')');
}

4280 4281 4282 4283 4284 4285 4286 4287 4288 4289
bool Item_func_set_user_var::send(Protocol *protocol, String *str_arg)
{
  if (result_field)
  {
    check(1);
    update();
    return protocol->store(result_field);
  }
  return Item::send(protocol, str_arg);
}
4290

unknown's avatar
unknown committed
4291 4292 4293 4294 4295 4296 4297 4298 4299 4300 4301 4302 4303
void Item_func_set_user_var::make_field(Send_field *tmp_field)
{
  if (result_field)
  {
    result_field->make_field(tmp_field);
    DBUG_ASSERT(tmp_field->table_name != 0);
    if (Item::name)
      tmp_field->col_name=Item::name;               // Use user supplied name
  }
  else
    Item::make_field(tmp_field);
}

4304 4305 4306 4307 4308 4309 4310 4311 4312 4313 4314 4315 4316 4317 4318 4319 4320 4321 4322 4323 4324 4325 4326 4327 4328 4329 4330 4331 4332 4333 4334 4335 4336 4337 4338 4339 4340 4341 4342

/*
  Save the value of a user variable into a field

  SYNOPSIS
    save_in_field()
      field           target field to save the value to
      no_conversion   flag indicating whether conversions are allowed

  DESCRIPTION
    Save the function value into a field and update the user variable
    accordingly. If a result field is defined and the target field doesn't
    coincide with it then the value from the result field will be used as
    the new value of the user variable.

    The reason to have this method rather than simply using the result
    field in the val_xxx() methods is that the value from the result field
    not always can be used when the result field is defined.
    Let's consider the following cases:
    1) when filling a tmp table the result field is defined but the value of it
    is undefined because it has to be produced yet. Thus we can't use it.
    2) on execution of an INSERT ... SELECT statement the save_in_field()
    function will be called to fill the data in the new record. If the SELECT
    part uses a tmp table then the result field is defined and should be
    used in order to get the correct result.

    The difference between the SET_USER_VAR function and regular functions
    like CONCAT is that the Item_func objects for the regular functions are
    replaced by Item_field objects after the values of these functions have
    been stored in a tmp table. Yet an object of the Item_field class cannot
    be used to update a user variable.
    Due to this we have to handle the result field in a special way here and
    in the Item_func_set_user_var::send() function.

  RETURN VALUES
    FALSE       Ok
    TRUE        Error
*/

4343 4344
int Item_func_set_user_var::save_in_field(Field *field, bool no_conversions,
                                          bool can_use_result_field)
4345
{
4346 4347
  bool use_result_field= (!can_use_result_field ? 0 :
                          (result_field && result_field != field));
4348 4349 4350 4351 4352 4353 4354 4355 4356 4357 4358 4359 4360 4361 4362 4363 4364 4365 4366 4367 4368 4369 4370 4371 4372 4373 4374 4375 4376 4377 4378 4379 4380 4381 4382 4383 4384 4385 4386 4387 4388 4389 4390 4391 4392 4393 4394 4395 4396 4397 4398 4399 4400 4401 4402 4403 4404
  int error;

  /* Update the value of the user variable */
  check(use_result_field);
  update();

  if (result_type() == STRING_RESULT ||
      result_type() == REAL_RESULT &&
      field->result_type() == STRING_RESULT)
  {
    String *result;
    CHARSET_INFO *cs= collation.collation;
    char buff[MAX_FIELD_WIDTH];		// Alloc buffer for small columns
    str_value.set_quick(buff, sizeof(buff), cs);
    result= entry->val_str(&null_value, &str_value, decimals);

    if (null_value)
    {
      str_value.set_quick(0, 0, cs);
      return set_field_to_null_with_conversions(field, no_conversions);
    }

    /* NOTE: If null_value == FALSE, "result" must be not NULL.  */

    field->set_notnull();
    error=field->store(result->ptr(),result->length(),cs);
    str_value.set_quick(0, 0, cs);
  }
  else if (result_type() == REAL_RESULT)
  {
    double nr= entry->val_real(&null_value);
    if (null_value)
      return set_field_to_null(field);
    field->set_notnull();
    error=field->store(nr);
  }
  else if (result_type() == DECIMAL_RESULT)
  {
    my_decimal decimal_value;
    my_decimal *value= entry->val_decimal(&null_value, &decimal_value);
    if (null_value)
      return set_field_to_null(field);
    field->set_notnull();
    error=field->store_decimal(value);
  }
  else
  {
    longlong nr= entry->val_int(&null_value);
    if (null_value)
      return set_field_to_null_with_conversions(field, no_conversions);
    field->set_notnull();
    error=field->store(nr, unsigned_flag);
  }
  return error;
}


unknown's avatar
unknown committed
4405 4406 4407
String *
Item_func_get_user_var::val_str(String *str)
{
4408
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
4409
  DBUG_ENTER("Item_func_get_user_var::val_str");
4410
  if (!var_entry)
4411
    DBUG_RETURN((String*) 0);			// No such variable
4412
  DBUG_RETURN(var_entry->val_str(&null_value, str, decimals));
unknown's avatar
unknown committed
4413 4414 4415
}


4416
double Item_func_get_user_var::val_real()
unknown's avatar
unknown committed
4417
{
4418
  DBUG_ASSERT(fixed == 1);
4419 4420
  if (!var_entry)
    return 0.0;					// No such variable
unknown's avatar
unknown committed
4421 4422 4423 4424 4425 4426 4427 4428 4429 4430
  return (var_entry->val_real(&null_value));
}


my_decimal *Item_func_get_user_var::val_decimal(my_decimal *dec)
{
  DBUG_ASSERT(fixed == 1);
  if (!var_entry)
    return 0;
  return var_entry->val_decimal(&null_value, dec);
unknown's avatar
unknown committed
4431 4432 4433 4434 4435
}


longlong Item_func_get_user_var::val_int()
{
4436
  DBUG_ASSERT(fixed == 1);
4437 4438 4439
  if (!var_entry)
    return LL(0);				// No such variable
  return (var_entry->val_int(&null_value));
unknown's avatar
unknown committed
4440 4441 4442
}


4443
/*
4444 4445 4446 4447 4448 4449 4450 4451 4452 4453
  Get variable by name and, if necessary, put the record of variable 
  use into the binary log.
  
  SYNOPSIS
    get_var_with_binlog()
      thd        Current thread
      name       Variable name 
      out_entry  [out] variable structure or NULL. The pointer is set 
                 regardless of whether function succeeded or not.

4454 4455 4456 4457
  When a user variable is invoked from an update query (INSERT, UPDATE etc),
  stores this variable and its value in thd->user_var_events, so that it can be
  written to the binlog (will be written just before the query is written, see
  log.cc).
4458

4459
  RETURN
4460
    0  OK
unknown's avatar
unknown committed
4461
    1  Failed to put appropriate record into binary log
4462

4463 4464
*/

4465 4466
int get_var_with_binlog(THD *thd, enum_sql_command sql_command,
                        LEX_STRING &name, user_var_entry **out_entry)
unknown's avatar
unknown committed
4467
{
4468
  BINLOG_USER_VAR_EVENT *user_var_event;
4469 4470
  user_var_entry *var_entry;
  var_entry= get_variable(&thd->user_vars, name, 0);
4471

4472 4473 4474 4475 4476 4477 4478 4479
  /*
    Any reference to user-defined variable which is done from stored
    function or trigger affects their execution and the execution of the
    calling statement. We must log all such variables even if they are 
    not involved in table-updating statements.
  */
  if (!(opt_bin_log && 
       (is_update_query(sql_command) || thd->in_sub_stmt)))
4480 4481 4482 4483
  {
    *out_entry= var_entry;
    return 0;
  }
4484 4485

  if (!var_entry)
unknown's avatar
unknown committed
4486
  {
4487
    /*
4488 4489 4490 4491
      If the variable does not exist, it's NULL, but we want to create it so
      that it gets into the binlog (if it didn't, the slave could be
      influenced by a variable of the same name previously set by another
      thread).
unknown's avatar
unknown committed
4492 4493
      We create it like if it had been explicitly set with SET before.
      The 'new' mimics what sql_yacc.yy does when 'SET @a=10;'.
4494 4495 4496
      sql_set_variables() is what is called from 'case SQLCOM_SET_OPTION'
      in dispatch_command()). Instead of building a one-element list to pass to
      sql_set_variables(), we could instead manually call check() and update();
4497 4498
      this would save memory and time; but calling sql_set_variables() makes
      one unique place to maintain (sql_set_variables()). 
4499 4500 4501

      Manipulation with lex is necessary since free_underlaid_joins
      is going to release memory belonging to the main query.
4502 4503 4504
    */

    List<set_var_base> tmp_var_list;
4505 4506
    LEX *sav_lex= thd->lex, lex_tmp;
    thd->lex= &lex_tmp;
4507
    lex_start(thd);
4508 4509
    tmp_var_list.push_back(new set_var_user(new Item_func_set_user_var(name,
                                                                       new Item_null())));
4510 4511
    /* Create the variable */
    if (sql_set_variables(thd, &tmp_var_list))
4512 4513
    {
      thd->lex= sav_lex;
4514
      goto err;
4515 4516
    }
    thd->lex= sav_lex;
4517 4518 4519
    if (!(var_entry= get_variable(&thd->user_vars, name, 0)))
      goto err;
  }
4520 4521
  else if (var_entry->used_query_id == thd->query_id ||
           mysql_bin_log.is_query_in_union(thd, var_entry->used_query_id))
4522 4523 4524 4525 4526 4527 4528 4529 4530
  {
    /* 
       If this variable was already stored in user_var_events by this query
       (because it's used in more than one place in the query), don't store
       it.
    */
    *out_entry= var_entry;
    return 0;
  }
4531 4532 4533 4534

  uint size;
  /*
    First we need to store value of var_entry, when the next situation
unknown's avatar
unknown committed
4535
    appears:
4536 4537
    > set @a:=1;
    > insert into t1 values (@a), (@a:=@a+1), (@a:=@a+1);
4538 4539 4540 4541 4542 4543
    We have to write to binlog value @a= 1.
    
    We allocate the user_var_event on user_var_events_alloc pool, not on
    the this-statement-execution pool because in SPs user_var_event objects 
    may need to be valid after current [SP] statement execution pool is
    destroyed.
4544
  */
4545 4546 4547
  size= ALIGN_SIZE(sizeof(BINLOG_USER_VAR_EVENT)) + var_entry->length;
  if (!(user_var_event= (BINLOG_USER_VAR_EVENT *)
        alloc_root(thd->user_var_events_alloc, size)))
4548 4549 4550 4551 4552 4553 4554 4555 4556 4557 4558 4559
    goto err;
  
  user_var_event->value= (char*) user_var_event +
    ALIGN_SIZE(sizeof(BINLOG_USER_VAR_EVENT));
  user_var_event->user_var_event= var_entry;
  user_var_event->type= var_entry->type;
  user_var_event->charset_number= var_entry->collation.collation->number;
  if (!var_entry->value)
  {
    /* NULL value*/
    user_var_event->length= 0;
    user_var_event->value= 0;
unknown's avatar
unknown committed
4560
  }
4561 4562 4563 4564 4565 4566 4567 4568 4569 4570
  else
  {
    user_var_event->length= var_entry->length;
    memcpy(user_var_event->value, var_entry->value,
           var_entry->length);
  }
  /* Mark that this variable has been used by this query */
  var_entry->used_query_id= thd->query_id;
  if (insert_dynamic(&thd->user_var_events, (gptr) &user_var_event))
    goto err;
4571 4572 4573
  
  *out_entry= var_entry;
  return 0;
4574

unknown's avatar
unknown committed
4575
err:
4576 4577 4578 4579 4580 4581 4582 4583 4584 4585 4586 4587
  *out_entry= var_entry;
  return 1;
}


void Item_func_get_user_var::fix_length_and_dec()
{
  THD *thd=current_thd;
  int error;
  maybe_null=1;
  decimals=NOT_FIXED_DEC;
  max_length=MAX_BLOB_WIDTH;
4588

4589
  error= get_var_with_binlog(thd, thd->lex->sql_command, name, &var_entry);
4590 4591

  if (var_entry)
4592
  {
4593
    collation.set(var_entry->collation);
4594 4595 4596
    switch (var_entry->type) {
    case REAL_RESULT:
      max_length= DBL_DIG + 8;
unknown's avatar
unknown committed
4597
      break;
4598 4599
    case INT_RESULT:
      max_length= MAX_BIGINT_WIDTH;
unknown's avatar
unknown committed
4600
      decimals=0;
4601 4602 4603 4604
      break;
    case STRING_RESULT:
      max_length= MAX_BLOB_WIDTH;
      break;
unknown's avatar
unknown committed
4605
    case DECIMAL_RESULT:
unknown's avatar
unknown committed
4606 4607
      max_length= DECIMAL_MAX_STR_LENGTH;
      decimals= DECIMAL_MAX_SCALE;
unknown's avatar
unknown committed
4608
      break;
unknown's avatar
unknown committed
4609
    case ROW_RESULT:                            // Keep compiler happy
unknown's avatar
unknown committed
4610 4611
    default:
      DBUG_ASSERT(0);
unknown's avatar
unknown committed
4612
      break;
4613 4614
    }
  }
4615
  else
4616 4617
  {
    collation.set(&my_charset_bin, DERIVATION_IMPLICIT);
4618
    null_value= 1;
4619
  }
4620

4621 4622
  if (error)
    thd->fatal_error();
4623

unknown's avatar
unknown committed
4624
  return;
unknown's avatar
unknown committed
4625 4626 4627
}


4628
bool Item_func_get_user_var::const_item() const
4629
{
4630
  return (!var_entry || current_thd->query_id != var_entry->update_query_id);
4631
}
unknown's avatar
unknown committed
4632 4633 4634 4635 4636 4637 4638 4639 4640 4641 4642 4643


enum Item_result Item_func_get_user_var::result_type() const
{
  user_var_entry *entry;
  if (!(entry = (user_var_entry*) hash_search(&current_thd->user_vars,
					      (byte*) name.str,
					      name.length)))
    return STRING_RESULT;
  return entry->type;
}

unknown's avatar
unknown committed
4644 4645 4646

void Item_func_get_user_var::print(String *str)
{
4647
  str->append(STRING_WITH_LEN("(@"));
unknown's avatar
unknown committed
4648 4649 4650 4651
  str->append(name.str,name.length);
  str->append(')');
}

4652

4653
bool Item_func_get_user_var::eq(const Item *item, bool binary_cmp) const
unknown's avatar
unknown committed
4654 4655 4656 4657 4658 4659
{
  /* Assume we don't have rtti */
  if (this == item)
    return 1;					// Same item is same.
  /* Check if other type is also a get_user_var() object */
  if (item->type() != FUNC_ITEM ||
4660
      ((Item_func*) item)->functype() != functype())
unknown's avatar
unknown committed
4661 4662 4663 4664 4665 4666 4667
    return 0;
  Item_func_get_user_var *other=(Item_func_get_user_var*) item;
  return (name.length == other->name.length &&
	  !memcmp(name.str, other->name.str, name.length));
}


4668
bool Item_func_get_user_var::set_value(THD *thd,
4669
                                       sp_rcontext * /*ctx*/, Item **it)
4670
{
4671
  Item_func_set_user_var *suv= new Item_func_set_user_var(get_name(), *it);
4672 4673 4674 4675
  /*
    Item_func_set_user_var is not fixed after construction, call
    fix_fields().
  */
4676
  return (!suv || suv->fix_fields(thd, it) || suv->check(0) || suv->update());
4677 4678 4679
}


4680
bool Item_user_var_as_out_param::fix_fields(THD *thd, Item **ref)
unknown's avatar
unknown committed
4681 4682
{
  DBUG_ASSERT(fixed == 0);
4683
  if (Item::fix_fields(thd, ref) ||
unknown's avatar
unknown committed
4684 4685 4686 4687 4688 4689 4690 4691 4692 4693 4694 4695 4696 4697 4698 4699 4700
      !(entry= get_variable(&thd->user_vars, name, 1)))
    return TRUE;
  entry->type= STRING_RESULT;
  /*
    Let us set the same collation which is used for loading
    of fields in LOAD DATA INFILE.
    (Since Item_user_var_as_out_param is used only there).
  */
  entry->collation.set(thd->variables.collation_database);
  entry->update_query_id= thd->query_id;
  return FALSE;
}


void Item_user_var_as_out_param::set_null_value(CHARSET_INFO* cs)
{
  if (::update_hash(entry, TRUE, 0, 0, STRING_RESULT, cs,
4701
                    DERIVATION_IMPLICIT, 0 /* unsigned_arg */))
unknown's avatar
unknown committed
4702 4703 4704 4705 4706 4707 4708 4709
    current_thd->fatal_error();			// Probably end of memory
}


void Item_user_var_as_out_param::set_value(const char *str, uint length,
                                           CHARSET_INFO* cs)
{
  if (::update_hash(entry, FALSE, (void*)str, length, STRING_RESULT, cs,
4710
                    DERIVATION_IMPLICIT, 0 /* unsigned_arg */))
unknown's avatar
unknown committed
4711 4712 4713 4714 4715 4716 4717 4718 4719 4720 4721 4722 4723 4724 4725 4726 4727 4728 4729 4730 4731 4732 4733 4734 4735 4736 4737 4738 4739 4740 4741 4742 4743 4744 4745 4746 4747 4748 4749
    current_thd->fatal_error();			// Probably end of memory
}


double Item_user_var_as_out_param::val_real()
{
  DBUG_ASSERT(0);
  return 0.0;
}


longlong Item_user_var_as_out_param::val_int()
{
  DBUG_ASSERT(0);
  return 0;
}


String* Item_user_var_as_out_param::val_str(String *str)
{
  DBUG_ASSERT(0);
  return 0;
}


my_decimal* Item_user_var_as_out_param::val_decimal(my_decimal *decimal_buffer)
{
  DBUG_ASSERT(0);
  return 0;
}


void Item_user_var_as_out_param::print(String *str)
{
  str->append('@');
  str->append(name.str,name.length);
}


4750 4751 4752 4753 4754 4755 4756 4757 4758 4759 4760 4761
Item_func_get_system_var::
Item_func_get_system_var(sys_var *var_arg, enum_var_type var_type_arg,
                       LEX_STRING *component_arg, const char *name_arg,
                       size_t name_len_arg)
  :var(var_arg), var_type(var_type_arg), component(*component_arg)
{
  /* set_name() will allocate the name */
  set_name(name_arg, name_len_arg, system_charset_info);
}


bool
unknown's avatar
unknown committed
4762
Item_func_get_system_var::fix_fields(THD *thd, Item **ref)
4763
{
4764
  Item *item;
4765
  DBUG_ENTER("Item_func_get_system_var::fix_fields");
4766

4767 4768 4769 4770 4771
  /*
    Evaluate the system variable and substitute the result (a basic constant)
    instead of this item. If the variable can not be evaluated,
    the error is reported in sys_var::item().
  */
4772
  if (!(item= var->item(thd, var_type, &component)))
4773 4774 4775 4776 4777 4778 4779 4780
    DBUG_RETURN(1);                             // Impossible
  item->set_name(name, 0, system_charset_info); // don't allocate a new name
  thd->change_item_tree(ref, item);

  DBUG_RETURN(0);
}


unknown's avatar
unknown committed
4781 4782
longlong Item_func_inet_aton::val_int()
{
4783
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
4784 4785 4786 4787 4788
  uint byte_result = 0;
  ulonglong result = 0;			// We are ready for 64 bit addresses
  const char *p,* end;
  char c = '.'; // we mark c to indicate invalid IP in case length is 0
  char buff[36];
4789
  int dot_count= 0;
unknown's avatar
unknown committed
4790

unknown's avatar
unknown committed
4791
  String *s,tmp(buff,sizeof(buff),&my_charset_bin);
unknown's avatar
unknown committed
4792 4793 4794 4795 4796 4797 4798 4799 4800 4801 4802 4803 4804 4805 4806 4807
  if (!(s = args[0]->val_str(&tmp)))		// If null value
    goto err;
  null_value=0;

  end= (p = s->ptr()) + s->length();
  while (p < end)
  {
    c = *p++;
    int digit = (int) (c - '0');		// Assume ascii
    if (digit >= 0 && digit <= 9)
    {
      if ((byte_result = byte_result * 10 + digit) > 255)
	goto err;				// Wrong address
    }
    else if (c == '.')
    {
4808
      dot_count++;
unknown's avatar
unknown committed
4809 4810 4811 4812 4813 4814 4815
      result= (result << 8) + (ulonglong) byte_result;
      byte_result = 0;
    }
    else
      goto err;					// Invalid character
  }
  if (c != '.')					// IP number can't end on '.'
4816
  {
4817 4818 4819 4820 4821 4822
    /*
      Handle short-forms addresses according to standard. Examples:
      127		-> 0.0.0.127
      127.1		-> 127.0.0.1
      127.2.1		-> 127.2.0.1
    */
unknown's avatar
unknown committed
4823
    switch (dot_count) {
4824 4825
    case 1: result<<= 8; /* Fall through */
    case 2: result<<= 8; /* Fall through */
4826
    }
unknown's avatar
unknown committed
4827
    return (result << 8) + (ulonglong) byte_result;
4828
  }
unknown's avatar
unknown committed
4829 4830 4831 4832 4833 4834

err:
  null_value=1;
  return 0;
}

unknown's avatar
unknown committed
4835

4836
void Item_func_match::init_search(bool no_order)
4837
{
unknown's avatar
unknown committed
4838
  DBUG_ENTER("Item_func_match::init_search");
4839 4840

  /* Check if init_search() has been called before */
4841
  if (ft_handler)
unknown's avatar
unknown committed
4842
    DBUG_VOID_RETURN;
4843

4844
  if (key == NO_SUCH_KEY)
4845 4846
  {
    List<Item> fields;
4847
    fields.push_back(new Item_string(" ",1, cmp_collation.collation));
4848 4849
    for (uint i=1; i < arg_count; i++)
      fields.push_back(args[i]);
4850
    concat_ws=new Item_func_concat_ws(fields);
unknown's avatar
unknown committed
4851 4852 4853
    /*
      Above function used only to get value and do not need fix_fields for it:
      Item_string - basic constant
unknown's avatar
unknown committed
4854 4855
      fields - fix_fields() was already called for this arguments
      Item_func_concat_ws - do not need fix_fields() to produce value
unknown's avatar
unknown committed
4856
    */
4857
    concat_ws->quick_fix_field();
4858
  }
4859

4860 4861
  if (master)
  {
4862 4863
    join_key=master->join_key=join_key|master->join_key;
    master->init_search(no_order);
4864 4865
    ft_handler=master->ft_handler;
    join_key=master->join_key;
unknown's avatar
unknown committed
4866
    DBUG_VOID_RETURN;
4867 4868
  }

unknown's avatar
unknown committed
4869
  String *ft_tmp= 0;
4870

4871
  // MATCH ... AGAINST (NULL) is meaningless, but possible
4872
  if (!(ft_tmp=key_item()->val_str(&value)))
4873
  {
4874 4875
    ft_tmp= &value;
    value.set("",0,cmp_collation.collation);
4876 4877
  }

4878 4879
  if (ft_tmp->charset() != cmp_collation.collation)
  {
4880
    uint dummy_errors;
4881
    search_value.copy(ft_tmp->ptr(), ft_tmp->length(), ft_tmp->charset(),
4882
                      cmp_collation.collation, &dummy_errors);
4883
    ft_tmp= &search_value;
4884 4885
  }

4886 4887
  if (join_key && !no_order)
    flags|=FT_SORTED;
4888
  ft_handler=table->file->ft_init_ext(flags, key, ft_tmp);
4889 4890 4891

  if (join_key)
    table->file->ft_handler=ft_handler;
unknown's avatar
unknown committed
4892 4893

  DBUG_VOID_RETURN;
4894 4895
}

unknown's avatar
unknown committed
4896

4897
bool Item_func_match::fix_fields(THD *thd, Item **ref)
unknown's avatar
unknown committed
4898
{
4899
  DBUG_ASSERT(fixed == 0);
unknown's avatar
unknown committed
4900
  Item *item;
4901
  LINT_INIT(item);				// Safe as arg_count is > 1
unknown's avatar
unknown committed
4902

4903 4904 4905
  maybe_null=1;
  join_key=0;

4906 4907 4908 4909 4910
  /*
    const_item is assumed in quite a bit of places, so it would be difficult
    to remove;  If it would ever to be removed, this should include
    modifications to find_best and auto_close as complement to auto_init code
    above.
4911
   */
4912
  if (Item_func::fix_fields(thd, ref) ||
4913
      !args[0]->const_during_execution())
4914 4915
  {
    my_error(ER_WRONG_ARGUMENTS,MYF(0),"AGAINST");
unknown's avatar
unknown committed
4916
    return TRUE;
4917
  }
unknown's avatar
unknown committed
4918

4919 4920
  const_item_cache=0;
  for (uint i=1 ; i < arg_count ; i++)
unknown's avatar
unknown committed
4921
  {
4922
    item=args[i];
unknown's avatar
unknown committed
4923
    if (item->type() == Item::REF_ITEM)
4924 4925
      args[i]= item= *((Item_ref *)item)->ref;
    if (item->type() != Item::FIELD_ITEM)
4926
      key=NO_SUCH_KEY;
unknown's avatar
unknown committed
4927
  }
4928 4929
  /*
    Check that all columns come from the same table.
4930
    We've already checked that columns in MATCH are fields so
4931 4932 4933
    PARAM_TABLE_BIT can only appear from AGAINST argument.
  */
  if ((used_tables_cache & ~PARAM_TABLE_BIT) != item->used_tables())
4934
    key=NO_SUCH_KEY;
4935

4936
  if (key == NO_SUCH_KEY && !(flags & FT_BOOL))
4937 4938
  {
    my_error(ER_WRONG_ARGUMENTS,MYF(0),"MATCH");
unknown's avatar
unknown committed
4939
    return TRUE;
4940
  }
4941
  table=((Item_field *)item)->field->table;
unknown's avatar
unknown committed
4942
  if (!(table->file->table_flags() & HA_CAN_FULLTEXT))
4943
  {
unknown's avatar
unknown committed
4944
    my_error(ER_TABLE_CANT_HANDLE_FT, MYF(0));
unknown's avatar
unknown committed
4945
    return 1;
4946
  }
4947
  table->fulltext_searched=1;
4948 4949
  return agg_arg_collations_for_comparison(cmp_collation,
                                           args+1, arg_count-1, 0);
unknown's avatar
unknown committed
4950
}
4951

unknown's avatar
unknown committed
4952 4953 4954
bool Item_func_match::fix_index()
{
  Item_field *item;
4955
  uint ft_to_key[MAX_KEY], ft_cnt[MAX_KEY], fts=0, keynr;
4956
  uint max_cnt=0, mkeys=0, i;
4957

4958
  if (key == NO_SUCH_KEY)
4959
    return 0;
4960 4961 4962
  
  if (!table) 
    goto err;
unknown's avatar
unknown committed
4963

4964
  for (keynr=0 ; keynr < table->s->keys ; keynr++)
unknown's avatar
unknown committed
4965
  {
4966
    if ((table->key_info[keynr].flags & HA_FULLTEXT) &&
4967
        (table->s->keys_in_use.is_set(keynr)))
unknown's avatar
unknown committed
4968
    {
4969
      ft_to_key[fts]=keynr;
unknown's avatar
unknown committed
4970 4971 4972 4973 4974 4975
      ft_cnt[fts]=0;
      fts++;
    }
  }

  if (!fts)
4976
    goto err;
unknown's avatar
unknown committed
4977

4978
  for (i=1; i < arg_count; i++)
unknown's avatar
unknown committed
4979
  {
4980
    item=(Item_field*)args[i];
4981
    for (keynr=0 ; keynr < fts ; keynr++)
unknown's avatar
unknown committed
4982
    {
4983
      KEY *ft_key=&table->key_info[ft_to_key[keynr]];
unknown's avatar
unknown committed
4984 4985 4986 4987 4988
      uint key_parts=ft_key->key_parts;

      for (uint part=0 ; part < key_parts ; part++)
      {
	if (item->field->eq(ft_key->key_part[part].field))
4989
	  ft_cnt[keynr]++;
unknown's avatar
unknown committed
4990 4991 4992 4993
      }
    }
  }

4994
  for (keynr=0 ; keynr < fts ; keynr++)
unknown's avatar
unknown committed
4995
  {
4996
    if (ft_cnt[keynr] > max_cnt)
unknown's avatar
unknown committed
4997
    {
4998
      mkeys=0;
4999 5000
      max_cnt=ft_cnt[mkeys]=ft_cnt[keynr];
      ft_to_key[mkeys]=ft_to_key[keynr];
5001 5002
      continue;
    }
5003
    if (max_cnt && ft_cnt[keynr] == max_cnt)
5004 5005
    {
      mkeys++;
5006 5007
      ft_cnt[mkeys]=ft_cnt[keynr];
      ft_to_key[mkeys]=ft_to_key[keynr];
5008
      continue;
unknown's avatar
unknown committed
5009 5010 5011
    }
  }

5012
  for (keynr=0 ; keynr <= mkeys ; keynr++)
unknown's avatar
unknown committed
5013
  {
5014 5015
    // partial keys doesn't work
    if (max_cnt < arg_count-1 ||
5016
        max_cnt < table->key_info[ft_to_key[keynr]].key_parts)
5017
      continue;
unknown's avatar
unknown committed
5018

5019
    key=ft_to_key[keynr];
5020

5021 5022 5023
    return 0;
  }

5024
err:
5025
  if (flags & FT_BOOL)
5026
  {
5027
    key=NO_SUCH_KEY;
5028 5029
    return 0;
  }
unknown's avatar
unknown committed
5030 5031
  my_message(ER_FT_MATCHING_KEY_NOT_FOUND,
             ER(ER_FT_MATCHING_KEY_NOT_FOUND), MYF(0));
5032
  return 1;
5033 5034
}

5035

5036
bool Item_func_match::eq(const Item *item, bool binary_cmp) const
5037
{
unknown's avatar
unknown committed
5038 5039
  if (item->type() != FUNC_ITEM ||
      ((Item_func*)item)->functype() != FT_FUNC ||
5040
      flags != ((Item_func_match*)item)->flags)
5041 5042 5043 5044 5045
    return 0;

  Item_func_match *ifm=(Item_func_match*) item;

  if (key == ifm->key && table == ifm->table &&
5046
      key_item()->eq(ifm->key_item(), binary_cmp))
5047
    return 1;
unknown's avatar
unknown committed
5048 5049 5050 5051

  return 0;
}

5052

5053
double Item_func_match::val_real()
unknown's avatar
unknown committed
5054
{
5055
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
5056
  DBUG_ENTER("Item_func_match::val");
unknown's avatar
unknown committed
5057
  if (ft_handler == NULL)
unknown's avatar
unknown committed
5058
    DBUG_RETURN(-1.0);
unknown's avatar
unknown committed
5059

5060
  if (key != NO_SUCH_KEY && table->null_row) /* NULL row from an outer join */
unknown's avatar
unknown committed
5061 5062
    return 0.0;

unknown's avatar
unknown committed
5063 5064 5065
  if (join_key)
  {
    if (table->file->ft_handler)
unknown's avatar
unknown committed
5066
      DBUG_RETURN(ft_handler->please->get_relevance(ft_handler));
unknown's avatar
unknown committed
5067 5068 5069
    join_key=0;
  }

5070
  if (key == NO_SUCH_KEY)
unknown's avatar
unknown committed
5071
  {
5072 5073
    String *a= concat_ws->val_str(&value);
    if ((null_value= (a == 0)) || !a->length())
unknown's avatar
unknown committed
5074 5075 5076
      DBUG_RETURN(0);
    DBUG_RETURN(ft_handler->please->find_relevance(ft_handler,
				      (byte *)a->ptr(), a->length()));
unknown's avatar
unknown committed
5077 5078
  }
  else
5079 5080
    DBUG_RETURN(ft_handler->please->find_relevance(ft_handler,
                                                   table->record[0], 0));
unknown's avatar
unknown committed
5081 5082
}

5083 5084
void Item_func_match::print(String *str)
{
5085
  str->append(STRING_WITH_LEN("(match "));
unknown's avatar
unknown committed
5086
  print_args(str, 1);
5087
  str->append(STRING_WITH_LEN(" against ("));
5088
  args[0]->print(str);
unknown's avatar
unknown committed
5089
  if (flags & FT_BOOL)
5090
    str->append(STRING_WITH_LEN(" in boolean mode"));
unknown's avatar
unknown committed
5091
  else if (flags & FT_EXPAND)
5092 5093
    str->append(STRING_WITH_LEN(" with query expansion"));
  str->append(STRING_WITH_LEN("))"));
5094
}
unknown's avatar
unknown committed
5095

unknown's avatar
unknown committed
5096 5097
longlong Item_func_bit_xor::val_int()
{
5098
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
5099 5100
  ulonglong arg1= (ulonglong) args[0]->val_int();
  ulonglong arg2= (ulonglong) args[1]->val_int();
5101
  if ((null_value= (args[0]->null_value || args[1]->null_value)))
unknown's avatar
unknown committed
5102 5103 5104 5105
    return 0;
  return (longlong) (arg1 ^ arg2);
}

5106

5107 5108 5109 5110
/***************************************************************************
  System variables
****************************************************************************/

5111 5112 5113 5114 5115 5116 5117 5118 5119 5120 5121 5122 5123 5124 5125 5126 5127
/*
  Return value of an system variable base[.name] as a constant item

  SYNOPSIS
    get_system_var()
    thd			Thread handler
    var_type		global / session
    name		Name of base or system variable
    component		Component.

  NOTES
    If component.str = 0 then the variable name is in 'name'

  RETURN
    0	error
    #	constant item
*/
5128

5129 5130 5131

Item *get_system_var(THD *thd, enum_var_type var_type, LEX_STRING name,
		     LEX_STRING component)
5132
{
5133 5134 5135
  sys_var *var;
  LEX_STRING *base_name, *component_name;

5136 5137 5138 5139 5140 5141 5142 5143 5144 5145
  if (component.str)
  {
    base_name= &component;
    component_name= &name;
  }
  else
  {
    base_name= &name;
    component_name= &component;			// Empty string
  }
unknown's avatar
unknown committed
5146

5147
  if (!(var= find_sys_var(base_name->str, base_name->length)))
unknown's avatar
unknown committed
5148
    return 0;
5149 5150 5151 5152
  if (component.str)
  {
    if (!var->is_struct())
    {
5153
      my_error(ER_VARIABLE_IS_NOT_STRUCT, MYF(0), base_name->str);
5154 5155 5156
      return 0;
    }
  }
unknown's avatar
unknown committed
5157
  thd->lex->uncacheable(UNCACHEABLE_SIDEEFFECT);
5158

5159 5160
  set_if_smaller(component_name->length, MAX_SYS_VAR_LENGTH);

5161
  return new Item_func_get_system_var(var, var_type, component_name,
5162
                                      NULL, 0);
5163 5164 5165
}


unknown's avatar
unknown committed
5166 5167
/*
  Check a user level lock.
5168 5169 5170 5171 5172 5173 5174 5175

  SYNOPSIS:
    val_int()

  RETURN VALUES
    1		Available
    0		Already taken
    NULL	Error
unknown's avatar
unknown committed
5176 5177
*/

5178
longlong Item_func_is_free_lock::val_int()
unknown's avatar
unknown committed
5179
{
5180
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
5181
  String *res=args[0]->val_str(&value);
5182
  User_level_lock *ull;
unknown's avatar
unknown committed
5183 5184

  null_value=0;
5185
  if (!res || !res->length())
unknown's avatar
unknown committed
5186 5187 5188 5189 5190 5191
  {
    null_value=1;
    return 0;
  }
  
  pthread_mutex_lock(&LOCK_user_locks);
5192
  ull= (User_level_lock *) hash_search(&hash_user_locks, (byte*) res->ptr(),
unknown's avatar
unknown committed
5193 5194 5195 5196 5197 5198
			  res->length());
  pthread_mutex_unlock(&LOCK_user_locks);
  if (!ull || !ull->locked)
    return 1;
  return 0;
}
unknown's avatar
unknown committed
5199

unknown's avatar
SCRUM  
unknown committed
5200 5201
longlong Item_func_is_used_lock::val_int()
{
5202
  DBUG_ASSERT(fixed == 1);
unknown's avatar
SCRUM  
unknown committed
5203
  String *res=args[0]->val_str(&value);
5204
  User_level_lock *ull;
unknown's avatar
SCRUM  
unknown committed
5205 5206 5207 5208 5209 5210

  null_value=1;
  if (!res || !res->length())
    return 0;
  
  pthread_mutex_lock(&LOCK_user_locks);
5211
  ull= (User_level_lock *) hash_search(&hash_user_locks, (byte*) res->ptr(),
unknown's avatar
SCRUM  
unknown committed
5212 5213 5214 5215 5216 5217 5218 5219 5220
			  res->length());
  pthread_mutex_unlock(&LOCK_user_locks);
  if (!ull || !ull->locked)
    return 0;

  null_value=0;
  return ull->thread_id;
}

5221

5222 5223 5224 5225 5226 5227 5228 5229 5230
longlong Item_func_row_count::val_int()
{
  DBUG_ASSERT(fixed == 1);
  THD *thd= current_thd;

  return thd->row_count_func;
}


5231 5232


5233
Item_func_sp::Item_func_sp(Name_resolution_context *context_arg, sp_name *name)
5234
  :Item_func(), context(context_arg), m_name(name), m_sp(NULL), sp_result_field(NULL)
5235
{
unknown's avatar
unknown committed
5236
  maybe_null= 1;
5237
  m_name->init_qname(current_thd);
unknown's avatar
unknown committed
5238
  dummy_table= (TABLE*) sql_calloc(sizeof(TABLE));
5239 5240
}

unknown's avatar
unknown committed
5241

5242 5243
Item_func_sp::Item_func_sp(Name_resolution_context *context_arg,
                           sp_name *name, List<Item> &list)
5244
  :Item_func(list), context(context_arg), m_name(name), m_sp(NULL),sp_result_field(NULL)
5245
{
unknown's avatar
unknown committed
5246
  maybe_null= 1;
5247
  m_name->init_qname(current_thd);
unknown's avatar
unknown committed
5248
  dummy_table= (TABLE*) sql_calloc(sizeof(TABLE));
5249 5250
}

5251

5252 5253 5254
void
Item_func_sp::cleanup()
{
5255
  if (sp_result_field)
5256
  {
5257 5258
    delete sp_result_field;
    sp_result_field= NULL;
5259
  }
5260
  m_sp= NULL;
5261
  dummy_table->s= NULL;
5262 5263
  Item_func::cleanup();
}
unknown's avatar
unknown committed
5264

5265 5266 5267
const char *
Item_func_sp::func_name() const
{
5268
  THD *thd= current_thd;
unknown's avatar
unknown committed
5269
  /* Calculate length to avoid reallocation of string for sure */
5270
  uint len= (((m_name->m_explicit_name ? m_name->m_db.length : 0) +
5271 5272
              m_name->m_name.length)*2 + //characters*quoting
             2 +                         // ` and `
5273 5274
             (m_name->m_explicit_name ?
              3 : 0) +                   // '`', '`' and '.' for the db
5275 5276
             1 +                         // end of string
             ALIGN_SIZE(1));             // to avoid String reallocation
unknown's avatar
unknown committed
5277
  String qname((char *)alloc_root(thd->mem_root, len), len,
5278
               system_charset_info);
5279

5280
  qname.length(0);
5281 5282 5283 5284 5285
  if (m_name->m_explicit_name)
  {
    append_identifier(thd, &qname, m_name->m_db.str, m_name->m_db.length);
    qname.append('.');
  }
5286 5287
  append_identifier(thd, &qname, m_name->m_name.str, m_name->m_name.length);
  return qname.ptr();
5288 5289
}

5290

5291 5292 5293 5294 5295 5296 5297 5298 5299 5300 5301 5302 5303 5304 5305 5306 5307 5308 5309 5310

/**
  @brief Initialize the result field by creating a temporary dummy table
    and assign it to a newly created field object. Meta data used to
    create the field is fetched from the sp_head belonging to the stored
    proceedure found in the stored procedure functon cache.
  
  @note This function should be called from fix_fields to init the result
    field. It is some what related to Item_field.

  @see Item_field

  @param thd A pointer to the session and thread context.

  @return Function return error status.
  @retval TRUE is returned on an error
  @retval FALSE is returned on success.
*/
bool
Item_func_sp::init_result_field(THD *thd)
unknown's avatar
unknown committed
5311
{
5312 5313 5314 5315 5316 5317 5318 5319
  DBUG_ENTER("Item_func_sp::init_result_field");
  
  char *empty_name= (char *) "";
  TABLE_SHARE *share;

  DBUG_ASSERT(m_sp == NULL);
  DBUG_ASSERT(sp_result_field == NULL);
  DBUG_ASSERT(dummy_table->s == NULL);  
unknown's avatar
unknown committed
5320

5321 5322
  if (!(m_sp= sp_find_routine(thd, TYPE_ENUM_FUNCTION, m_name,
                               &thd->sp_func_cache, TRUE)))
unknown's avatar
unknown committed
5323
  {
5324 5325 5326
    my_error(ER_SP_DOES_NOT_EXIST, MYF(0), "FUNCTION", m_name->m_qname.str);
    context->process_error(thd);
    DBUG_RETURN(TRUE);
unknown's avatar
unknown committed
5327
  }
5328 5329 5330 5331 5332 5333 5334 5335 5336 5337 5338 5339 5340 5341 5342

  /*
     A Field need to be attached to a Table.
     Below we "create" a dummy table by initializing 
     the needed pointers.
   */
  dummy_table->s= share= &dummy_table->share_not_to_be_used;
  dummy_table->alias = empty_name;
  dummy_table->maybe_null = maybe_null;
  dummy_table->in_use= thd;
  dummy_table->copy_blobs= TRUE;
  share->table_cache_key = empty_name;
  share->table_name = empty_name;

  if (!(sp_result_field= m_sp->create_result_field(max_length, name, dummy_table)))
unknown's avatar
unknown committed
5343
  {
5344
   DBUG_RETURN(TRUE);
unknown's avatar
unknown committed
5345
  }
5346 5347
  
  if (sp_result_field->pack_length() > sizeof(result_buf))
unknown's avatar
unknown committed
5348
  {
5349 5350 5351
    sp_result_field->move_field(sql_alloc(sp_result_field->pack_length()));
  } else {
    sp_result_field->move_field(result_buf);
unknown's avatar
unknown committed
5352
  }
5353 5354 5355 5356
  
  sp_result_field->null_ptr= (uchar *) &null_value;
  sp_result_field->null_bit= 1;
  
5357

5358
  DBUG_RETURN(FALSE);
unknown's avatar
unknown committed
5359 5360
}

5361 5362
/**
  @brief Initialize local members with values from the Field interface.
unknown's avatar
unknown committed
5363

5364 5365 5366 5367 5368
  @note called from Item::fix_fields.
*/
void Item_func_sp::fix_length_and_dec()
{
  DBUG_ENTER("Item_func_sp::fix_length_and_dec");
unknown's avatar
unknown committed
5369

5370 5371 5372 5373 5374 5375 5376 5377 5378 5379 5380 5381 5382 5383 5384 5385
  DBUG_ASSERT(sp_result_field);
  decimals= sp_result_field->decimals();
  max_length= sp_result_field->field_length;
  collation.set(sp_result_field->charset());
  maybe_null= 1;
  unsigned_flag= test(sp_result_field->flags & UNSIGNED_FLAG);

  DBUG_VOID_RETURN;
}

/**
  @brief Execute function & store value in field.

  @return Function returns error status.
  @retval FALSE on success.
  @retval TRUE if an error occurred.
unknown's avatar
unknown committed
5386 5387
*/

5388
bool
5389
Item_func_sp::execute()
5390
{
5391
  THD *thd= current_thd;
5392
  
5393 5394 5395 5396
  /*
    Get field in virtual tmp table to store result. Create the field if
    invoked first time.
  */
5397

5398 5399 5400

  /* Execute function and store the return value in the field. */

5401
  if (execute_impl(thd))
5402 5403 5404
  {
    null_value= 1;
    context->process_error(thd);
5405 5406
    if (thd->killed)
      thd->send_kill_message();
5407 5408 5409 5410 5411
    return TRUE;
  }

  /* Check that the field (the value) is not NULL. */

5412
  null_value= sp_result_field->is_null();
5413 5414

  return null_value;
5415 5416 5417
}


5418 5419 5420 5421 5422 5423 5424 5425 5426 5427
/**
   @brief Execute function and store the return value in the field.

   @note This function was intended to be the concrete implementation of
    the interface function execute. This was never realized.

   @return The error state.
   @retval FALSE on success
   @retval TRUE if an error occurred.
*/
5428
bool
5429
Item_func_sp::execute_impl(THD *thd)
5430
{
5431
  bool err_status= TRUE;
5432
  Sub_statement_state statement_state;
5433 5434 5435
#ifndef NO_EMBEDDED_ACCESS_CHECKS
  Security_context *save_security_ctx= thd->security_ctx;
#endif
5436

5437 5438
  DBUG_ENTER("Item_func_sp::execute_impl");

5439 5440 5441 5442 5443 5444 5445
#ifndef NO_EMBEDDED_ACCESS_CHECKS
  if (context->security_ctx)
  {
    /* Set view definer security context */
    thd->security_ctx= context->security_ctx;
  }
#endif
5446
  if (sp_check_access(thd))
5447
    goto error;
5448

5449 5450 5451 5452 5453
  /*
    Disable the binlogging if this is not a SELECT statement. If this is a
    SELECT, leave binlogging on, so execute_function() code writes the
    function call into binlog.
  */
5454
  thd->reset_sub_statement_state(&statement_state, SUB_STMT_FUNCTION);
5455
  err_status= m_sp->execute_function(thd, args, arg_count, sp_result_field); 
5456
  thd->restore_sub_statement_state(&statement_state);
unknown's avatar
unknown committed
5457

5458
error:
5459
#ifndef NO_EMBEDDED_ACCESS_CHECKS
unknown's avatar
unknown committed
5460
  thd->security_ctx= save_security_ctx;
5461
#endif
5462

5463
  DBUG_RETURN(err_status);
5464 5465
}

5466

unknown's avatar
unknown committed
5467 5468 5469 5470
void
Item_func_sp::make_field(Send_field *tmp_field)
{
  DBUG_ENTER("Item_func_sp::make_field");
5471 5472
  DBUG_ASSERT(sp_result_field);
  sp_result_field->make_field(tmp_field);
unknown's avatar
unknown committed
5473 5474 5475 5476
  DBUG_VOID_RETURN;
}


5477 5478
enum enum_field_types
Item_func_sp::field_type() const
5479
{
5480
  DBUG_ENTER("Item_func_sp::field_type");
5481 5482
  DBUG_ASSERT(sp_result_field);
  DBUG_RETURN(sp_result_field->type());
5483 5484
}

5485 5486
Item_result
Item_func_sp::result_type() const
5487
{
5488 5489
  DBUG_ENTER("Item_func_sp::result_type");
  DBUG_PRINT("info", ("m_sp = %p", m_sp));
5490 5491
  DBUG_ASSERT(sp_result_field);
  DBUG_RETURN(sp_result_field->result_type());
5492 5493
}

5494 5495 5496
longlong Item_func_found_rows::val_int()
{
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
5497
  return current_thd->found_rows();
5498
}
unknown's avatar
unknown committed
5499

unknown's avatar
unknown committed
5500

unknown's avatar
unknown committed
5501 5502 5503 5504 5505
Field *
Item_func_sp::tmp_table_field(TABLE *t_arg)
{
  DBUG_ENTER("Item_func_sp::tmp_table_field");

5506 5507
  DBUG_ASSERT(sp_result_field);
  DBUG_RETURN(sp_result_field);
unknown's avatar
unknown committed
5508
}
5509

unknown's avatar
unknown committed
5510

5511 5512
/**
  @brief Checks if requested access to function can be granted to user.
5513 5514
    If function isn't found yet, it searches function first.
    If function can't be found or user don't have requested access
unknown's avatar
unknown committed
5515
    error is raised.
5516 5517 5518 5519 5520 5521 5522

  @param thd thread handler

  @return Indication if the access was granted or not.
  @retval FALSE Access is granted.
  @retval TRUE Requested access can't be granted or function doesn't exists.
    
5523
*/
unknown's avatar
unknown committed
5524

5525
bool
5526
Item_func_sp::sp_check_access(THD *thd)
5527
{
5528 5529
  DBUG_ENTER("Item_func_sp::sp_check_access");
  DBUG_ASSERT(m_sp);
unknown's avatar
unknown committed
5530
#ifndef NO_EMBEDDED_ACCESS_CHECKS
5531
  if (check_routine_access(thd, EXECUTE_ACL,
unknown's avatar
unknown committed
5532
			   m_sp->m_db.str, m_sp->m_name.str, 0, FALSE))
5533
    DBUG_RETURN(TRUE);
5534
#endif
unknown's avatar
unknown committed
5535

5536
  DBUG_RETURN(FALSE);
unknown's avatar
unknown committed
5537
}
5538

5539

5540 5541 5542 5543
bool
Item_func_sp::fix_fields(THD *thd, Item **ref)
{
  bool res;
5544
  DBUG_ENTER("Item_func_sp::fix_fields");
5545
  DBUG_ASSERT(fixed == 0);
5546 5547 5548 5549 5550 5551 5552 5553 5554 5555 5556
 
  /*
    We must call init_result_field before Item_func::fix_fields() 
    to make m_sp and result_field members available to fix_length_and_dec(),
    which is called from Item_func::fix_fields().
  */
  res= init_result_field(thd);

  if (res)
    DBUG_RETURN(res);

5557
  res= Item_func::fix_fields(thd, ref);
5558 5559 5560 5561 5562

  if (res)
    DBUG_RETURN(res);

  if (thd->lex->view_prepare_mode)
unknown's avatar
unknown committed
5563
  {
5564 5565
    /*
      Here we check privileges of the stored routine only during view
5566 5567 5568 5569 5570 5571 5572
      creation, in order to validate the view.  A runtime check is
      perfomed in Item_func_sp::execute(), and this method is not
      called during context analysis.  Notice, that during view
      creation we do not infer into stored routine bodies and do not
      check privileges of its statements, which would probably be a
      good idea especially if the view has SQL SECURITY DEFINER and
      the used stored procedure has SQL SECURITY DEFINER.
5573
    */
5574
    res= sp_check_access(thd);
5575
#ifndef NO_EMBEDDED_ACCESS_CHECKS
5576 5577 5578
    /*
      Try to set and restore the security context to see whether it's valid
    */
5579
    Security_context *save_secutiry_ctx;
5580 5581
    res= set_routine_security_ctx(thd, m_sp, false, &save_secutiry_ctx);
    if (!res)
5582
      sp_restore_security_context(thd, save_secutiry_ctx);
5583
    
5584
#endif /* ! NO_EMBEDDED_ACCESS_CHECKS */
unknown's avatar
unknown committed
5585
  }
unknown's avatar
unknown committed
5586 5587
  if (!m_sp->m_chistics->detistic)
   used_tables_cache |= RAND_TABLE_BIT;
5588
  DBUG_RETURN(res);
5589
}
unknown's avatar
unknown committed
5590 5591 5592 5593 5594 5595 5596 5597


void Item_func_sp::update_used_tables()
{
  Item_func::update_used_tables();
  if (!m_sp->m_chistics->detistic)
   used_tables_cache |= RAND_TABLE_BIT;
}