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
  nagg++;
388
  if (!my_charset_same(collation, dt.collation))
389
  {
390 391 392
    /* 
       We do allow to use binary strings (like BLOBS)
       together with character strings.
unknown's avatar
unknown committed
393 394
       Binaries have more precedance than a character
       string of the same derivation.
395
    */
396
    if (collation == &my_charset_bin)
397
    {
398 399 400
      if (derivation <= dt.derivation)
	; // Do nothing
      else
401 402 403 404
      {
	set(dt); 
        strong= nagg;
      }
405
    }
406
    else if (dt.collation == &my_charset_bin)
407
    {
408
      if (dt.derivation <= derivation)
409
      {
410
        set(dt);
411 412
        strong= nagg;
      }
413 414
      else
       ; // Do nothing
415
    }
416 417 418
    else if ((flags & MY_COLL_ALLOW_SUPERSET_CONV) &&
             derivation < dt.derivation &&
             collation->state & MY_CS_UNICODE)
419
    {
420 421 422 423 424 425 426 427 428 429 430
      // Do nothing
    }
    else if ((flags & MY_COLL_ALLOW_SUPERSET_CONV) &&
             dt.derivation < derivation &&
             dt.collation->state & MY_CS_UNICODE)
    {
      set(dt);
      strong= nagg;
    }
    else if ((flags & MY_COLL_ALLOW_COERCIBLE_CONV) &&
             derivation < dt.derivation &&
431
             dt.derivation >= DERIVATION_COERCIBLE)
432 433 434 435 436
    {
      // Do nothing;
    }
    else if ((flags & MY_COLL_ALLOW_COERCIBLE_CONV) &&
             dt.derivation < derivation &&
437
             derivation >= DERIVATION_COERCIBLE)
438 439 440
    {
      set(dt);
      strong= nagg;
441
    }
442 443
    else
    {
444
      // Cannot apply conversion
445
      set(0, DERIVATION_NONE);
446
      return 1;
447
    }
448
  }
449
  else if (derivation < dt.derivation)
450
  {
451
    // Do nothing
452
  }
453
  else if (dt.derivation < derivation)
454
  {
455
    set(dt);
456
    strong= nagg;
457
  }
458 459 460
  else
  { 
    if (collation == dt.collation)
461
    {
462 463 464 465 466
      // Do nothing
    }
    else 
    {
      if (derivation == DERIVATION_EXPLICIT)
467
      {
468 469
	set(0, DERIVATION_NONE);
	return 1;
470
      }
471 472 473
      CHARSET_INFO *bin= get_charset_by_csname(collation->csname, 
					       MY_CS_BINSORT,MYF(0));
      set(bin, DERIVATION_NONE);
474
    }
475 476 477 478
  }
  return 0;
}

unknown's avatar
unknown committed
479
Item_field::Item_field(Field *f)
480
  :Item_ident(NullS, f->table_name, f->field_name)
unknown's avatar
unknown committed
481 482
{
  set_field(f);
483 484 485 486 487
  /*
    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
488 489
}

490
Item_field::Item_field(THD *thd, Field *f)
491
  :Item_ident(f->table->table_cache_key, f->table_name, f->field_name)
492
{
493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513
  /*
    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);
514 515 516 517 518 519
    /*
      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;
520
  }
521 522 523
  set_field(f);
}

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

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;
541
  db_name=field_par->table->table_cache_key;
542
  unsigned_flag=test(field_par->flags & UNSIGNED_FLAG);
543
  collation.set(field_par->charset(), DERIVATION_IMPLICIT);
544
  fixed= 1;
unknown's avatar
unknown committed
545 546
}

547 548 549 550 551 552 553 554 555 556 557 558 559 560

/*
  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
561 562 563
const char *Item_ident::full_name() const
{
  char *tmp;
564
  if (!table_name || !field_name)
unknown's avatar
unknown committed
565
    return field_name ? field_name : name ? name : "tmp_field";
unknown's avatar
unknown committed
566
  if (db_name && db_name[0])
unknown's avatar
unknown committed
567
  {
unknown's avatar
unknown committed
568 569
    tmp=(char*) sql_alloc((uint) strlen(db_name)+(uint) strlen(table_name)+
			  (uint) strlen(field_name)+3);
unknown's avatar
unknown committed
570 571 572 573
    strxmov(tmp,db_name,".",table_name,".",field_name,NullS);
  }
  else
  {
574 575 576 577 578 579 580 581
    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
582 583 584 585 586 587 588
  }
  return tmp;
}

/* ARGSUSED */
String *Item_field::val_str(String *str)
{
589
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
590 591
  if ((null_value=field->is_null()))
    return 0;
unknown's avatar
unknown committed
592
  str->set_charset(str_value.charset());
unknown's avatar
unknown committed
593 594 595 596 597
  return field->val_str(str,&str_value);
}

double Item_field::val()
{
598
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
599 600 601 602 603 604 605
  if ((null_value=field->is_null()))
    return 0.0;
  return field->val_real();
}

longlong Item_field::val_int()
{
606
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
607 608 609 610 611 612 613 614 615 616
  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;
617
  str->set_charset(str_value.charset());
unknown's avatar
unknown committed
618 619 620
  return result_field->val_str(str,&str_value);
}

621
bool Item_field::get_date(TIME *ltime,uint fuzzydate)
unknown's avatar
unknown committed
622 623 624 625 626 627 628 629 630
{
  if ((null_value=field->is_null()) || field->get_date(ltime,fuzzydate))
  {
    bzero((char*) ltime,sizeof(*ltime));
    return 1;
  }
  return 0;
}

631
bool Item_field::get_date_result(TIME *ltime,uint fuzzydate)
632 633 634 635 636 637 638 639 640 641
{
  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
642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665
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();
}

666

667
bool Item_field::eq(const Item *item, bool binary_cmp) const
unknown's avatar
unknown committed
668
{
669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690
  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 ||
691 692
	     (item_field->db_name && !strcmp(item_field->db_name,
					     db_name))))));
unknown's avatar
unknown committed
693 694
}

695

unknown's avatar
unknown committed
696 697 698 699
table_map Item_field::used_tables() const
{
  if (field->table->const_table)
    return 0;					// const item
unknown's avatar
unknown committed
700
  return (depended_from ? OUTER_REF_TABLE_BIT : field->table->map);
unknown's avatar
unknown committed
701 702
}

703

704
Item *Item_field::get_tmp_table_item(THD *thd)
705
{
706
  Item_field *new_item= new Item_field(thd, this);
707 708 709 710
  if (new_item)
    new_item->field= new_item->result_field;
  return new_item;
}
unknown's avatar
unknown committed
711

712

unknown's avatar
unknown committed
713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728
/*
  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
729 730
String *Item_int::val_str(String *str)
{
unknown's avatar
unknown committed
731
  // following assert is redundant, because fixed=1 assigned in constructor
732
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
733
  str->set(value, &my_charset_bin);
unknown's avatar
unknown committed
734 735 736 737 738
  return str;
}

void Item_int::print(String *str)
{
unknown's avatar
unknown committed
739 740
  // my_charset_bin is good enough for numbers
  str_value.set(value, &my_charset_bin);
unknown's avatar
unknown committed
741
  str->append(str_value);
unknown's avatar
unknown committed
742 743
}

744

unknown's avatar
unknown committed
745 746 747 748 749 750 751
Item_uint::Item_uint(const char *str_arg, uint length):
  Item_int(str_arg, length)
{
  unsigned_flag= 1;
}


unknown's avatar
unknown committed
752 753
String *Item_uint::val_str(String *str)
{
unknown's avatar
unknown committed
754
  // following assert is redundant, because fixed=1 assigned in constructor
755
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
756
  str->set((ulonglong) value, &my_charset_bin);
unknown's avatar
unknown committed
757 758 759
  return str;
}

760

unknown's avatar
unknown committed
761 762
void Item_uint::print(String *str)
{
763
  // latin1 is good enough for numbers
unknown's avatar
unknown committed
764 765
  str_value.set((ulonglong) value, default_charset());
  str->append(str_value);
unknown's avatar
unknown committed
766 767
}

unknown's avatar
unknown committed
768 769 770

String *Item_real::val_str(String *str)
{
unknown's avatar
unknown committed
771
  // following assert is redundant, because fixed=1 assigned in constructor
772
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
773
  str->set(value,decimals,&my_charset_bin);
unknown's avatar
unknown committed
774 775 776
  return str;
}

777

unknown's avatar
unknown committed
778 779
void Item_string::print(String *str)
{
780 781
  str->append('_');
  str->append(collation.collation->csname);
unknown's avatar
unknown committed
782
  str->append('\'');
unknown's avatar
unknown committed
783
  str_value.print(str);
unknown's avatar
unknown committed
784 785 786
  str->append('\'');
}

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


unknown's avatar
unknown committed
813 814 815 816 817 818
Item *Item_null::safe_charset_converter(CHARSET_INFO *tocs)
{
  collation.set(tocs);
  return this;
}

819 820 821 822 823 824 825 826 827 828 829 830 831 832 833
/*********************** 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();
}

834 835
Item_param::Item_param(unsigned pos_in_query_arg) :
  state(NO_VALUE),
836
  item_result_type(STRING_RESULT),
837 838
  /* Don't pretend to be a literal unless value for this item is set. */
  item_type(PARAM_ITEM),
839
  param_type(MYSQL_TYPE_STRING),
840
  pos_in_query(pos_in_query_arg),
841 842 843
  set_param_func(default_set_param_func)
{
  name= (char*) "?";
844 845 846 847 848 849
  /* 
    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;
850 851
}

unknown's avatar
unknown committed
852
void Item_param::set_null()
853 854
{
  DBUG_ENTER("Item_param::set_null");
855
  /* These are cleared after each execution by reset() method */
856
  max_length= 0;
857 858 859 860 861 862 863 864 865
  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;
866
  DBUG_VOID_RETURN;
unknown's avatar
unknown committed
867 868
}

869
void Item_param::set_int(longlong i, uint32 max_length_arg)
870 871
{
  DBUG_ENTER("Item_param::set_int");
872 873 874 875
  value.integer= (longlong) i;
  state= INT_VALUE;
  max_length= max_length_arg;
  decimals= 0;
876
  maybe_null= 0;
877
  DBUG_VOID_RETURN;
unknown's avatar
unknown committed
878 879
}

880
void Item_param::set_double(double d)
881 882
{
  DBUG_ENTER("Item_param::set_double");
883 884 885
  value.real= d;
  state= REAL_VALUE;
  max_length= DBL_DIG + 8;
886
  decimals= NOT_FIXED_DEC;
887
  maybe_null= 0;
888
  DBUG_VOID_RETURN;
unknown's avatar
unknown committed
889 890
}

891

892 893 894 895 896 897 898 899 900 901 902 903 904 905 906
/*
  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.
*/
907
void Item_param::set_time(TIME *tm, timestamp_type type, uint32 max_length_arg)
908
{ 
909
  DBUG_ENTER("Item_param::set_time");
910

911 912
  value.time= *tm;
  value.time.time_type= type;
913

914 915 916 917 918 919 920 921 922 923 924
  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);
  }

925 926 927 928 929 930
  state= TIME_VALUE;
  maybe_null= 0;
  max_length= max_length_arg;
  decimals= 0;
  DBUG_VOID_RETURN;
}
unknown's avatar
unknown committed
931

932 933 934 935 936 937 938 939

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
940 941 942
  uint dummy_errors;
  if (str_value.copy(str, length, &my_charset_bin, &my_charset_bin,
                     &dummy_errors))
943 944
    DBUG_RETURN(TRUE);
  state= STRING_VALUE;
945
  maybe_null= 0;
946 947 948
  /* 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);
949 950 951
}


952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967
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;
968
  maybe_null= 0;
969 970

  DBUG_RETURN(FALSE);
971 972 973
}


974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992
/*
  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
993 994 995
    switch (entry->type) {
    case REAL_RESULT:
      set_double(*(double*)entry->value);
996 997
      item_type= Item::REAL_ITEM;
      item_result_type= REAL_RESULT;
unknown's avatar
unknown committed
998 999 1000
      break;
    case INT_RESULT:
      set_int(*(longlong*)entry->value, 21);
1001 1002
      item_type= Item::INT_ITEM;
      item_result_type= INT_RESULT;
unknown's avatar
unknown committed
1003 1004
      break;
    case STRING_RESULT:
1005
    {
unknown's avatar
unknown committed
1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032
      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();
1033 1034 1035 1036 1037 1038 1039 1040
    }
  }
  else
    set_null();

  DBUG_RETURN(0);
}

1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052
/*
    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()
1053 1054 1055 1056 1057 1058
{
  /* 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);
1059
  str_value_ptr.length(0);
1060
  /*
1061 1062
    We must prevent all charset conversions untill data has been written
    to the binary log.
1063 1064 1065
  */
  str_value.set_charset(&my_charset_bin);
  state= NO_VALUE;
1066 1067
  maybe_null= 1;
  null_value= 0;
1068 1069 1070 1071 1072 1073 1074 1075 1076
  /*
    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
1077 1078 1079
}


unknown's avatar
unknown committed
1080
int Item_param::save_in_field(Field *field, bool no_conversions)
unknown's avatar
unknown committed
1081 1082
{
  field->set_notnull();
1083 1084 1085 1086 1087 1088 1089 1090

  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);
1091
    return 0;
1092 1093 1094 1095 1096
  case STRING_VALUE:
  case LONG_DATA_VALUE:
    return field->store(str_value.ptr(), str_value.length(),
                        str_value.charset());
  case NULL_VALUE:
1097
    return set_field_to_null_with_conversions(field, no_conversions);
1098 1099 1100
  case NO_VALUE:
  default:
    DBUG_ASSERT(0);
unknown's avatar
unknown committed
1101
  }
1102
  return 1;
unknown's avatar
unknown committed
1103 1104
}

1105

1106 1107
bool Item_param::get_time(TIME *res)
{
1108 1109 1110 1111 1112 1113 1114 1115 1116 1117
  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);
1118
}
1119

1120

1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131
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
1132 1133
double Item_param::val() 
{
1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150
  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;
      return my_strntod(str_value.charset(), (char*) str_value.ptr(),
                        str_value.length(), (char**) 0, &dummy_err);
    }
  case TIME_VALUE:
    /*
      This works for example when user says SELECT ?+0.0 and supplies
      time value for the placeholder.
    */
1151
    return ulonglong2double(TIME_to_ulonglong(&value.time));
1152
  case NULL_VALUE:
1153
    return 0.0;
unknown's avatar
unknown committed
1154
  default:
1155
    DBUG_ASSERT(0);
unknown's avatar
unknown committed
1156
  }
1157
  return 0.0;
unknown's avatar
unknown committed
1158 1159
} 

1160

unknown's avatar
unknown committed
1161 1162
longlong Item_param::val_int() 
{ 
1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178
  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
1179
  default:
1180
    DBUG_ASSERT(0);
unknown's avatar
unknown committed
1181
  }
1182
  return 0;
unknown's avatar
unknown committed
1183 1184
}

1185

unknown's avatar
unknown committed
1186 1187
String *Item_param::val_str(String* str) 
{ 
1188 1189 1190
  switch (state) {
  case STRING_VALUE:
  case LONG_DATA_VALUE:
1191
    return &str_value_ptr;
1192 1193 1194 1195 1196
  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
1197
    return str;
1198 1199
  case TIME_VALUE:
  {
1200
    if (str->reserve(MAX_DATE_STRING_REP_LENGTH))
1201
      break;
1202 1203
    str->length((uint) my_TIME_to_str(&value.time, (char*) str->ptr()));
    str->set_charset(&my_charset_bin);
unknown's avatar
unknown committed
1204
    return str;
1205 1206 1207
  }
  case NULL_VALUE:
    return NULL; 
unknown's avatar
unknown committed
1208
  default:
1209
    DBUG_ASSERT(0);
unknown's avatar
unknown committed
1210
  }
1211
  return str;
unknown's avatar
unknown committed
1212
}
1213 1214 1215 1216

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

1221
const String *Item_param::query_val_str(String* str) const
1222
{
1223 1224 1225 1226 1227 1228 1229 1230
  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:
1231
    {
1232 1233 1234 1235 1236 1237
      char *buf, *ptr;
      str->length(0);
      /*
        TODO: in case of error we need to notify replication
        that binary log contains wrong statement 
      */
1238
      if (str->reserve(MAX_DATE_STRING_REP_LENGTH+3))
1239 1240 1241 1242 1243 1244
        break; 

      /* Create date string inplace */
      buf= str->c_ptr_quick();
      ptr= buf;
      *ptr++= '\'';
1245
      ptr+= (uint) my_TIME_to_str(&value.time, ptr);
1246 1247 1248
      *ptr++= '\'';
      str->length((uint32) (ptr - buf));
      break;
1249
    }
1250 1251
  case STRING_VALUE:
  case LONG_DATA_VALUE:
1252
    {
1253 1254 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 1265
      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;
1266
    }
1267 1268 1269 1270
  case NULL_VALUE:
    return &my_null_string;
  default:
    DBUG_ASSERT(0);
1271 1272 1273
  }
  return str;
}
1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298


/*
  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);
    }
1299 1300 1301 1302
    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 */

1303 1304
    max_length= str_value.length();
    decimals= 0;
1305 1306 1307 1308 1309 1310
    /*
      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());
1311 1312 1313 1314
  }
  return rc;
}

unknown's avatar
unknown committed
1315 1316
/* End of Item_param related */

1317

unknown's avatar
unknown committed
1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328
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)
{
1329
  // Item_copy_string is used without fix_fields call
unknown's avatar
unknown committed
1330 1331 1332 1333 1334
  if (null_value)
    return (String*) 0;
  return &str_value;
}

unknown's avatar
unknown committed
1335 1336 1337 1338 1339 1340 1341 1342 1343 1344

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
1345
/*
1346
  Functions to convert item to field (for send_fields)
unknown's avatar
unknown committed
1347 1348 1349 1350
*/

/* ARGSUSED */
bool Item::fix_fields(THD *thd,
unknown's avatar
unknown committed
1351 1352
		      struct st_table_list *list,
		      Item ** ref)
unknown's avatar
unknown committed
1353
{
1354 1355

  // We do not check fields which are fixed during construction
unknown's avatar
unknown committed
1356
  DBUG_ASSERT(fixed == 0 || basic_const_item());
1357
  fixed= 1;
unknown's avatar
unknown committed
1358 1359 1360
  return 0;
}

1361 1362
double Item_ref_null_helper::val()
{
1363
  DBUG_ASSERT(fixed == 1);
1364
  double tmp= (*ref)->val_result();
unknown's avatar
unknown committed
1365
  owner->was_null|= null_value= (*ref)->null_value;
1366 1367
  return tmp;
}
1368 1369


1370 1371
longlong Item_ref_null_helper::val_int()
{
1372
  DBUG_ASSERT(fixed == 1);
1373
  longlong tmp= (*ref)->val_int_result();
unknown's avatar
unknown committed
1374
  owner->was_null|= null_value= (*ref)->null_value;
1375 1376
  return tmp;
}
1377 1378


1379 1380
String* Item_ref_null_helper::val_str(String* s)
{
1381
  DBUG_ASSERT(fixed == 1);
1382
  String* tmp= (*ref)->str_result(s);
unknown's avatar
unknown committed
1383
  owner->was_null|= null_value= (*ref)->null_value;
1384 1385
  return tmp;
}
1386 1387


1388
bool Item_ref_null_helper::get_date(TIME *ltime, uint fuzzydate)
1389 1390 1391
{  
  return (owner->was_null|= null_value= (*ref)->get_date(ltime, fuzzydate));
}
unknown's avatar
unknown committed
1392

unknown's avatar
unknown committed
1393 1394 1395 1396 1397 1398

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

  SYNOPSIS
    mark_as_dependent()
1399
    thd - thread handler
unknown's avatar
unknown committed
1400 1401 1402 1403 1404
    last - select from which current item depend
    current  - current select
    item - item which should be marked
*/

1405
static void mark_as_dependent(THD *thd, SELECT_LEX *last, SELECT_LEX *current,
unknown's avatar
unknown committed
1406 1407
			      Item_ident *item)
{
1408
  // store pointer on SELECT_LEX from which item is dependent
unknown's avatar
unknown committed
1409 1410
  item->depended_from= last;
  current->mark_as_dependent(last);
1411
  if (thd->lex->describe & DESCRIBE_EXTENDED)
1412 1413 1414 1415 1416 1417 1418 1419 1420 1421
  {
    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
1422 1423 1424
}


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

	  Item_subselect *prev_subselect_item= prev_unit->item;
1475
          place= prev_subselect_item->parsing_place;
1476 1477
          /*
            check table fields only if subquery used somewhere out of HAVING
1478 1479
            or outer SELECT do not use groupping (i.e. tables are
            accessable)
1480
          */
1481
          if ((place != IN_HAVING ||
1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492
               (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;
          }
1493
	  if (sl->resolve_mode == SELECT_LEX::SELECT_MODE &&
unknown's avatar
unknown committed
1494
	      (refer= find_item_in_list(this, sl->item_list, &counter,
1495 1496
                                        REPORT_EXCEPT_NOT_FOUND,
                                        &not_used)) !=
1497
	       (Item **) not_found_item)
1498
	  {
1499
	    if (refer && (*refer)->fixed) // Avoid crash in case of error
1500
	    {
unknown's avatar
unknown committed
1501 1502
	      prev_subselect_item->used_tables_cache|= (*refer)->used_tables();
	      prev_subselect_item->const_item_cache&= (*refer)->const_item();
1503
	    }
1504
	    break;
1505 1506 1507
	  }

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

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

1570
	mark_as_dependent(thd, last, cursel, rf);
1571 1572
	return 0;
      }
unknown's avatar
unknown committed
1573
      else
unknown's avatar
unknown committed
1574
      {
1575
	mark_as_dependent(thd, last, cursel, this);
unknown's avatar
unknown committed
1576
	if (last->having_fix_field)
1577 1578
	{
	  Item_ref *rf;
1579 1580
          rf= new Item_ref((where->db[0] ? where->db : 0),
                           (char*) where->alias, (char*) field_name);
1581 1582
	  if (!rf)
	    return 1;
1583
          thd->change_item_tree(ref, rf);
1584 1585 1586 1587
	  /*
	    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
1588
	  return rf->fix_fields(thd, tables, ref) ||  rf->check_cols(1);
1589
	}
unknown's avatar
unknown committed
1590
      }
1591
    }
1592 1593 1594
    else if (!tmp)
      return -1;

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

unknown's avatar
unknown committed
1609 1610
void Item_field::cleanup()
{
unknown's avatar
unknown committed
1611
  DBUG_ENTER("Item_field::cleanup");
unknown's avatar
unknown committed
1612
  Item_ident::cleanup();
1613 1614 1615 1616 1617
  /*
    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'.
   */
1618
  field= result_field= 0;
unknown's avatar
unknown committed
1619
  DBUG_VOID_RETURN;
unknown's avatar
unknown committed
1620
}
unknown's avatar
unknown committed
1621 1622 1623

void Item::init_make_field(Send_field *tmp_field,
			   enum enum_field_types field_type)
unknown's avatar
unknown committed
1624
{
1625
  char *empty_name= (char*) "";
unknown's avatar
unknown committed
1626
  tmp_field->db_name=		empty_name;
1627 1628 1629 1630
  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
1631
  tmp_field->charsetnr=         collation.collation->number;
unknown's avatar
unknown committed
1632 1633 1634
  tmp_field->flags=             (maybe_null ? 0 : NOT_NULL_FLAG) | 
                                (my_binary_compare(collation.collation) ?
                                 BINARY_FLAG : 0);
unknown's avatar
unknown committed
1635 1636 1637
  tmp_field->type=field_type;
  tmp_field->length=max_length;
  tmp_field->decimals=decimals;
1638 1639
  if (unsigned_flag)
    tmp_field->flags |= UNSIGNED_FLAG;
unknown's avatar
unknown committed
1640 1641
}

unknown's avatar
unknown committed
1642
void Item::make_field(Send_field *tmp_field)
unknown's avatar
unknown committed
1643
{
unknown's avatar
unknown committed
1644
  init_make_field(tmp_field, field_type());
unknown's avatar
unknown committed
1645 1646 1647
}


1648 1649 1650 1651 1652
void Item_empty_string::make_field(Send_field *tmp_field)
{
  init_make_field(tmp_field,FIELD_TYPE_VAR_STRING);
}

unknown's avatar
unknown committed
1653

unknown's avatar
unknown committed
1654
enum_field_types Item::field_type() const
unknown's avatar
unknown committed
1655
{
unknown's avatar
unknown committed
1656 1657 1658
  return ((result_type() == STRING_RESULT) ? FIELD_TYPE_VAR_STRING :
	  (result_type() == INT_RESULT) ? FIELD_TYPE_LONGLONG :
	  FIELD_TYPE_DOUBLE);
unknown's avatar
unknown committed
1659 1660
}

1661

1662 1663
Field *Item::tmp_table_field_from_field_type(TABLE *table)
{
1664 1665 1666 1667 1668 1669
  /*
    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()) {
1670
  case MYSQL_TYPE_DECIMAL:
1671 1672
    return new Field_decimal((char*) 0, max_length, null_ptr, 0, Field::NONE,
			     name, table, decimals, 0, unsigned_flag);
1673
  case MYSQL_TYPE_TINY:
1674 1675
    return new Field_tiny((char*) 0, max_length, null_ptr, 0, Field::NONE,
			  name, table, 0, unsigned_flag);
1676
  case MYSQL_TYPE_SHORT:
1677 1678
    return new Field_short((char*) 0, max_length, null_ptr, 0, Field::NONE,
			   name, table, 0, unsigned_flag);
1679
  case MYSQL_TYPE_LONG:
1680 1681
    return new Field_long((char*) 0, max_length, null_ptr, 0, Field::NONE,
			  name, table, 0, unsigned_flag);
1682 1683
#ifdef HAVE_LONG_LONG
  case MYSQL_TYPE_LONGLONG:
1684 1685
    return new Field_longlong((char*) 0, max_length, null_ptr, 0, Field::NONE,
			      name, table, 0, unsigned_flag);
1686
#endif
1687 1688 1689 1690 1691 1692 1693 1694 1695
  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);
1696 1697
  case MYSQL_TYPE_NEWDATE:
  case MYSQL_TYPE_INT24:
1698 1699
    return new Field_medium((char*) 0, max_length, null_ptr, 0, Field::NONE,
			    name, table, 0, unsigned_flag);
1700 1701 1702 1703 1704 1705 1706 1707
  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:
1708 1709 1710 1711 1712 1713
    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 */
1714 1715
  case MYSQL_TYPE_ENUM:
  case MYSQL_TYPE_SET:
1716 1717 1718 1719 1720 1721 1722 1723 1724 1725
  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);
1726 1727 1728 1729 1730
  case MYSQL_TYPE_TINY_BLOB:
  case MYSQL_TYPE_MEDIUM_BLOB:
  case MYSQL_TYPE_LONG_BLOB:
  case MYSQL_TYPE_BLOB:
  case MYSQL_TYPE_GEOMETRY:
1731
    break;					// Blob handled outside of case
1732
  }
1733 1734 1735 1736

  /* 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);
1737 1738
}

1739

unknown's avatar
unknown committed
1740 1741
/* ARGSUSED */
void Item_field::make_field(Send_field *tmp_field)
unknown's avatar
unknown committed
1742
{
unknown's avatar
unknown committed
1743
  field->make_field(tmp_field);
1744
  DBUG_ASSERT(tmp_field->table_name);
unknown's avatar
unknown committed
1745 1746
  if (name)
    tmp_field->col_name=name;			// Use user supplied name
unknown's avatar
unknown committed
1747 1748
}

1749

unknown's avatar
unknown committed
1750
/*
1751
  Set a field:s value from a item
unknown's avatar
unknown committed
1752 1753 1754 1755 1756 1757 1758
*/

void Item_field::save_org_in_field(Field *to)
{
  if (field->is_null())
  {
    null_value=1;
1759
    set_field_to_null_with_conversions(to, 1);
unknown's avatar
unknown committed
1760 1761 1762 1763 1764 1765 1766 1767 1768
  }
  else
  {
    to->set_notnull();
    field_conv(to,field);
    null_value=0;
  }
}

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

1785

unknown's avatar
unknown committed
1786 1787 1788 1789 1790 1791 1792 1793 1794 1795 1796 1797 1798 1799 1800 1801
/*
  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
1802
int Item_null::save_in_field(Field *field, bool no_conversions)
unknown's avatar
unknown committed
1803
{
1804
  return set_field_to_null_with_conversions(field, no_conversions);
unknown's avatar
unknown committed
1805 1806 1807
}


1808 1809 1810 1811 1812 1813 1814 1815 1816 1817 1818 1819
/*
  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
1820
int Item_null::save_safe_in_field(Field *field)
unknown's avatar
unknown committed
1821 1822 1823 1824 1825
{
  return set_field_to_null(field);
}


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

1866

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

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

unknown's avatar
unknown committed
1886 1887

int Item_int::save_in_field(Field *field, bool no_conversions)
unknown's avatar
unknown committed
1888 1889 1890 1891 1892
{
  longlong nr=val_int();
  if (null_value)
    return set_field_to_null(field);
  field->set_notnull();
unknown's avatar
unknown committed
1893
  return field->store(nr);
unknown's avatar
unknown committed
1894 1895
}

unknown's avatar
unknown committed
1896 1897 1898 1899
Item_num *Item_uint::neg()
{
  return new Item_real(name, - ((double) value), 0, max_length);
}
unknown's avatar
unknown committed
1900 1901

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

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

unknown's avatar
unknown committed
1916
inline uint char_val(char X)
unknown's avatar
unknown committed
1917 1918 1919 1920 1921 1922
{
  return (uint) (X >= '0' && X <= '9' ? X-'0' :
		 X >= 'A' && X <= 'Z' ? X-'A'+10 :
		 X-'a'+10);
}

1923

1924
Item_varbinary::Item_varbinary(const char *str, uint str_length)
unknown's avatar
unknown committed
1925 1926 1927 1928 1929 1930
{
  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
1931
  str_value.set(ptr,max_length,&my_charset_bin);
unknown's avatar
unknown committed
1932 1933 1934 1935 1936 1937 1938 1939 1940
  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
1941
  collation.set(&my_charset_bin, DERIVATION_COERCIBLE);
unknown's avatar
unknown committed
1942
  fixed= 1;
unknown's avatar
unknown committed
1943 1944 1945 1946
}

longlong Item_varbinary::val_int()
{
unknown's avatar
unknown committed
1947
  // following assert is redundant, because fixed=1 assigned in constructor
1948
  DBUG_ASSERT(fixed == 1);
unknown's avatar
unknown committed
1949 1950 1951 1952 1953 1954 1955 1956 1957 1958
  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
1959
int Item_varbinary::save_in_field(Field *field, bool no_conversions)
unknown's avatar
unknown committed
1960
{
1961
  int error;
unknown's avatar
unknown committed
1962 1963 1964
  field->set_notnull();
  if (field->result_type() == STRING_RESULT)
  {
1965
    error=field->store(str_value.ptr(),str_value.length(),collation.collation);
unknown's avatar
unknown committed
1966 1967 1968 1969
  }
  else
  {
    longlong nr=val_int();
1970
    error=field->store(nr);
unknown's avatar
unknown committed
1971
  }
unknown's avatar
unknown committed
1972
  return error;
unknown's avatar
unknown committed
1973 1974 1975
}


unknown's avatar
unknown committed
1976 1977 1978 1979 1980
/*
  Pack data in buffer for sending
*/

bool Item_null::send(Protocol *protocol, String *packet)
unknown's avatar
unknown committed
1981
{
unknown's avatar
unknown committed
1982
  return protocol->store_null();
unknown's avatar
unknown committed
1983 1984 1985
}

/*
unknown's avatar
unknown committed
1986
  This is only called from items that is not of type item_field
unknown's avatar
unknown committed
1987 1988
*/

unknown's avatar
unknown committed
1989
bool Item::send(Protocol *protocol, String *buffer)
unknown's avatar
unknown committed
1990
{
unknown's avatar
unknown committed
1991 1992 1993 1994 1995 1996
  bool result;
  enum_field_types type;
  LINT_INIT(result);

  switch ((type=field_type())) {
  default:
1997 1998 1999 2000 2001 2002 2003 2004 2005
  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
2006 2007 2008 2009 2010
  case MYSQL_TYPE_STRING:
  case MYSQL_TYPE_VAR_STRING:
  {
    String *res;
    if ((res=val_str(buffer)))
2011
      result= protocol->store(res->ptr(),res->length(),res->charset());
unknown's avatar
unknown committed
2012 2013 2014 2015
    break;
  }
  case MYSQL_TYPE_TINY:
  {
2016
    longlong nr;
unknown's avatar
unknown committed
2017 2018 2019 2020 2021 2022 2023 2024 2025 2026 2027 2028 2029
    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;
  }
2030
  case MYSQL_TYPE_INT24:
unknown's avatar
unknown committed
2031 2032 2033 2034 2035 2036 2037 2038 2039 2040 2041 2042 2043 2044 2045 2046
  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
2047 2048 2049
  case MYSQL_TYPE_FLOAT:
  {
    float nr;
unknown's avatar
unknown committed
2050
    nr= (float) val();
unknown's avatar
unknown committed
2051 2052 2053 2054
    if (!null_value)
      result= protocol->store(nr, decimals, buffer);
    break;
  }
unknown's avatar
unknown committed
2055 2056 2057 2058 2059 2060 2061 2062 2063 2064
  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:
2065
  case MYSQL_TYPE_TIMESTAMP:
unknown's avatar
unknown committed
2066 2067
  {
    TIME tm;
2068
    get_date(&tm, TIME_FUZZY_DATE);
unknown's avatar
unknown committed
2069 2070 2071 2072 2073 2074 2075 2076 2077 2078 2079 2080 2081 2082 2083 2084 2085 2086 2087 2088 2089
    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
2090 2091
}

unknown's avatar
unknown committed
2092 2093

bool Item_field::send(Protocol *protocol, String *buffer)
unknown's avatar
unknown committed
2094
{
unknown's avatar
unknown committed
2095
  return protocol->store(result_field);
unknown's avatar
unknown committed
2096 2097
}

2098

unknown's avatar
unknown committed
2099 2100 2101
/*
  This is used for HAVING clause
  Find field in select list having the same name
2102
*/
unknown's avatar
unknown committed
2103

unknown's avatar
unknown committed
2104
bool Item_ref::fix_fields(THD *thd,TABLE_LIST *tables, Item **reference)
unknown's avatar
unknown committed
2105
{
2106
  DBUG_ASSERT(fixed == 0);
2107
  uint counter;
2108
  enum_parsing_place place= NO_MATTER;
2109
  bool not_used;
unknown's avatar
unknown committed
2110 2111
  if (!ref)
  {
2112
    TABLE_LIST *where= 0, *table_list;
2113
    SELECT_LEX_UNIT *prev_unit= thd->lex->current_select->master_unit();
2114
    SELECT_LEX *sl= prev_unit->outer_select();
2115 2116 2117 2118 2119
    /*
      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
2120
    if ((ref= find_item_in_list(this, 
2121
				*(thd->lex->current_select->get_item_list()),
2122
				&counter,
2123
				((sl && 
2124
				  thd->lex->current_select->master_unit()->
2125
				  first_select()->linkage !=
2126 2127
				  DERIVED_TABLE_TYPE) ? 
				  REPORT_EXCEPT_NOT_FOUND :
2128
				  REPORT_ALL_ERRORS ), &not_used)) ==
unknown's avatar
unknown committed
2129
	(Item **)not_found_item)
unknown's avatar
unknown committed
2130
    {
2131
      Field *tmp= (Field*) not_found_field;
2132
      SELECT_LEX *last= 0;
unknown's avatar
unknown committed
2133
      /*
2134
	We can't find table field in select list of current select,
unknown's avatar
unknown committed
2135
	consequently we have to find it in outer subselect(s).
unknown's avatar
unknown committed
2136 2137 2138
	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
2139
	mention of table name, but if we join tables in one list it will
2140
	cause error ER_NON_UNIQ_ERROR in find_item_in_list.
unknown's avatar
unknown committed
2141
      */
2142
      for ( ; sl ; sl= (prev_unit= sl->master_unit())->outer_select())
2143
      {
2144
	last= sl;
unknown's avatar
unknown committed
2145
	Item_subselect *prev_subselect_item= prev_unit->item;
2146 2147
	if (sl->resolve_mode == SELECT_LEX::SELECT_MODE &&
	    (ref= find_item_in_list(this, sl->item_list,
2148 2149
                                    &counter, REPORT_EXCEPT_NOT_FOUND,
                                    &not_used)) !=
unknown's avatar
unknown committed
2150
	   (Item **)not_found_item)
2151
	{
2152
	  if (ref && (*ref)->fixed) // Avoid crash in case of error
2153
	  {
unknown's avatar
unknown committed
2154 2155
	    prev_subselect_item->used_tables_cache|= (*ref)->used_tables();
	    prev_subselect_item->const_item_cache&= (*ref)->const_item();
2156
	  }
2157
	  break;
2158
	}
2159
	table_list= sl->get_table_list();
2160
	if (sl->resolve_mode == SELECT_LEX::INSERT_MODE && table_list)
2161 2162 2163 2164
	{
	  // it is primary INSERT st_select_lex => skip first table resolving
	  table_list= table_list->next;
	}
2165
        place= prev_subselect_item->parsing_place;
2166 2167 2168 2169 2170
        /*
          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)
        */
2171
        if ((place != IN_HAVING ||
2172 2173 2174 2175 2176 2177 2178 2179 2180 2181
             (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
2182 2183
	prev_subselect_item->used_tables_cache|= OUTER_REF_TABLE_BIT;
	prev_subselect_item->const_item_cache= 0;
2184

2185 2186
	if (sl->master_unit()->first_select()->linkage ==
	    DERIVED_TABLE_TYPE)
2187
	  break; // do not look over derived table
2188
      }
2189

unknown's avatar
unknown committed
2190
      if (!ref)
2191
	return 1;
2192
      if (!tmp)
2193
	return -1;
2194
      if (ref == (Item **)not_found_item && tmp == not_found_field)
unknown's avatar
unknown committed
2195
      {
2196 2197 2198 2199
        // 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
2200
	return 1;
unknown's avatar
unknown committed
2201
      }
2202
      if (tmp != not_found_field)
2203
      {
2204 2205 2206 2207 2208 2209 2210 2211
        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)))
2212
	  return 1;
2213
	thd->change_item_tree(reference, fld);
2214
	mark_as_dependent(thd, last, thd->lex->current_select, fld);
2215 2216
	return 0;
      }
2217
      if (!last->ref_pointer_array[counter])
unknown's avatar
unknown committed
2218
      {
2219 2220 2221
        my_error(ER_ILLEGAL_REFERENCE, MYF(0), name,
                 "forward reference in item list");
        return -1;
unknown's avatar
unknown committed
2222
      }
2223
      DBUG_ASSERT((*ref)->fixed);
2224 2225
      mark_as_dependent(thd, last, thd->lex->current_select,
                        this);
2226 2227 2228 2229 2230 2231 2232 2233 2234 2235 2236 2237 2238
      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;
      }
2239
      ref= last->ref_pointer_array + counter;
unknown's avatar
unknown committed
2240
    }
2241
    else if (!ref)
unknown's avatar
unknown committed
2242
      return 1;
2243 2244 2245 2246 2247 2248 2249 2250
    else
    {
      if (!(*ref)->fixed)
      {
	my_error(ER_ILLEGAL_REFERENCE, MYF(0), name,
		 "forward reference in item list");
	return -1;
      }
2251
      ref= thd->lex->current_select->ref_pointer_array + counter;
2252
    }
unknown's avatar
unknown committed
2253
  }
2254

2255 2256 2257 2258 2259 2260 2261
  /*
    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.
  */
2262
  if (((*ref)->with_sum_func && name &&
2263
       (depended_from ||
2264 2265
	!(thd->lex->current_select->linkage != GLOBAL_OPTIONS_TYPE &&
	  thd->lex->current_select->having_fix_field))) ||
2266 2267 2268 2269 2270 2271 2272 2273
      !(*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;
  }
2274 2275 2276 2277 2278 2279 2280 2281 2282 2283

  set_properties();

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

void Item_ref::set_properties()
{
2284 2285 2286
  max_length= (*ref)->max_length;
  maybe_null= (*ref)->maybe_null;
  decimals=   (*ref)->decimals;
2287
  collation.set((*ref)->collation);
unknown's avatar
unknown committed
2288
  with_sum_func= (*ref)->with_sum_func;
2289
  fixed= 1;
unknown's avatar
unknown committed
2290 2291
}

unknown's avatar
unknown committed
2292 2293 2294 2295 2296 2297 2298 2299 2300 2301 2302
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)
{
2303
  str->append("<ref_null_helper>(", 18);
unknown's avatar
unknown committed
2304 2305 2306 2307 2308 2309 2310 2311 2312 2313
  if (ref && *ref)
    (*ref)->print(str);
  else
    str->append('?');
  str->append(')');
}


void Item_null_helper::print(String *str)
{
2314
  str->append("<null_helper>(", 14);
unknown's avatar
unknown committed
2315 2316 2317 2318 2319
  store->print(str);
  str->append(')');
}


unknown's avatar
SCRUM  
unknown committed
2320 2321
bool Item_default_value::eq(const Item *item, bool binary_cmp) const
{
unknown's avatar
SCRUM  
unknown committed
2322
  return item->type() == DEFAULT_VALUE_ITEM && 
unknown's avatar
SCRUM  
unknown committed
2323 2324 2325
    ((Item_default_value *)item)->arg->eq(arg, binary_cmp);
}

2326

2327 2328 2329
bool Item_default_value::fix_fields(THD *thd,
				    struct st_table_list *table_list,
				    Item **items)
unknown's avatar
SCRUM  
unknown committed
2330
{
2331
  DBUG_ASSERT(fixed == 0);
unknown's avatar
SCRUM  
unknown committed
2332
  if (!arg)
2333 2334
  {
    fixed= 1;
2335
    return 0;
2336
  }
unknown's avatar
unknown committed
2337
  if (!arg->fixed && arg->fix_fields(thd, table_list, &arg))
2338 2339
    return 1;
  
unknown's avatar
SCRUM  
unknown committed
2340 2341 2342 2343 2344 2345 2346 2347 2348 2349 2350 2351 2352 2353
  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
2354 2355
  def_field->move_field(def_field->table->default_values -
                        def_field->table->record[0]);
unknown's avatar
SCRUM  
unknown committed
2356 2357 2358 2359
  set_field(def_field);
  return 0;
}

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

unknown's avatar
unknown committed
2372 2373 2374 2375 2376 2377 2378
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);
}


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

unknown's avatar
unknown committed
2387 2388 2389 2390 2391 2392 2393 2394 2395 2396 2397 2398 2399 2400 2401 2402 2403 2404 2405 2406 2407 2408
  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
  {
2409
    Field *tmp_field= field_arg->field;
unknown's avatar
unknown committed
2410
    /* charset doesn't matter here, it's to avoid sigsegv only */
2411 2412
    set_field(new Field_null(0, 0, Field::NONE, tmp_field->field_name,
			     tmp_field->table, &my_charset_bin));
unknown's avatar
unknown committed
2413 2414 2415 2416 2417 2418
  }
  return 0;
}

void Item_insert_value::print(String *str)
{
2419
  str->append("values(", 7);
unknown's avatar
unknown committed
2420 2421 2422 2423
  arg->print(str);
  str->append(')');
}

unknown's avatar
unknown committed
2424
/*
2425 2426
  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
2427 2428 2429 2430 2431 2432
*/

Item_result item_cmp_type(Item_result a,Item_result b)
{
  if (a == STRING_RESULT && b == STRING_RESULT)
    return STRING_RESULT;
2433
  if (a == INT_RESULT && b == INT_RESULT)
unknown's avatar
unknown committed
2434
    return INT_RESULT;
unknown's avatar
unknown committed
2435 2436
  else if (a == ROW_RESULT || b == ROW_RESULT)
    return ROW_RESULT;
2437
  return REAL_RESULT;
unknown's avatar
unknown committed
2438 2439 2440
}


2441
void resolve_const_item(THD *thd, Item **ref, Item *comp_item)
unknown's avatar
unknown committed
2442
{
2443 2444
  Item *item= *ref;
  Item *new_item;
unknown's avatar
unknown committed
2445
  if (item->basic_const_item())
2446
    return;                                     // Can't be better
unknown's avatar
unknown committed
2447 2448 2449 2450 2451 2452 2453
  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
2454
    String tmp(buff,sizeof(buff),&my_charset_bin),*result;
unknown's avatar
unknown committed
2455 2456
    result=item->val_str(&tmp);
    if (item->null_value)
2457 2458 2459 2460 2461 2462 2463
      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
2464
  }
2465
  else if (res_type == INT_RESULT)
unknown's avatar
unknown committed
2466 2467 2468 2469
  {
    longlong result=item->val_int();
    uint length=item->max_length;
    bool null_value=item->null_value;
2470 2471
    new_item= (null_value ? (Item*) new Item_null(name) :
               (Item*) new Item_int(name, result, length));
unknown's avatar
unknown committed
2472 2473 2474 2475 2476 2477
  }
  else
  {						// It must REAL_RESULT
    double result=item->val();
    uint length=item->max_length,decimals=item->decimals;
    bool null_value=item->null_value;
2478 2479 2480 2481
    new_item= (null_value ? (Item*) new Item_null(name) : (Item*)
               new Item_real(name, result, decimals, length));
  }
  if (new_item)
2482
    thd->change_item_tree(ref, new_item);
unknown's avatar
unknown committed
2483 2484 2485 2486 2487 2488 2489 2490 2491 2492 2493 2494 2495 2496 2497 2498 2499
}

/*
  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
2500 2501
    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
2502 2503 2504
    item_result=item->val_str(&item_tmp);
    if (item->null_value)
      return 1;					// This must be true
2505
    field->val_str(&field_tmp);
unknown's avatar
unknown committed
2506
    return !stringcmp(&field_tmp,item_result);
unknown's avatar
unknown committed
2507 2508 2509 2510 2511 2512 2513 2514 2515
  }
  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();
}

2516 2517 2518 2519 2520 2521 2522 2523 2524 2525
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
2526 2527
  case ROW_RESULT:
    return new Item_cache_row();
2528 2529 2530 2531 2532 2533 2534
  default:
    // should never be in real life
    DBUG_ASSERT(0);
    return 0;
  }
}

unknown's avatar
unknown committed
2535 2536 2537

void Item_cache::print(String *str)
{
2538
  str->append("<cache>(", 8);
unknown's avatar
unknown committed
2539 2540 2541 2542 2543 2544 2545 2546 2547 2548 2549 2550 2551 2552 2553 2554 2555 2556 2557 2558 2559 2560
  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;
}


2561 2562
void Item_cache_str::store(Item *item)
{
unknown's avatar
merge  
unknown committed
2563
  value_buff.set(buffer, sizeof(buffer), item->collation.collation);
2564
  value= item->str_result(&value_buff);
2565 2566
  if ((null_value= item->null_value))
    value= 0;
2567
  else if (value != &value_buff)
2568 2569 2570 2571 2572 2573 2574 2575 2576
  {
    /*
      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;
    */
2577 2578
    value_buff.copy(*value);
    value= &value_buff;
2579 2580
  }
}
2581 2582


2583
double Item_cache_str::val()
2584 2585
{
  DBUG_ASSERT(fixed == 1);
2586
  int err;
2587
  if (value)
2588
    return my_strntod(value->charset(), (char*) value->ptr(),
2589
		      value->length(), (char**) 0, &err);
2590 2591 2592
  else
    return (double)0;
}
2593 2594


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

2606

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

2615

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

2632

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

2644

unknown's avatar
unknown committed
2645 2646 2647 2648 2649
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
2650
  my_error(ER_OPERAND_COLUMNS, MYF(0), 1);
unknown's avatar
unknown committed
2651 2652 2653
  DBUG_VOID_RETURN;
}

2654

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

2665

unknown's avatar
unknown committed
2666 2667
bool Item_cache_row::null_inside()
{
unknown's avatar
unknown committed
2668
  for (uint i= 0; i < item_count; i++)
unknown's avatar
unknown committed
2669 2670 2671 2672 2673 2674 2675 2676 2677 2678 2679 2680 2681 2682 2683 2684
  {
    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;
}

2685

unknown's avatar
unknown committed
2686 2687
void Item_cache_row::bring_value()
{
unknown's avatar
unknown committed
2688
  for (uint i= 0; i < item_count; i++)
unknown's avatar
unknown committed
2689 2690 2691
    values[i]->bring_value();
  return;
}
unknown's avatar
unknown committed
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 2739 2740
/*
  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
2741 2742
  :Item(thd, item), item_type(item->result_type()),
   orig_type(item_type)
2743 2744
{
  DBUG_ASSERT(item->fixed);
unknown's avatar
unknown committed
2745 2746 2747 2748 2749

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


2757 2758 2759 2760 2761 2762 2763
/*
  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)
*/
2764 2765 2766 2767 2768 2769
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
2770 2771 2772 2773 2774 2775 2776 2777 2778 2779 2780 2781 2782 2783 2784 2785 2786 2787 2788 2789

/*
  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 ||
2790
          (from->collation.collation == to->collation.collation)));
unknown's avatar
unknown committed
2791 2792 2793
}


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

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

2850 2851
    old_cs= collation.collation->name;
    old_derivation= collation.derivation_name();
2852 2853 2854 2855 2856 2857 2858 2859 2860 2861
    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;
    }

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

2871

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

2877 2878 2879 2880 2881 2882 2883 2884 2885 2886 2887 2888 2889 2890
  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;
  }
}
2891 2892 2893 2894 2895 2896 2897 2898 2899 2900 2901 2902 2903 2904 2905 2906 2907 2908 2909 2910 2911

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;
}

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

unknown's avatar
unknown committed
2920 2921 2922 2923 2924 2925 2926
/*****************************************************************************
** Instantiate templates
*****************************************************************************/

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