sql_lex.h 80 KB
Newer Older
1
/* Copyright 2000-2008 MySQL AB, 2008 Sun Microsystems, Inc.
unknown's avatar
unknown committed
2

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

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

unknown's avatar
unknown committed
12 13 14 15
   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 */

16 17 18
/**
  @defgroup Semantic_Analysis Semantic Analysis
*/
unknown's avatar
unknown committed
19

20 21 22
#ifndef SQL_LEX_INCLUDED
#define SQL_LEX_INCLUDED

23 24 25 26 27
#include "violite.h"                            /* SSL_type */
#include "sql_trigger.h"
#include "item.h"               /* From item_subselect.h: subselect_union_engine */
#include "thr_lock.h"                  /* thr_lock_type, TL_UNLOCK */

unknown's avatar
unknown committed
28 29 30 31 32 33
/* YACC and LEX Definitions */

/* These may not be declared yet */
class Table_ident;
class sql_exchange;
class LEX_COLUMN;
34
class sp_head;
35
class sp_name;
36 37
class sp_instr;
class sp_pcontext;
unknown's avatar
unknown committed
38
class st_alter_tablespace;
39
class partition_info;
unknown's avatar
unknown committed
40
class Event_parse_data;
41 42
class set_var_base;
class sys_var;
43 44 45 46 47 48
class Item_func_match;
class Alter_drop;
class Alter_column;
class Key;
class File_parser;
class Key_part_spec;
49

50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96
#ifdef MYSQL_SERVER
/*
  There are 8 different type of table access so there is no more than
  combinations 2^8 = 256:

  . STMT_READS_TRANS_TABLE

  . STMT_READS_NON_TRANS_TABLE

  . STMT_READS_TEMP_TRANS_TABLE

  . STMT_READS_TEMP_NON_TRANS_TABLE

  . STMT_WRITES_TRANS_TABLE

  . STMT_WRITES_NON_TRANS_TABLE

  . STMT_WRITES_TEMP_TRANS_TABLE

  . STMT_WRITES_TEMP_NON_TRANS_TABLE

  The unsafe conditions for each combination is represented within a byte
  and stores the status of the option --binlog-direct-non-trans-updates,
  whether the trx-cache is empty or not, and whether the isolation level
  is lower than ISO_REPEATABLE_READ:

  . option (OFF/ON)
  . trx-cache (empty/not empty)
  . isolation (>= ISO_REPEATABLE_READ / < ISO_REPEATABLE_READ)

  bits 0 : . OFF, . empty, . >= ISO_REPEATABLE_READ
  bits 1 : . OFF, . empty, . < ISO_REPEATABLE_READ
  bits 2 : . OFF, . not empty, . >= ISO_REPEATABLE_READ
  bits 3 : . OFF, . not empty, . < ISO_REPEATABLE_READ
  bits 4 : . ON, . empty, . >= ISO_REPEATABLE_READ
  bits 5 : . ON, . empty, . < ISO_REPEATABLE_READ
  bits 6 : . ON, . not empty, . >= ISO_REPEATABLE_READ
  bits 7 : . ON, . not empty, . < ISO_REPEATABLE_READ
*/
extern uint binlog_unsafe_map[256];
/*
  Initializes the array with unsafe combinations and its respective
  conditions.
*/
void binlog_unsafe_map_init();
#endif

97 98 99 100 101 102 103 104
/**
  used by the parser to store internal variable name
*/
struct sys_var_with_base
{
  sys_var *var;
  LEX_STRING base_name;
};
unknown's avatar
unknown committed
105

106
#ifdef MYSQL_SERVER
107 108 109 110
/*
  The following hack is needed because mysql_yacc.cc does not define
  YYSTYPE before including this file
*/
unknown's avatar
unknown committed
111 112 113 114
#ifdef MYSQL_YACC
#define LEX_YYSTYPE void *
#else
#include "lex_symbol.h"
115
#if MYSQL_LEX
116
#include "item_func.h"            /* Cast_target used in sql_yacc.h */
unknown's avatar
unknown committed
117 118
#include "sql_yacc.h"
#define LEX_YYSTYPE YYSTYPE *
119 120 121
#else
#define LEX_YYSTYPE void *
#endif
unknown's avatar
unknown committed
122
#endif
123
#endif
unknown's avatar
unknown committed
124

125 126 127
/*
  When a command is added here, be sure it's also added in mysqld.cc
  in "struct show_var_st status_vars[]= {" ...
128 129 130 131 132

  If the command returns a result set or is not allowed in stored
  functions or triggers, please also make sure that
  sp_get_flags_for_command (sp_head.cc) returns proper flags for the
  added SQLCOM_.
133 134
*/

unknown's avatar
unknown committed
135
enum enum_sql_command {
136 137 138 139 140
  SQLCOM_SELECT, SQLCOM_CREATE_TABLE, SQLCOM_CREATE_INDEX, SQLCOM_ALTER_TABLE,
  SQLCOM_UPDATE, SQLCOM_INSERT, SQLCOM_INSERT_SELECT,
  SQLCOM_DELETE, SQLCOM_TRUNCATE, SQLCOM_DROP_TABLE, SQLCOM_DROP_INDEX,

  SQLCOM_SHOW_DATABASES, SQLCOM_SHOW_TABLES, SQLCOM_SHOW_FIELDS,
141 142
  SQLCOM_SHOW_KEYS, SQLCOM_SHOW_VARIABLES, SQLCOM_SHOW_STATUS,
  SQLCOM_SHOW_ENGINE_LOGS, SQLCOM_SHOW_ENGINE_STATUS, SQLCOM_SHOW_ENGINE_MUTEX,
143
  SQLCOM_SHOW_PROCESSLIST, SQLCOM_SHOW_MASTER_STAT, SQLCOM_SHOW_SLAVE_STAT,
144
  SQLCOM_SHOW_GRANTS, SQLCOM_SHOW_CREATE, SQLCOM_SHOW_CHARSETS,
145
  SQLCOM_SHOW_COLLATIONS, SQLCOM_SHOW_CREATE_DB, SQLCOM_SHOW_TABLE_STATUS,
146
  SQLCOM_SHOW_TRIGGERS,
147

unknown's avatar
unknown committed
148
  SQLCOM_LOAD,SQLCOM_SET_OPTION,SQLCOM_LOCK_TABLES,SQLCOM_UNLOCK_TABLES,
149
  SQLCOM_GRANT,
150
  SQLCOM_CHANGE_DB, SQLCOM_CREATE_DB, SQLCOM_DROP_DB, SQLCOM_ALTER_DB,
151
  SQLCOM_REPAIR, SQLCOM_REPLACE, SQLCOM_REPLACE_SELECT,
152
  SQLCOM_CREATE_FUNCTION, SQLCOM_DROP_FUNCTION,
153
  SQLCOM_REVOKE,SQLCOM_OPTIMIZE, SQLCOM_CHECK,
unknown's avatar
unknown committed
154
  SQLCOM_ASSIGN_TO_KEYCACHE, SQLCOM_PRELOAD_KEYS,
155
  SQLCOM_FLUSH, SQLCOM_KILL, SQLCOM_ANALYZE,
unknown's avatar
unknown committed
156
  SQLCOM_ROLLBACK, SQLCOM_ROLLBACK_TO_SAVEPOINT,
unknown's avatar
WL#1967  
unknown committed
157
  SQLCOM_COMMIT, SQLCOM_SAVEPOINT, SQLCOM_RELEASE_SAVEPOINT,
158
  SQLCOM_SLAVE_START, SQLCOM_SLAVE_STOP,
159 160
  SQLCOM_BEGIN, SQLCOM_CHANGE_MASTER,
  SQLCOM_RENAME_TABLE,
161
  SQLCOM_RESET, SQLCOM_PURGE, SQLCOM_PURGE_BEFORE, SQLCOM_SHOW_BINLOGS,
162
  SQLCOM_SHOW_OPEN_TABLES,
163
  SQLCOM_HA_OPEN, SQLCOM_HA_CLOSE, SQLCOM_HA_READ,
164
  SQLCOM_SHOW_SLAVE_HOSTS, SQLCOM_DELETE_MULTI, SQLCOM_UPDATE_MULTI,
unknown's avatar
unknown committed
165
  SQLCOM_SHOW_BINLOG_EVENTS, SQLCOM_SHOW_NEW_MASTER, SQLCOM_DO,
unknown's avatar
unknown committed
166
  SQLCOM_SHOW_WARNS, SQLCOM_EMPTY_QUERY, SQLCOM_SHOW_ERRORS,
167
  SQLCOM_SHOW_STORAGE_ENGINES, SQLCOM_SHOW_PRIVILEGES,
168 169
  SQLCOM_HELP, SQLCOM_CREATE_USER, SQLCOM_DROP_USER, SQLCOM_RENAME_USER,
  SQLCOM_REVOKE_ALL, SQLCOM_CHECKSUM,
170
  SQLCOM_CREATE_PROCEDURE, SQLCOM_CREATE_SPFUNCTION, SQLCOM_CALL,
171
  SQLCOM_DROP_PROCEDURE, SQLCOM_ALTER_PROCEDURE,SQLCOM_ALTER_FUNCTION,
unknown's avatar
unknown committed
172 173
  SQLCOM_SHOW_CREATE_PROC, SQLCOM_SHOW_CREATE_FUNC,
  SQLCOM_SHOW_STATUS_PROC, SQLCOM_SHOW_STATUS_FUNC,
unknown's avatar
unknown committed
174
  SQLCOM_PREPARE, SQLCOM_EXECUTE, SQLCOM_DEALLOCATE_PREPARE,
unknown's avatar
VIEW  
unknown committed
175
  SQLCOM_CREATE_VIEW, SQLCOM_DROP_VIEW,
176
  SQLCOM_CREATE_TRIGGER, SQLCOM_DROP_TRIGGER,
unknown's avatar
unknown committed
177 178
  SQLCOM_XA_START, SQLCOM_XA_END, SQLCOM_XA_PREPARE,
  SQLCOM_XA_COMMIT, SQLCOM_XA_ROLLBACK, SQLCOM_XA_RECOVER,
unknown's avatar
unknown committed
179
  SQLCOM_SHOW_PROC_CODE, SQLCOM_SHOW_FUNC_CODE,
unknown's avatar
unknown committed
180
  SQLCOM_ALTER_TABLESPACE,
181
  SQLCOM_INSTALL_PLUGIN, SQLCOM_UNINSTALL_PLUGIN,
182 183
  SQLCOM_SHOW_AUTHORS, SQLCOM_BINLOG_BASE64_EVENT,
  SQLCOM_SHOW_PLUGINS,
184
  SQLCOM_SHOW_CONTRIBUTORS,
unknown's avatar
unknown committed
185
  SQLCOM_CREATE_SERVER, SQLCOM_DROP_SERVER, SQLCOM_ALTER_SERVER,
unknown's avatar
unknown committed
186
  SQLCOM_CREATE_EVENT, SQLCOM_ALTER_EVENT, SQLCOM_DROP_EVENT,
unknown's avatar
unknown committed
187 188
  SQLCOM_SHOW_CREATE_EVENT, SQLCOM_SHOW_EVENTS,
  SQLCOM_SHOW_CREATE_TRIGGER,
189
  SQLCOM_ALTER_DB_UPGRADE,
unknown's avatar
unknown committed
190
  SQLCOM_SHOW_PROFILE, SQLCOM_SHOW_PROFILES,
Marc Alff's avatar
Marc Alff committed
191
  SQLCOM_SIGNAL, SQLCOM_RESIGNAL,
192
  SQLCOM_SHOW_RELAYLOG_EVENTS, 
193 194 195 196
  /*
    When a command is added here, be sure it's also added in mysqld.cc
    in "struct show_var_st status_vars[]= {" ...
  */
197 198
  /* This should be the last !!! */
  SQLCOM_END
unknown's avatar
unknown committed
199 200
};

unknown's avatar
unknown committed
201 202 203
// describe/explain types
#define DESCRIBE_NORMAL		1
#define DESCRIBE_EXTENDED	2
unknown's avatar
unknown committed
204
/*
205
  This is not within #ifdef because we want "EXPLAIN PARTITIONS ..." to produce
unknown's avatar
unknown committed
206 207 208
  additional "partitions" column even if partitioning is not compiled in.
*/
#define DESCRIBE_PARTITIONS	4
unknown's avatar
unknown committed
209

210 211
#ifdef MYSQL_SERVER

212
enum enum_sp_suid_behaviour
unknown's avatar
unknown committed
213
{
214 215 216
  SP_IS_DEFAULT_SUID= 0,
  SP_IS_NOT_SUID,
  SP_IS_SUID
unknown's avatar
unknown committed
217
};
218

219 220 221 222 223 224 225 226 227
enum enum_sp_data_access
{
  SP_DEFAULT_ACCESS= 0,
  SP_CONTAINS_SQL,
  SP_NO_SQL,
  SP_READS_SQL_DATA,
  SP_MODIFIES_SQL_DATA
};

228 229
const LEX_STRING sp_data_access_name[]=
{
unknown's avatar
unknown committed
230 231 232 233 234
  { C_STRING_WITH_LEN("") },
  { C_STRING_WITH_LEN("CONTAINS SQL") },
  { C_STRING_WITH_LEN("NO SQL") },
  { C_STRING_WITH_LEN("READS SQL DATA") },
  { C_STRING_WITH_LEN("MODIFIES SQL DATA") }
235
};
236

unknown's avatar
VIEW  
unknown committed
237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253
#define DERIVED_SUBQUERY	1
#define DERIVED_VIEW		2

enum enum_view_create_mode
{
  VIEW_CREATE_NEW,		// check that there are not such VIEW/table
  VIEW_ALTER,			// check that VIEW .frm with such name exists
  VIEW_CREATE_OR_REPLACE	// check only that there are not such table
};

enum enum_drop_mode
{
  DROP_DEFAULT, // mode is not specified
  DROP_CASCADE, // CASCADE option
  DROP_RESTRICT // RESTRICT option
};

254 255 256 257 258 259
/* Options to add_table_to_list() */
#define TL_OPTION_UPDATING	1
#define TL_OPTION_FORCE_INDEX	2
#define TL_OPTION_IGNORE_LEAVES 4
#define TL_OPTION_ALIAS         8

unknown's avatar
unknown committed
260 261
typedef List<Item> List_item;

unknown's avatar
unknown committed
262 263 264 265 266 267 268 269
/* SERVERS CACHE CHANGES */
typedef struct st_lex_server_options
{
  long port;
  uint server_name_length;
  char *server_name, *host, *db, *username, *password, *scheme, *socket, *owner;
} LEX_SERVER_OPTIONS;

270 271 272 273 274 275 276 277 278

/**
  Structure to hold parameters for CHANGE MASTER or START/STOP SLAVE
  or SHOW NEW MASTER.

  Remark: this should not be confused with Master_info (and perhaps
  would better be renamed to st_lex_replication_info).  Some fields,
  e.g., delay, are saved in Relay_log_info, not in Master_info.
*/
unknown's avatar
unknown committed
279 280
typedef struct st_lex_master_info
{
281
  char *host, *user, *password, *log_file_name;
unknown's avatar
unknown committed
282
  uint port, connect_retry;
Andrei Elkin's avatar
Andrei Elkin committed
283
  float heartbeat_period;
unknown's avatar
unknown committed
284
  ulonglong pos;
unknown's avatar
unknown committed
285
  ulong server_id;
286 287 288 289
  /*
    Enum is used for making it possible to detect if the user
    changed variable or if it should be left at old value
   */
Andrei Elkin's avatar
Andrei Elkin committed
290
  enum {LEX_MI_UNCHANGED, LEX_MI_DISABLE, LEX_MI_ENABLE}
Andrei Elkin's avatar
Andrei Elkin committed
291
    ssl, ssl_verify_server_cert, heartbeat_opt, repl_ignore_server_ids_opt;
unknown's avatar
unknown committed
292
  char *ssl_key, *ssl_cert, *ssl_ca, *ssl_capath, *ssl_cipher;
293
  char *relay_log_name;
294
  ulong relay_log_pos;
Andrei Elkin's avatar
Andrei Elkin committed
295
  DYNAMIC_ARRAY repl_ignore_server_ids;
unknown's avatar
unknown committed
296 297
} LEX_MASTER_INFO;

298

299 300
enum sub_select_type
{
unknown's avatar
unknown committed
301 302
  UNSPECIFIED_TYPE,UNION_TYPE, INTERSECT_TYPE,
  EXCEPT_TYPE, GLOBAL_OPTIONS_TYPE, DERIVED_TABLE_TYPE, OLAP_TYPE
303 304 305 306
};

enum olap_type 
{
307
  UNSPECIFIED_OLAP_TYPE, CUBE_TYPE, ROLLUP_TYPE
308
};
309

unknown's avatar
unknown committed
310 311 312 313 314
enum tablespace_op_type
{
  NO_TABLESPACE_OP, DISCARD_TABLESPACE, IMPORT_TABLESPACE
};

315 316 317 318 319
/* 
  String names used to print a statement with index hints.
  Keep in sync with index_hint_type.
*/
extern const char * index_hint_type_name[];
320
typedef uchar index_clause_map;
321 322 323 324 325 326 327 328 329 330 331 332 333

/*
  Bits in index_clause_map : one for each possible FOR clause in
  USE/FORCE/IGNORE INDEX index hint specification
*/
#define INDEX_HINT_MASK_JOIN  (1)
#define INDEX_HINT_MASK_GROUP (1 << 1)
#define INDEX_HINT_MASK_ORDER (1 << 2)

#define INDEX_HINT_MASK_ALL (INDEX_HINT_MASK_JOIN | INDEX_HINT_MASK_GROUP | \
                             INDEX_HINT_MASK_ORDER)

/* Single element of an USE/FORCE/IGNORE INDEX list specified as a SQL hint  */
unknown's avatar
unknown committed
334
class Index_hint : public Sql_alloc
335 336 337 338 339 340 341 342 343 344 345 346
{
public:
  /* The type of the hint : USE/FORCE/IGNORE */
  enum index_hint_type type;
  /* Where the hit applies to. A bitmask of INDEX_HINT_MASK_<place> values */
  index_clause_map clause;
  /* 
    The index name. Empty (str=NULL) name represents an empty list 
    USE INDEX () clause 
  */ 
  LEX_STRING key_name;

unknown's avatar
unknown committed
347
  Index_hint (enum index_hint_type type_arg, index_clause_map clause_arg,
348 349 350 351 352 353
              char *str, uint length) :
    type(type_arg), clause(clause_arg)
  {
    key_name.str= str;
    key_name.length= length;
  }
354 355

  void print(THD *thd, String *str);
356 357
}; 

unknown's avatar
unknown committed
358 359 360
/* 
  The state of the lex parsing for selects 
   
361 362 363 364 365 366 367 368 369 370
   master and slaves are pointers to select_lex.
   master is pointer to upper level node.
   slave is pointer to lower level node
   select_lex is a SELECT without union
   unit is container of either
     - One SELECT
     - UNION of selects
   select_lex and unit are both inherited form select_lex_node
   neighbors are two select_lex or units on the same level

unknown's avatar
unknown committed
371
   All select describing structures linked with following pointers:
372
   - list of neighbors (next/prev) (prev of first element point to slave
unknown's avatar
unknown committed
373
     pointer of upper structure)
374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400
     - For select this is a list of UNION's (or one element list)
     - For units this is a list of sub queries for the upper level select

   - pointer to master (master), which is
     If this is a unit
       - pointer to outer select_lex
     If this is a select_lex
       - pointer to outer unit structure for select

   - pointer to slave (slave), which is either:
     If this is a unit:
       - first SELECT that belong to this unit
     If this is a select_lex
       - first unit that belong to this SELECT (subquries or derived tables)

   - list of all select_lex (link_next/link_prev)
     This is to be used for things like derived tables creation, where we
     go through this list and create the derived tables.

   If unit contain several selects (UNION now, INTERSECT etc later)
   then it have special select_lex called fake_select_lex. It used for
   storing global parameters (like ORDER BY, LIMIT) and executing union.
   Subqueries used in global ORDER BY clause will be attached to this
   fake_select_lex, which will allow them correctly resolve fields of
   'upper' UNION and outer selects.

   For example for following query:
401

unknown's avatar
unknown committed
402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417
   select *
     from table1
     where table1.field IN (select * from table1_1_1 union
                            select * from table1_1_2)
     union
   select *
     from table2
     where table2.field=(select (select f1 from table2_1_1_1_1
                                   where table2_1_1_1_1.f2=table2_1_1.f3)
                           from table2_1_1
                           where table2_1_1.f1=table2.f2)
     union
   select * from table3;

   we will have following structure:

418 419 420 421 422
   select1: (select * from table1 ...)
   select2: (select * from table2 ...)
   select3: (select * from table3)
   select1.1.1: (select * from table1_1_1)
   ...
unknown's avatar
unknown committed
423 424

     main unit
unknown's avatar
(SCRUM)  
unknown committed
425
     fake0
unknown's avatar
unknown committed
426 427 428 429 430 431 432 433
     select1 select2 select3
     |^^     |^
    s|||     ||master
    l|||     |+---------------------------------+
    a|||     +---------------------------------+|
    v|||master                         slave   ||
    e||+-------------------------+             ||
     V|            neighbor      |             V|
unknown's avatar
(SCRUM)  
unknown committed
434
     unit1.1<+==================>unit1.2       unit2.1
unknown's avatar
unknown committed
435 436
     fake1.1
     select1.1.1 select 1.1.2    select1.2.1   select2.1.1
unknown's avatar
unknown committed
437 438 439 440 441 442 443 444
                                               |^
                                               ||
                                               V|
                                               unit2.1.1.1
                                               select2.1.1.1.1


   relation in main unit will be following:
445 446 447 448 449 450
   (bigger picture for:
      main unit
      fake0
      select1 select2 select3
   in the above picture)

unknown's avatar
unknown committed
451
         main unit
unknown's avatar
(SCRUM)  
unknown committed
452 453 454 455 456 457 458 459
         |^^^^|fake_select_lex
         |||||+--------------------------------------------+
         ||||+--------------------------------------------+|
         |||+------------------------------+              ||
         ||+--------------+                |              ||
    slave||master         |                |              ||
         V|      neighbor |       neighbor |        master|V
         select1<========>select2<========>select3        fake0
unknown's avatar
unknown committed
460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475

    list of all select_lex will be following (as it will be constructed by
    parser):

    select1->select2->select3->select2.1.1->select 2.1.2->select2.1.1.1.1-+
                                                                          |
    +---------------------------------------------------------------------+
    |
    +->select1.1.1->select1.1.2

*/

/* 
    Base class for st_select_lex (SELECT_LEX) & 
    st_select_lex_unit (SELECT_LEX_UNIT)
*/
Konstantin Osipov's avatar
Konstantin Osipov committed
476
struct LEX;
477 478
class st_select_lex;
class st_select_lex_unit;
Tor Didriksen's avatar
Tor Didriksen committed
479 480


481 482
class st_select_lex_node {
protected:
unknown's avatar
unknown committed
483 484 485
  st_select_lex_node *next, **prev,   /* neighbor list */
    *master, *slave,                  /* vertical links */
    *link_next, **link_prev;          /* list of whole SELECT_LEX */
486
public:
unknown's avatar
unknown committed
487

488
  ulonglong options;
489 490 491 492 493 494 495 496

  /*
    In sql_cache we store SQL_CACHE flag as specified by user to be
    able to restore SELECT statement from internal structures.
  */
  enum e_sql_cache { SQL_CACHE_UNSPECIFIED, SQL_NO_CACHE, SQL_CACHE };
  e_sql_cache sql_cache;

497 498 499 500
  /*
    result of this query can't be cached, bit field, can be :
      UNCACHEABLE_DEPENDENT
      UNCACHEABLE_RAND
501
      UNCACHEABLE_SIDEEFFECT
502
      UNCACHEABLE_EXPLAIN
503
      UNCACHEABLE_PREPARE
504 505
  */
  uint8 uncacheable;
506
  enum sub_select_type linkage;
unknown's avatar
unknown committed
507
  bool no_table_names_allowed; /* used for global order by */
508
  bool no_error; /* suppress error message (convert it to warnings) */
509

510
  static void *operator new(size_t size) throw ()
511
  {
512
    return sql_alloc(size);
513
  }
514
  static void *operator new(size_t size, MEM_ROOT *mem_root) throw ()
unknown's avatar
unknown committed
515
  { return (void*) alloc_root(mem_root, (uint) size); }
unknown's avatar
unknown committed
516
  static void operator delete(void *ptr,size_t size) { TRASH(ptr, size); }
517
  static void operator delete(void *ptr, MEM_ROOT *mem_root) {}
Tor Didriksen's avatar
Tor Didriksen committed
518 519 520 521 522 523 524 525 526

  // Ensures that at least all members used during cleanup() are initialized.
  st_select_lex_node()
    : next(NULL), prev(NULL),
      master(NULL), slave(NULL),
      link_next(NULL), link_prev(NULL),
      linkage(UNSPECIFIED_TYPE)
  {
  }
527
  virtual ~st_select_lex_node() {}
Tor Didriksen's avatar
Tor Didriksen committed
528

529 530 531
  inline st_select_lex_node* get_master() { return master; }
  virtual void init_query();
  virtual void init_select();
unknown's avatar
unknown committed
532 533
  void include_down(st_select_lex_node *upper);
  void include_neighbour(st_select_lex_node *before);
unknown's avatar
(SCRUM)  
unknown committed
534
  void include_standalone(st_select_lex_node *sel, st_select_lex_node **ref);
unknown's avatar
unknown committed
535 536
  void include_global(st_select_lex_node **plink);
  void exclude();
537 538 539

  virtual st_select_lex_unit* master_unit()= 0;
  virtual st_select_lex* outer_select()= 0;
unknown's avatar
(SCRUM)  
unknown committed
540
  virtual st_select_lex* return_after_parsing()= 0;
541 542 543 544 545 546

  virtual bool set_braces(bool value);
  virtual bool inc_in_sum_expr();
  virtual uint get_in_sum_expr();
  virtual TABLE_LIST* get_table_list();
  virtual List<Item>* get_item_list();
unknown's avatar
unknown committed
547
  virtual ulong get_table_join_options();
unknown's avatar
unknown committed
548
  virtual TABLE_LIST *add_table_to_list(THD *thd, Table_ident *table,
549
					LEX_STRING *alias,
unknown's avatar
unknown committed
550
					ulong table_options,
551
					thr_lock_type flags= TL_UNLOCK,
552
                                        enum_mdl_type mdl_type= MDL_SHARED_READ,
unknown's avatar
unknown committed
553
					List<Index_hint> *hints= 0,
unknown's avatar
unknown committed
554
                                        LEX_STRING *option= 0);
unknown's avatar
unknown committed
555
  virtual void set_lock_for_tables(thr_lock_type lock_type) {}
unknown's avatar
unknown committed
556

unknown's avatar
unknown committed
557
  friend class st_select_lex_unit;
Konstantin Osipov's avatar
Konstantin Osipov committed
558
  friend bool mysql_new_select(LEX *lex, bool move_down);
559
  friend bool mysql_make_view(THD *thd, File_parser *parser,
560
                              TABLE_LIST *table, uint flags);
unknown's avatar
unknown committed
561 562 563
private:
  void fast_exclude();
};
564
typedef class st_select_lex_node SELECT_LEX_NODE;
unknown's avatar
unknown committed
565 566 567 568 569

/* 
   SELECT_LEX_UNIT - unit of selects (UNION, INTERSECT, ...) group 
   SELECT_LEXs
*/
unknown's avatar
unknown committed
570 571 572 573
class THD;
class select_result;
class JOIN;
class select_union;
574
class Procedure;
Tor Didriksen's avatar
Tor Didriksen committed
575 576


577
class st_select_lex_unit: public st_select_lex_node {
unknown's avatar
unknown committed
578 579 580 581
protected:
  TABLE_LIST result_table_list;
  select_union *union_result;
  TABLE *table; /* temporary table using for appending UNION results */
582

unknown's avatar
unknown committed
583
  select_result *result;
584
  ulonglong found_rows_for_union;
585 586
  bool saved_error;

587
public:
Tor Didriksen's avatar
Tor Didriksen committed
588 589 590 591 592 593 594 595
  // Ensures that at least all members used during cleanup() are initialized.
  st_select_lex_unit()
    : union_result(NULL), table(NULL), result(NULL),
      cleaned(false),
      fake_select_lex(NULL)
  {
  }

unknown's avatar
unknown committed
596
  bool  prepared, // prepare phase already performed for UNION (unit)
unknown's avatar
unknown committed
597
    optimized, // optimize phase already performed for UNION (unit)
598 599
    executed, // already executed
    cleaned;
600 601 602

  // list of fields which points to temporary table for union
  List<Item> item_list;
unknown's avatar
unknown committed
603 604 605 606 607 608 609
  /*
    list of types of items inside union (used for union & derived tables)
    
    Item_type_holders from which this list consist may have pointers to Field,
    pointers is valid only after preparing SELECTS of this unit and before
    any SELECT of this unit execution
  */
610
  List<Item> types;
unknown's avatar
unknown committed
611 612 613 614
  /*
    Pointer to 'last' select or pointer to unit where stored
    global parameters for union
  */
unknown's avatar
(SCRUM)  
unknown committed
615
  st_select_lex *global_parameters;
616
  //node on wich we should return current_select pointer after parsing subquery
unknown's avatar
(SCRUM)  
unknown committed
617
  st_select_lex *return_to;
unknown's avatar
unknown committed
618 619
  /* LIMIT clause runtime counters */
  ha_rows select_limit_cnt, offset_limit_cnt;
620
  /* not NULL if unit used in subselect, point to subselect item */
unknown's avatar
unknown committed
621
  Item_subselect *item;
unknown's avatar
(SCRUM)  
unknown committed
622
  /* thread handler */
623
  THD *thd;
unknown's avatar
unknown committed
624 625 626 627
  /*
    SELECT_LEX for hidden SELECT in onion which process global
    ORDER BY and LIMIT
  */
unknown's avatar
(SCRUM)  
unknown committed
628
  st_select_lex *fake_select_lex;
629

630
  st_select_lex *union_distinct; /* pointer to the last UNION DISTINCT */
631
  bool describe; /* union exec() called for EXPLAIN */
632
  Procedure *last_procedure;	 /* Pointer to procedure, if such exists */
unknown's avatar
unknown committed
633

unknown's avatar
unknown committed
634
  void init_query();
635 636
  st_select_lex_unit* master_unit();
  st_select_lex* outer_select();
637 638
  st_select_lex* first_select()
  {
639
    return reinterpret_cast<st_select_lex*>(slave);
640 641 642
  }
  st_select_lex_unit* next_unit()
  {
643
    return reinterpret_cast<st_select_lex_unit*>(next);
644
  }
unknown's avatar
(SCRUM)  
unknown committed
645
  st_select_lex* return_after_parsing() { return return_to; }
unknown's avatar
unknown committed
646
  void exclude_level();
647
  void exclude_tree();
648

unknown's avatar
unknown committed
649
  /* UNION methods */
650
  bool prepare(THD *thd, select_result *result, ulong additional_options);
unknown's avatar
unknown committed
651 652
  bool exec();
  bool cleanup();
653
  inline void unclean() { cleaned= 0; }
unknown's avatar
unknown committed
654
  void reinit_exec_mechanism();
unknown's avatar
unknown committed
655

656
  void print(String *str, enum_query_type query_type);
657

unknown's avatar
unknown committed
658
  bool add_fake_select_lex(THD *thd);
659
  void init_prepare_fake_select_lex(THD *thd);
660
  inline bool is_prepared() { return prepared; }
unknown's avatar
unknown committed
661
  bool change_result(select_subselect *result, select_subselect *old_result);
662
  void set_limit(st_select_lex *values);
663
  void set_thd(THD *thd_arg) { thd= thd_arg; }
unknown's avatar
unknown committed
664
  inline bool is_union (); 
unknown's avatar
unknown committed
665

666
  friend void lex_start(THD *thd);
667
  friend int subselect_union_engine::exec();
668 669

  List<Item> *get_unit_column_types();
unknown's avatar
unknown committed
670
};
671

unknown's avatar
cleanup  
unknown committed
672
typedef class st_select_lex_unit SELECT_LEX_UNIT;
unknown's avatar
unknown committed
673 674

/*
675
  SELECT_LEX - store information of parsed SELECT statment
unknown's avatar
unknown committed
676
*/
677 678
class st_select_lex: public st_select_lex_node
{
679
public:
680
  Name_resolution_context context;
unknown's avatar
unknown committed
681
  char *db;
unknown's avatar
unknown committed
682
  Item *where, *having;                         /* WHERE & HAVING clauses */
683
  Item *prep_where; /* saved WHERE clause for prepared statement processing */
unknown's avatar
unknown committed
684
  Item *prep_having;/* saved HAVING clause for prepared statement processing */
685 686
  /* Saved values of the WHERE and HAVING clauses*/
  Item::cond_result cond_value, having_value;
unknown's avatar
VIEW  
unknown committed
687
  /* point on lex in which it was created, used in view subquery detection */
Konstantin Osipov's avatar
Konstantin Osipov committed
688
  LEX *parent_lex;
689
  enum olap_type olap;
unknown's avatar
unknown committed
690
  /* FROM clause - points to the beginning of the TABLE_LIST::next_local list. */
691 692
  SQL_I_List<TABLE_LIST>  table_list;
  SQL_I_List<ORDER>       group_list; /* GROUP BY clause. */
unknown's avatar
unknown committed
693
  List<Item>          item_list;  /* list of fields & expressions */
694
  List<String>        interval_list;
unknown's avatar
unknown committed
695
  bool	              is_item_list_lookup;
unknown's avatar
unknown committed
696 697 698 699 700 701
  /* 
    Usualy it is pointer to ftfunc_list_alloc, but in union used to create fake
    select_lex for calling mysql_select under results of union
  */
  List<Item_func_match> *ftfunc_list;
  List<Item_func_match> ftfunc_list_alloc;
unknown's avatar
unknown committed
702
  JOIN *join; /* after JOIN::prepare it is pointer to corresponding JOIN */
703
  List<TABLE_LIST> top_join_list; /* join list of the top level          */
704
  List<TABLE_LIST> *join_list;    /* list for the currently parsed join  */
705
  TABLE_LIST *embedding;          /* table embedding to the above list   */
unknown's avatar
unknown committed
706 707 708 709 710 711
  /*
    Beginning of the list of leaves in a FROM clause, where the leaves
    inlcude all base tables including view tables. The tables are connected
    by TABLE_LIST::next_leaf, so leaf_tables points to the left-most leaf.
  */
  TABLE_LIST *leaf_tables;
712
  const char *type;               /* type of select for EXPLAIN          */
unknown's avatar
(SCRUM)  
unknown committed
713

714 715
  SQL_I_List<ORDER> order_list;   /* ORDER clause */
  SQL_I_List<ORDER> *gorder_list;
716
  Item *select_limit, *offset_limit;  /* LIMIT clause parameters */
unknown's avatar
(SCRUM)  
unknown committed
717 718 719
  // Arrays of pointers to top elements of all_fields list
  Item **ref_pointer_array;

unknown's avatar
merge  
unknown committed
720 721 722 723 724 725
  /*
    number of items in select_list and HAVING clause used to get number
    bigger then can be number of entries that will be added to all item
    list during split_sum_func
  */
  uint select_n_having_items;
726
  uint cond_count;    /* number of arguments of and/or/xor in where/having/on */
unknown's avatar
unknown committed
727 728
  uint between_count; /* number of between predicates in where/having/on      */
  uint max_equal_elems; /* maximal number of elements in multiple equalities  */   
unknown's avatar
unknown committed
729 730 731 732 733
  /*
    Number of fields used in select list or where clause of current select
    and all inner subselects.
  */
  uint select_n_where_fields;
unknown's avatar
(SCRUM)  
unknown committed
734 735 736
  enum_parsing_place parsing_place; /* where we are parsing expression */
  bool with_sum_func;   /* sum function indicator */

unknown's avatar
unknown committed
737
  ulong table_join_options;
738
  uint in_sum_expr;
unknown's avatar
unknown committed
739
  uint select_number; /* number of select (used for EXPLAIN) */
unknown's avatar
unknown committed
740 741
  int nest_level;     /* nesting level of select */
  Item_sum *inner_sum_func_list; /* list of sum func in nested selects */ 
742
  uint with_wild; /* item list contain '*' */
unknown's avatar
unknown committed
743 744 745
  bool  braces;   	/* SELECT ... UNION (SELECT ... ) <- this braces */
  /* TRUE when having fix field called in processing of this SELECT */
  bool having_fix_field;
746 747
  /* TRUE when GROUP BY fix field called in processing of this SELECT */
  bool group_fix_field;
748 749
  /* List of references to fields referenced from inner selects */
  List<Item_outer_ref> inner_refs_list;
750 751 752 753 754
  /* Number of Item_sum-derived objects in this SELECT */
  uint n_sum_items;
  /* Number of Item_sum-derived objects in children and descendant SELECTs */
  uint n_child_sum_items;

755 756
  /* explicit LIMIT clause was used */
  bool explicit_limit;
757 758 759 760 761
  /*
    there are subquery in HAVING clause => we can't close tables before
    query processing end even if we use temporary table
  */
  bool subquery_in_having;
762 763
  /* TRUE <=> this SELECT is correlated w.r.t. some ancestor select */
  bool is_correlated;
764 765 766 767 768 769 770 771 772 773 774 775 776
  /*
    This variable is required to ensure proper work of subqueries and
    stored procedures. Generally, one should use the states of
    Query_arena to determine if it's a statement prepare or first
    execution of a stored procedure. However, in case when there was an
    error during the first execution of a stored procedure, the SP body
    is not expelled from the SP cache. Therefore, a deeply nested
    subquery might be left unoptimized. So we need this per-subquery
    variable to inidicate the optimization/execution state of every
    subquery. Prepared statements work OK in that regard, as in
    case of an error during prepare the PS is not created.
  */
  bool first_execution;
777
  bool first_natural_join_processing;
unknown's avatar
unknown committed
778
  bool first_cond_optimization;
unknown's avatar
unknown committed
779 780
  /* do not wrap view fields with Item_ref */
  bool no_wrap_view_item;
781 782
  /* exclude this select from check of unique_table() */
  bool exclude_from_table_unique_test;
783 784 785 786
  /* List of fields that aren't under an aggregate function */
  List<Item_field> non_agg_fields;
  /* index in the select list of the expression currently being fixed */
  int cur_pos_in_select_list;
787

788
  List<udf_func>     udf_list;                  /* udf function calls stack */
789

790 791 792 793 794 795 796 797 798 799 800 801 802 803
  /* 
    This is a copy of the original JOIN USING list that comes from
    the parser. The parser :
      1. Sets the natural_join of the second TABLE_LIST in the join
         and the st_select_lex::prev_join_using.
      2. Makes a parent TABLE_LIST and sets its is_natural_join/
       join_using_fields members.
      3. Uses the wrapper TABLE_LIST as a table in the upper level.
    We cannot assign directly to join_using_fields in the parser because
    at stage (1.) the parent TABLE_LIST is not constructed yet and
    the assignment will override the JOIN USING fields of the lower level
    joins on the right.
  */
  List<String> *prev_join_using;
804 805 806 807 808 809 810 811 812 813
  /*
    Bitmap used in the ONLY_FULL_GROUP_BY_MODE to prevent mixture of aggregate
    functions and non aggregated fields when GROUP BY list is absent.
    Bits:
      0 - non aggregated fields are used in this select,
          defined as NON_AGG_FIELD_USED.
      1 - aggregate functions are used in this select,
          defined as SUM_FUNC_USED.
  */
  uint8 full_group_by_flag;
unknown's avatar
unknown committed
814 815
  void init_query();
  void init_select();
816
  st_select_lex_unit* master_unit();
817 818 819 820
  st_select_lex_unit* first_inner_unit() 
  { 
    return (st_select_lex_unit*) slave; 
  }
821
  st_select_lex* outer_select();
unknown's avatar
unknown committed
822
  st_select_lex* next_select() { return (st_select_lex*) next; }
823
  st_select_lex* next_select_in_list() 
824 825 826 827 828 829 830
  {
    return (st_select_lex*) link_next;
  }
  st_select_lex_node** next_select_in_list_addr()
  {
    return &link_next;
  }
unknown's avatar
(SCRUM)  
unknown committed
831
  st_select_lex* return_after_parsing()
832 833 834
  {
    return master_unit()->return_after_parsing();
  }
835

unknown's avatar
(SCRUM)  
unknown committed
836 837
  void mark_as_dependent(st_select_lex *last);

838 839 840
  bool set_braces(bool value);
  bool inc_in_sum_expr();
  uint get_in_sum_expr();
unknown's avatar
unknown committed
841

unknown's avatar
unknown committed
842 843
  bool add_item_to_list(THD *thd, Item *item);
  bool add_group_to_list(THD *thd, Item *item, bool asc);
844
  bool add_ftfunc_to_list(Item_func_match *func);
unknown's avatar
(SCRUM)  
unknown committed
845
  bool add_order_to_list(THD *thd, Item *item, bool asc);
unknown's avatar
unknown committed
846
  TABLE_LIST* add_table_to_list(THD *thd, Table_ident *table,
847
				LEX_STRING *alias,
unknown's avatar
unknown committed
848
				ulong table_options,
849
				thr_lock_type flags= TL_UNLOCK,
850
                                enum_mdl_type mdl_type= MDL_SHARED_READ,
unknown's avatar
unknown committed
851
				List<Index_hint> *hints= 0,
852
                                LEX_STRING *option= 0);
unknown's avatar
(SCRUM)  
unknown committed
853
  TABLE_LIST* get_table_list();
854 855 856 857 858
  bool init_nested_join(THD *thd);
  TABLE_LIST *end_nested_join(THD *thd);
  TABLE_LIST *nest_last_join(THD *thd);
  void add_joined_table(TABLE_LIST *table);
  TABLE_LIST *convert_right_join();
unknown's avatar
(SCRUM)  
unknown committed
859 860
  List<Item>* get_item_list();
  ulong get_table_join_options();
unknown's avatar
unknown committed
861
  void set_lock_for_tables(thr_lock_type lock_type);
unknown's avatar
unknown committed
862 863 864 865
  inline void init_order()
  {
    order_list.elements= 0;
    order_list.first= 0;
866
    order_list.next= &order_list.first;
unknown's avatar
unknown committed
867
  }
868 869 870 871 872 873 874
  /*
    This method created for reiniting LEX in mysql_admin_table() and can be
    used only if you are going remove all SELECT_LEX & units except belonger
    to LEX (LEX::unit & LEX::select, for other purposes there are
    SELECT_LEX_UNIT::exclude_level & SELECT_LEX_UNIT::exclude_tree
  */
  void cut_subtree() { slave= 0; }
unknown's avatar
(SCRUM)  
unknown committed
875 876
  bool test_limit();

877
  friend void lex_start(THD *thd);
878
  st_select_lex() : n_sum_items(0), n_child_sum_items(0) {}
unknown's avatar
(SCRUM)  
unknown committed
879
  void make_empty_select()
880 881 882 883
  {
    init_query();
    init_select();
  }
unknown's avatar
unknown committed
884
  bool setup_ref_array(THD *thd, uint order_group_num);
885 886 887 888 889
  void print(THD *thd, String *str, enum_query_type query_type);
  static void print_order(String *str,
                          ORDER *order,
                          enum_query_type query_type);
  void print_limit(THD *thd, String *str, enum_query_type query_type);
890
  void fix_prepare_information(THD *thd, Item **conds, Item **having_conds);
891 892 893 894 895
  /*
    Destroy the used execution plan (JOIN) of this subtree (this
    SELECT_LEX and all nested SELECT_LEXes and SELECT_LEX_UNITs).
  */
  bool cleanup();
896 897 898 899 900
  /*
    Recursively cleanup the join of this select lex and of all nested
    select lexes.
  */
  void cleanup_all_joins(bool full);
901 902 903 904 905 906 907 908 909 910 911 912

  void set_index_hint_type(enum index_hint_type type, index_clause_map clause);

  /* 
   Add a index hint to the tagged list of hints. The type and clause of the
   hint will be the current ones (set by set_index_hint()) 
  */
  bool add_index_hint (THD *thd, char *str, uint length);

  /* make a list to hold index hints */
  void alloc_index_hints (THD *thd);
  /* read and clear the index hints */
unknown's avatar
unknown committed
913
  List<Index_hint>* pop_index_hints(void) 
914
  {
unknown's avatar
unknown committed
915
    List<Index_hint> *hints= index_hints;
916 917 918 919 920 921 922 923 924 925 926
    index_hints= NULL;
    return hints;
  }

  void clear_index_hints(void) { index_hints= NULL; }

private:  
  /* current index hint kind. used in filling up index_hints */
  enum index_hint_type current_index_hint_type;
  index_clause_map current_index_hint_clause;
  /* a list of USE/FORCE/IGNORE INDEX */
unknown's avatar
unknown committed
927
  List<Index_hint> *index_hints;
unknown's avatar
unknown committed
928
};
unknown's avatar
cleanup  
unknown committed
929
typedef class st_select_lex SELECT_LEX;
930

unknown's avatar
unknown committed
931 932 933 934 935 936
inline bool st_select_lex_unit::is_union ()
{ 
  return first_select()->next_select() && 
    first_select()->next_select()->linkage == UNION_TYPE;
}

unknown's avatar
unknown committed
937 938 939 940 941 942 943 944 945 946 947 948 949 950 951 952 953 954
#define ALTER_ADD_COLUMN	(1L << 0)
#define ALTER_DROP_COLUMN	(1L << 1)
#define ALTER_CHANGE_COLUMN	(1L << 2)
#define ALTER_ADD_INDEX		(1L << 3)
#define ALTER_DROP_INDEX	(1L << 4)
#define ALTER_RENAME		(1L << 5)
#define ALTER_ORDER		(1L << 6)
#define ALTER_OPTIONS		(1L << 7)
#define ALTER_CHANGE_COLUMN_DEFAULT (1L << 8)
#define ALTER_KEYS_ONOFF        (1L << 9)
#define ALTER_CONVERT           (1L << 10)
#define ALTER_FORCE		(1L << 11)
#define ALTER_RECREATE          (1L << 12)
#define ALTER_ADD_PARTITION     (1L << 13)
#define ALTER_DROP_PARTITION    (1L << 14)
#define ALTER_COALESCE_PARTITION (1L << 15)
#define ALTER_REORGANIZE_PARTITION (1L << 16) 
#define ALTER_PARTITION          (1L << 17)
955
#define ALTER_ADMIN_PARTITION    (1L << 18)
unknown's avatar
unknown committed
956 957 958
#define ALTER_TABLE_REORG        (1L << 19)
#define ALTER_REBUILD_PARTITION  (1L << 20)
#define ALTER_ALL_PARTITION      (1L << 21)
959 960
#define ALTER_REMOVE_PARTITIONING (1L << 22)
#define ALTER_FOREIGN_KEY        (1L << 23)
961
#define ALTER_TRUNCATE_PARTITION (1L << 24)
962

unknown's avatar
unknown committed
963 964 965 966 967 968 969
enum enum_alter_table_change_level
{
  ALTER_TABLE_METADATA_ONLY= 0,
  ALTER_TABLE_DATA_CHANGED= 1,
  ALTER_TABLE_INDEX_CHANGED= 2
};

970 971 972 973

/**
  Temporary hack to enable a class bound forward declaration
  of the enum_alter_table_change_level enumeration. To be
974
  removed once Alter_info is moved to the sql_alter.h
975 976 977 978 979 980 981 982 983 984 985 986 987
  header.
*/
class Alter_table_change_level
{
private:
  typedef enum enum_alter_table_change_level enum_type;
  enum_type value;
public:
  void operator = (enum_type v) { value = v; }
  operator enum_type () { return value; }
};


988 989 990 991 992 993 994 995
/**
  @brief Parsing data for CREATE or ALTER TABLE.

  This structure contains a list of columns or indexes to be created,
  altered or dropped.
*/

class Alter_info
996
{
997
public:
unknown's avatar
unknown committed
998 999 1000
  List<Alter_drop>              drop_list;
  List<Alter_column>            alter_list;
  List<Key>                     key_list;
unknown's avatar
unknown committed
1001
  List<Create_field>            create_list;
unknown's avatar
unknown committed
1002 1003 1004 1005
  uint                          flags;
  enum enum_enable_or_disable   keys_onoff;
  enum tablespace_op_type       tablespace_op;
  List<char>                    partition_names;
1006
  uint                          num_parts;
unknown's avatar
unknown committed
1007
  enum_alter_table_change_level change_level;
unknown's avatar
unknown committed
1008
  Create_field                 *datetime_field;
unknown's avatar
unknown committed
1009 1010
  bool                          error_if_not_empty;

1011

1012 1013 1014 1015
  Alter_info() :
    flags(0),
    keys_onoff(LEAVE_AS_IS),
    tablespace_op(NO_TABLESPACE_OP),
1016
    num_parts(0),
unknown's avatar
unknown committed
1017 1018 1019
    change_level(ALTER_TABLE_METADATA_ONLY),
    datetime_field(NULL),
    error_if_not_empty(FALSE)
1020 1021 1022
  {}

  void reset()
unknown's avatar
unknown committed
1023
  {
1024 1025 1026 1027 1028
    drop_list.empty();
    alter_list.empty();
    key_list.empty();
    create_list.empty();
    flags= 0;
unknown's avatar
unknown committed
1029 1030
    keys_onoff= LEAVE_AS_IS;
    tablespace_op= NO_TABLESPACE_OP;
1031
    num_parts= 0;
unknown's avatar
unknown committed
1032
    partition_names.empty();
unknown's avatar
unknown committed
1033 1034 1035
    change_level= ALTER_TABLE_METADATA_ONLY;
    datetime_field= 0;
    error_if_not_empty= FALSE;
unknown's avatar
unknown committed
1036
  }
1037 1038 1039 1040 1041
  Alter_info(const Alter_info &rhs, MEM_ROOT *mem_root);
private:
  Alter_info &operator=(const Alter_info &rhs); // not implemented
  Alter_info(const Alter_info &rhs);            // not implemented
};
1042

1043 1044 1045
struct st_sp_chistics
{
  LEX_STRING comment;
1046
  enum enum_sp_suid_behaviour suid;
1047
  bool detistic;
1048
  enum enum_sp_data_access daccess;
1049 1050
};

1051 1052
extern const LEX_STRING null_lex_str;
extern const LEX_STRING empty_lex_str;
1053 1054 1055 1056 1057 1058 1059

struct st_trg_chistics
{
  enum trg_action_time_type action_time;
  enum trg_event_type event;
};

unknown's avatar
unknown committed
1060
extern sys_var *trg_new_row_fake_var;
1061

unknown's avatar
unknown committed
1062 1063 1064
enum xa_option_words {XA_NONE, XA_JOIN, XA_RESUME, XA_ONE_PHASE,
                      XA_SUSPEND, XA_FOR_MIGRATE};

1065
extern const LEX_STRING null_lex_str;
1066

1067
class Sroutine_hash_entry;
1068

1069
/*
1070 1071 1072 1073 1074
  Class representing list of all tables used by statement and other
  information which is necessary for opening and locking its tables,
  like SQL command for this statement.

  Also contains information about stored functions used by statement
1075 1076 1077 1078
  since during its execution we may have to add all tables used by its
  stored functions/triggers to this list in order to pre-open and lock
  them.

Konstantin Osipov's avatar
Konstantin Osipov committed
1079
  Also used by LEX::reset_n_backup/restore_backup_query_tables_list()
1080 1081 1082 1083 1084 1085
  methods to save and restore this information.
*/

class Query_tables_list
{
public:
1086 1087 1088 1089 1090 1091 1092
  /**
    SQL command for this statement. Part of this class since the
    process of opening and locking tables for the statement needs
    this information to determine correct type of lock for some of
    the tables.
  */
  enum_sql_command sql_command;
1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103
  /* Global list of all tables used by this statement */
  TABLE_LIST *query_tables;
  /* Pointer to next_global member of last element in the previous list. */
  TABLE_LIST **query_tables_last;
  /*
    If non-0 then indicates that query requires prelocking and points to
    next_global member of last own element in query table list (i.e. last
    table which was not added to it as part of preparation to prelocking).
    0 - indicates that this query does not need prelocking.
  */
  TABLE_LIST **query_tables_own_last;
1104 1105 1106 1107 1108
  /*
    Set of stored routines called by statement.
    (Note that we use lazy-initialization for this hash).
  */
  enum { START_SROUTINES_HASH_SIZE= 16 };
1109 1110 1111 1112 1113 1114 1115 1116 1117 1118
  HASH sroutines;
  /*
    List linking elements of 'sroutines' set. Allows you to add new elements
    to this set as you iterate through the list of existing elements.
    'sroutines_list_own_last' is pointer to ::next member of last element of
    this list which represents routine which is explicitly used by query.
    'sroutines_list_own_elements' number of explicitly used routines.
    We use these two members for restoring of 'sroutines_list' to the state
    in which it was right after query parsing.
  */
1119 1120 1121
  SQL_I_List<Sroutine_hash_entry> sroutines_list;
  Sroutine_hash_entry **sroutines_list_own_last;
  uint sroutines_list_own_elements;
1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137

  /*
    These constructor and destructor serve for creation/destruction
    of Query_tables_list instances which are used as backup storage.
  */
  Query_tables_list() {}
  ~Query_tables_list() {}

  /* Initializes (or resets) Query_tables_list object for "real" use. */
  void reset_query_tables_list(bool init);
  void destroy_query_tables_list();
  void set_query_tables_list(Query_tables_list *state)
  {
    *this= *state;
  }

unknown's avatar
unknown committed
1138 1139 1140 1141 1142
  /*
    Direct addition to the list of query tables.
    If you are using this function, you must ensure that the table
    object, in particular table->db member, is initialized.
  */
1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169
  void add_to_query_tables(TABLE_LIST *table)
  {
    *(table->prev_global= query_tables_last)= table;
    query_tables_last= &table->next_global;
  }
  bool requires_prelocking()
  {
    return test(query_tables_own_last);
  }
  void mark_as_requiring_prelocking(TABLE_LIST **tables_own_last)
  {
    query_tables_own_last= tables_own_last;
  }
  /* Return pointer to first not-own table in query-tables or 0 */
  TABLE_LIST* first_not_own_table()
  {
    return ( query_tables_own_last ? *query_tables_own_last : 0);
  }
  void chop_off_not_own_tables()
  {
    if (query_tables_own_last)
    {
      *query_tables_own_last= 0;
      query_tables_last= query_tables_own_last;
      query_tables_own_last= 0;
    }
  }
1170

Konstantin Osipov's avatar
Konstantin Osipov committed
1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181
  /** Return a pointer to the last element in query table list. */
  TABLE_LIST *last_table()
  {
    /* Don't use offsetof() macro in order to avoid warnings. */
    return query_tables ?
           (TABLE_LIST*) ((char*) query_tables_last -
                          ((char*) &(query_tables->next_global) -
                           (char*) query_tables)) :
           0;
  }

1182
  /**
1183
    Enumeration listing of all types of unsafe statement.
1184

1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205
    @note The order of elements of this enumeration type must
    correspond to the order of the elements of the @c explanations
    array defined in the body of @c THD::issue_unsafe_warnings.
  */
  enum enum_binlog_stmt_unsafe {
    /**
      SELECT..LIMIT is unsafe because the set of rows returned cannot
      be predicted.
    */
    BINLOG_STMT_UNSAFE_LIMIT= 0,
    /**
      INSERT DELAYED is unsafe because the time when rows are inserted
      cannot be predicted.
    */
    BINLOG_STMT_UNSAFE_INSERT_DELAYED,
    /**
      Access to log tables is unsafe because slave and master probably
      log different things.
    */
    BINLOG_STMT_UNSAFE_SYSTEM_TABLE,
    /**
1206 1207 1208 1209 1210 1211 1212
      Inserting into an autoincrement column in a stored routine is unsafe.
      Even with just one autoincrement column, if the routine is invoked more than 
      once slave is not guaranteed to execute the statement graph same way as 
      the master.
      And since it's impossible to estimate how many times a routine can be invoked at 
      the query pre-execution phase (see lock_tables), the statement is marked
      pessimistically unsafe. 
1213
    */
1214
    BINLOG_STMT_UNSAFE_AUTOINC_COLUMNS,
1215 1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226
    /**
      Using a UDF (user-defined function) is unsafe.
    */
    BINLOG_STMT_UNSAFE_UDF,
    /**
      Using most system variables is unsafe, because slave may run
      with different options than master.
    */
    BINLOG_STMT_UNSAFE_SYSTEM_VARIABLE,
    /**
      Using some functions is unsafe (e.g., UUID).
    */
Sven Sandberg's avatar
Sven Sandberg committed
1227
    BINLOG_STMT_UNSAFE_SYSTEM_FUNCTION,
1228

1229 1230 1231 1232 1233 1234 1235
    /**
      Mixing transactional and non-transactional statements are unsafe if
      non-transactional reads or writes are occur after transactional
      reads or writes inside a transaction.
    */
    BINLOG_STMT_UNSAFE_NONTRANS_AFTER_TRANS,

1236 1237 1238 1239 1240 1241
    /**
      Mixing self-logging and non-self-logging engines in a statement
      is unsafe.
    */
    BINLOG_STMT_UNSAFE_MULTIPLE_ENGINES_AND_SELF_LOGGING_ENGINE,

1242 1243 1244 1245 1246 1247
    /**
      Statements that read from both transactional and non-transactional
      tables and write to any of them are unsafe.
    */
    BINLOG_STMT_UNSAFE_MIXED_STATEMENT,

1248 1249 1250 1251 1252 1253 1254 1255 1256 1257
    /* The last element of this enumeration type. */
    BINLOG_STMT_UNSAFE_COUNT
  };
  /**
    This has all flags from 0 (inclusive) to BINLOG_STMT_FLAG_COUNT
    (exclusive) set.
  */
  static const int BINLOG_STMT_UNSAFE_ALL_FLAGS=
    ((1 << BINLOG_STMT_UNSAFE_COUNT) - 1);

1258 1259 1260 1261 1262
  /**
    Maps elements of enum_binlog_stmt_unsafe to error codes.
  */
  static const int binlog_stmt_unsafe_errcode[BINLOG_STMT_UNSAFE_COUNT];

1263 1264 1265 1266 1267
  /**
    Determine if this statement is marked as unsafe.

    @retval 0 if the statement is not marked as unsafe.
    @retval nonzero if the statement is marked as unsafe.
1268
  */
1269
  inline bool is_stmt_unsafe() const {
1270
    return get_stmt_unsafe_flags() != 0;
1271 1272 1273
  }

  /**
1274 1275
    Flag the current (top-level) statement as unsafe.
    The flag will be reset after the statement has finished.
1276

1277 1278
    @param unsafe_type The type of unsafety: one of the @c
    BINLOG_STMT_FLAG_UNSAFE_* flags in @c enum_binlog_stmt_flag.
1279
  */
1280 1281 1282 1283 1284
  inline void set_stmt_unsafe(enum_binlog_stmt_unsafe unsafe_type) {
    DBUG_ENTER("set_stmt_unsafe");
    DBUG_ASSERT(unsafe_type >= 0 && unsafe_type < BINLOG_STMT_UNSAFE_COUNT);
    binlog_stmt_flags|= (1U << unsafe_type);
    DBUG_VOID_RETURN;
1285
  }
1286

1287
  /**
1288 1289 1290 1291 1292 1293
    Set the bits of binlog_stmt_flags determining the type of
    unsafeness of the current statement.  No existing bits will be
    cleared, but new bits may be set.

    @param flags A binary combination of zero or more bits, (1<<flag)
    where flag is a member of enum_binlog_stmt_unsafe.
1294
  */
1295 1296 1297 1298
  inline void set_stmt_unsafe_flags(uint32 flags) {
    DBUG_ENTER("set_stmt_unsafe_flags");
    DBUG_ASSERT((flags & ~BINLOG_STMT_UNSAFE_ALL_FLAGS) == 0);
    binlog_stmt_flags|= flags;
1299
    DBUG_VOID_RETURN;
1300 1301
  }

1302
  /**
1303 1304 1305 1306 1307 1308 1309 1310
    Return a binary combination of all unsafe warnings for the
    statement.  If the statement has been marked as unsafe by the
    'flag' member of enum_binlog_stmt_unsafe, then the return value
    from this function has bit (1<<flag) set to 1.
  */
  inline uint32 get_stmt_unsafe_flags() const {
    DBUG_ENTER("get_stmt_unsafe_flags");
    DBUG_RETURN(binlog_stmt_flags & BINLOG_STMT_UNSAFE_ALL_FLAGS);
1311 1312
  }

1313 1314 1315 1316 1317
  /**
    Mark the current statement as safe; i.e., clear all bits in
    binlog_stmt_flags that correspond to elements of
    enum_binlog_stmt_unsafe.
  */
1318
  inline void clear_stmt_unsafe() {
1319
    DBUG_ENTER("clear_stmt_unsafe");
1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343
    binlog_stmt_flags&= ~BINLOG_STMT_UNSAFE_ALL_FLAGS;
    DBUG_VOID_RETURN;
  }

  /**
    Determine if this statement is a row injection.

    @retval 0 if the statement is not a row injection
    @retval nonzero if the statement is a row injection
  */
  inline bool is_stmt_row_injection() const {
    return binlog_stmt_flags &
      (1U << (BINLOG_STMT_UNSAFE_COUNT + BINLOG_STMT_TYPE_ROW_INJECTION));
  }

  /**
    Flag the statement as a row injection.  A row injection is either
    a BINLOG statement, or a row event in the relay log executed by
    the slave SQL thread.
  */
  inline void set_stmt_row_injection() {
    DBUG_ENTER("set_stmt_row_injection");
    binlog_stmt_flags|=
      (1U << (BINLOG_STMT_UNSAFE_COUNT + BINLOG_STMT_TYPE_ROW_INJECTION));
1344
    DBUG_VOID_RETURN;
1345 1346
  }

1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 1365 1366 1367 1368
  enum enum_stmt_accessed_table
  {
    /*
       If a transactional table is about to be read. Note that
       a write implies a read.
    */
    STMT_READS_TRANS_TABLE= 0,
    /*
       If a non-transactional table is about to be read. Note that
       a write implies a read.
    */
    STMT_READS_NON_TRANS_TABLE,
    /*
       If a temporary transactional table is about to be read. Note
       that a write implies a read.
    */
    STMT_READS_TEMP_TRANS_TABLE,
    /*
       If a temporary non-transactional table is about to be read. Note
      that a write implies a read.
    */
    STMT_READS_TEMP_NON_TRANS_TABLE,
1369 1370 1371 1372 1373 1374 1375 1376 1377 1378 1379 1380
    /*
       If a transactional table is about to be updated.
    */
    STMT_WRITES_TRANS_TABLE,
    /*
       If a non-transactional table is about to be updated.
    */
    STMT_WRITES_NON_TRANS_TABLE,
    /*
       If a temporary transactional table is about to be updated.
    */
    STMT_WRITES_TEMP_TRANS_TABLE,
1381 1382 1383 1384 1385 1386 1387 1388 1389 1390
    /*
       If a temporary non-transactional table is about to be updated.
    */
    STMT_WRITES_TEMP_NON_TRANS_TABLE,
    /*
      The last element of the enumeration. Please, if necessary add
      anything before this.
    */
    STMT_ACCESS_TABLE_COUNT
  };
1391

1392
#ifndef DBUG_OFF
1393 1394 1395 1396 1397 1398 1399 1400 1401 1402 1403 1404 1405 1406 1407 1408 1409 1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425
  static inline const char *stmt_accessed_table_string(enum_stmt_accessed_table accessed_table)
  {
    switch (accessed_table)
    {
      case STMT_READS_TRANS_TABLE:
         return "STMT_READS_TRANS_TABLE";
      break;
      case STMT_READS_NON_TRANS_TABLE:
        return "STMT_READS_NON_TRANS_TABLE";
      break;
      case STMT_READS_TEMP_TRANS_TABLE:
        return "STMT_READS_TEMP_TRANS_TABLE";
      break;
      case STMT_READS_TEMP_NON_TRANS_TABLE:
        return "STMT_READS_TEMP_NON_TRANS_TABLE";
      break;  
      case STMT_WRITES_TRANS_TABLE:
        return "STMT_WRITES_TRANS_TABLE";
      break;
      case STMT_WRITES_NON_TRANS_TABLE:
        return "STMT_WRITES_NON_TRANS_TABLE";
      break;
      case STMT_WRITES_TEMP_TRANS_TABLE:
        return "STMT_WRITES_TEMP_TRANS_TABLE";
      break;
      case STMT_WRITES_TEMP_NON_TRANS_TABLE:
        return "STMT_WRITES_TEMP_NON_TRANS_TABLE";
      break;
      case STMT_ACCESS_TABLE_COUNT:
      default:
        DBUG_ASSERT(0);
      break;
    }
1426 1427
    MY_ASSERT_UNREACHABLE();
    return "";
1428
  }
1429
#endif  /* DBUG */
1430
               
1431 1432 1433 1434 1435 1436 1437 1438 1439 1440 1441 1442 1443 1444 1445 1446
  #define BINLOG_DIRECT_ON 0xF0    /* unsafe when
                                      --binlog-direct-non-trans-updates
                                      is ON */

  #define BINLOG_DIRECT_OFF 0xF    /* unsafe when
                                      --binlog-direct-non-trans-updates
                                      is OFF */

  #define TRX_CACHE_EMPTY 0x33     /* unsafe when trx-cache is empty */

  #define TRX_CACHE_NOT_EMPTY 0xCC /* unsafe when trx-cache is not empty */

  #define IL_LT_REPEATABLE 0xAA    /* unsafe when < ISO_REPEATABLE_READ */

  #define IL_GTE_REPEATABLE 0x55   /* unsafe when >= ISO_REPEATABLE_READ */
  
1447 1448 1449 1450 1451 1452 1453 1454 1455
  /**
    Sets the type of table that is about to be accessed while executing a
    statement.

    @param accessed_table Enumeration type that defines the type of table,
                           e.g. temporary, transactional, non-transactional.
  */
  inline void set_stmt_accessed_table(enum_stmt_accessed_table accessed_table)
  {
1456
    DBUG_ENTER("LEX::set_stmt_accessed_table");
1457 1458 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468

    DBUG_ASSERT(accessed_table >= 0 && accessed_table < STMT_ACCESS_TABLE_COUNT);
    stmt_accessed_table_flag |= (1U << accessed_table);

    DBUG_VOID_RETURN;
  }

  /**
    Checks if a type of table is about to be accessed while executing a
    statement.

    @param accessed_table Enumeration type that defines the type of table,
1469
           e.g. temporary, transactional, non-transactional.
1470 1471 1472 1473 1474 1475 1476

    @return
      @retval TRUE  if the type of the table is about to be accessed
      @retval FALSE otherwise
  */
  inline bool stmt_accessed_table(enum_stmt_accessed_table accessed_table)
  {
1477
    DBUG_ENTER("LEX::stmt_accessed_table");
1478 1479 1480 1481 1482 1483 1484

    DBUG_ASSERT(accessed_table >= 0 && accessed_table < STMT_ACCESS_TABLE_COUNT);

    DBUG_RETURN((stmt_accessed_table_flag & (1U << accessed_table)) != 0);
  }

  /**
1485 1486
    Checks if a temporary non-transactional table is about to be accessed
    while executing a statement.
1487 1488

    @return
1489 1490
      @retval TRUE  if a temporary non-transactional table is about to be
                    accessed
1491 1492
      @retval FALSE otherwise
  */
1493
  inline bool stmt_accessed_non_trans_temp_table()
1494
  {
1495
    DBUG_ENTER("THD::stmt_accessed_non_trans_temp_table");
1496 1497

    DBUG_RETURN((stmt_accessed_table_flag &
1498
                ((1U << STMT_READS_TEMP_NON_TRANS_TABLE) |
1499 1500 1501
                 (1U << STMT_WRITES_TEMP_NON_TRANS_TABLE))) != 0);
  }

1502 1503
  /*
    Checks if a mixed statement is unsafe.
1504

1505 1506 1507 1508 1509 1510 1511 1512
    
    @param in_multi_stmt_transaction_mode defines if there is an on-going
           multi-transactional statement.
    @param binlog_direct defines if --binlog-direct-non-trans-updates is
           active.
    @param trx_cache_is_not_empty defines if the trx-cache is empty or not.
    @param trx_isolation defines the isolation level.
 
1513
    @return
1514
      @retval TRUE if the mixed statement is unsafe
1515 1516
      @retval FALSE otherwise
  */
1517 1518 1519 1520
  inline bool is_mixed_stmt_unsafe(bool in_multi_stmt_transaction_mode,
                                   bool binlog_direct,
                                   bool trx_cache_is_not_empty,
                                   uint tx_isolation)
1521
  {
1522
    bool unsafe= FALSE;
1523

1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538 1539 1540 1541 1542 1543 1544 1545 1546 1547 1548 1549 1550 1551 1552 1553 1554 1555 1556 1557
    if (in_multi_stmt_transaction_mode)
    {
       uint condition=
         (binlog_direct ? BINLOG_DIRECT_ON : BINLOG_DIRECT_OFF) &
         (trx_cache_is_not_empty ? TRX_CACHE_NOT_EMPTY : TRX_CACHE_EMPTY) &
         (tx_isolation >= ISO_REPEATABLE_READ ? IL_GTE_REPEATABLE : IL_LT_REPEATABLE);

      unsafe= (binlog_unsafe_map[stmt_accessed_table_flag] & condition);

#if !defined(DBUG_OFF)
      DBUG_PRINT("LEX::is_mixed_stmt_unsafe", ("RESULT %02X %02X %02X\n", condition,
              binlog_unsafe_map[stmt_accessed_table_flag],
              (binlog_unsafe_map[stmt_accessed_table_flag] & condition)));
 
      int type_in= 0;
      for (; type_in < STMT_ACCESS_TABLE_COUNT; type_in++)
      {
        if (stmt_accessed_table((enum_stmt_accessed_table) type_in))
          DBUG_PRINT("LEX::is_mixed_stmt_unsafe", ("ACCESSED %s ",
                  stmt_accessed_table_string((enum_stmt_accessed_table) type_in)));
      }
#endif
    }

    if (stmt_accessed_table(STMT_WRITES_NON_TRANS_TABLE) &&
      stmt_accessed_table(STMT_READS_TRANS_TABLE) &&
      tx_isolation < ISO_REPEATABLE_READ)
      unsafe= TRUE;
    else if (stmt_accessed_table(STMT_WRITES_TEMP_NON_TRANS_TABLE) &&
      stmt_accessed_table(STMT_READS_TRANS_TABLE) &&
      tx_isolation < ISO_REPEATABLE_READ)
      unsafe= TRUE;

    return(unsafe);
1558 1559
  }

unknown's avatar
unknown committed
1560 1561 1562 1563 1564 1565
  /**
    true if the parsed tree contains references to stored procedures
    or functions, false otherwise
  */
  bool uses_stored_routines() const
  { return sroutines_list.elements != 0; }
1566

1567
private:
1568

1569
  /**
1570
    Enumeration listing special types of statements.
1571

1572
    Currently, the only possible type is ROW_INJECTION.
1573
  */
1574
  enum enum_binlog_stmt_type {
1575 1576 1577 1578
    /**
      The statement is a row injection (i.e., either a BINLOG
      statement or a row event executed by the slave SQL thread).
    */
1579 1580 1581 1582
    BINLOG_STMT_TYPE_ROW_INJECTION = 0,

    /** The last element of this enumeration type. */
    BINLOG_STMT_TYPE_COUNT
1583 1584
  };

1585
  /**
1586 1587 1588 1589 1590 1591
    Bit field indicating the type of statement.

    There are two groups of bits:

    - The low BINLOG_STMT_UNSAFE_COUNT bits indicate the types of
      unsafeness that the current statement has.
1592

1593 1594
    - The next BINLOG_STMT_TYPE_COUNT bits indicate if the statement
      is of some special type.
1595

1596 1597 1598
    This must be a member of LEX, not of THD: each stored procedure
    needs to remember its unsafeness state between calls and each
    stored procedure has its own LEX object (but no own THD object).
1599 1600
  */
  uint32 binlog_stmt_flags;
1601 1602 1603 1604 1605 1606

  /**
    Bit field that determines the type of tables that are about to be
    be accessed while executing a statement.
  */
  uint32 stmt_accessed_table_flag;
1607 1608 1609
};


1610 1611 1612 1613 1614 1615 1616 1617 1618 1619 1620 1621
/*
  st_parsing_options contains the flags for constructions that are
  allowed in the current statement.
*/

struct st_parsing_options
{
  bool allows_variable;
  bool allows_select_into;
  bool allows_select_procedure;
  bool allows_derived;

1622 1623
  st_parsing_options() { reset(); }
  void reset();
1624 1625 1626
};


1627 1628 1629 1630 1631 1632 1633 1634 1635 1636 1637 1638 1639 1640 1641 1642 1643 1644 1645 1646 1647 1648 1649 1650
/**
  The state of the lexical parser, when parsing comments.
*/
enum enum_comment_state
{
  /**
    Not parsing comments.
  */
  NO_COMMENT,
  /**
    Parsing comments that need to be preserved.
    Typically, these are user comments '/' '*' ... '*' '/'.
  */
  PRESERVE_COMMENT,
  /**
    Parsing comments that need to be discarded.
    Typically, these are special comments '/' '*' '!' ... '*' '/',
    or '/' '*' '!' 'M' 'M' 'm' 'm' 'm' ... '*' '/', where the comment
    markers should not be expanded.
  */
  DISCARD_COMMENT
};


1651
/**
unknown's avatar
unknown committed
1652
  @brief This class represents the character input stream consumed during
1653
  lexical analysis.
unknown's avatar
unknown committed
1654

1655 1656 1657 1658 1659 1660 1661 1662
  In addition to consuming the input stream, this class performs some
  comment pre processing, by filtering out out of bound special text
  from the query input stream.
  Two buffers, with pointers inside each buffers, are maintained in
  parallel. The 'raw' buffer is the original query text, which may
  contain out-of-bound comments. The 'cpp' (for comments pre processor)
  is the pre-processed buffer that contains only the query text that
  should be seen once out-of-bound data is removed.
1663
*/
unknown's avatar
unknown committed
1664

1665 1666 1667
class Lex_input_stream
{
public:
1668
  Lex_input_stream()
1669 1670 1671 1672 1673 1674 1675 1676 1677
  {
  }

  ~Lex_input_stream()
  {
  }

  /**
     Object initializer. Must be called before usage.
1678

1679 1680 1681
     @retval FALSE OK
     @retval TRUE  Error
  */
1682
  bool init(THD *thd, char *buff, unsigned int length);
1683

unknown's avatar
unknown committed
1684
  void reset(char *buff, unsigned int length);
1685

1686 1687
  /**
    Set the echo mode.
unknown's avatar
unknown committed
1688

1689 1690 1691 1692 1693 1694 1695 1696 1697
    When echo is true, characters parsed from the raw input stream are
    preserved. When false, characters parsed are silently ignored.
    @param echo the echo mode.
  */
  void set_echo(bool echo)
  {
    m_echo= echo;
  }

1698 1699 1700 1701 1702 1703 1704 1705 1706 1707 1708 1709
  void save_in_comment_state()
  {
    m_echo_saved= m_echo;
    in_comment_saved= in_comment;
  }

  void restore_in_comment_state()
  {
    m_echo= m_echo_saved;
    in_comment= in_comment_saved;
  }

1710 1711 1712 1713 1714 1715 1716 1717 1718 1719 1720 1721 1722 1723 1724 1725 1726 1727
  /**
    Skip binary from the input stream.
    @param n number of bytes to accept.
  */
  void skip_binary(int n)
  {
    if (m_echo)
    {
      memcpy(m_cpp_ptr, m_ptr, n);
      m_cpp_ptr += n;
    }
    m_ptr += n;
  }

  /**
    Get a character, and advance in the stream.
    @return the next character to parse.
  */
Davi Arnaut's avatar
Davi Arnaut committed
1728
  unsigned char yyGet()
1729 1730 1731 1732 1733 1734 1735 1736 1737 1738 1739
  {
    char c= *m_ptr++;
    if (m_echo)
      *m_cpp_ptr++ = c;
    return c;
  }

  /**
    Get the last character accepted.
    @return the last character accepted.
  */
Davi Arnaut's avatar
Davi Arnaut committed
1740
  unsigned char yyGetLast()
1741 1742 1743 1744 1745 1746 1747
  {
    return m_ptr[-1];
  }

  /**
    Look at the next character to parse, but do not accept it.
  */
Davi Arnaut's avatar
Davi Arnaut committed
1748
  unsigned char yyPeek()
1749 1750 1751 1752 1753 1754 1755 1756
  {
    return m_ptr[0];
  }

  /**
    Look ahead at some character to parse.
    @param n offset of the character to look up
  */
Davi Arnaut's avatar
Davi Arnaut committed
1757
  unsigned char yyPeekn(int n)
1758 1759 1760 1761 1762 1763 1764 1765 1766 1767 1768 1769 1770 1771 1772 1773 1774 1775 1776 1777 1778 1779 1780 1781 1782 1783 1784 1785 1786 1787 1788 1789 1790 1791 1792 1793 1794 1795 1796 1797 1798
  {
    return m_ptr[n];
  }

  /**
    Cancel the effect of the last yyGet() or yySkip().
    Note that the echo mode should not change between calls to yyGet / yySkip
    and yyUnget. The caller is responsible for ensuring that.
  */
  void yyUnget()
  {
    m_ptr--;
    if (m_echo)
      m_cpp_ptr--;
  }

  /**
    Accept a character, by advancing the input stream.
  */
  void yySkip()
  {
    if (m_echo)
      *m_cpp_ptr++ = *m_ptr++;
    else
      m_ptr++;
  }

  /**
    Accept multiple characters at once.
    @param n the number of characters to accept.
  */
  void yySkipn(int n)
  {
    if (m_echo)
    {
      memcpy(m_cpp_ptr, m_ptr, n);
      m_cpp_ptr += n;
    }
    m_ptr += n;
  }

1799 1800 1801 1802 1803 1804 1805 1806 1807 1808 1809 1810 1811 1812
  /**
    Puts a character back into the stream, canceling
    the effect of the last yyGet() or yySkip().
    Note that the echo mode should not change between calls
    to unput, get, or skip from the stream.
  */
  char *yyUnput(char ch)
  {
    *--m_ptr= ch;
    if (m_echo)
      m_cpp_ptr--;
    return m_ptr;
  }

1813 1814 1815 1816 1817 1818 1819 1820 1821 1822 1823 1824 1825 1826 1827 1828 1829 1830 1831 1832
  /**
    End of file indicator for the query text to parse.
    @return true if there are no more characters to parse
  */
  bool eof()
  {
    return (m_ptr >= m_end_of_query);
  }

  /**
    End of file indicator for the query text to parse.
    @param n number of characters expected
    @return true if there are less than n characters to parse
  */
  bool eof(int n)
  {
    return ((m_ptr + n) >= m_end_of_query);
  }

  /** Get the raw query buffer. */
unknown's avatar
unknown committed
1833
  const char *get_buf()
1834 1835 1836 1837 1838
  {
    return m_buf;
  }

  /** Get the pre-processed query buffer. */
unknown's avatar
unknown committed
1839
  const char *get_cpp_buf()
1840 1841 1842 1843 1844
  {
    return m_cpp_buf;
  }

  /** Get the end of the raw query buffer. */
unknown's avatar
unknown committed
1845
  const char *get_end_of_query()
1846 1847 1848 1849 1850 1851 1852 1853 1854 1855 1856 1857 1858 1859 1860 1861 1862 1863 1864 1865 1866 1867 1868 1869 1870 1871 1872
  {
    return m_end_of_query;
  }

  /** Mark the stream position as the start of a new token. */
  void start_token()
  {
    m_tok_start_prev= m_tok_start;
    m_tok_start= m_ptr;
    m_tok_end= m_ptr;

    m_cpp_tok_start_prev= m_cpp_tok_start;
    m_cpp_tok_start= m_cpp_ptr;
    m_cpp_tok_end= m_cpp_ptr;
  }

  /**
    Adjust the starting position of the current token.
    This is used to compensate for starting whitespace.
  */
  void restart_token()
  {
    m_tok_start= m_ptr;
    m_cpp_tok_start= m_cpp_ptr;
  }

  /** Get the token start position, in the raw buffer. */
unknown's avatar
unknown committed
1873
  const char *get_tok_start()
1874 1875 1876 1877 1878
  {
    return m_tok_start;
  }

  /** Get the token start position, in the pre-processed buffer. */
unknown's avatar
unknown committed
1879
  const char *get_cpp_tok_start()
1880 1881 1882 1883 1884
  {
    return m_cpp_tok_start;
  }

  /** Get the token end position, in the raw buffer. */
unknown's avatar
unknown committed
1885
  const char *get_tok_end()
1886 1887 1888 1889 1890
  {
    return m_tok_end;
  }

  /** Get the token end position, in the pre-processed buffer. */
unknown's avatar
unknown committed
1891
  const char *get_cpp_tok_end()
1892 1893 1894 1895 1896
  {
    return m_cpp_tok_end;
  }

  /** Get the previous token start position, in the raw buffer. */
unknown's avatar
unknown committed
1897
  const char *get_tok_start_prev()
1898 1899 1900 1901 1902
  {
    return m_tok_start_prev;
  }

  /** Get the current stream pointer, in the raw buffer. */
unknown's avatar
unknown committed
1903
  const char *get_ptr()
1904 1905 1906 1907 1908
  {
    return m_ptr;
  }

  /** Get the current stream pointer, in the pre-processed buffer. */
unknown's avatar
unknown committed
1909
  const char *get_cpp_ptr()
1910 1911 1912 1913 1914 1915 1916 1917 1918 1919 1920 1921 1922 1923 1924
  {
    return m_cpp_ptr;
  }

  /** Get the length of the current token, in the raw buffer. */
  uint yyLength()
  {
    /*
      The assumption is that the lexical analyser is always 1 character ahead,
      which the -1 account for.
    */
    DBUG_ASSERT(m_ptr > m_tok_start);
    return (uint) ((m_ptr - m_tok_start) - 1);
  }

unknown's avatar
unknown committed
1925 1926 1927 1928 1929 1930 1931 1932 1933
  /** Get the utf8-body string. */
  const char *get_body_utf8_str()
  {
    return m_body_utf8;
  }

  /** Get the utf8-body length. */
  uint get_body_utf8_length()
  {
1934
    return (uint) (m_body_utf8_ptr - m_body_utf8);
unknown's avatar
unknown committed
1935 1936 1937 1938 1939 1940 1941 1942 1943 1944
  }

  void body_utf8_start(THD *thd, const char *begin_ptr);
  void body_utf8_append(const char *ptr);
  void body_utf8_append(const char *ptr, const char *end_ptr);
  void body_utf8_append_literal(THD *thd,
                                const LEX_STRING *txt,
                                CHARSET_INFO *txt_cs,
                                const char *end_ptr);

1945 1946 1947 1948 1949 1950 1951 1952 1953 1954 1955 1956
  /** Current thread. */
  THD *m_thd;

  /** Current line number. */
  uint yylineno;

  /** Length of the last token parsed. */
  uint yytoklen;

  /** Interface with bison, value of the last token parsed. */
  LEX_YYSTYPE yylval;

1957 1958 1959 1960 1961 1962 1963 1964 1965 1966 1967
  /**
    LALR(2) resolution, look ahead token.
    Value of the next token to return, if any,
    or -1, if no token was parsed in advance.
    Note: 0 is a legal token, and represents YYEOF.
  */
  int lookahead_token;

  /** LALR(2) resolution, value of the look ahead token.*/
  LEX_YYSTYPE lookahead_yylval;

1968 1969
private:
  /** Pointer to the current position in the raw input stream. */
1970
  char *m_ptr;
1971 1972

  /** Starting position of the last token parsed, in the raw buffer. */
unknown's avatar
unknown committed
1973
  const char *m_tok_start;
1974

1975
  /** Ending position of the previous token parsed, in the raw buffer. */
unknown's avatar
unknown committed
1976
  const char *m_tok_end;
1977

1978
  /** End of the query text in the input stream, in the raw buffer. */
unknown's avatar
unknown committed
1979
  const char *m_end_of_query;
1980

1981
  /** Starting position of the previous token parsed, in the raw buffer. */
unknown's avatar
unknown committed
1982
  const char *m_tok_start_prev;
1983

1984
  /** Begining of the query text in the input stream, in the raw buffer. */
unknown's avatar
unknown committed
1985
  const char *m_buf;
1986

unknown's avatar
unknown committed
1987 1988 1989
  /** Length of the raw buffer. */
  uint m_buf_length;

1990 1991
  /** Echo the parsed stream to the pre-processed buffer. */
  bool m_echo;
1992
  bool m_echo_saved;
1993 1994

  /** Pre-processed buffer. */
unknown's avatar
unknown committed
1995
  char *m_cpp_buf;
1996 1997

  /** Pointer to the current position in the pre-processed input stream. */
unknown's avatar
unknown committed
1998
  char *m_cpp_ptr;
1999 2000 2001 2002 2003

  /**
    Starting position of the last token parsed,
    in the pre-processed buffer.
  */
unknown's avatar
unknown committed
2004
  const char *m_cpp_tok_start;
2005 2006 2007 2008 2009

  /**
    Starting position of the previous token parsed,
    in the pre-procedded buffer.
  */
unknown's avatar
unknown committed
2010
  const char *m_cpp_tok_start_prev;
2011 2012 2013 2014 2015

  /**
    Ending position of the previous token parsed,
    in the pre-processed buffer.
  */
unknown's avatar
unknown committed
2016
  const char *m_cpp_tok_end;
2017

unknown's avatar
unknown committed
2018 2019 2020 2021 2022 2023 2024 2025 2026 2027 2028 2029
  /** UTF8-body buffer created during parsing. */
  char *m_body_utf8;

  /** Pointer to the current position in the UTF8-body buffer. */
  char *m_body_utf8_ptr;

  /**
    Position in the pre-processed buffer. The query from m_cpp_buf to
    m_cpp_utf_processed_ptr is converted to UTF8-body.
  */
  const char *m_cpp_utf8_processed_ptr;

2030
public:
2031 2032 2033 2034

  /** Current state of the lexical analyser. */
  enum my_lex_states next_state;

2035 2036 2037 2038
  /**
    Position of ';' in the stream, to delimit multiple queries.
    This delimiter is in the raw buffer.
  */
unknown's avatar
unknown committed
2039
  const char *found_semicolon;
2040

2041 2042
  /** Token character bitmaps, to detect 7bit strings. */
  uchar tok_bitmap;
unknown's avatar
unknown committed
2043

2044 2045
  /** SQL_MODE = IGNORE_SPACE. */
  bool ignore_space;
2046 2047

  /**
2048
    TRUE if we're parsing a prepared statement: in this mode
2049
    we should allow placeholders.
2050 2051
  */
  bool stmt_prepare_mode;
2052 2053 2054 2055
  /**
    TRUE if we should allow multi-statements.
  */
  bool multi_statements;
2056 2057 2058

  /** State of the lexical analyser for comments. */
  enum_comment_state in_comment;
2059
  enum_comment_state in_comment_saved;
unknown's avatar
unknown committed
2060 2061 2062 2063 2064 2065 2066 2067 2068 2069 2070 2071 2072 2073 2074 2075 2076 2077 2078 2079 2080 2081 2082

  /**
    Starting position of the TEXT_STRING or IDENT in the pre-processed
    buffer.

    NOTE: this member must be used within MYSQLlex() function only.
  */
  const char *m_cpp_text_start;

  /**
    Ending position of the TEXT_STRING or IDENT in the pre-processed
    buffer.

    NOTE: this member must be used within MYSQLlex() function only.
    */
  const char *m_cpp_text_end;

  /**
    Character set specified by the character-set-introducer.

    NOTE: this member must be used within MYSQLlex() function only.
  */
  CHARSET_INFO *m_underscore_cs;
2083 2084
};

Marc Alff's avatar
Marc Alff committed
2085 2086 2087 2088 2089 2090 2091 2092 2093 2094 2095 2096 2097 2098 2099 2100 2101 2102 2103 2104 2105 2106 2107 2108 2109 2110 2111 2112 2113
/**
  Abstract representation of a statement.
  This class is an interface between the parser and the runtime.
  The parser builds the appropriate sub classes of Sql_statement
  to represent a SQL statement in the parsed tree.
  The execute() method in the sub classes contain the runtime implementation.
  Note that this interface is used for SQL statement recently implemented,
  the code for older statements tend to load the LEX structure with more
  attributes instead.
  The recommended way to implement new statements is to sub-class
  Sql_statement, as this improves code modularity (see the 'big switch' in
  dispatch_command()), and decrease the total size of the LEX structure
  (therefore saving memory in stored programs).
*/
class Sql_statement : public Sql_alloc
{
public:
  /**
    Execute this SQL statement.
    @param thd the current thread.
    @return 0 on success.
  */
  virtual bool execute(THD *thd) = 0;

protected:
  /**
    Constructor.
    @param lex the LEX structure that represents parts of this statement.
  */
Konstantin Osipov's avatar
Konstantin Osipov committed
2114
  Sql_statement(LEX *lex)
Marc Alff's avatar
Marc Alff committed
2115 2116 2117 2118 2119 2120 2121 2122 2123 2124 2125 2126 2127 2128 2129 2130 2131 2132 2133 2134 2135 2136 2137 2138
    : m_lex(lex)
  {}

  /** Destructor. */
  virtual ~Sql_statement()
  {
    /*
      Sql_statement objects are allocated in thd->mem_root.
      In MySQL, the C++ destructor is never called, the underlying MEM_ROOT is
      simply destroyed instead.
      Do not rely on the destructor for any cleanup.
    */
    DBUG_ASSERT(FALSE);
  }

protected:
  /**
    The legacy LEX structure for this statement.
    The LEX structure contains the existing properties of the parsed tree.
    TODO: with time, attributes from LEX should move to sub classes of
    Sql_statement, so that the parser only builds Sql_statement objects
    with the minimum set of attributes, instead of a LEX structure that
    contains the collection of every possible attribute.
  */
Konstantin Osipov's avatar
Konstantin Osipov committed
2139
  LEX *m_lex;
Marc Alff's avatar
Marc Alff committed
2140
};
2141

unknown's avatar
unknown committed
2142 2143
/* The state of the lex parsing. This is saved in the THD struct */

Konstantin Osipov's avatar
Konstantin Osipov committed
2144
struct LEX: public Query_tables_list
2145
{
unknown's avatar
unknown committed
2146
  SELECT_LEX_UNIT unit;                         /* most upper unit */
2147 2148
  SELECT_LEX select_lex;                        /* first SELECT_LEX */
  /* current SELECT_LEX in parsing */
unknown's avatar
(SCRUM)  
unknown committed
2149
  SELECT_LEX *current_select;
2150 2151
  /* list of all SELECT_LEX */
  SELECT_LEX *all_selects_list;
2152

2153 2154
  char *length,*dec,*change;
  LEX_STRING name;
unknown's avatar
unknown committed
2155
  char *help_arg;
2156
  char *backup_dir;				/* For RESTORE/BACKUP */
unknown's avatar
unknown committed
2157
  char* to_log;                                 /* For PURGE MASTER LOGS TO */
2158
  char* x509_subject,*x509_issuer,*ssl_cipher;
unknown's avatar
unknown committed
2159 2160
  String *wild;
  sql_exchange *exchange;
unknown's avatar
unknown committed
2161
  select_result *result;
2162
  Item *default_value, *on_update_value;
unknown's avatar
unknown committed
2163
  LEX_STRING comment, ident;
unknown's avatar
unknown committed
2164
  LEX_USER *grant_user;
unknown's avatar
unknown committed
2165
  XID *xid;
unknown's avatar
unknown committed
2166
  THD *thd;
unknown's avatar
WL#2936  
unknown committed
2167 2168 2169 2170

  /* maintain a list of used plugins for this LEX */
  DYNAMIC_ARRAY plugins;
  plugin_ref plugins_static_buffer[INITIAL_LEX_PLUGIN_LIST_SIZE];
2171

unknown's avatar
unknown committed
2172
  CHARSET_INFO *charset;
2173
  bool text_string_is_7bit;
2174 2175
  /* store original leaf_tables for INSERT SELECT and PS/SP */
  TABLE_LIST *leaf_tables_insert;
2176

2177 2178
  /** SELECT of CREATE VIEW statement */
  LEX_STRING create_view_select;
2179

unknown's avatar
unknown committed
2180
  /** Start of 'ON table', in trigger statements.  */
2181
  const char* raw_trg_on_table_name_begin;
unknown's avatar
unknown committed
2182
  /** End of 'ON table', in trigger statements. */
2183 2184
  const char* raw_trg_on_table_name_end;

2185 2186
  /* Partition info structure filled in by PARTITION BY parse part */
  partition_info *part_info;
unknown's avatar
unknown committed
2187

2188 2189 2190 2191 2192 2193
  /*
    The definer of the object being created (view, trigger, stored routine).
    I.e. the value of DEFINER clause.
  */
  LEX_USER *definer;

unknown's avatar
unknown committed
2194 2195
  List<Key_part_spec> col_list;
  List<Key_part_spec> ref_list;
2196
  List<String>	      interval_list;
unknown's avatar
unknown committed
2197
  List<LEX_USER>      users_list;
unknown's avatar
unknown committed
2198
  List<LEX_COLUMN>    columns;
unknown's avatar
unknown committed
2199
  List<Item>	      *insert_list,field_list,value_list,update_list;
2200
  List<List_item>     many_values;
unknown's avatar
unknown committed
2201
  List<set_var_base>  var_list;
2202
  List<Item_func_set_user_var> set_var_list; // in-query assignment list
2203
  List<Item_param>    param_list;
unknown's avatar
VIEW  
unknown committed
2204
  List<LEX_STRING>    view_list; // view list (list of field names in view)
unknown's avatar
unknown committed
2205 2206 2207 2208 2209 2210 2211 2212 2213 2214 2215 2216 2217 2218 2219
  /*
    A stack of name resolution contexts for the query. This stack is used
    at parse time to set local name resolution contexts for various parts
    of a query. For example, in a JOIN ... ON (some_condition) clause the
    Items in 'some_condition' must be resolved only against the operands
    of the the join, and not against the whole clause. Similarly, Items in
    subqueries should be resolved against the subqueries (and outer queries).
    The stack is used in the following way: when the parser detects that
    all Items in some clause need a local context, it creates a new context
    and pushes it on the stack. All newly created Items always store the
    top-most context in the stack. Once the parser leaves the clause that
    required a local context, the parser pops the top-most context.
  */
  List<Name_resolution_context> context_stack;

2220 2221
  SQL_I_List<ORDER> proc_list;
  SQL_I_List<TABLE_LIST> auxiliary_table_list, save_list;
unknown's avatar
unknown committed
2222
  Create_field	      *last_field;
unknown's avatar
unknown committed
2223
  Item_sum *in_sum_func;
unknown's avatar
unknown committed
2224
  udf_func udf;
2225 2226
  HA_CHECK_OPT   check_opt;			// check/repair options
  HA_CREATE_INFO create_info;
unknown's avatar
unknown committed
2227
  KEY_CREATE_INFO key_create_info;
unknown's avatar
unknown committed
2228
  LEX_MASTER_INFO mi;				// used by CHANGE MASTER
unknown's avatar
unknown committed
2229
  LEX_SERVER_OPTIONS server_options;
2230
  USER_RESOURCES mqh;
2231
  ulong type;
unknown's avatar
unknown committed
2232 2233 2234 2235 2236 2237 2238 2239 2240 2241
  /*
    This variable is used in post-parse stage to declare that sum-functions,
    or functions which have sense only if GROUP BY is present, are allowed.
    For example in a query
    SELECT ... FROM ...WHERE MIN(i) == 1 GROUP BY ... HAVING MIN(i) > 2
    MIN(i) in the WHERE clause is not allowed in the opposite to MIN(i)
    in the HAVING clause. Due to possible nesting of select construct
    the variable can contain 0 or 1 for each nest level.
  */
  nesting_map allow_sum_func;
Marc Alff's avatar
Marc Alff committed
2242 2243 2244

  Sql_statement *m_stmt;

2245 2246 2247 2248 2249 2250 2251 2252
  /*
    Usually `expr` rule of yacc is quite reused but some commands better
    not support subqueries which comes standard with this rule, like
    KILL, HA_READ, CREATE/ALTER EVENT etc. Set this to `false` to get
    syntax error back.
  */
  bool expr_allows_subselect;

unknown's avatar
unknown committed
2253
  enum SSL_type ssl_type;			/* defined in violite.h */
2254
  enum enum_duplicates duplicates;
unknown's avatar
unknown committed
2255
  enum enum_tx_isolation tx_isolation;
2256
  enum enum_ha_read_modes ha_read_mode;
unknown's avatar
unknown committed
2257
  union {
unknown's avatar
unknown committed
2258
    enum ha_rkey_function ha_rkey_mode;
unknown's avatar
unknown committed
2259 2260
    enum xa_option_words xa_opt;
  };
unknown's avatar
unknown committed
2261
  enum enum_var_type option_type;
unknown's avatar
VIEW  
unknown committed
2262 2263
  enum enum_view_create_mode create_view_mode;
  enum enum_drop_mode drop_mode;
2264

unknown's avatar
unknown committed
2265
  uint profile_query_id;
2266
  uint profile_options;
unknown's avatar
unknown committed
2267
  uint uint_geom_type;
unknown's avatar
unknown committed
2268
  uint grant, grant_tot_col, which_columns;
2269 2270 2271
  enum Foreign_key::fk_match_opt fk_match_option;
  enum Foreign_key::fk_option fk_update_opt;
  enum Foreign_key::fk_option fk_delete_opt;
2272
  uint slave_thd_opt, start_transaction_opt;
unknown's avatar
unknown committed
2273
  int nest_level;
2274 2275 2276 2277 2278 2279
  /*
    In LEX representing update which were transformed to multi-update
    stores total number of tables. For LEX representing multi-delete
    holds number of tables from which we will delete records.
  */
  uint table_count;
unknown's avatar
unknown committed
2280
  uint8 describe;
2281 2282 2283
  /*
    A flag that indicates what kinds of derived tables are present in the
    query (0 if no derived tables, otherwise a combination of flags
unknown's avatar
unknown committed
2284
    DERIVED_SUBQUERY and DERIVED_VIEW).
2285
  */
unknown's avatar
VIEW  
unknown committed
2286 2287
  uint8 derived_tables;
  uint8 create_view_algorithm;
unknown's avatar
unknown committed
2288
  uint8 create_view_check;
2289
  bool drop_if_exists, drop_temporary, local_file, one_shot_set;
2290
  bool autocommit;
2291 2292
  bool verbose, no_write_to_binlog;

2293
  enum enum_yes_no_unknown tx_chain, tx_release;
unknown's avatar
unknown committed
2294 2295 2296 2297 2298 2299 2300
  /*
    Special JOIN::prepare mode: changing of query is prohibited.
    When creating a view, we need to just check its syntax omitting
    any optimizations: afterwards definition of the view will be
    reconstructed by means of ::print() methods and written to
    to an .frm file. We need this definition to stay untouched.
  */
unknown's avatar
VIEW  
unknown committed
2301
  bool view_prepare_mode;
2302
  bool safe_to_cache_query;
2303
  bool subqueries, ignore;
2304
  st_parsing_options parsing_options;
2305
  Alter_info alter_info;
Konstantin Osipov's avatar
Konstantin Osipov committed
2306 2307 2308 2309 2310 2311
  /*
    For CREATE TABLE statement last element of table list which is not
    part of SELECT or LIKE part (i.e. either element for table we are
    creating or last of tables referenced by foreign keys).
  */
  TABLE_LIST *create_last_non_select_table;
unknown's avatar
unknown committed
2312 2313
  /* Prepared statements SQL syntax:*/
  LEX_STRING prepared_stmt_name; /* Statement name (in all queries) */
unknown's avatar
unknown committed
2314
  /*
2315 2316 2317
    Prepared statement query text or name of variable that holds the
    prepared statement (in PREPARE ... queries)
  */
unknown's avatar
unknown committed
2318
  LEX_STRING prepared_stmt_code;
2319 2320
  /* If true, prepared_stmt_code is a name of variable that holds the query */
  bool prepared_stmt_code_is_varref;
unknown's avatar
unknown committed
2321
  /* Names of user variables holding parameters (in EXECUTE) */
unknown's avatar
unknown committed
2322
  List<LEX_STRING> prepared_stmt_params;
2323
  sp_head *sphead;
2324
  sp_name *spname;
2325
  bool sp_lex_in_use;	/* Keep track on lex usage in SPs for error handling */
2326
  bool all_privileges;
2327
  bool proxy_priv;
2328
  sp_pcontext *spcont;
2329

2330
  st_sp_chistics sp_chistics;
unknown's avatar
unknown committed
2331

unknown's avatar
unknown committed
2332
  Event_parse_data *event_parse_data;
unknown's avatar
unknown committed
2333

unknown's avatar
VIEW  
unknown committed
2334 2335 2336 2337 2338 2339
  bool only_view;       /* used for SHOW CREATE TABLE/VIEW */
  /*
    field_list was created for view and should be removed before PS/SP
    rexecuton
  */
  bool empty_field_list_on_rset;
2340 2341 2342
  /*
    view created to be run from definer (standard behaviour)
  */
2343
  uint8 create_view_suid;
2344 2345 2346
  /* Characterstics of trigger being created */
  st_trg_chistics trg_chistics;
  /*
2347 2348 2349 2350 2351
    List of all items (Item_trigger_field objects) representing fields in
    old/new version of row in trigger. We use this list for checking whenever
    all such fields are valid at trigger creation time and for binding these
    fields to TABLE object at table open (altough for latter pointer to table
    being opened is probably enough).
2352
  */
2353
  SQL_I_List<Item_trigger_field> trg_table_fields;
2354

2355
  /*
2356 2357 2358 2359 2360
    stmt_definition_begin is intended to point to the next word after
    DEFINER-clause in the following statements:
      - CREATE TRIGGER (points to "TRIGGER");
      - CREATE PROCEDURE (points to "PROCEDURE");
      - CREATE FUNCTION (points to "FUNCTION" or "AGGREGATE");
2361
      - CREATE EVENT (points to "EVENT")
2362 2363

    This pointer is required to add possibly omitted DEFINER-clause to the
2364
    DDL-statement before dumping it to the binlog.
2365

2366 2367 2368
    keyword_delayed_begin_offset is the offset to the beginning of the DELAYED
    keyword in INSERT DELAYED statement. keyword_delayed_end_offset is the
    offset to the character right after the DELAYED keyword.
2369
  */
2370 2371
  union {
    const char *stmt_definition_begin;
2372
    uint keyword_delayed_begin_offset;
2373
  };
2374

2375 2376 2377 2378
  union {
    const char *stmt_definition_end;
    uint keyword_delayed_end_offset;
  };
2379

2380 2381 2382 2383 2384 2385 2386
  /**
    During name resolution search only in the table list given by 
    Name_resolution_context::first_name_resolution_table and
    Name_resolution_context::last_name_resolution_table
    (see Item_field::fix_fields()). 
  */
  bool use_only_table_context;
unknown's avatar
unknown committed
2387 2388 2389 2390 2391 2392

  /*
    Reference to a struct that contains information in various commands
    to add/create/drop/change table spaces.
  */
  st_alter_tablespace *alter_tablespace_info;
2393 2394
  
  bool escape_used;
2395
  bool is_lex_started; /* If lex_start() did run. For debugging. */
unknown's avatar
unknown committed
2396

2397 2398 2399 2400 2401 2402 2403 2404 2405 2406 2407 2408 2409 2410 2411 2412
  /*
    Special case for SELECT .. FOR UPDATE and LOCK TABLES .. WRITE.

    Protect from a impending GRL as otherwise the thread might deadlock
    if it starts waiting for the GRL in mysql_lock_tables.

    The protection is needed because there is a race between setting
    the global read lock and waiting for all open tables to be closed.
    The problem is a circular wait where a thread holding "old" open
    tables will wait for the global read lock to be released while the
    thread holding the global read lock will wait for all "old" open
    tables to be closed -- the flush part of flush tables with read
    lock.
  */
  bool protect_against_global_read_lock;

Konstantin Osipov's avatar
Konstantin Osipov committed
2413
  LEX();
2414

Konstantin Osipov's avatar
Konstantin Osipov committed
2415
  virtual ~LEX()
2416
  {
2417
    destroy_query_tables_list();
unknown's avatar
WL#2936  
unknown committed
2418 2419
    plugin_unlock_list(NULL, (plugin_ref *)plugins.buffer, plugins.elements);
    delete_dynamic(&plugins);
2420
  }
2421

2422
  inline void uncacheable(uint8 cause)
2423 2424
  {
    safe_to_cache_query= 0;
2425 2426 2427 2428 2429 2430

    /*
      There are no sense to mark select_lex and union fields of LEX,
      but we should merk all subselects as uncacheable from current till
      most upper
    */
unknown's avatar
(SCRUM)  
unknown committed
2431
    SELECT_LEX *sl;
unknown's avatar
unknown committed
2432 2433 2434 2435
    SELECT_LEX_UNIT *un;
    for (sl= current_select, un= sl->master_unit();
	 un != &unit;
	 sl= sl->outer_select(), un= sl->master_unit())
2436
    {
2437 2438
      sl->uncacheable|= cause;
      un->uncacheable|= cause;
2439
    }
2440
  }
2441 2442
  void set_trg_event_type_for_tables();

unknown's avatar
VIEW  
unknown committed
2443 2444 2445 2446 2447 2448
  TABLE_LIST *unlink_first_table(bool *link_to_local);
  void link_first_table_back(TABLE_LIST *first, bool link_to_local);
  void first_lists_tables_same();

  bool can_be_merged();
  bool can_use_merged();
2449
  bool can_not_use_merged();
unknown's avatar
VIEW  
unknown committed
2450
  bool only_view_structure();
unknown's avatar
unknown committed
2451
  bool need_correct_ident();
2452
  uint8 get_effective_with_check(TABLE_LIST *view);
2453 2454
  /*
    Is this update command where 'WHITH CHECK OPTION' clause is important
2455

2456
    SYNOPSIS
Konstantin Osipov's avatar
Konstantin Osipov committed
2457
      LEX::which_check_option_applicable()
2458 2459 2460 2461 2462 2463 2464 2465 2466 2467 2468 2469

    RETURN
      TRUE   have to take 'WHITH CHECK OPTION' clause into account
      FALSE  'WHITH CHECK OPTION' clause do not need
  */
  inline bool which_check_option_applicable()
  {
    switch (sql_command) {
    case SQLCOM_UPDATE:
    case SQLCOM_UPDATE_MULTI:
    case SQLCOM_INSERT:
    case SQLCOM_INSERT_SELECT:
2470 2471
    case SQLCOM_REPLACE:
    case SQLCOM_REPLACE_SELECT:
2472 2473 2474 2475 2476 2477
    case SQLCOM_LOAD:
      return TRUE;
    default:
      return FALSE;
    }
  }
2478

2479
  void cleanup_after_one_table_open();
unknown's avatar
unknown committed
2480

2481
  bool push_context(Name_resolution_context *context)
unknown's avatar
unknown committed
2482
  {
2483
    return context_stack.push_front(context);
unknown's avatar
unknown committed
2484 2485 2486 2487 2488 2489 2490
  }

  void pop_context()
  {
    context_stack.pop();
  }

2491
  bool copy_db_to(char **p_db, size_t *p_db_length) const;
2492

unknown's avatar
unknown committed
2493 2494 2495 2496
  Name_resolution_context *current_context()
  {
    return context_stack.head();
  }
2497 2498 2499 2500
  /*
    Restore the LEX and THD in case of a parse error.
  */
  static void cleanup_lex_after_parse_error(THD *thd);
2501 2502 2503

  void reset_n_backup_query_tables_list(Query_tables_list *backup);
  void restore_backup_query_tables_list(Query_tables_list *backup);
unknown's avatar
unknown committed
2504 2505

  bool table_or_sp_used();
2506
  bool is_partition_management() const;
2507

2508 2509 2510 2511 2512 2513 2514 2515 2516 2517 2518 2519 2520 2521 2522 2523 2524 2525 2526 2527 2528
  /**
    @brief check if the statement is a single-level join
    @return result of the check
      @retval TRUE  The statement doesn't contain subqueries, unions and 
                    stored procedure calls.
      @retval FALSE There are subqueries, UNIONs or stored procedure calls.
  */
  bool is_single_level_stmt() 
  { 
    /* 
      This check exploits the fact that the last added to all_select_list is
      on its top. So select_lex (as the first added) will be at the tail 
      of the list.
    */ 
    if (&select_lex == all_selects_list && !sroutines.records)
    {
      DBUG_ASSERT(!all_selects_list->next_select_in_list());
      return TRUE;
    }
    return FALSE;
  }
Konstantin Osipov's avatar
Konstantin Osipov committed
2529
};
unknown's avatar
unknown committed
2530

2531

Marc Alff's avatar
Marc Alff committed
2532 2533 2534 2535 2536 2537 2538 2539
/**
  Set_signal_information is a container used in the parsed tree to represent
  the collection of assignments to condition items in the SIGNAL and RESIGNAL
  statements.
*/
class Set_signal_information
{
public:
2540 2541
  /** Empty default constructor, use clear() */
 Set_signal_information() {} 
Marc Alff's avatar
Marc Alff committed
2542 2543 2544 2545 2546 2547 2548 2549 2550 2551 2552 2553

  /** Copy constructor. */
  Set_signal_information(const Set_signal_information& set);

  /** Destructor. */
  ~Set_signal_information()
  {}

  /** Clear all items. */
  void clear();

  /**
2554
    For each condition item assignment, m_item[] contains the parsed tree
Marc Alff's avatar
Marc Alff committed
2555 2556 2557 2558 2559 2560 2561
    that represents the expression assigned, if any.
    m_item[] is an array indexed by Diag_condition_item_name.
  */
  Item *m_item[LAST_DIAG_SET_PROPERTY+1];
};


2562 2563 2564 2565 2566 2567 2568 2569 2570
/**
  The internal state of the syntax parser.
  This object is only available during parsing,
  and is private to the syntax parser implementation (sql_yacc.yy).
*/
class Yacc_state
{
public:
  Yacc_state()
2571 2572 2573 2574 2575 2576 2577 2578 2579
  {
    reset();
  }

  void reset()
  {
    yacc_yyss= NULL;
    yacc_yyvs= NULL;
    m_set_signal_info.clear();
2580
    m_lock_type= TL_READ_DEFAULT;
2581
    m_mdl_type= MDL_SHARED_READ;
2582
  }
2583 2584 2585

  ~Yacc_state();

2586 2587 2588 2589 2590 2591 2592
  /**
    Reset part of the state which needs resetting before parsing
    substatement.
  */
  void reset_before_substatement()
  {
    m_lock_type= TL_READ_DEFAULT;
2593
    m_mdl_type= MDL_SHARED_READ;
2594 2595
  }

2596 2597 2598 2599
  /**
    Bison internal state stack, yyss, when dynamically allocated using
    my_yyoverflow().
  */
2600
  uchar *yacc_yyss;
2601 2602 2603 2604 2605

  /**
    Bison internal semantic value stack, yyvs, when dynamically allocated using
    my_yyoverflow().
  */
2606
  uchar *yacc_yyvs;
2607

Marc Alff's avatar
Marc Alff committed
2608 2609 2610 2611 2612 2613
  /**
    Fragments of parsed tree,
    used during the parsing of SIGNAL and RESIGNAL.
  */
  Set_signal_information m_set_signal_info;

2614 2615 2616 2617 2618 2619 2620 2621 2622 2623 2624 2625 2626 2627 2628 2629 2630 2631 2632
  /**
    Type of lock to be used for tables being added to the statement's
    table list in table_factor, table_alias_ref, single_multi and
    table_wild_one rules.
    Statements which use these rules but require lock type different
    from one specified by this member have to override it by using
    st_select_lex::set_lock_for_tables() method.

    The default value of this member is TL_READ_DEFAULT. The only two
    cases in which we change it are:
    - When parsing SELECT HIGH_PRIORITY.
    - Rule for DELETE. In which we use this member to pass information
      about type of lock from delete to single_multi part of rule.

    We should try to avoid introducing new use cases as we would like
    to get rid of this member eventually.
  */
  thr_lock_type m_lock_type;

2633 2634 2635 2636 2637 2638
  /**
    The type of requested metadata lock for tables added to
    the statement table list.
  */
  enum_mdl_type m_mdl_type;

2639 2640 2641 2642 2643 2644 2645 2646 2647 2648 2649 2650 2651 2652
  /*
    TODO: move more attributes from the LEX structure here.
  */
};

/**
  Internal state of the parser.
  The complete state consist of:
  - state data used during lexical parsing,
  - state data used during syntactic parsing.
*/
class Parser_state
{
public:
2653 2654
  Parser_state()
    : m_yacc()
2655 2656
  {}

2657 2658 2659 2660 2661 2662
  /**
     Object initializer. Must be called before usage.

     @retval FALSE OK
     @retval TRUE  Error
  */
2663
  bool init(THD *thd, char *buff, unsigned int length)
2664 2665 2666 2667
  {
    return m_lip.init(thd, buff, length);
  }

2668 2669 2670 2671 2672
  ~Parser_state()
  {}

  Lex_input_stream m_lip;
  Yacc_state m_yacc;
2673

unknown's avatar
unknown committed
2674
  void reset(char *found_semicolon, unsigned int length)
2675 2676 2677 2678
  {
    m_lip.reset(found_semicolon, length);
    m_yacc.reset();
  }
2679 2680 2681
};


Konstantin Osipov's avatar
Konstantin Osipov committed
2682
struct st_lex_local: public LEX
unknown's avatar
unknown committed
2683
{
2684
  static void *operator new(size_t size) throw()
unknown's avatar
unknown committed
2685
  {
2686
    return sql_alloc(size);
unknown's avatar
unknown committed
2687
  }
2688
  static void *operator new(size_t size, MEM_ROOT *mem_root) throw()
unknown's avatar
unknown committed
2689 2690 2691
  {
    return (void*) alloc_root(mem_root, (uint) size);
  }
unknown's avatar
unknown committed
2692 2693
  static void operator delete(void *ptr,size_t size)
  { TRASH(ptr, size); }
2694 2695
  static void operator delete(void *ptr, MEM_ROOT *mem_root)
  { /* Never called */ }
unknown's avatar
unknown committed
2696
};
unknown's avatar
unknown committed
2697

unknown's avatar
unknown committed
2698 2699
extern void lex_init(void);
extern void lex_free(void);
2700
extern void lex_start(THD *thd);
unknown's avatar
unknown committed
2701
extern void lex_end(LEX *lex);
2702
extern int MYSQLlex(void *arg, void *yythd);
2703 2704

extern void trim_whitespace(CHARSET_INFO *cs, LEX_STRING *str);
unknown's avatar
unknown committed
2705

2706 2707
extern bool is_lex_native_function(const LEX_STRING *name);

2708 2709 2710 2711
/**
  @} (End of group Semantic_Analysis)
*/

Marc Alff's avatar
Marc Alff committed
2712
void my_missing_function_error(const LEX_STRING &token, const char *name);
2713
bool is_keyword(const char *name, uint len);
2714

2715
#endif /* MYSQL_SERVER */
2716
#endif /* SQL_LEX_INCLUDED */