item.cc 75.1 KB
Newer Older
unknown's avatar
unknown committed
1
/* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
unknown's avatar
unknown committed
2

unknown's avatar
unknown committed
3 4 5 6
   This program is free software; you can redistribute it and/or modify
   it under the terms of the GNU General Public License as published by
   the Free Software Foundation; either version 2 of the License, or
   (at your option) any later version.
unknown's avatar
unknown committed
7

unknown's avatar
unknown committed
8 9 10 11
   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.
unknown's avatar
unknown committed
12

unknown's avatar
unknown committed
13 14 15 16 17 18 19 20 21 22 23 24 25
   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 */


#ifdef __GNUC__
#pragma implementation				// gcc: Class implementation
#endif

#include "mysql_priv.h"
#include <m_ctype.h>
#include "my_dir.h"

26 27
static void mark_as_dependent(THD *thd,
			      SELECT_LEX *last, SELECT_LEX *current,
unknown's avatar
unknown committed
28 29
			      Item_ident *item);

30 31
const String my_null_string("NULL", 4, default_charset_info);

unknown's avatar
unknown committed
32 33 34 35 36 37 38 39 40 41 42
/*****************************************************************************
** Item functions
*****************************************************************************/

/* Init all special items */

void item_init(void)
{
  item_user_lock_init();
}

43 44
Item::Item():
  fixed(0)
unknown's avatar
unknown committed
45
{
46
  marker= 0;
47
  maybe_null=null_value=with_sum_func=unsigned_flag=0;
48
  collation.set(&my_charset_bin, DERIVATION_COERCIBLE);
49 50
  name= 0;
  decimals= 0; max_length= 0;
51 52 53 54

  /* Put item in free list so that we can free all items at end */
  THD *thd= current_thd;
  next= thd->free_list;
55
  thd->free_list= this;
56
  /*
57
    Item constructor can be called during execution other then SQL_COM
58
    command => we should check thd->lex->current_select on zero (thd->lex
unknown's avatar
unknown committed
59
    can be uninitialised)
60
  */
61
  if (thd->lex->current_select)
62
  {
63
    enum_parsing_place place= 
64
      thd->lex->current_select->parsing_place;
65 66
    if (place == SELECT_LIST ||
	place == IN_HAVING)
67
      thd->lex->current_select->select_n_having_items++;
68
  }
unknown's avatar
unknown committed
69 70
}

71
/*
72
  Constructor used by Item_field, Item_*_ref & agregate (sum) functions.
73 74 75
  Used for duplicating lists in processing queries with temporary
  tables
*/
76 77 78 79 80 81 82 83 84 85 86 87
Item::Item(THD *thd, Item *item):
  str_value(item->str_value),
  name(item->name),
  max_length(item->max_length),
  marker(item->marker),
  decimals(item->decimals),
  maybe_null(item->maybe_null),
  null_value(item->null_value),
  unsigned_flag(item->unsigned_flag),
  with_sum_func(item->with_sum_func),
  fixed(item->fixed),
  collation(item->collation)
88
{
89
  next= thd->free_list;				// Put in free list
90
  thd->free_list= this;
91 92
}

unknown's avatar
unknown committed
93 94 95 96 97 98

void Item::print_item_w_name(String *str)
{
  print(str);
  if (name)
  {
99
    str->append(" AS `", 5);
unknown's avatar
unknown committed
100 101 102 103 104 105
    str->append(name);
    str->append('`');
  }
}


unknown's avatar
unknown committed
106 107
Item_ident::Item_ident(const char *db_name_par,const char *table_name_par,
		       const char *field_name_par)
unknown's avatar
unknown committed
108
  :orig_db_name(db_name_par), orig_table_name(table_name_par), 
109
   orig_field_name(field_name_par),
110 111 112
   db_name(db_name_par), table_name(table_name_par), 
   field_name(field_name_par), cached_field_index(NO_CACHED_FIELD_INDEX), 
   cached_table(0), depended_from(0)
unknown's avatar
unknown committed
113 114 115 116
{
  name = (char*) field_name_par;
}

117
// Constructor used by Item_field & Item_*_ref (see Item comment)
118 119
Item_ident::Item_ident(THD *thd, Item_ident *item)
  :Item(thd, item),
120 121 122
   orig_db_name(item->orig_db_name),
   orig_table_name(item->orig_table_name), 
   orig_field_name(item->orig_field_name),
123 124 125
   db_name(item->db_name),
   table_name(item->table_name),
   field_name(item->field_name),
126
   cached_field_index(item->cached_field_index),
127
   cached_table(item->cached_table),
128
   depended_from(item->depended_from)
129
{}
130

131 132
void Item_ident::cleanup()
{
unknown's avatar
unknown committed
133 134 135 136 137
  DBUG_ENTER("Item_ident::cleanup");
  DBUG_PRINT("enter", ("b:%s(%s), t:%s(%s), f:%s(%s)",
		       db_name, orig_db_name,
		       table_name, orig_table_name,
		       field_name, orig_field_name));
138
  Item::cleanup();
139 140 141
  db_name= orig_db_name; 
  table_name= orig_table_name;
  field_name= orig_field_name;
unknown's avatar
unknown committed
142
  DBUG_VOID_RETURN;
143 144
}

unknown's avatar
unknown committed
145 146 147 148 149
bool Item_ident::remove_dependence_processor(byte * arg)
{
  DBUG_ENTER("Item_ident::remove_dependence_processor");
  if (depended_from == (st_select_lex *) arg)
    depended_from= 0;
150
  DBUG_RETURN(0);
unknown's avatar
unknown committed
151 152 153
}


unknown's avatar
unknown committed
154 155 156 157
bool Item::check_cols(uint c)
{
  if (c != 1)
  {
unknown's avatar
unknown committed
158
    my_error(ER_OPERAND_COLUMNS, MYF(0), c);
unknown's avatar
unknown committed
159 160 161 162 163
    return 1;
  }
  return 0;
}

unknown's avatar
unknown committed
164 165

void Item::set_name(const char *str, uint length, CHARSET_INFO *cs)
unknown's avatar
unknown committed
166 167 168
{
  if (!length)
  {
unknown's avatar
unknown committed
169 170 171 172
    /* Empty string, used by AS or internal function like last_insert_id() */
    name= (char*) str;
    return;
  }
173 174 175 176 177 178 179 180 181
  if (cs->ctype)
  {
    // This will probably need a better implementation in the future:
    // a function in CHARSET_INFO structure.
    while (length && !my_isgraph(cs,*str))
    {						// Fix problem with yacc
      length--;
      str++;
    }
unknown's avatar
unknown committed
182
  }
unknown's avatar
unknown committed
183 184 185 186 187 188 189 190 191
  if (!my_charset_same(cs, system_charset_info))
  {
    uint32 res_length;
    name= sql_strmake_with_convert(str, length, cs,
				   MAX_ALIAS_NAME, system_charset_info,
				   &res_length);
  }
  else
    name=sql_strmake(str, min(length,MAX_ALIAS_NAME));
unknown's avatar
unknown committed
192 193
}

unknown's avatar
unknown committed
194

195
/*
196 197 198
  This function is called when:
  - Comparing items in the WHERE clause (when doing where optimization)
  - When trying to find an ORDER BY/GROUP BY item in the SELECT part
199 200 201
*/

bool Item::eq(const Item *item, bool binary_cmp) const
unknown's avatar
unknown committed
202 203
{
  return type() == item->type() && name && item->name &&
204
    !my_strcasecmp(system_charset_info,name,item->name);
unknown's avatar
unknown committed
205 206
}

unknown's avatar
unknown committed
207

unknown's avatar
unknown committed
208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242
Item *Item::safe_charset_converter(CHARSET_INFO *tocs)
{
  /*
    Don't allow automatic conversion to non-Unicode charsets,
    as it potentially loses data.
  */
  if (!(tocs->state & MY_CS_UNICODE))
    return NULL; // safe conversion is not possible
  return new Item_func_conv_charset(this, tocs);
}


Item *Item_string::safe_charset_converter(CHARSET_INFO *tocs)
{
  Item_string *conv;
  uint conv_errors;
  String tmp, cstr, *ostr= val_str(&tmp);
  cstr.copy(ostr->ptr(), ostr->length(), ostr->charset(), tocs, &conv_errors);
  if (conv_errors || !(conv= new Item_string(cstr.ptr(), cstr.length(),
                                             cstr.charset(),
                                             collation.derivation)))
  {
    /*
      Safe conversion is not possible (or EOM).
      We could not convert a string into the requested character set
      without data loss. The target charset does not cover all the
      characters from the string. Operation cannot be done correctly.
    */
    return NULL;
  }
  conv->str_value.copy();
  return conv;
}


243 244 245 246 247
bool Item_string::eq(const Item *item, bool binary_cmp) const
{
  if (type() == item->type())
  {
    if (binary_cmp)
unknown's avatar
unknown committed
248
      return !stringcmp(&str_value, &item->str_value);
249
    return !sortcmp(&str_value, &item->str_value, collation.collation);
250 251 252 253 254
  }
  return 0;
}


unknown's avatar
unknown committed
255 256 257 258 259
/*
  Get the value of the function as a TIME structure.
  As a extra convenience the time structure is reset on error!
 */

260
bool Item::get_date(TIME *ltime,uint fuzzydate)
unknown's avatar
unknown committed
261 262
{
  char buff[40];
unknown's avatar
unknown committed
263
  String tmp(buff,sizeof(buff), &my_charset_bin),*res;
unknown's avatar
unknown committed
264
  if (!(res=val_str(&tmp)) ||
265 266
      str_to_datetime_with_warn(res->ptr(), res->length(),
                                ltime, fuzzydate) <= MYSQL_TIMESTAMP_ERROR)
unknown's avatar
unknown committed
267 268 269 270 271 272 273 274 275 276 277 278 279 280 281
  {
    bzero((char*) ltime,sizeof(*ltime));
    return 1;
  }
  return 0;
}

/*
  Get time of first argument.
  As a extra convenience the time structure is reset on error!
 */

bool Item::get_time(TIME *ltime)
{
  char buff[40];
unknown's avatar
unknown committed
282
  String tmp(buff,sizeof(buff),&my_charset_bin),*res;
unknown's avatar
unknown committed
283
  if (!(res=val_str(&tmp)) ||
284
      str_to_time_with_warn(res->ptr(), res->length(), ltime))
unknown's avatar
unknown committed
285 286 287 288 289 290 291
  {
    bzero((char*) ltime,sizeof(*ltime));
    return 1;
  }
  return 0;
}

292
CHARSET_INFO *Item::default_charset()
293
{
unknown's avatar
unknown committed
294
  return current_thd->variables.collation_connection;
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 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349
/*
  Move SUM items out from item tree and replace with reference

  SYNOPSIS
    split_sum_func2()
    thd			Thread handler
    ref_pointer_array	Pointer to array of reference fields
    fields		All fields in select
    ref			Pointer to item

  NOTES
   This is from split_sum_func2() for items that should be split

   All found SUM items are added FIRST in the fields list and
   we replace the item with a reference.

   thd->fatal_error() may be called if we are out of memory
*/


void Item::split_sum_func2(THD *thd, Item **ref_pointer_array,
                           List<Item> &fields, Item **ref)
{
  if (type() != SUM_FUNC_ITEM && with_sum_func)
  {
    /* Will split complicated items and ignore simple ones */
    split_sum_func(thd, ref_pointer_array, fields);
  }
  else if ((type() == SUM_FUNC_ITEM ||
            (used_tables() & ~PARAM_TABLE_BIT)) &&
           type() != REF_ITEM)
  {
    /*
      Replace item with a reference so that we can easily calculate
      it (in case of sum functions) or copy it (in case of fields)

      The test above is to ensure we don't do a reference for things
      that are constants (PARAM_TABLE_BIT is in effect a constant)
      or already referenced (for example an item in HAVING)
    */
    uint el= fields.elements;
    Item *new_item;    
    ref_pointer_array[el]= this;
    if (!(new_item= new Item_ref(ref_pointer_array + el, 0, name)))
      return;                                   // fatal_error is set
    fields.push_front(this);
    ref_pointer_array[el]= this;
    thd->change_item_tree(ref, new_item);
  }
}


350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385
/*
   Aggregate two collations together taking
   into account their coercibility (aka derivation):

   0 == DERIVATION_EXPLICIT  - an explicitely written COLLATE clause
   1 == DERIVATION_NONE      - a mix of two different collations
   2 == DERIVATION_IMPLICIT  - a column
   3 == DERIVATION_COERCIBLE - a string constant

   The most important rules are:

   1. If collations are the same:
      chose this collation, and the strongest derivation.

   2. If collations are different:
     - Character sets may differ, but only if conversion without
       data loss is possible. The caller provides flags whether
       character set conversion attempts should be done. If no
       flags are substituted, then the character sets must be the same.
       Currently processed flags are:
         MY_COLL_ALLOW_SUPERSET_CONV  - allow conversion to a superset
         MY_COLL_ALLOW_COERCIBLE_CONV - allow conversion of a coercible value
     - two EXPLICIT collations produce an error, e.g. this is wrong:
       CONCAT(expr1 collate latin1_swedish_ci, expr2 collate latin1_german_ci)
     - the side with smaller derivation value wins,
       i.e. a column is stronger than a string constant,
       an explicit COLLATE clause is stronger than a column.
     - if derivations are the same, we have DERIVATION_NONE,
       we'll wait for an explicit COLLATE clause which possibly can
       come from another argument later: for example, this is valid,
       but we don't know yet when collecting the first two arguments:
         CONCAT(latin1_swedish_ci_column,
                latin1_german1_ci_column,
                expr COLLATE latin1_german2_ci)
*/
bool DTCollation::aggregate(DTCollation &dt, uint flags)
386
{
387
  if (!my_charset_same(collation, dt.collation))
388
  {
389 390 391
    /* 
       We do allow to use binary strings (like BLOBS)
       together with character strings.
unknown's avatar
unknown committed
392 393
       Binaries have more precedance than a character
       string of the same derivation.
394
    */
395
    if (collation == &my_charset_bin)
396
    {
397 398 399
      if (derivation <= dt.derivation)
	; // Do nothing
      else
400 401 402
      {
	set(dt); 
      }
403
    }
404
    else if (dt.collation == &my_charset_bin)
405
    {
406
      if (dt.derivation <= derivation)
407
      {
408
        set(dt);
409
      }
410 411
      else
       ; // Do nothing
412
    }
413 414 415
    else if ((flags & MY_COLL_ALLOW_SUPERSET_CONV) &&
             derivation < dt.derivation &&
             collation->state & MY_CS_UNICODE)
416
    {
417 418 419 420 421 422 423 424 425 426
      // Do nothing
    }
    else if ((flags & MY_COLL_ALLOW_SUPERSET_CONV) &&
             dt.derivation < derivation &&
             dt.collation->state & MY_CS_UNICODE)
    {
      set(dt);
    }
    else if ((flags & MY_COLL_ALLOW_COERCIBLE_CONV) &&
             derivation < dt.derivation &&
427
             dt.derivation >= DERIVATION_SYSCONST)
428 429 430 431 432
    {
      // Do nothing;
    }
    else if ((flags & MY_COLL_ALLOW_COERCIBLE_CONV) &&
             dt.derivation < derivation &&
433
             derivation >= DERIVATION_SYSCONST)
434 435
    {
      set(dt);
436
    }
437 438
    else
    {
439
      // Cannot apply conversion
440
      set(0, DERIVATION_NONE);
441
      return 1;
442
    }
443
  }
444
  else if (derivation < dt.derivation)
445
  {
446
    // Do nothing
447
  }
448
  else if (dt.derivation < derivation)
449
  {
450
    set(dt);
451
  }
452 453 454
  else
  { 
    if (collation == dt.collation)
455
    {
456 457 458 459 460
      // Do nothing
    }
    else 
    {
      if (derivation == DERIVATION_EXPLICIT)
461
      {
462 463
	set(0, DERIVATION_NONE);
	return 1;
464
      }
465 466 467
      CHARSET_INFO *bin= get_charset_by_csname(collation->csname, 
					       MY_CS_BINSORT,MYF(0));
      set(bin, DERIVATION_NONE);
468
    }
469 470 471 472
  }
  return 0;
}

unknown's avatar
unknown committed
473
Item_field::Item_field(Field *f)
474
  :Item_ident(NullS, f->table_name, f->field_name)
unknown's avatar
unknown committed
475 476
{
  set_field(f);
477 478 479 480 481
  /*
    field_name and talbe_name should not point to garbage
    if this item is to be reused
  */
  orig_table_name= orig_field_name= "";
unknown's avatar
unknown committed
482 483
}

484
Item_field::Item_field(THD *thd, Field *f)
485
  :Item_ident(f->table->table_cache_key, f->table_name, f->field_name)
486
{
487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507
  /*
    We always need to provide Item_field with a fully qualified field
    name to avoid ambiguity when executing prepared statements like
    SELECT * from d1.t1, d2.t1; (assuming d1.t1 and d2.t1 have columns
    with same names).
    This is because prepared statements never deal with wildcards in
    select list ('*') and always fix fields using fully specified path
    (i.e. db.table.column).
    No check for OOM: if db_name is NULL, we'll just get
    "Field not found" error.
    We need to copy db_name, table_name and field_name because they must
    be allocated in the statement memory, not in table memory (the table
    structure can go away and pop up again between subsequent executions
    of a prepared statement).
  */
  if (thd->current_arena->is_stmt_prepare())
  {
    if (db_name)
      orig_db_name= thd->strdup(db_name);
    orig_table_name= thd->strdup(table_name);
    orig_field_name= thd->strdup(field_name);
508 509 510 511 512 513
    /*
      We don't restore 'name' in cleanup because it's not changed
      during execution. Still we need it to point to persistent
      memory if this item is to be reused.
    */
    name= (char*) orig_field_name;
514
  }
515 516 517
  set_field(f);
}

518
// Constructor need to process subselect with temporary tables (see Item)
519
Item_field::Item_field(THD *thd, Item_field *item)
520
  :Item_ident(thd, item),
521 522
   field(item->field),
   result_field(item->result_field)
523 524 525
{
  collation.set(DERIVATION_IMPLICIT);
}
unknown's avatar
unknown committed
526 527 528 529 530 531 532 533 534

void Item_field::set_field(Field *field_par)
{
  field=result_field=field_par;			// for easy coding with fields
  maybe_null=field->maybe_null();
  max_length=field_par->field_length;
  decimals= field->decimals();
  table_name=field_par->table_name;
  field_name=field_par->field_name;
535
  db_name=field_par->table->table_cache_key;
536
  unsigned_flag=test(field_par->flags & UNSIGNED_FLAG);
537
  collation.set(field_par->charset(), DERIVATION_IMPLICIT);
538
  fixed= 1;
unknown's avatar
unknown committed
539 540
}

541 542 543 544 545 546 547 548 549 550 551 552 553 554

/*
  Reset this item to point to a field from the new temporary table.
  This is used when we create a new temporary table for each execution
  of prepared statement.
*/

void Item_field::reset_field(Field *f)
{
  set_field(f);
  /* 'name' is pointing at field->field_name of old field */
  name= (char*) f->field_name;
}

unknown's avatar
unknown committed
555 556 557
const char *Item_ident::full_name() const
{
  char *tmp;
558
  if (!table_name || !field_name)
unknown's avatar
unknown committed
559
    return field_name ? field_name : name ? name : "tmp_field";
unknown's avatar
unknown committed
560
  if (db_name && db_name[0])
unknown's avatar
unknown committed
561
  {
unknown's avatar
unknown committed
562 563
    tmp=(char*) sql_alloc((uint) strlen(db_name)+(uint) strlen(table_name)+
			  (uint) strlen(field_name)+3);
unknown's avatar
unknown committed
564 565 566 567
    strxmov(tmp,db_name,".",table_name,".",field_name,NullS);
  }
  else
  {
568 569 570 571 572 573 574 575
    if (table_name[0])
    {
      tmp= (char*) sql_alloc((uint) strlen(table_name) +
			     (uint) strlen(field_name) + 2);
      strxmov(tmp, table_name, ".", field_name, NullS);
    }
    else
      tmp= (char*) field_name;
unknown's avatar
unknown committed
576 577 578 579 580 581 582
  }
  return tmp;
}

/* ARGSUSED */
String *Item_field::val_str(String *str)
{
583
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
584 585
  if ((null_value=field->is_null()))
    return 0;
unknown's avatar
unknown committed
586
  str->set_charset(str_value.charset());
unknown's avatar
unknown committed
587 588 589 590 591
  return field->val_str(str,&str_value);
}

double Item_field::val()
{
592
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
593 594 595 596 597 598 599
  if ((null_value=field->is_null()))
    return 0.0;
  return field->val_real();
}

longlong Item_field::val_int()
{
600
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
601 602 603 604 605 606 607 608 609 610
  if ((null_value=field->is_null()))
    return 0;
  return field->val_int();
}


String *Item_field::str_result(String *str)
{
  if ((null_value=result_field->is_null()))
    return 0;
611
  str->set_charset(str_value.charset());
unknown's avatar
unknown committed
612 613 614
  return result_field->val_str(str,&str_value);
}

615
bool Item_field::get_date(TIME *ltime,uint fuzzydate)
unknown's avatar
unknown committed
616 617 618 619 620 621 622 623 624
{
  if ((null_value=field->is_null()) || field->get_date(ltime,fuzzydate))
  {
    bzero((char*) ltime,sizeof(*ltime));
    return 1;
  }
  return 0;
}

625
bool Item_field::get_date_result(TIME *ltime,uint fuzzydate)
626 627 628 629 630 631 632 633 634 635
{
  if ((null_value=result_field->is_null()) ||
      result_field->get_date(ltime,fuzzydate))
  {
    bzero((char*) ltime,sizeof(*ltime));
    return 1;
  }
  return 0;
}

unknown's avatar
unknown committed
636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659
bool Item_field::get_time(TIME *ltime)
{
  if ((null_value=field->is_null()) || field->get_time(ltime))
  {
    bzero((char*) ltime,sizeof(*ltime));
    return 1;
  }
  return 0;
}

double Item_field::val_result()
{
  if ((null_value=result_field->is_null()))
    return 0.0;
  return result_field->val_real();
}

longlong Item_field::val_int_result()
{
  if ((null_value=result_field->is_null()))
    return 0;
  return result_field->val_int();
}

660

661
bool Item_field::eq(const Item *item, bool binary_cmp) const
unknown's avatar
unknown committed
662
{
663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684
  if (item->type() != FIELD_ITEM)
    return 0;
  
  Item_field *item_field= (Item_field*) item;
  if (item_field->field)
    return item_field->field == field;
  /*
    We may come here when we are trying to find a function in a GROUP BY
    clause from the select list.
    In this case the '100 % correct' way to do this would be to first
    run fix_fields() on the GROUP BY item and then retry this function, but
    I think it's better to relax the checking a bit as we will in
    most cases do the correct thing by just checking the field name.
    (In cases where we would choose wrong we would have to generate a
    ER_NON_UNIQ_ERROR).
  */
  return (!my_strcasecmp(system_charset_info, item_field->name,
			 field_name) &&
	  (!item_field->table_name ||
	   (!my_strcasecmp(table_alias_charset, item_field->table_name,
			   table_name) &&
	    (!item_field->db_name ||
685 686
	     (item_field->db_name && !strcmp(item_field->db_name,
					     db_name))))));
unknown's avatar
unknown committed
687 688
}

689

unknown's avatar
unknown committed
690 691 692 693
table_map Item_field::used_tables() const
{
  if (field->table->const_table)
    return 0;					// const item
unknown's avatar
unknown committed
694
  return (depended_from ? OUTER_REF_TABLE_BIT : field->table->map);
unknown's avatar
unknown committed
695 696
}

697

698
Item *Item_field::get_tmp_table_item(THD *thd)
699
{
700
  Item_field *new_item= new Item_field(thd, this);
701 702 703 704
  if (new_item)
    new_item->field= new_item->result_field;
  return new_item;
}
unknown's avatar
unknown committed
705

706

unknown's avatar
unknown committed
707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722
/*
  Create an item from a string we KNOW points to a valid longlong/ulonglong
  end \0 terminated number string
*/

Item_int::Item_int(const char *str_arg, uint length)
{
  char *end_ptr= (char*) str_arg + length;
  int error;
  value= my_strtoll10(str_arg, &end_ptr, &error);
  max_length= (uint) (end_ptr - str_arg);
  name= (char*) str_arg;
  fixed= 1;
}


unknown's avatar
unknown committed
723 724
String *Item_int::val_str(String *str)
{
unknown's avatar
unknown committed
725
  // following assert is redundant, because fixed=1 assigned in constructor
726
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
727
  str->set(value, &my_charset_bin);
unknown's avatar
unknown committed
728 729 730 731 732
  return str;
}

void Item_int::print(String *str)
{
unknown's avatar
unknown committed
733 734
  // my_charset_bin is good enough for numbers
  str_value.set(value, &my_charset_bin);
unknown's avatar
unknown committed
735
  str->append(str_value);
unknown's avatar
unknown committed
736 737
}

738

unknown's avatar
unknown committed
739 740 741 742 743 744 745
Item_uint::Item_uint(const char *str_arg, uint length):
  Item_int(str_arg, length)
{
  unsigned_flag= 1;
}


unknown's avatar
unknown committed
746 747
String *Item_uint::val_str(String *str)
{
unknown's avatar
unknown committed
748
  // following assert is redundant, because fixed=1 assigned in constructor
749
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
750
  str->set((ulonglong) value, &my_charset_bin);
unknown's avatar
unknown committed
751 752 753
  return str;
}

754

unknown's avatar
unknown committed
755 756
void Item_uint::print(String *str)
{
757
  // latin1 is good enough for numbers
unknown's avatar
unknown committed
758 759
  str_value.set((ulonglong) value, default_charset());
  str->append(str_value);
unknown's avatar
unknown committed
760 761
}

unknown's avatar
unknown committed
762 763 764

String *Item_real::val_str(String *str)
{
unknown's avatar
unknown committed
765
  // following assert is redundant, because fixed=1 assigned in constructor
766
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
767
  str->set(value,decimals,&my_charset_bin);
unknown's avatar
unknown committed
768 769 770
  return str;
}

771

unknown's avatar
unknown committed
772 773
void Item_string::print(String *str)
{
774 775
  str->append('_');
  str->append(collation.collation->csname);
unknown's avatar
unknown committed
776
  str->append('\'');
unknown's avatar
unknown committed
777
  str_value.print(str);
unknown's avatar
unknown committed
778 779 780
  str->append('\'');
}

781 782
bool Item_null::eq(const Item *item, bool binary_cmp) const
{ return item->type() == type(); }
783 784
double Item_null::val()
{
unknown's avatar
unknown committed
785 786
  // following assert is redundant, because fixed=1 assigned in constructor
  DBUG_ASSERT(fixed == 1);
787 788 789 790 791
  null_value=1;
  return 0.0;
}
longlong Item_null::val_int()
{
unknown's avatar
unknown committed
792 793
  // following assert is redundant, because fixed=1 assigned in constructor
  DBUG_ASSERT(fixed == 1);
794 795 796
  null_value=1;
  return 0;
}
unknown's avatar
unknown committed
797 798
/* ARGSUSED */
String *Item_null::val_str(String *str)
799
{
unknown's avatar
unknown committed
800 801
  // following assert is redundant, because fixed=1 assigned in constructor
  DBUG_ASSERT(fixed == 1);
802 803 804
  null_value=1;
  return 0;
}
unknown's avatar
unknown committed
805 806


unknown's avatar
unknown committed
807 808 809 810 811 812
Item *Item_null::safe_charset_converter(CHARSET_INFO *tocs)
{
  collation.set(tocs);
  return this;
}

813 814 815 816 817 818 819 820 821 822 823 824 825 826 827
/*********************** Item_param related ******************************/

/* 
  Default function of Item_param::set_param_func, so in case
  of malformed packet the server won't SIGSEGV
*/

static void
default_set_param_func(Item_param *param,
                       uchar **pos __attribute__((unused)),
                       ulong len __attribute__((unused)))
{
  param->set_null();
}

828 829
Item_param::Item_param(unsigned pos_in_query_arg) :
  state(NO_VALUE),
830
  item_result_type(STRING_RESULT),
831 832
  /* Don't pretend to be a literal unless value for this item is set. */
  item_type(PARAM_ITEM),
833
  param_type(MYSQL_TYPE_STRING),
834
  pos_in_query(pos_in_query_arg),
835 836 837
  set_param_func(default_set_param_func)
{
  name= (char*) "?";
838 839 840 841 842 843
  /* 
    Since we can't say whenever this item can be NULL or cannot be NULL
    before mysql_stmt_execute(), so we assuming that it can be NULL until
    value is set.
  */
  maybe_null= 1;
844 845
}

unknown's avatar
unknown committed
846
void Item_param::set_null()
847 848
{
  DBUG_ENTER("Item_param::set_null");
849
  /* These are cleared after each execution by reset() method */
850
  max_length= 0;
851 852 853 854 855 856 857 858 859
  null_value= 1;
  /* 
    Because of NULL and string values we need to set max_length for each new
    placeholder value: user can submit NULL for any placeholder type, and 
    string length can be different in each execution.
  */
  max_length= 0;
  decimals= 0;
  state= NULL_VALUE;
860
  DBUG_VOID_RETURN;
unknown's avatar
unknown committed
861 862
}

863
void Item_param::set_int(longlong i, uint32 max_length_arg)
864 865
{
  DBUG_ENTER("Item_param::set_int");
866 867 868 869
  value.integer= (longlong) i;
  state= INT_VALUE;
  max_length= max_length_arg;
  decimals= 0;
870
  maybe_null= 0;
871
  DBUG_VOID_RETURN;
unknown's avatar
unknown committed
872 873
}

874
void Item_param::set_double(double d)
875 876
{
  DBUG_ENTER("Item_param::set_double");
877 878 879
  value.real= d;
  state= REAL_VALUE;
  max_length= DBL_DIG + 8;
880
  decimals= NOT_FIXED_DEC;
881
  maybe_null= 0;
882
  DBUG_VOID_RETURN;
unknown's avatar
unknown committed
883 884
}

885

886 887 888 889 890 891 892 893 894 895 896 897 898 899 900
/*
  Set parameter value from TIME value.

  SYNOPSIS
    set_time()
      tm             - datetime value to set (time_type is ignored)
      type           - type of datetime value
      max_length_arg - max length of datetime value as string

  NOTE
    If we value to be stored is not normalized, zero value will be stored
    instead and proper warning will be produced. This function relies on
    the fact that even wrong value sent over binary protocol fits into
    MAX_DATE_STRING_REP_LENGTH buffer.
*/
901
void Item_param::set_time(TIME *tm, timestamp_type type, uint32 max_length_arg)
902
{ 
903
  DBUG_ENTER("Item_param::set_time");
904

905 906
  value.time= *tm;
  value.time.time_type= type;
907

908 909 910 911 912 913 914 915 916 917 918
  if (value.time.year > 9999 || value.time.month > 12 ||
      value.time.day > 31 ||
      type != MYSQL_TIMESTAMP_TIME && value.time.hour > 23 ||
      value.time.minute > 59 || value.time.second > 59)
  {
    char buff[MAX_DATE_STRING_REP_LENGTH];
    uint length= my_TIME_to_str(&value.time, buff);
    make_truncated_value_warning(current_thd, buff, length, type);
    set_zero_time(&value.time, MYSQL_TIMESTAMP_ERROR);
  }

919 920 921 922 923 924
  state= TIME_VALUE;
  maybe_null= 0;
  max_length= max_length_arg;
  decimals= 0;
  DBUG_VOID_RETURN;
}
unknown's avatar
unknown committed
925

926 927 928 929 930 931 932 933

bool Item_param::set_str(const char *str, ulong length)
{
  DBUG_ENTER("Item_param::set_str");
  /*
    Assign string with no conversion: data is converted only after it's
    been written to the binary log.
  */
unknown's avatar
unknown committed
934 935 936
  uint dummy_errors;
  if (str_value.copy(str, length, &my_charset_bin, &my_charset_bin,
                     &dummy_errors))
937 938
    DBUG_RETURN(TRUE);
  state= STRING_VALUE;
939
  maybe_null= 0;
940 941 942
  /* max_length and decimals are set after charset conversion */
  /* sic: str may be not null-terminated, don't add DBUG_PRINT here */
  DBUG_RETURN(FALSE);
943 944 945
}


946 947 948 949 950 951 952 953 954 955 956 957 958 959 960 961
bool Item_param::set_longdata(const char *str, ulong length)
{
  DBUG_ENTER("Item_param::set_longdata");

  /*
    If client character set is multibyte, end of long data packet
    may hit at the middle of a multibyte character.  Additionally,
    if binary log is open we must write long data value to the
    binary log in character set of client. This is why we can't
    convert long data to connection character set as it comes
    (here), and first have to concatenate all pieces together,
    write query to the binary log and only then perform conversion.
  */
  if (str_value.append(str, length, &my_charset_bin))
    DBUG_RETURN(TRUE);
  state= LONG_DATA_VALUE;
962
  maybe_null= 0;
963 964

  DBUG_RETURN(FALSE);
965 966 967
}


968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986
/*
  Set parameter value from user variable value.

  SYNOPSIS
   set_from_user_var
     thd   Current thread
     entry User variable structure (NULL means use NULL value)

  RETURN
    0 OK
    1 Out of memort
*/

bool Item_param::set_from_user_var(THD *thd, const user_var_entry *entry)
{
  DBUG_ENTER("Item_param::set_from_user_var");
  if (entry && entry->value)
  {
    item_result_type= entry->type;
unknown's avatar
unknown committed
987 988 989
    switch (entry->type) {
    case REAL_RESULT:
      set_double(*(double*)entry->value);
990 991
      item_type= Item::REAL_ITEM;
      item_result_type= REAL_RESULT;
unknown's avatar
unknown committed
992 993 994
      break;
    case INT_RESULT:
      set_int(*(longlong*)entry->value, 21);
995 996
      item_type= Item::INT_ITEM;
      item_result_type= INT_RESULT;
unknown's avatar
unknown committed
997 998
      break;
    case STRING_RESULT:
999
    {
unknown's avatar
unknown committed
1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026
      CHARSET_INFO *fromcs= entry->collation.collation;
      CHARSET_INFO *tocs= thd->variables.collation_connection;
      uint32 dummy_offset;

      value.cs_info.character_set_client= fromcs;
      /*
        Setup source and destination character sets so that they
        are different only if conversion is necessary: this will
        make later checks easier.
      */
      value.cs_info.final_character_set_of_str_value=
        String::needs_conversion(0, fromcs, tocs, &dummy_offset) ?
        tocs : fromcs;
      /*
        Exact value of max_length is not known unless data is converted to
        charset of connection, so we have to set it later.
      */
      item_type= Item::STRING_ITEM;
      item_result_type= STRING_RESULT;

      if (set_str((const char *)entry->value, entry->length))
        DBUG_RETURN(1);
      break;
    }
    default:
      DBUG_ASSERT(0);
      set_null();
1027 1028 1029 1030 1031 1032 1033 1034
    }
  }
  else
    set_null();

  DBUG_RETURN(0);
}

1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046
/*
    Resets parameter after execution.
  
  SYNOPSIS
     Item_param::reset()
 
  NOTES
    We clear null_value here instead of setting it in set_* methods, 
    because we want more easily handle case for long data.
*/

void Item_param::reset()
1047 1048 1049 1050 1051 1052
{
  /* Shrink string buffer if it's bigger than max possible CHAR column */
  if (str_value.alloced_length() > MAX_CHAR_WIDTH)
    str_value.free();
  else
    str_value.length(0);
1053
  str_value_ptr.length(0);
1054
  /*
1055 1056
    We must prevent all charset conversions untill data has been written
    to the binary log.
1057 1058 1059
  */
  str_value.set_charset(&my_charset_bin);
  state= NO_VALUE;
1060 1061
  maybe_null= 1;
  null_value= 0;
1062 1063 1064 1065 1066 1067 1068 1069 1070
  /*
    Don't reset item_type to PARAM_ITEM: it's only needed to guard
    us from item optimizations at prepare stage, when item doesn't yet
    contain a literal of some kind.
    In all other cases when this object is accessed its value is
    set (this assumption is guarded by 'state' and
    DBUG_ASSERTS(state != NO_VALUE) in all Item_param::get_*
    methods).
  */
unknown's avatar
unknown committed
1071 1072 1073
}


unknown's avatar
unknown committed
1074
int Item_param::save_in_field(Field *field, bool no_conversions)
unknown's avatar
unknown committed
1075 1076
{
  field->set_notnull();
1077 1078 1079 1080 1081 1082 1083 1084

  switch (state) {
  case INT_VALUE:
    return field->store(value.integer);
  case REAL_VALUE:
    return field->store(value.real);
  case TIME_VALUE:
    field->store_time(&value.time, value.time.time_type);
1085
    return 0;
1086 1087 1088 1089 1090
  case STRING_VALUE:
  case LONG_DATA_VALUE:
    return field->store(str_value.ptr(), str_value.length(),
                        str_value.charset());
  case NULL_VALUE:
1091
    return set_field_to_null_with_conversions(field, no_conversions);
1092 1093 1094
  case NO_VALUE:
  default:
    DBUG_ASSERT(0);
unknown's avatar
unknown committed
1095
  }
1096
  return 1;
unknown's avatar
unknown committed
1097 1098
}

1099

1100 1101
bool Item_param::get_time(TIME *res)
{
1102 1103 1104 1105 1106 1107 1108 1109 1110 1111
  if (state == TIME_VALUE)
  {
    *res= value.time;
    return 0;
  }
  /*
    If parameter value isn't supplied assertion will fire in val_str()
    which is called from Item::get_time().
  */
  return Item::get_time(res);
1112
}
1113

1114

1115 1116 1117 1118 1119 1120 1121 1122 1123 1124 1125
bool Item_param::get_date(TIME *res, uint fuzzydate)
{
  if (state == TIME_VALUE)
  {
    *res= value.time;
    return 0;
  }
  return Item::get_date(res, fuzzydate);
}


unknown's avatar
unknown committed
1126 1127
double Item_param::val() 
{
1128 1129 1130 1131 1132 1133 1134 1135 1136
  switch (state) {
  case REAL_VALUE:
    return value.real;
  case INT_VALUE:
    return (double) value.integer;
  case STRING_VALUE:
  case LONG_DATA_VALUE:
    {
      int dummy_err;
unknown's avatar
unknown committed
1137
      char *end_not_used;
1138
      return my_strntod(str_value.charset(), (char*) str_value.ptr(),
unknown's avatar
unknown committed
1139
                        str_value.length(), &end_not_used, &dummy_err);
1140 1141 1142 1143 1144 1145
    }
  case TIME_VALUE:
    /*
      This works for example when user says SELECT ?+0.0 and supplies
      time value for the placeholder.
    */
1146
    return ulonglong2double(TIME_to_ulonglong(&value.time));
1147
  case NULL_VALUE:
1148
    return 0.0;
unknown's avatar
unknown committed
1149
  default:
1150
    DBUG_ASSERT(0);
unknown's avatar
unknown committed
1151
  }
1152
  return 0.0;
unknown's avatar
unknown committed
1153 1154
} 

1155

unknown's avatar
unknown committed
1156 1157
longlong Item_param::val_int() 
{ 
1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173
  switch (state) {
  case REAL_VALUE:
    return (longlong) (value.real + (value.real > 0 ? 0.5 : -0.5));
  case INT_VALUE:
    return value.integer;
  case STRING_VALUE:
  case LONG_DATA_VALUE:
    {
      int dummy_err;
      return my_strntoll(str_value.charset(), str_value.ptr(),
                         str_value.length(), 10, (char**) 0, &dummy_err);
    }
  case TIME_VALUE:
    return (longlong) TIME_to_ulonglong(&value.time);
  case NULL_VALUE:
    return 0; 
unknown's avatar
unknown committed
1174
  default:
1175
    DBUG_ASSERT(0);
unknown's avatar
unknown committed
1176
  }
1177
  return 0;
unknown's avatar
unknown committed
1178 1179
}

1180

unknown's avatar
unknown committed
1181 1182
String *Item_param::val_str(String* str) 
{ 
1183 1184 1185
  switch (state) {
  case STRING_VALUE:
  case LONG_DATA_VALUE:
1186
    return &str_value_ptr;
1187 1188 1189 1190 1191
  case REAL_VALUE:
    str->set(value.real, NOT_FIXED_DEC, &my_charset_bin);
    return str;
  case INT_VALUE:
    str->set(value.integer, &my_charset_bin);
unknown's avatar
unknown committed
1192
    return str;
1193 1194
  case TIME_VALUE:
  {
1195
    if (str->reserve(MAX_DATE_STRING_REP_LENGTH))
1196
      break;
1197 1198
    str->length((uint) my_TIME_to_str(&value.time, (char*) str->ptr()));
    str->set_charset(&my_charset_bin);
unknown's avatar
unknown committed
1199
    return str;
1200 1201 1202
  }
  case NULL_VALUE:
    return NULL; 
unknown's avatar
unknown committed
1203
  default:
1204
    DBUG_ASSERT(0);
unknown's avatar
unknown committed
1205
  }
1206
  return str;
unknown's avatar
unknown committed
1207
}
1208 1209 1210 1211

/*
  Return Param item values in string format, for generating the dynamic 
  query used in update/binary logs
1212 1213
  TODO: change interface and implementation to fill log data in place
  and avoid one more memcpy/alloc between str and log string.
1214 1215
*/

1216
const String *Item_param::query_val_str(String* str) const
1217
{
1218 1219 1220 1221 1222 1223 1224 1225
  switch (state) {
  case INT_VALUE:
    str->set(value.integer, &my_charset_bin);
    break;
  case REAL_VALUE:
    str->set(value.real, NOT_FIXED_DEC, &my_charset_bin);
    break;
  case TIME_VALUE:
1226
    {
1227 1228 1229 1230 1231 1232
      char *buf, *ptr;
      str->length(0);
      /*
        TODO: in case of error we need to notify replication
        that binary log contains wrong statement 
      */
1233
      if (str->reserve(MAX_DATE_STRING_REP_LENGTH+3))
1234 1235 1236 1237 1238 1239
        break; 

      /* Create date string inplace */
      buf= str->c_ptr_quick();
      ptr= buf;
      *ptr++= '\'';
1240
      ptr+= (uint) my_TIME_to_str(&value.time, ptr);
1241 1242 1243
      *ptr++= '\'';
      str->length((uint32) (ptr - buf));
      break;
1244
    }
1245 1246
  case STRING_VALUE:
  case LONG_DATA_VALUE:
1247
    {
1248 1249 1250 1251 1252 1253 1254 1255 1256 1257 1258 1259 1260
      char *buf, *ptr;
      str->length(0);
      if (str->reserve(str_value.length()*2+3))
        break;

      buf= str->c_ptr_quick();
      ptr= buf;
      *ptr++= '\'';
      ptr+= escape_string_for_mysql(str_value.charset(), ptr,
                                    str_value.ptr(), str_value.length());
      *ptr++= '\'';
      str->length(ptr - buf);
      break;
1261
    }
1262 1263 1264 1265
  case NULL_VALUE:
    return &my_null_string;
  default:
    DBUG_ASSERT(0);
1266 1267 1268
  }
  return str;
}
1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293


/*
  Convert string from client character set to the character set of
  connection.
*/

bool Item_param::convert_str_value(THD *thd)
{
  bool rc= FALSE;
  if (state == STRING_VALUE || state == LONG_DATA_VALUE)
  {
    /*
      Check is so simple because all charsets were set up properly
      in setup_one_conversion_function, where typecode of
      placeholder was also taken into account: the variables are different
      here only if conversion is really necessary.
    */
    if (value.cs_info.final_character_set_of_str_value !=
        value.cs_info.character_set_client)
    {
      rc= thd->convert_string(&str_value,
                              value.cs_info.character_set_client,
                              value.cs_info.final_character_set_of_str_value);
    }
1294 1295 1296 1297
    else
      str_value.set_charset(value.cs_info.final_character_set_of_str_value);
    /* Here str_value is guaranteed to be in final_character_set_of_str_value */

1298 1299
    max_length= str_value.length();
    decimals= 0;
1300 1301 1302 1303 1304 1305
    /*
      str_value_ptr is returned from val_str(). It must be not alloced
      to prevent it's modification by val_str() invoker.
    */
    str_value_ptr.set(str_value.ptr(), str_value.length(),
                      str_value.charset());
1306 1307 1308 1309
  }
  return rc;
}

unknown's avatar
unknown committed
1310 1311
/* End of Item_param related */

1312

unknown's avatar
unknown committed
1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323
void Item_copy_string::copy()
{
  String *res=item->val_str(&str_value);
  if (res && res != &str_value)
    str_value.copy(*res);
  null_value=item->null_value;
}

/* ARGSUSED */
String *Item_copy_string::val_str(String *str)
{
1324
  // Item_copy_string is used without fix_fields call
unknown's avatar
unknown committed
1325 1326 1327 1328 1329
  if (null_value)
    return (String*) 0;
  return &str_value;
}

unknown's avatar
unknown committed
1330 1331 1332 1333 1334 1335 1336 1337 1338 1339

int Item_copy_string::save_in_field(Field *field, bool no_conversions)
{
  if (null_value)
    return set_field_to_null(field);
  field->set_notnull();
  return field->store(str_value.ptr(),str_value.length(),
		      collation.collation);
}

unknown's avatar
unknown committed
1340
/*
1341
  Functions to convert item to field (for send_fields)
unknown's avatar
unknown committed
1342 1343 1344 1345
*/

/* ARGSUSED */
bool Item::fix_fields(THD *thd,
unknown's avatar
unknown committed
1346 1347
		      struct st_table_list *list,
		      Item ** ref)
unknown's avatar
unknown committed
1348
{
1349 1350

  // We do not check fields which are fixed during construction
unknown's avatar
unknown committed
1351
  DBUG_ASSERT(fixed == 0 || basic_const_item());
1352
  fixed= 1;
unknown's avatar
unknown committed
1353 1354 1355
  return 0;
}

1356 1357
double Item_ref_null_helper::val()
{
1358
  DBUG_ASSERT(fixed == 1);
1359
  double tmp= (*ref)->val_result();
unknown's avatar
unknown committed
1360
  owner->was_null|= null_value= (*ref)->null_value;
1361 1362
  return tmp;
}
1363 1364


1365 1366
longlong Item_ref_null_helper::val_int()
{
1367
  DBUG_ASSERT(fixed == 1);
1368
  longlong tmp= (*ref)->val_int_result();
unknown's avatar
unknown committed
1369
  owner->was_null|= null_value= (*ref)->null_value;
1370 1371
  return tmp;
}
1372 1373


1374 1375
String* Item_ref_null_helper::val_str(String* s)
{
1376
  DBUG_ASSERT(fixed == 1);
1377
  String* tmp= (*ref)->str_result(s);
unknown's avatar
unknown committed
1378
  owner->was_null|= null_value= (*ref)->null_value;
1379 1380
  return tmp;
}
1381 1382


1383
bool Item_ref_null_helper::get_date(TIME *ltime, uint fuzzydate)
1384 1385 1386
{  
  return (owner->was_null|= null_value= (*ref)->get_date(ltime, fuzzydate));
}
unknown's avatar
unknown committed
1387

unknown's avatar
unknown committed
1388 1389 1390 1391 1392 1393

/*
  Mark item and SELECT_LEXs as dependent if it is not outer resolving

  SYNOPSIS
    mark_as_dependent()
1394
    thd - thread handler
unknown's avatar
unknown committed
1395 1396 1397 1398 1399
    last - select from which current item depend
    current  - current select
    item - item which should be marked
*/

1400
static void mark_as_dependent(THD *thd, SELECT_LEX *last, SELECT_LEX *current,
unknown's avatar
unknown committed
1401 1402
			      Item_ident *item)
{
1403
  // store pointer on SELECT_LEX from which item is dependent
unknown's avatar
unknown committed
1404 1405
  item->depended_from= last;
  current->mark_as_dependent(last);
1406
  if (thd->lex->describe & DESCRIBE_EXTENDED)
1407 1408 1409 1410 1411 1412 1413 1414 1415 1416
  {
    char warn_buff[MYSQL_ERRMSG_SIZE];
    sprintf(warn_buff, ER(ER_WARN_FIELD_RESOLVED),
	    (item->db_name?item->db_name:""), (item->db_name?".":""),
	    (item->table_name?item->table_name:""), (item->table_name?".":""),
	    item->field_name,
	    current->select_number, last->select_number);
    push_warning(thd, MYSQL_ERROR::WARN_LEVEL_NOTE,
		 ER_WARN_FIELD_RESOLVED, warn_buff);
  }
unknown's avatar
unknown committed
1417 1418 1419
}


unknown's avatar
unknown committed
1420
bool Item_field::fix_fields(THD *thd, TABLE_LIST *tables, Item **ref)
unknown's avatar
unknown committed
1421
{
1422
  enum_parsing_place place= NO_MATTER;
unknown's avatar
unknown committed
1423
  DBUG_ASSERT(fixed == 0);
1424
  if (!field)					// If field is not checked
unknown's avatar
unknown committed
1425
  {
1426
    TABLE_LIST *where= 0;
1427
    bool upward_lookup= 0;
1428
    Field *tmp= (Field *)not_found_field;
unknown's avatar
unknown committed
1429
    if ((tmp= find_field_in_tables(thd, this, tables, &where, 0)) ==
1430
	not_found_field)
unknown's avatar
unknown committed
1431 1432
    {
      /*
unknown's avatar
unknown committed
1433
	We can't find table field in table list of current select,
unknown's avatar
unknown committed
1434
	consequently we have to find it in outer subselect(s).
unknown's avatar
unknown committed
1435 1436 1437
	We can't join lists of outer & current select, because of scope
	of view rules. For example if both tables (outer & current) have
	field 'field' it is not mistake to refer to this field without
unknown's avatar
unknown committed
1438 1439 1440
	mention of table name, but if we join tables in one list it will
	cause error ER_NON_UNIQ_ERROR in find_field_in_tables.
      */
unknown's avatar
unknown committed
1441
      SELECT_LEX *last= 0;
unknown's avatar
unknown committed
1442 1443 1444
#ifdef EMBEDDED_LIBRARY
      thd->net.last_errno= 0;
#endif
1445
      TABLE_LIST *table_list;
1446
      Item **refer= (Item **)not_found_item;
1447
      uint counter;
1448
      bool not_used;
1449
      // Prevent using outer fields in subselects, that is not supported now
1450
      SELECT_LEX *cursel= (SELECT_LEX *) thd->lex->current_select;
unknown's avatar
unknown committed
1451
      if (cursel->master_unit()->first_select()->linkage != DERIVED_TABLE_TYPE)
1452 1453 1454
      {
	SELECT_LEX_UNIT *prev_unit= cursel->master_unit();
	for (SELECT_LEX *sl= prev_unit->outer_select();
1455
	     sl;
1456
	     sl= (prev_unit= sl->master_unit())->outer_select())
1457
	{
1458
	  upward_lookup= 1;
1459
	  table_list= (last= sl)->get_table_list();
1460
	  if (sl->resolve_mode == SELECT_LEX::INSERT_MODE && table_list)
1461
	  {
1462 1463 1464 1465
            /*
              it is primary INSERT st_select_lex => skip first table
              resolving
            */
1466 1467
	    table_list= table_list->next;
	  }
unknown's avatar
unknown committed
1468 1469

	  Item_subselect *prev_subselect_item= prev_unit->item;
1470
          place= prev_subselect_item->parsing_place;
1471 1472
          /*
            check table fields only if subquery used somewhere out of HAVING
1473 1474
            or outer SELECT do not use groupping (i.e. tables are
            accessable)
1475
          */
1476
          if ((place != IN_HAVING ||
1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487
               (sl->with_sum_func == 0 && sl->group_list.elements == 0)) &&
              (tmp= find_field_in_tables(thd, this,
                                         table_list, &where,
                                         0)) != not_found_field)
          {
            if (!tmp)
              return -1;
            prev_subselect_item->used_tables_cache|= tmp->table->map;
            prev_subselect_item->const_item_cache= 0;
            break;
          }
1488
	  if (sl->resolve_mode == SELECT_LEX::SELECT_MODE &&
unknown's avatar
unknown committed
1489
	      (refer= find_item_in_list(this, sl->item_list, &counter,
1490 1491
                                        REPORT_EXCEPT_NOT_FOUND,
                                        &not_used)) !=
1492
	       (Item **) not_found_item)
1493
	  {
1494
	    if (refer && (*refer)->fixed) // Avoid crash in case of error
1495
	    {
unknown's avatar
unknown committed
1496 1497
	      prev_subselect_item->used_tables_cache|= (*refer)->used_tables();
	      prev_subselect_item->const_item_cache&= (*refer)->const_item();
1498
	    }
1499
	    break;
1500 1501 1502
	  }

	  // Reference is not found => depend from outer (or just error)
unknown's avatar
unknown committed
1503 1504
	  prev_subselect_item->used_tables_cache|= OUTER_REF_TABLE_BIT;
	  prev_subselect_item->const_item_cache= 0;
1505

1506 1507
	  if (sl->master_unit()->first_select()->linkage ==
	      DERIVED_TABLE_TYPE)
1508
	    break; // do not look over derived table
1509
	}
1510
      }
unknown's avatar
unknown committed
1511
      if (!tmp)
1512
	return -1;
1513 1514 1515
      else if (!refer)
	return 1;
      else if (tmp == not_found_field && refer == (Item **)not_found_item)
unknown's avatar
unknown committed
1516
      {
1517
	if (upward_lookup)
unknown's avatar
unknown committed
1518
	{
1519 1520 1521
	  // We can't say exactly what absend table or field
	  my_printf_error(ER_BAD_FIELD_ERROR, ER(ER_BAD_FIELD_ERROR), MYF(0),
			  full_name(), thd->where);
unknown's avatar
unknown committed
1522
	}
1523
	else
unknown's avatar
unknown committed
1524
	{
1525 1526
	  // Call to report error
	  find_field_in_tables(thd, this, tables, &where, 1);
unknown's avatar
unknown committed
1527
	}
unknown's avatar
unknown committed
1528 1529
	return -1;
      }
1530 1531
      else if (refer != (Item **)not_found_item)
      {
1532
	if (!last->ref_pointer_array[counter])
1533 1534 1535 1536 1537
	{
	  my_error(ER_ILLEGAL_REFERENCE, MYF(0), name,
		   "forward reference in item list");
	  return -1;
	}
1538
        DBUG_ASSERT((*refer)->fixed);
1539 1540
        /*
          Here, a subset of actions performed by Item_ref::set_properties
unknown's avatar
unknown committed
1541 1542 1543
          is not enough. So we pass ptr to NULL into Item_[direct]_ref
          constructor, so no initialization is performed, and call 
          fix_fields() below.
1544 1545 1546
        */
        Item *save= last->ref_pointer_array[counter];
        last->ref_pointer_array[counter]= NULL;
1547 1548 1549
	Item_ref *rf= (place == IN_HAVING ?
                       new Item_ref(last->ref_pointer_array + counter,
                                    (char *)table_name,
1550
                                    (char *)field_name) :
1551 1552
                       new Item_direct_ref(last->ref_pointer_array + counter,
                                           (char *)table_name,
1553
                                           (char *)field_name));
unknown's avatar
unknown committed
1554
	if (!rf)
1555
	  return 1;
1556
        thd->change_item_tree(ref, rf);
1557
        last->ref_pointer_array[counter]= save;
1558 1559 1560 1561
	/*
	  rf is Item_ref => never substitute other items (in this case)
	  during fix_fields() => we can use rf after fix_fields()
	*/
unknown's avatar
unknown committed
1562
	if (rf->fix_fields(thd, tables, ref) || rf->check_cols(1))
unknown's avatar
unknown committed
1563
	  return 1;
unknown's avatar
unknown committed
1564

1565
	mark_as_dependent(thd, last, cursel, rf);
1566 1567
	return 0;
      }
unknown's avatar
unknown committed
1568
      else
unknown's avatar
unknown committed
1569
      {
1570
	mark_as_dependent(thd, last, cursel, this);
unknown's avatar
unknown committed
1571
	if (last->having_fix_field)
1572 1573
	{
	  Item_ref *rf;
1574 1575
          rf= new Item_ref((where->db[0] ? where->db : 0),
                           (char*) where->alias, (char*) field_name);
1576 1577
	  if (!rf)
	    return 1;
1578
          thd->change_item_tree(ref, rf);
1579 1580 1581 1582
	  /*
	    rf is Item_ref => never substitute other items (in this case)
	    during fix_fields() => we can use rf after fix_fields()
	  */
unknown's avatar
unknown committed
1583
	  return rf->fix_fields(thd, tables, ref) ||  rf->check_cols(1);
1584
	}
unknown's avatar
unknown committed
1585
      }
1586
    }
1587 1588 1589
    else if (!tmp)
      return -1;

unknown's avatar
unknown committed
1590 1591
    set_field(tmp);
  }
unknown's avatar
unknown committed
1592
  else if (thd->set_query_id && field->query_id != thd->query_id)
1593 1594 1595 1596 1597
  {
    /* We only come here in unions */
    TABLE *table=field->table;
    field->query_id=thd->query_id;
    table->used_fields++;
unknown's avatar
unknown committed
1598
    table->used_keys.intersect(field->part_of_key);
1599
    fixed= 1;
1600
  }
unknown's avatar
unknown committed
1601 1602 1603
  return 0;
}

unknown's avatar
unknown committed
1604 1605
void Item_field::cleanup()
{
unknown's avatar
unknown committed
1606
  DBUG_ENTER("Item_field::cleanup");
unknown's avatar
unknown committed
1607
  Item_ident::cleanup();
1608 1609 1610 1611 1612
  /*
    Even if this object was created by direct link to field in setup_wild()
    it will be linked correctly next tyme by name of field and table alias.
    I.e. we can drop 'field'.
   */
1613
  field= result_field= 0;
unknown's avatar
unknown committed
1614
  DBUG_VOID_RETURN;
unknown's avatar
unknown committed
1615
}
unknown's avatar
unknown committed
1616 1617 1618

void Item::init_make_field(Send_field *tmp_field,
			   enum enum_field_types field_type)
unknown's avatar
unknown committed
1619
{
1620
  char *empty_name= (char*) "";
unknown's avatar
unknown committed
1621
  tmp_field->db_name=		empty_name;
1622 1623 1624 1625
  tmp_field->org_table_name=	empty_name;
  tmp_field->org_col_name=	empty_name;
  tmp_field->table_name=	empty_name;
  tmp_field->col_name=		name;
unknown's avatar
unknown committed
1626
  tmp_field->charsetnr=         collation.collation->number;
unknown's avatar
unknown committed
1627 1628 1629
  tmp_field->flags=             (maybe_null ? 0 : NOT_NULL_FLAG) | 
                                (my_binary_compare(collation.collation) ?
                                 BINARY_FLAG : 0);
unknown's avatar
unknown committed
1630 1631 1632
  tmp_field->type=field_type;
  tmp_field->length=max_length;
  tmp_field->decimals=decimals;
1633 1634
  if (unsigned_flag)
    tmp_field->flags |= UNSIGNED_FLAG;
unknown's avatar
unknown committed
1635 1636
}

unknown's avatar
unknown committed
1637
void Item::make_field(Send_field *tmp_field)
unknown's avatar
unknown committed
1638
{
unknown's avatar
unknown committed
1639
  init_make_field(tmp_field, field_type());
unknown's avatar
unknown committed
1640 1641 1642
}


1643 1644 1645 1646 1647
void Item_empty_string::make_field(Send_field *tmp_field)
{
  init_make_field(tmp_field,FIELD_TYPE_VAR_STRING);
}

unknown's avatar
unknown committed
1648

unknown's avatar
unknown committed
1649
enum_field_types Item::field_type() const
unknown's avatar
unknown committed
1650
{
unknown's avatar
unknown committed
1651 1652 1653
  return ((result_type() == STRING_RESULT) ? FIELD_TYPE_VAR_STRING :
	  (result_type() == INT_RESULT) ? FIELD_TYPE_LONGLONG :
	  FIELD_TYPE_DOUBLE);
unknown's avatar
unknown committed
1654 1655
}

1656

1657 1658
Field *Item::tmp_table_field_from_field_type(TABLE *table)
{
1659 1660 1661 1662 1663 1664
  /*
    The field functions defines a field to be not null if null_ptr is not 0
  */
  uchar *null_ptr= maybe_null ? (uchar*) "" : 0;

  switch (field_type()) {
1665
  case MYSQL_TYPE_DECIMAL:
1666 1667
    return new Field_decimal((char*) 0, max_length, null_ptr, 0, Field::NONE,
			     name, table, decimals, 0, unsigned_flag);
1668
  case MYSQL_TYPE_TINY:
1669 1670
    return new Field_tiny((char*) 0, max_length, null_ptr, 0, Field::NONE,
			  name, table, 0, unsigned_flag);
1671
  case MYSQL_TYPE_SHORT:
1672 1673
    return new Field_short((char*) 0, max_length, null_ptr, 0, Field::NONE,
			   name, table, 0, unsigned_flag);
1674
  case MYSQL_TYPE_LONG:
1675 1676
    return new Field_long((char*) 0, max_length, null_ptr, 0, Field::NONE,
			  name, table, 0, unsigned_flag);
1677 1678
#ifdef HAVE_LONG_LONG
  case MYSQL_TYPE_LONGLONG:
1679 1680
    return new Field_longlong((char*) 0, max_length, null_ptr, 0, Field::NONE,
			      name, table, 0, unsigned_flag);
1681
#endif
1682 1683 1684 1685 1686 1687 1688 1689 1690
  case MYSQL_TYPE_FLOAT:
    return new Field_float((char*) 0, max_length, null_ptr, 0, Field::NONE,
			   name, table, decimals, 0, unsigned_flag);
  case MYSQL_TYPE_DOUBLE:
    return new Field_double((char*) 0, max_length, null_ptr, 0, Field::NONE,
			    name, table, decimals, 0, unsigned_flag);
  case MYSQL_TYPE_NULL:
    return new Field_null((char*) 0, max_length, Field::NONE,
			  name, table, &my_charset_bin);
1691 1692
  case MYSQL_TYPE_NEWDATE:
  case MYSQL_TYPE_INT24:
1693 1694
    return new Field_medium((char*) 0, max_length, null_ptr, 0, Field::NONE,
			    name, table, 0, unsigned_flag);
1695 1696 1697 1698 1699 1700 1701 1702
  case MYSQL_TYPE_DATE:
    return new Field_date(maybe_null, name, table, &my_charset_bin);
  case MYSQL_TYPE_TIME:
    return new Field_time(maybe_null, name, table, &my_charset_bin);
  case MYSQL_TYPE_TIMESTAMP:
  case MYSQL_TYPE_DATETIME:
    return new Field_datetime(maybe_null, name, table, &my_charset_bin);
  case MYSQL_TYPE_YEAR:
1703 1704 1705 1706 1707 1708
    return new Field_year((char*) 0, max_length, null_ptr, 0, Field::NONE,
			  name, table);
  default:
    /* This case should never be choosen */
    DBUG_ASSERT(0);
    /* If something goes awfully wrong, it's better to get a string than die */
1709 1710
  case MYSQL_TYPE_ENUM:
  case MYSQL_TYPE_SET:
1711 1712 1713 1714 1715 1716 1717 1718 1719 1720
  case MYSQL_TYPE_VAR_STRING:
    if (max_length > 255)
      break;					// If blob
    return new Field_varstring(max_length, maybe_null, name, table,
			       collation.collation);
  case MYSQL_TYPE_STRING:
    if (max_length > 255)			// If blob
      break;
    return new Field_string(max_length, maybe_null, name, table,
			    collation.collation);
1721 1722 1723 1724 1725
  case MYSQL_TYPE_TINY_BLOB:
  case MYSQL_TYPE_MEDIUM_BLOB:
  case MYSQL_TYPE_LONG_BLOB:
  case MYSQL_TYPE_BLOB:
  case MYSQL_TYPE_GEOMETRY:
1726
    break;					// Blob handled outside of case
1727
  }
1728 1729 1730 1731

  /* blob is special as it's generated for both blobs and long strings */
  return new Field_blob(max_length, maybe_null, name, table,
			collation.collation);
1732 1733
}

1734

unknown's avatar
unknown committed
1735 1736
/* ARGSUSED */
void Item_field::make_field(Send_field *tmp_field)
unknown's avatar
unknown committed
1737
{
unknown's avatar
unknown committed
1738
  field->make_field(tmp_field);
1739
  DBUG_ASSERT(tmp_field->table_name);
unknown's avatar
unknown committed
1740 1741
  if (name)
    tmp_field->col_name=name;			// Use user supplied name
unknown's avatar
unknown committed
1742 1743
}

1744

unknown's avatar
unknown committed
1745
/*
1746
  Set a field:s value from a item
unknown's avatar
unknown committed
1747 1748 1749 1750 1751 1752 1753
*/

void Item_field::save_org_in_field(Field *to)
{
  if (field->is_null())
  {
    null_value=1;
1754
    set_field_to_null_with_conversions(to, 1);
unknown's avatar
unknown committed
1755 1756 1757 1758 1759 1760 1761 1762 1763
  }
  else
  {
    to->set_notnull();
    field_conv(to,field);
    null_value=0;
  }
}

unknown's avatar
unknown committed
1764
int Item_field::save_in_field(Field *to, bool no_conversions)
unknown's avatar
unknown committed
1765 1766 1767 1768
{
  if (result_field->is_null())
  {
    null_value=1;
1769
    return set_field_to_null_with_conversions(to, no_conversions);
unknown's avatar
unknown committed
1770 1771 1772 1773 1774 1775 1776 1777 1778 1779
  }
  else
  {
    to->set_notnull();
    field_conv(to,result_field);
    null_value=0;
  }
  return 0;
}

1780

unknown's avatar
unknown committed
1781 1782 1783 1784 1785 1786 1787 1788 1789 1790 1791 1792 1793 1794 1795 1796
/*
  Store null in field

  SYNOPSIS
    save_in_field()
    field		Field where we want to store NULL

  DESCRIPTION
    This is used on INSERT.
    Allow NULL to be inserted in timestamp and auto_increment values

  RETURN VALUES
    0	 ok
    1	 Field doesn't support NULL values and can't handle 'field = NULL'
*/   

unknown's avatar
unknown committed
1797
int Item_null::save_in_field(Field *field, bool no_conversions)
unknown's avatar
unknown committed
1798
{
1799
  return set_field_to_null_with_conversions(field, no_conversions);
unknown's avatar
unknown committed
1800 1801 1802
}


1803 1804 1805 1806 1807 1808 1809 1810 1811 1812 1813 1814
/*
  Store null in field

  SYNOPSIS
    save_safe_in_field()
    field		Field where we want to store NULL

  RETURN VALUES
    0	 ok
    1	 Field doesn't support NULL values
*/   

unknown's avatar
unknown committed
1815
int Item_null::save_safe_in_field(Field *field)
unknown's avatar
unknown committed
1816 1817 1818 1819 1820
{
  return set_field_to_null(field);
}


unknown's avatar
unknown committed
1821
int Item::save_in_field(Field *field, bool no_conversions)
unknown's avatar
unknown committed
1822
{
1823
  int error;
unknown's avatar
unknown committed
1824 1825 1826 1827 1828
  if (result_type() == STRING_RESULT ||
      result_type() == REAL_RESULT &&
      field->result_type() == STRING_RESULT)
  {
    String *result;
1829
    CHARSET_INFO *cs= collation.collation;
unknown's avatar
unknown committed
1830
    char buff[MAX_FIELD_WIDTH];		// Alloc buffer for small columns
unknown's avatar
unknown committed
1831 1832
    str_value.set_quick(buff, sizeof(buff), cs);
    result=val_str(&str_value);
unknown's avatar
unknown committed
1833
    if (null_value)
1834
    {
unknown's avatar
unknown committed
1835
      str_value.set_quick(0, 0, cs);
1836
      return set_field_to_null_with_conversions(field, no_conversions);
1837
    }
unknown's avatar
unknown committed
1838
    field->set_notnull();
1839
    error=field->store(result->ptr(),result->length(),cs);
1840
    str_value.set_quick(0, 0, cs);
unknown's avatar
unknown committed
1841 1842 1843 1844 1845 1846 1847
  }
  else if (result_type() == REAL_RESULT)
  {
    double nr=val();
    if (null_value)
      return set_field_to_null(field);
    field->set_notnull();
1848
    error=field->store(nr);
unknown's avatar
unknown committed
1849 1850 1851 1852 1853
  }
  else
  {
    longlong nr=val_int();
    if (null_value)
1854
      return set_field_to_null_with_conversions(field, no_conversions);
unknown's avatar
unknown committed
1855
    field->set_notnull();
1856
    error=field->store(nr);
unknown's avatar
unknown committed
1857
  }
unknown's avatar
unknown committed
1858
  return error;
unknown's avatar
unknown committed
1859 1860
}

1861

unknown's avatar
unknown committed
1862
int Item_string::save_in_field(Field *field, bool no_conversions)
unknown's avatar
unknown committed
1863 1864 1865 1866 1867 1868
{
  String *result;
  result=val_str(&str_value);
  if (null_value)
    return set_field_to_null(field);
  field->set_notnull();
unknown's avatar
unknown committed
1869
  return field->store(result->ptr(),result->length(),collation.collation);
unknown's avatar
unknown committed
1870 1871
}

unknown's avatar
unknown committed
1872
int Item_uint::save_in_field(Field *field, bool no_conversions)
1873
{
1874 1875 1876 1877
  /*
    TODO: To be fixed when wen have a
    field->store(longlong, unsigned_flag) method 
  */
unknown's avatar
unknown committed
1878
  return Item_int::save_in_field(field, no_conversions);
1879 1880
}

unknown's avatar
unknown committed
1881 1882

int Item_int::save_in_field(Field *field, bool no_conversions)
unknown's avatar
unknown committed
1883 1884 1885 1886 1887
{
  longlong nr=val_int();
  if (null_value)
    return set_field_to_null(field);
  field->set_notnull();
unknown's avatar
unknown committed
1888
  return field->store(nr);
unknown's avatar
unknown committed
1889 1890
}

unknown's avatar
unknown committed
1891 1892 1893 1894
Item_num *Item_uint::neg()
{
  return new Item_real(name, - ((double) value), 0, max_length);
}
unknown's avatar
unknown committed
1895 1896

int Item_real::save_in_field(Field *field, bool no_conversions)
unknown's avatar
unknown committed
1897 1898 1899 1900 1901
{
  double nr=val();
  if (null_value)
    return set_field_to_null(field);
  field->set_notnull();
unknown's avatar
unknown committed
1902
  return field->store(nr);
unknown's avatar
unknown committed
1903 1904 1905 1906 1907 1908 1909 1910
}

/****************************************************************************
** varbinary item
** In string context this is a binary string
** In number context this is a longlong value.
****************************************************************************/

unknown's avatar
unknown committed
1911
inline uint char_val(char X)
unknown's avatar
unknown committed
1912 1913 1914 1915 1916 1917
{
  return (uint) (X >= '0' && X <= '9' ? X-'0' :
		 X >= 'A' && X <= 'Z' ? X-'A'+10 :
		 X-'a'+10);
}

1918

1919
Item_varbinary::Item_varbinary(const char *str, uint str_length)
unknown's avatar
unknown committed
1920 1921 1922 1923 1924 1925
{
  name=(char*) str-2;				// Lex makes this start with 0x
  max_length=(str_length+1)/2;
  char *ptr=(char*) sql_alloc(max_length+1);
  if (!ptr)
    return;
unknown's avatar
unknown committed
1926
  str_value.set(ptr,max_length,&my_charset_bin);
unknown's avatar
unknown committed
1927 1928 1929 1930 1931 1932 1933 1934 1935
  char *end=ptr+max_length;
  if (max_length*2 != str_length)
    *ptr++=char_val(*str++);			// Not even, assume 0 prefix
  while (ptr != end)
  {
    *ptr++= (char) (char_val(str[0])*16+char_val(str[1]));
    str+=2;
  }
  *ptr=0;					// Keep purify happy
1936
  collation.set(&my_charset_bin, DERIVATION_COERCIBLE);
unknown's avatar
unknown committed
1937
  fixed= 1;
unknown's avatar
unknown committed
1938 1939 1940 1941
}

longlong Item_varbinary::val_int()
{
unknown's avatar
unknown committed
1942
  // following assert is redundant, because fixed=1 assigned in constructor
1943
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
1944 1945 1946 1947 1948 1949 1950 1951 1952 1953
  char *end=(char*) str_value.ptr()+str_value.length(),
       *ptr=end-min(str_value.length(),sizeof(longlong));

  ulonglong value=0;
  for (; ptr != end ; ptr++)
    value=(value << 8)+ (ulonglong) (uchar) *ptr;
  return (longlong) value;
}


unknown's avatar
unknown committed
1954
int Item_varbinary::save_in_field(Field *field, bool no_conversions)
unknown's avatar
unknown committed
1955
{
1956
  int error;
unknown's avatar
unknown committed
1957 1958 1959
  field->set_notnull();
  if (field->result_type() == STRING_RESULT)
  {
1960
    error=field->store(str_value.ptr(),str_value.length(),collation.collation);
unknown's avatar
unknown committed
1961 1962 1963 1964
  }
  else
  {
    longlong nr=val_int();
1965
    error=field->store(nr);
unknown's avatar
unknown committed
1966
  }
unknown's avatar
unknown committed
1967
  return error;
unknown's avatar
unknown committed
1968 1969 1970
}


unknown's avatar
unknown committed
1971 1972 1973 1974 1975
/*
  Pack data in buffer for sending
*/

bool Item_null::send(Protocol *protocol, String *packet)
unknown's avatar
unknown committed
1976
{
unknown's avatar
unknown committed
1977
  return protocol->store_null();
unknown's avatar
unknown committed
1978 1979 1980
}

/*
unknown's avatar
unknown committed
1981
  This is only called from items that is not of type item_field
unknown's avatar
unknown committed
1982 1983
*/

unknown's avatar
unknown committed
1984
bool Item::send(Protocol *protocol, String *buffer)
unknown's avatar
unknown committed
1985
{
unknown's avatar
unknown committed
1986 1987 1988 1989 1990 1991
  bool result;
  enum_field_types type;
  LINT_INIT(result);

  switch ((type=field_type())) {
  default:
1992 1993 1994 1995 1996 1997 1998 1999 2000
  case MYSQL_TYPE_NULL:
  case MYSQL_TYPE_DECIMAL:
  case MYSQL_TYPE_ENUM:
  case MYSQL_TYPE_SET:
  case MYSQL_TYPE_TINY_BLOB:
  case MYSQL_TYPE_MEDIUM_BLOB:
  case MYSQL_TYPE_LONG_BLOB:
  case MYSQL_TYPE_BLOB:
  case MYSQL_TYPE_GEOMETRY:
unknown's avatar
unknown committed
2001 2002 2003 2004 2005
  case MYSQL_TYPE_STRING:
  case MYSQL_TYPE_VAR_STRING:
  {
    String *res;
    if ((res=val_str(buffer)))
2006
      result= protocol->store(res->ptr(),res->length(),res->charset());
unknown's avatar
unknown committed
2007 2008 2009 2010
    break;
  }
  case MYSQL_TYPE_TINY:
  {
2011
    longlong nr;
unknown's avatar
unknown committed
2012 2013 2014 2015 2016 2017 2018 2019 2020 2021 2022 2023 2024
    nr= val_int();
    if (!null_value)
      result= protocol->store_tiny(nr);
    break;
  }
  case MYSQL_TYPE_SHORT:
  {
    longlong nr;
    nr= val_int();
    if (!null_value)
      result= protocol->store_short(nr);
    break;
  }
2025
  case MYSQL_TYPE_INT24:
unknown's avatar
unknown committed
2026 2027 2028 2029 2030 2031 2032 2033 2034 2035 2036 2037 2038 2039 2040 2041
  case MYSQL_TYPE_LONG:
  {
    longlong nr;
    nr= val_int();
    if (!null_value)
      result= protocol->store_long(nr);
    break;
  }
  case MYSQL_TYPE_LONGLONG:
  {
    longlong nr;
    nr= val_int();
    if (!null_value)
      result= protocol->store_longlong(nr, unsigned_flag);
    break;
  }
unknown's avatar
unknown committed
2042 2043 2044
  case MYSQL_TYPE_FLOAT:
  {
    float nr;
unknown's avatar
unknown committed
2045
    nr= (float) val();
unknown's avatar
unknown committed
2046 2047 2048 2049
    if (!null_value)
      result= protocol->store(nr, decimals, buffer);
    break;
  }
unknown's avatar
unknown committed
2050 2051 2052 2053 2054 2055 2056 2057 2058 2059
  case MYSQL_TYPE_DOUBLE:
  {
    double nr;
    nr= val();
    if (!null_value)
      result= protocol->store(nr, decimals, buffer);
    break;
  }
  case MYSQL_TYPE_DATETIME:
  case MYSQL_TYPE_DATE:
2060
  case MYSQL_TYPE_TIMESTAMP:
unknown's avatar
unknown committed
2061 2062
  {
    TIME tm;
2063
    get_date(&tm, TIME_FUZZY_DATE);
unknown's avatar
unknown committed
2064 2065 2066 2067 2068 2069 2070 2071 2072 2073 2074 2075 2076 2077 2078 2079 2080 2081 2082 2083 2084
    if (!null_value)
    {
      if (type == MYSQL_TYPE_DATE)
	return protocol->store_date(&tm);
      else
	result= protocol->store(&tm);
    }
    break;
  }
  case MYSQL_TYPE_TIME:
  {
    TIME tm;
    get_time(&tm);
    if (!null_value)
      result= protocol->store_time(&tm);
    break;
  }
  }
  if (null_value)
    result= protocol->store_null();
  return result;
unknown's avatar
unknown committed
2085 2086
}

unknown's avatar
unknown committed
2087 2088

bool Item_field::send(Protocol *protocol, String *buffer)
unknown's avatar
unknown committed
2089
{
unknown's avatar
unknown committed
2090
  return protocol->store(result_field);
unknown's avatar
unknown committed
2091 2092
}

2093

unknown's avatar
unknown committed
2094 2095 2096
/*
  This is used for HAVING clause
  Find field in select list having the same name
2097
*/
unknown's avatar
unknown committed
2098

unknown's avatar
unknown committed
2099
bool Item_ref::fix_fields(THD *thd,TABLE_LIST *tables, Item **reference)
unknown's avatar
unknown committed
2100
{
2101
  DBUG_ASSERT(fixed == 0);
2102
  uint counter;
2103
  enum_parsing_place place= NO_MATTER;
2104
  bool not_used;
unknown's avatar
unknown committed
2105 2106
  if (!ref)
  {
2107
    TABLE_LIST *where= 0, *table_list;
2108
    SELECT_LEX_UNIT *prev_unit= thd->lex->current_select->master_unit();
2109
    SELECT_LEX *sl= prev_unit->outer_select();
2110 2111 2112 2113 2114
    /*
      Finding only in current select will be performed for selects that have 
      not outer one and for derived tables (which not support using outer 
      fields for now)
    */
unknown's avatar
unknown committed
2115
    if ((ref= find_item_in_list(this, 
2116
				*(thd->lex->current_select->get_item_list()),
2117
				&counter,
2118
				((sl && 
2119
				  thd->lex->current_select->master_unit()->
2120
				  first_select()->linkage !=
2121 2122
				  DERIVED_TABLE_TYPE) ? 
				  REPORT_EXCEPT_NOT_FOUND :
2123
				  REPORT_ALL_ERRORS ), &not_used)) ==
unknown's avatar
unknown committed
2124
	(Item **)not_found_item)
unknown's avatar
unknown committed
2125
    {
2126
      Field *tmp= (Field*) not_found_field;
2127
      SELECT_LEX *last= 0;
unknown's avatar
unknown committed
2128
      /*
2129
	We can't find table field in select list of current select,
unknown's avatar
unknown committed
2130
	consequently we have to find it in outer subselect(s).
unknown's avatar
unknown committed
2131 2132 2133
	We can't join lists of outer & current select, because of scope
	of view rules. For example if both tables (outer & current) have
	field 'field' it is not mistake to refer to this field without
unknown's avatar
unknown committed
2134
	mention of table name, but if we join tables in one list it will
2135
	cause error ER_NON_UNIQ_ERROR in find_item_in_list.
unknown's avatar
unknown committed
2136
      */
2137
      for ( ; sl ; sl= (prev_unit= sl->master_unit())->outer_select())
2138
      {
2139
	last= sl;
unknown's avatar
unknown committed
2140
	Item_subselect *prev_subselect_item= prev_unit->item;
2141 2142
	if (sl->resolve_mode == SELECT_LEX::SELECT_MODE &&
	    (ref= find_item_in_list(this, sl->item_list,
2143 2144
                                    &counter, REPORT_EXCEPT_NOT_FOUND,
                                    &not_used)) !=
unknown's avatar
unknown committed
2145
	   (Item **)not_found_item)
2146
	{
2147
	  if (ref && (*ref)->fixed) // Avoid crash in case of error
2148
	  {
unknown's avatar
unknown committed
2149 2150
	    prev_subselect_item->used_tables_cache|= (*ref)->used_tables();
	    prev_subselect_item->const_item_cache&= (*ref)->const_item();
2151
	  }
2152
	  break;
2153
	}
2154
	table_list= sl->get_table_list();
2155
	if (sl->resolve_mode == SELECT_LEX::INSERT_MODE && table_list)
2156 2157 2158 2159
	{
	  // it is primary INSERT st_select_lex => skip first table resolving
	  table_list= table_list->next;
	}
2160
        place= prev_subselect_item->parsing_place;
2161 2162 2163 2164 2165
        /*
          check table fields only if subquery used somewhere out of HAVING
          or SELECT list or outer SELECT do not use groupping (i.e. tables
          are accessable)
        */
2166
        if ((place != IN_HAVING ||
2167 2168 2169 2170 2171 2172 2173 2174 2175 2176
             (sl->with_sum_func == 0 && sl->group_list.elements == 0)) &&
            (tmp= find_field_in_tables(thd, this,
                                       table_list, &where,
                                       0)) != not_found_field)
        {
          prev_subselect_item->used_tables_cache|= tmp->table->map;
          prev_subselect_item->const_item_cache= 0;
          break;
        }
        // Reference is not found => depend from outer (or just error)
unknown's avatar
unknown committed
2177 2178
	prev_subselect_item->used_tables_cache|= OUTER_REF_TABLE_BIT;
	prev_subselect_item->const_item_cache= 0;
2179

2180 2181
	if (sl->master_unit()->first_select()->linkage ==
	    DERIVED_TABLE_TYPE)
2182
	  break; // do not look over derived table
2183
      }
2184

unknown's avatar
unknown committed
2185
      if (!ref)
2186
	return 1;
2187
      if (!tmp)
2188
	return -1;
2189
      if (ref == (Item **)not_found_item && tmp == not_found_field)
unknown's avatar
unknown committed
2190
      {
2191 2192 2193 2194
        // We can't say exactly what absend (table or field)
        my_printf_error(ER_BAD_FIELD_ERROR, ER(ER_BAD_FIELD_ERROR), MYF(0),
                        full_name(), thd->where);
	ref= 0;                                 // Safety
unknown's avatar
unknown committed
2195
	return 1;
unknown's avatar
unknown committed
2196
      }
2197
      if (tmp != not_found_field)
2198
      {
2199 2200 2201 2202 2203 2204 2205 2206
        Item_field* fld;
        /*
          Set ref to 0 as we are replacing this item with the found item
          and this will ensure we get an error if this item would be
          used elsewhere
        */
	ref= 0;                                 // Safety
	if (!(fld= new Item_field(tmp)))
2207
	  return 1;
2208
	thd->change_item_tree(reference, fld);
2209
	mark_as_dependent(thd, last, thd->lex->current_select, fld);
2210 2211
	return 0;
      }
2212
      if (!last->ref_pointer_array[counter])
unknown's avatar
unknown committed
2213
      {
2214 2215 2216
        my_error(ER_ILLEGAL_REFERENCE, MYF(0), name,
                 "forward reference in item list");
        return -1;
unknown's avatar
unknown committed
2217
      }
2218
      DBUG_ASSERT((*ref)->fixed);
2219 2220
      mark_as_dependent(thd, last, thd->lex->current_select,
                        this);
2221 2222 2223 2224 2225 2226 2227 2228 2229 2230 2231 2232 2233
      if (place == IN_HAVING)
      {
        Item_ref *rf;
        if (!(rf= new Item_direct_ref(last->ref_pointer_array + counter,
                                      (char *)table_name,
                                      (char *)field_name)))
          return 1;
        ref= 0;                                 // Safety
        if (rf->fix_fields(thd, tables, ref) || rf->check_cols(1))
	  return 1;
        thd->change_item_tree(reference, rf);
        return 0;
      }
2234
      ref= last->ref_pointer_array + counter;
unknown's avatar
unknown committed
2235
    }
2236
    else if (!ref)
unknown's avatar
unknown committed
2237
      return 1;
2238 2239 2240 2241 2242 2243 2244 2245
    else
    {
      if (!(*ref)->fixed)
      {
	my_error(ER_ILLEGAL_REFERENCE, MYF(0), name,
		 "forward reference in item list");
	return -1;
      }
2246
      ref= thd->lex->current_select->ref_pointer_array + counter;
2247
    }
unknown's avatar
unknown committed
2248
  }
2249

2250 2251 2252 2253 2254 2255 2256
  /*
    The following conditional is changed as to correctly identify 
    incorrect references in group functions or forward references 
    with sub-select's / derived tables, while it prevents this 
    check when Item_ref is created in an expression involving 
    summing function, which is to be placed in the user variable.
  */
2257
  if (((*ref)->with_sum_func && name &&
2258
       (depended_from ||
2259 2260
	!(thd->lex->current_select->linkage != GLOBAL_OPTIONS_TYPE &&
	  thd->lex->current_select->having_fix_field))) ||
2261 2262 2263 2264 2265 2266 2267 2268
      !(*ref)->fixed)
  {
    my_error(ER_ILLEGAL_REFERENCE, MYF(0), name, 
	     ((*ref)->with_sum_func?
	      "reference on group function":
	      "forward reference in item list"));
    return 1;
  }
2269 2270 2271 2272 2273 2274 2275 2276 2277 2278

  set_properties();

  if (ref && (*ref)->check_cols(1))
    return 1;
  return 0;
}

void Item_ref::set_properties()
{
2279 2280 2281
  max_length= (*ref)->max_length;
  maybe_null= (*ref)->maybe_null;
  decimals=   (*ref)->decimals;
2282
  collation.set((*ref)->collation);
unknown's avatar
unknown committed
2283
  with_sum_func= (*ref)->with_sum_func;
unknown's avatar
unknown committed
2284
  unsigned_flag= (*ref)->unsigned_flag;
2285
  fixed= 1;
unknown's avatar
unknown committed
2286 2287
}

unknown's avatar
unknown committed
2288 2289 2290 2291 2292 2293 2294 2295 2296 2297 2298
void Item_ref::print(String *str)
{
  if (ref && *ref)
    (*ref)->print(str);
  else
    Item_ident::print(str);
}


void Item_ref_null_helper::print(String *str)
{
2299
  str->append("<ref_null_helper>(", 18);
unknown's avatar
unknown committed
2300 2301 2302 2303 2304 2305 2306 2307 2308 2309
  if (ref && *ref)
    (*ref)->print(str);
  else
    str->append('?');
  str->append(')');
}


void Item_null_helper::print(String *str)
{
2310
  str->append("<null_helper>(", 14);
unknown's avatar
unknown committed
2311 2312 2313 2314 2315
  store->print(str);
  str->append(')');
}


unknown's avatar
SCRUM  
unknown committed
2316 2317
bool Item_default_value::eq(const Item *item, bool binary_cmp) const
{
unknown's avatar
SCRUM  
unknown committed
2318
  return item->type() == DEFAULT_VALUE_ITEM && 
unknown's avatar
SCRUM  
unknown committed
2319 2320 2321
    ((Item_default_value *)item)->arg->eq(arg, binary_cmp);
}

2322

2323 2324 2325
bool Item_default_value::fix_fields(THD *thd,
				    struct st_table_list *table_list,
				    Item **items)
unknown's avatar
SCRUM  
unknown committed
2326
{
2327
  DBUG_ASSERT(fixed == 0);
unknown's avatar
SCRUM  
unknown committed
2328
  if (!arg)
2329 2330
  {
    fixed= 1;
2331
    return 0;
2332
  }
unknown's avatar
unknown committed
2333
  if (!arg->fixed && arg->fix_fields(thd, table_list, &arg))
2334 2335
    return 1;
  
unknown's avatar
SCRUM  
unknown committed
2336 2337 2338 2339 2340 2341 2342 2343 2344 2345 2346 2347 2348 2349
  if (arg->type() == REF_ITEM)
  {
    Item_ref *ref= (Item_ref *)arg;
    if (ref->ref[0]->type() != FIELD_ITEM)
    {
      return 1;
    }
    arg= ref->ref[0];
  }
  Item_field *field_arg= (Item_field *)arg;
  Field *def_field= (Field*) sql_alloc(field_arg->field->size_of());
  if (!def_field)
    return 1;
  memcpy(def_field, field_arg->field, field_arg->field->size_of());
unknown's avatar
unknown committed
2350 2351
  def_field->move_field(def_field->table->default_values -
                        def_field->table->record[0]);
unknown's avatar
SCRUM  
unknown committed
2352 2353 2354 2355
  set_field(def_field);
  return 0;
}

unknown's avatar
SCRUM  
unknown committed
2356 2357
void Item_default_value::print(String *str)
{
unknown's avatar
SCRUM  
unknown committed
2358 2359
  if (!arg)
  {
unknown's avatar
unknown committed
2360
    str->append("default", 7);
unknown's avatar
SCRUM  
unknown committed
2361
    return;
unknown's avatar
SCRUM  
unknown committed
2362
  }
unknown's avatar
unknown committed
2363
  str->append("default(", 8);
unknown's avatar
SCRUM  
unknown committed
2364 2365 2366
  arg->print(str);
  str->append(')');
}
2367

unknown's avatar
unknown committed
2368 2369 2370 2371 2372 2373 2374
bool Item_insert_value::eq(const Item *item, bool binary_cmp) const
{
  return item->type() == INSERT_VALUE_ITEM &&
    ((Item_default_value *)item)->arg->eq(arg, binary_cmp);
}


2375 2376 2377
bool Item_insert_value::fix_fields(THD *thd,
				   struct st_table_list *table_list,
				   Item **items)
unknown's avatar
unknown committed
2378
{
2379
  DBUG_ASSERT(fixed == 0);
unknown's avatar
unknown committed
2380
  if (!arg->fixed && arg->fix_fields(thd, table_list, &arg))
2381 2382
    return 1;

unknown's avatar
unknown committed
2383 2384 2385 2386 2387 2388 2389 2390 2391 2392 2393 2394 2395 2396 2397 2398 2399 2400 2401 2402 2403 2404
  if (arg->type() == REF_ITEM)
  {
    Item_ref *ref= (Item_ref *)arg;
    if (ref->ref[0]->type() != FIELD_ITEM)
    {
      return 1;
    }
    arg= ref->ref[0];
  }
  Item_field *field_arg= (Item_field *)arg;
  if (field_arg->field->table->insert_values)
  {
    Field *def_field= (Field*) sql_alloc(field_arg->field->size_of());
    if (!def_field)
      return 1;
    memcpy(def_field, field_arg->field, field_arg->field->size_of());
    def_field->move_field(def_field->table->insert_values -
                          def_field->table->record[0]);
    set_field(def_field);
  }
  else
  {
2405
    Field *tmp_field= field_arg->field;
unknown's avatar
unknown committed
2406
    /* charset doesn't matter here, it's to avoid sigsegv only */
2407 2408
    set_field(new Field_null(0, 0, Field::NONE, tmp_field->field_name,
			     tmp_field->table, &my_charset_bin));
unknown's avatar
unknown committed
2409 2410 2411 2412 2413 2414
  }
  return 0;
}

void Item_insert_value::print(String *str)
{
2415
  str->append("values(", 7);
unknown's avatar
unknown committed
2416 2417 2418 2419
  arg->print(str);
  str->append(')');
}

unknown's avatar
unknown committed
2420
/*
2421 2422
  If item is a const function, calculate it and return a const item
  The original item is freed if not returned
unknown's avatar
unknown committed
2423 2424 2425 2426 2427 2428
*/

Item_result item_cmp_type(Item_result a,Item_result b)
{
  if (a == STRING_RESULT && b == STRING_RESULT)
    return STRING_RESULT;
2429
  if (a == INT_RESULT && b == INT_RESULT)
unknown's avatar
unknown committed
2430
    return INT_RESULT;
unknown's avatar
unknown committed
2431 2432
  else if (a == ROW_RESULT || b == ROW_RESULT)
    return ROW_RESULT;
2433
  return REAL_RESULT;
unknown's avatar
unknown committed
2434 2435 2436
}


2437
void resolve_const_item(THD *thd, Item **ref, Item *comp_item)
unknown's avatar
unknown committed
2438
{
2439 2440
  Item *item= *ref;
  Item *new_item;
unknown's avatar
unknown committed
2441
  if (item->basic_const_item())
2442
    return;                                     // Can't be better
unknown's avatar
unknown committed
2443 2444 2445 2446 2447 2448 2449
  Item_result res_type=item_cmp_type(comp_item->result_type(),
				     item->result_type());
  char *name=item->name;			// Alloced by sql_alloc

  if (res_type == STRING_RESULT)
  {
    char buff[MAX_FIELD_WIDTH];
unknown's avatar
unknown committed
2450
    String tmp(buff,sizeof(buff),&my_charset_bin),*result;
unknown's avatar
unknown committed
2451 2452
    result=item->val_str(&tmp);
    if (item->null_value)
2453 2454 2455 2456 2457 2458 2459
      new_item= new Item_null(name);
    else
    {
      uint length= result->length();
      char *tmp_str= sql_strmake(result->ptr(), length);
      new_item= new Item_string(name, tmp_str, length, result->charset());
    }
unknown's avatar
unknown committed
2460
  }
2461
  else if (res_type == INT_RESULT)
unknown's avatar
unknown committed
2462 2463 2464 2465
  {
    longlong result=item->val_int();
    uint length=item->max_length;
    bool null_value=item->null_value;
2466 2467
    new_item= (null_value ? (Item*) new Item_null(name) :
               (Item*) new Item_int(name, result, length));
unknown's avatar
unknown committed
2468 2469 2470 2471 2472 2473
  }
  else
  {						// It must REAL_RESULT
    double result=item->val();
    uint length=item->max_length,decimals=item->decimals;
    bool null_value=item->null_value;
2474 2475 2476 2477
    new_item= (null_value ? (Item*) new Item_null(name) : (Item*)
               new Item_real(name, result, decimals, length));
  }
  if (new_item)
2478
    thd->change_item_tree(ref, new_item);
unknown's avatar
unknown committed
2479 2480 2481 2482 2483 2484 2485 2486 2487 2488 2489 2490 2491 2492 2493 2494 2495
}

/*
  Return true if the value stored in the field is equal to the const item
  We need to use this on the range optimizer because in some cases
  we can't store the value in the field without some precision/character loss.
*/

bool field_is_equal_to_item(Field *field,Item *item)
{

  Item_result res_type=item_cmp_type(field->result_type(),
				     item->result_type());
  if (res_type == STRING_RESULT)
  {
    char item_buff[MAX_FIELD_WIDTH];
    char field_buff[MAX_FIELD_WIDTH];
unknown's avatar
unknown committed
2496 2497
    String item_tmp(item_buff,sizeof(item_buff),&my_charset_bin),*item_result;
    String field_tmp(field_buff,sizeof(field_buff),&my_charset_bin);
unknown's avatar
unknown committed
2498 2499 2500
    item_result=item->val_str(&item_tmp);
    if (item->null_value)
      return 1;					// This must be true
2501
    field->val_str(&field_tmp);
unknown's avatar
unknown committed
2502
    return !stringcmp(&field_tmp,item_result);
unknown's avatar
unknown committed
2503 2504 2505 2506 2507 2508 2509 2510 2511
  }
  if (res_type == INT_RESULT)
    return 1;					// Both where of type int
  double result=item->val();
  if (item->null_value)
    return 1;
  return result == field->val_real();
}

2512 2513 2514 2515 2516 2517 2518 2519 2520 2521
Item_cache* Item_cache::get_cache(Item_result type)
{
  switch (type)
  {
  case INT_RESULT:
    return new Item_cache_int();
  case REAL_RESULT:
    return new Item_cache_real();
  case STRING_RESULT:
    return new Item_cache_str();
unknown's avatar
unknown committed
2522 2523
  case ROW_RESULT:
    return new Item_cache_row();
2524 2525 2526 2527 2528 2529 2530
  default:
    // should never be in real life
    DBUG_ASSERT(0);
    return 0;
  }
}

unknown's avatar
unknown committed
2531 2532 2533

void Item_cache::print(String *str)
{
2534
  str->append("<cache>(", 8);
unknown's avatar
unknown committed
2535 2536 2537 2538 2539 2540 2541 2542 2543 2544 2545 2546 2547 2548 2549 2550 2551 2552 2553 2554 2555 2556
  if (example)
    example->print(str);
  else
    Item::print(str);
  str->append(')');
}


void Item_cache_int::store(Item *item)
{
  value= item->val_int_result();
  null_value= item->null_value;
}


void Item_cache_real::store(Item *item)
{
  value= item->val_result();
  null_value= item->null_value;
}


2557 2558
void Item_cache_str::store(Item *item)
{
unknown's avatar
merge  
unknown committed
2559
  value_buff.set(buffer, sizeof(buffer), item->collation.collation);
2560
  value= item->str_result(&value_buff);
2561 2562
  if ((null_value= item->null_value))
    value= 0;
2563
  else if (value != &value_buff)
2564 2565 2566 2567 2568 2569 2570 2571 2572
  {
    /*
      We copy string value to avoid changing value if 'item' is table field
      in queries like following (where t1.c is varchar):
      select a, 
             (select a,b,c from t1 where t1.a=t2.a) = ROW(a,2,'a'),
             (select c from t1 where a=t2.a)
        from t2;
    */
2573 2574
    value_buff.copy(*value);
    value= &value_buff;
2575 2576
  }
}
2577 2578


2579
double Item_cache_str::val()
2580 2581
{
  DBUG_ASSERT(fixed == 1);
2582
  int err;
2583
  if (value)
unknown's avatar
unknown committed
2584 2585
  {
    char *end_not_used;
2586
    return my_strntod(value->charset(), (char*) value->ptr(),
unknown's avatar
unknown committed
2587 2588 2589
		      value->length(), &end_not_used, &err);
  }
  return (double)0;
2590
}
2591 2592


2593 2594
longlong Item_cache_str::val_int()
{
2595
  DBUG_ASSERT(fixed == 1);
2596
  int err;
2597 2598
  if (value)
    return my_strntoll(value->charset(), value->ptr(),
2599
		       value->length(), 10, (char**) 0, &err);
2600 2601 2602
  else
    return (longlong)0;
}
unknown's avatar
unknown committed
2603

2604

unknown's avatar
unknown committed
2605 2606
bool Item_cache_row::allocate(uint num)
{
unknown's avatar
unknown committed
2607
  item_count= num;
unknown's avatar
unknown committed
2608
  THD *thd= current_thd;
unknown's avatar
unknown committed
2609 2610
  return (!(values= 
	    (Item_cache **) thd->calloc(sizeof(Item_cache *)*item_count)));
unknown's avatar
unknown committed
2611 2612
}

2613

unknown's avatar
unknown committed
2614 2615
bool Item_cache_row::setup(Item * item)
{
unknown's avatar
unknown committed
2616
  example= item;
unknown's avatar
unknown committed
2617 2618
  if (!values && allocate(item->cols()))
    return 1;
unknown's avatar
unknown committed
2619
  for (uint i= 0; i < item_count; i++)
unknown's avatar
unknown committed
2620
  {
unknown's avatar
unknown committed
2621
    Item *el= item->el(i);
unknown's avatar
unknown committed
2622 2623
    Item_cache *tmp;
    if (!(tmp= values[i]= Item_cache::get_cache(el->result_type())))
unknown's avatar
unknown committed
2624
      return 1;
unknown's avatar
unknown committed
2625
    tmp->setup(el);
unknown's avatar
unknown committed
2626 2627 2628 2629
  }
  return 0;
}

2630

unknown's avatar
unknown committed
2631 2632 2633 2634
void Item_cache_row::store(Item * item)
{
  null_value= 0;
  item->bring_value();
unknown's avatar
unknown committed
2635
  for (uint i= 0; i < item_count; i++)
unknown's avatar
unknown committed
2636 2637 2638 2639 2640 2641
  {
    values[i]->store(item->el(i));
    null_value|= values[i]->null_value;
  }
}

2642

unknown's avatar
unknown committed
2643 2644 2645 2646 2647
void Item_cache_row::illegal_method_call(const char *method)
{
  DBUG_ENTER("Item_cache_row::illegal_method_call");
  DBUG_PRINT("error", ("!!! %s method was called for row item", method));
  DBUG_ASSERT(0);
unknown's avatar
unknown committed
2648
  my_error(ER_OPERAND_COLUMNS, MYF(0), 1);
unknown's avatar
unknown committed
2649 2650 2651
  DBUG_VOID_RETURN;
}

2652

unknown's avatar
unknown committed
2653 2654
bool Item_cache_row::check_cols(uint c)
{
unknown's avatar
unknown committed
2655
  if (c != item_count)
unknown's avatar
unknown committed
2656
  {
unknown's avatar
unknown committed
2657
    my_error(ER_OPERAND_COLUMNS, MYF(0), c);
unknown's avatar
unknown committed
2658 2659 2660 2661 2662
    return 1;
  }
  return 0;
}

2663

unknown's avatar
unknown committed
2664 2665
bool Item_cache_row::null_inside()
{
unknown's avatar
unknown committed
2666
  for (uint i= 0; i < item_count; i++)
unknown's avatar
unknown committed
2667 2668 2669 2670 2671 2672 2673 2674 2675 2676 2677 2678 2679 2680 2681 2682
  {
    if (values[i]->cols() > 1)
    {
      if (values[i]->null_inside())
	return 1;
    }
    else
    {
      values[i]->val_int();
      if (values[i]->null_value)
	return 1;
    }
  }
  return 0;
}

2683

unknown's avatar
unknown committed
2684 2685
void Item_cache_row::bring_value()
{
unknown's avatar
unknown committed
2686
  for (uint i= 0; i < item_count; i++)
unknown's avatar
unknown committed
2687 2688 2689
    values[i]->bring_value();
  return;
}
unknown's avatar
unknown committed
2690

2691

2692 2693 2694 2695 2696 2697 2698 2699 2700 2701 2702 2703 2704 2705 2706 2707 2708 2709 2710 2711 2712 2713 2714 2715 2716 2717 2718 2719 2720 2721 2722 2723 2724 2725 2726 2727 2728 2729 2730 2731 2732 2733 2734 2735 2736 2737 2738
/*
  Returns field for temporary table dependind on item type

  SYNOPSIS
    get_holder_example_field()
    thd            - thread handler
    item           - pointer to item
    table          - empty table object

  NOTE
    It is possible to return field for Item_func 
    items only if field type of this item is 
    date or time or datetime type.
    also see function field_types_to_be_kept() from
    field.cc

  RETURN
    # - field
    0 - no field
*/

Field *get_holder_example_field(THD *thd, Item *item, TABLE *table)
{
  DBUG_ASSERT(table);

  Item_func *tmp_item= 0;
  if (item->type() == Item::FIELD_ITEM)
    return (((Item_field*) item)->field);
  if (item->type() == Item::FUNC_ITEM)
    tmp_item= (Item_func *) item;
  else if (item->type() == Item::SUM_FUNC_ITEM)
  {
    Item_sum *item_sum= (Item_sum *) item;
    if (item_sum->keep_field_type())
    {
      if (item_sum->args[0]->type() == Item::FIELD_ITEM)
        return (((Item_field*) item_sum->args[0])->field);
      if (item_sum->args[0]->type() == Item::FUNC_ITEM)
        tmp_item= (Item_func *) item_sum->args[0];
    }
  }
  return (tmp_item && field_types_to_be_kept(tmp_item->field_type()) ?
          tmp_item->tmp_table_field(table) : 0);
}


Item_type_holder::Item_type_holder(THD *thd, Item *item, TABLE *table)
unknown's avatar
unknown committed
2739 2740
  :Item(thd, item), item_type(item->result_type()),
   orig_type(item_type)
2741 2742
{
  DBUG_ASSERT(item->fixed);
unknown's avatar
unknown committed
2743 2744 2745 2746 2747

  /*
    It is safe assign pointer on field, because it will be used just after
    all JOIN::prepare calls and before any SELECT execution
  */
2748
  field_example= get_holder_example_field(thd, item, table);
2749
  max_length= real_length(item);
2750
  maybe_null= item->maybe_null;
2751
  collation.set(item->collation);
2752 2753 2754
}


2755 2756 2757 2758 2759 2760 2761
/*
  STRING_RESULT, REAL_RESULT, INT_RESULT, ROW_RESULT

  ROW_RESULT should never appear in Item_type_holder::join_types,
  but it is included in following table just to make table full
  (there DBUG_ASSERT in function to catch ROW_RESULT)
*/
2762 2763 2764 2765 2766 2767
static Item_result type_convertor[4][4]=
{{STRING_RESULT, STRING_RESULT, STRING_RESULT, ROW_RESULT},
 {STRING_RESULT, REAL_RESULT,   REAL_RESULT,   ROW_RESULT},
 {STRING_RESULT, REAL_RESULT,   INT_RESULT,    ROW_RESULT},
 {ROW_RESULT,    ROW_RESULT,    ROW_RESULT,    ROW_RESULT}};

unknown's avatar
unknown committed
2768 2769 2770 2771 2772 2773 2774 2775 2776 2777 2778 2779 2780 2781 2782 2783 2784 2785 2786 2787

/*
  Values of 'from' field can be stored in 'to' field.

  SYNOPSIS
    is_attr_compatible()
    from        Item which values should be saved
    to          Item where values should be saved

  RETURN
    1   can be saved
    0   can not be saved
*/

inline bool is_attr_compatible(Item *from, Item *to)
{
  return ((to->max_length >= from->max_length) &&
          (to->maybe_null || !from->maybe_null) &&
          (to->result_type() != STRING_RESULT ||
           from->result_type() != STRING_RESULT ||
2788
          (from->collation.collation == to->collation.collation)));
unknown's avatar
unknown committed
2789 2790 2791
}


2792
bool Item_type_holder::join_types(THD *thd, Item *item, TABLE *table)
2793
{
2794
  uint32 new_length= real_length(item);
unknown's avatar
unknown committed
2795 2796
  bool use_new_field= 0, use_expression_type= 0;
  Item_result new_result_type= type_convertor[item_type][item->result_type()];
2797
  Field *field= get_holder_example_field(thd, item, table);
2798
  bool item_is_a_field= (field != NULL);
2799
  /*
unknown's avatar
unknown committed
2800 2801
    Check if both items point to fields: in this case we
    can adjust column types of result table in the union smartly.
2802
  */
2803
  if (field_example && item_is_a_field)
2804
  {
unknown's avatar
unknown committed
2805 2806 2807 2808
    /* Can 'field_example' field store data of the column? */
    if ((use_new_field=
         (!field->field_cast_compatible(field_example->field_cast_type()) ||
          !is_attr_compatible(item, this))))
2809
    {
2810
      /*
unknown's avatar
unknown committed
2811 2812
        The old field can't store value of the new field.
        Check if the new field can store value of the old one.
2813
      */
unknown's avatar
unknown committed
2814 2815 2816
      use_expression_type|=
        (!field_example->field_cast_compatible(field->field_cast_type()) ||
         !is_attr_compatible(this, item));
2817 2818
    }
  }
2819
  else if (field_example || item_is_a_field)
2820
  {
unknown's avatar
unknown committed
2821 2822 2823 2824
    /*
      Expression types can't be mixed with field types, we have to use
      expression types.
    */
2825
    use_new_field= 1;                           // make next if test easier
unknown's avatar
unknown committed
2826
    use_expression_type= 1;
2827
  }
2828

unknown's avatar
unknown committed
2829
  /* Check whether size/type of the result item should be changed */
2830
  if (use_new_field ||
unknown's avatar
unknown committed
2831
      (new_result_type != item_type) || (new_length > max_length) ||
2832
      (!maybe_null && item->maybe_null) ||
2833 2834
      (item_type == STRING_RESULT && 
       collation.collation != item->collation.collation))
2835
  {
2836 2837
    const char *old_cs,*old_derivation;
    if (use_expression_type || !item_is_a_field)
2838 2839
      field_example= 0;
    else
unknown's avatar
unknown committed
2840 2841 2842 2843 2844
    {
      /*
        It is safe to assign a pointer to field here, because it will be used
        before any table is closed.
      */
2845
      field_example= field;
unknown's avatar
unknown committed
2846
    }
unknown's avatar
unknown committed
2847

2848 2849
    old_cs= collation.collation->name;
    old_derivation= collation.derivation_name();
2850 2851 2852 2853 2854 2855 2856 2857 2858 2859
    if (item_type == STRING_RESULT && collation.aggregate(item->collation))
    {
      my_error(ER_CANT_AGGREGATE_2COLLATIONS, MYF(0),
	       old_cs, old_derivation,
	       item->collation.collation->name,
	       item->collation.derivation_name(),
	       "UNION");
      return 1;
    }

2860
    max_length= max(max_length, new_length);
2861 2862
    decimals= max(decimals, item->decimals);
    maybe_null|= item->maybe_null;
unknown's avatar
unknown committed
2863
    item_type= new_result_type;
2864 2865
  }
  DBUG_ASSERT(item_type != ROW_RESULT);
2866
  return 0;
2867 2868
}

2869

2870 2871 2872
uint32 Item_type_holder::real_length(Item *item)
{
  if (item->type() == Item::FIELD_ITEM)
unknown's avatar
unknown committed
2873
    return ((Item_field *)item)->max_disp_length();
2874

2875 2876 2877 2878 2879 2880 2881 2882 2883 2884 2885 2886 2887 2888
  switch (item->result_type())
  {
  case STRING_RESULT:
    return item->max_length;
  case REAL_RESULT:
    return 53;
  case INT_RESULT:
    return 20;
  case ROW_RESULT:
  default:
    DBUG_ASSERT(0); // we should never go there
    return 0;
  }
}
2889 2890 2891 2892 2893 2894 2895 2896 2897 2898 2899 2900 2901 2902 2903 2904 2905 2906 2907 2908 2909

double Item_type_holder::val()
{
  DBUG_ASSERT(0); // should never be called
  return 0.0;
}


longlong Item_type_holder::val_int()
{
  DBUG_ASSERT(0); // should never be called
  return 0;
}


String *Item_type_holder::val_str(String*)
{
  DBUG_ASSERT(0); // should never be called
  return 0;
}

2910 2911 2912 2913 2914 2915 2916 2917
void Item_result_field::cleanup()
{
  DBUG_ENTER("Item_result_field::cleanup()");
  Item::cleanup();
  result_field= 0;
  DBUG_VOID_RETURN;
}

unknown's avatar
unknown committed
2918 2919 2920 2921 2922 2923 2924
/*****************************************************************************
** Instantiate templates
*****************************************************************************/

#ifdef __GNUC__
template class List<Item>;
template class List_iterator<Item>;
unknown's avatar
unknown committed
2925
template class List_iterator_fast<Item>;
unknown's avatar
unknown committed
2926 2927
template class List<List_item>;
#endif