mirror of
https://github.com/MariaDB/server.git
synced 2025-05-29 21:42:28 +03:00
New multi-key-cache handling. This was needed becasue the old one didn't work reliable with MERGE tables. ALTER TABLE table_name ... CHARACTER SET ... now changes all char/varchar/text columns to the given character set (One must use ALTER TABLE ... DEFAULT CHARACTER SET ... to change the default character set) Fixed that have_compress is detected properly (fixes problems with func_compress.test on platforms without zlib) New syntax for CACHE INDEX ('keys' is optional if no index name is given and one mentions the key cache name only ones) Removed compiler warnings Added mysql_set_server_option() to allow clients like PHP to easaily set/reset the multi-statement flag. BUILD/compile-pentium-valgrind-max: Add test of isam client/mysql.cc: CLIENT_MULTI_QUERIES -> CLIENT_MULTI_STATEMENTS include/my_base.h: Remove HA_EXTRA_SET_KEY_CACHE include/my_no_pthread.h: Add defines to ignore rw-locks when running without threads include/my_sys.h: Added function for multi-key-caches include/myisam.h: Added function to handle multi-key-caches include/mysql.h: Added mysql_set_server_option include/mysql_com.h: CLIENT_MULTI_QUERIES -> CLIENT_MULTI_STATEMENTS Added enum_mysql_set_option include/mysqld_error.h: Added error message for unknown key cache innobase/srv/srv0start.c: Removed warning that is confused for MySQL users libmysql/libmysql.c: Added mysql_set_server_option() libmysql/libmysql.def: Added mysql_set_server_option() myisam/ft_nlq_search.c: Removed compiler warning myisam/ft_static.c: Removed compiler warning and fixed wrong return value myisam/mi_check.c: Clean up multi-key-cache usage myisam/mi_checksum.c: Removed not used variable myisam/mi_close.c: keycache -> key_cache myisam/mi_delete_all.c: keycache -> key_cache myisam/mi_extra.c: keycache -> key_cache Removed HA_EXTRA_SET_KEY_CACHE myisam/mi_keycache.c: Changed logic so that it's MyISAM that is responsible for assign tables to different key caches instead of the upper level myisam/mi_locking.c: Don't change key cache on unlock (must be done before) myisam/mi_open.c: Fetch key cache to use from multi_key_cache_search() myisam/mi_page.c: keycache -> key_cache myisam/mi_panic.c: keycache -> key_cache myisam/mi_preload.c: keycache -> key_cache myisam/mi_test1.c: Use KEY_CACHE_BLOCK_SIZE myisam/mi_test2.c: Always test resize_key_cache() myisam/mi_test3.c: Use KEY_CACHE_BLOCK_SIZE instead of 512 myisam/myisamchk.c: update for multiple key caches myisam/myisamdef.h: Remove reg_keycache Add unique_name_length for storing length of unique_file_name myisam/myisamlog.c: Change how end_key_cache() is called mysql-test/mysql-test-run.sh: Fixed web link Added name of failed test to abort row. mysql-test/r/alter_table.result: Testing of ALTER TABLE ... [DEFAULT] CHARACTER SET mysql-test/r/case.result: Update result for DEFAULT CHARSET... mysql-test/r/cast.result: Update result for DEFAULT CHARSET... mysql-test/r/create.result: Update result for DEFAULT CHARSET... mysql-test/r/ctype_collate.result: Update result for DEFAULT CHARSET... mysql-test/r/ctype_latin1_de.result: Update result for DEFAULT CHARSET... mysql-test/r/ctype_many.result: Update result for DEFAULT CHARSET... mysql-test/r/ctype_mb.result: Update result for DEFAULT CHARSET... mysql-test/r/ctype_recoding.result: Update result for DEFAULT CHARSET... mysql-test/r/ctype_ucs.result: Update result for DEFAULT CHARSET... mysql-test/r/derived.result: Use STRAIGHT_JOIN to make join order predictable mysql-test/r/fulltext.result: Update result for DEFAULT CHARSET... mysql-test/r/func_str.result: Update result for DEFAULT CHARSET... mysql-test/r/func_system.result: Update result for DEFAULT CHARSET... mysql-test/r/gis-rtree.result: Update result for DEFAULT CHARSET... mysql-test/r/innodb.result: Update result for DEFAULT CHARSET... mysql-test/r/key_cache.result: Update test for new key cache syntax. Added more tests mysql-test/r/merge.result: Update result for DEFAULT CHARSET... mysql-test/r/preload.result: New syntax mysql-test/r/show_check.result: Update result for DEFAULT CHARSET... mysql-test/r/sql_mode.result: Update result for DEFAULT CHARSET... mysql-test/r/subselect.result: Update result for DEFAULT CHARSET... mysql-test/r/type_blob.result: Update result for DEFAULT CHARSET... mysql-test/r/type_enum.result: Update result for DEFAULT CHARSET... mysql-test/r/type_nchar.result: Update result for DEFAULT CHARSET... mysql-test/r/type_set.result: Update result for DEFAULT CHARSET... mysql-test/r/union.result: Use STRAIGHT_JOIN to make join order predictable mysql-test/t/alter_table.test: Testing of ALTER TABLE ... [DEFAULT] CHARACTER SET mysql-test/t/ctype_many.test: Update result for DEFAULT CHARSET... mysql-test/t/derived.test: Use STRAIGHT_JOIN to make join order predictable mysql-test/t/isam.test: Use disable warnings for test loop mysql-test/t/join.test: Update test now when we only support 61 tables in join mysql-test/t/key_cache.test: Update test for new key cache syntax. Added more tests mysql-test/t/preload.test: Update for new syntax mysql-test/t/union.test: Use STRAIGHT_JOIN to make join order predictable mysys/Makefile.am: Added mf_keycaches.c mysys/hash.c: TRUE -> 1 mysys/mf_keycache.c: Removed compiler warnings Striped end space Fixed indentation and improved function comments TRUE -> 1 Changed parameters to end_key_cache() to make it easer to use Fixed bug when using key blocks size > 1024 bytes (First part of index file could be overwritten with wrong data) Split function flush_key_blocks into two functions to not get mutex used twice when called from flush_all_key_blocks() mysys/my_bitmap.c: More debugging Safe bitmap_free() Fixed indentation mysys/my_getopt.c: Ensure that we initialize option->value, option->max_value and value from GET_ASK_ADDR mysys/my_thr_init.c: Remove not used mutex THR_LOCK_keycache mysys/typelib.c: Fixed function comments sql-common/client.c: CLIENT_MULTI_QUERIES -> CLIENT_MULTI_STATEMENTS Fixed the multi_result flag is set also on SELECT;s sql/ha_myisam.cc: Fixed multiple key_cache handling (Now done on MyISAM level) sql/ha_myisammrg.cc: Fixed multiple key_cache handling (Now done on MyISAM level) sql/handler.cc: New multi key cache handling sql/handler.h: New multi key cache handling Added support for default character set sql/item.h: Added function cleanup() (Needed for prepared statements / cursors) sql/item_cmpfunc.h: Added cleanup function sql/item_func.cc: Indentation cleanup sql/mysql_priv.h: New multi-key-cache functions Removed LOCK_assign sql/mysqld.cc: New multi-key-cache handling Fixed that variable have_compress is set correctly sql/protocol.cc: SELECT didn't work reliable in multi-statements sql/set_var.cc: Support for new key cache variables sql/set_var.h: Support for new key cache variables sql/share/czech/errmsg.txt: New error messages sql/share/danish/errmsg.txt: New error messages sql/share/dutch/errmsg.txt: New error messages sql/share/english/errmsg.txt: New error messages sql/share/estonian/errmsg.txt: New error messages sql/share/french/errmsg.txt: New error messages sql/share/german/errmsg.txt: New error messages sql/share/greek/errmsg.txt: New error messages sql/share/hungarian/errmsg.txt: New error messages sql/share/italian/errmsg.txt: New error messages sql/share/japanese/errmsg.txt: New error messages sql/share/korean/errmsg.txt: New error messages sql/share/norwegian-ny/errmsg.txt: New error messages sql/share/norwegian/errmsg.txt: New error messages sql/share/polish/errmsg.txt: New error messages sql/share/portuguese/errmsg.txt: New error messages sql/share/romanian/errmsg.txt: New error messages sql/share/russian/errmsg.txt: New error messages sql/share/serbian/errmsg.txt: New error messages sql/share/slovak/errmsg.txt: New error messages sql/share/spanish/errmsg.txt: New error messages sql/share/swedish/errmsg.txt: New error messages sql/share/ukrainian/errmsg.txt: New error messages sql/sql_base.cc: Removed all key_cache handling (this is now done on MyISAM level) Change table_charset -> default_table_charset sql/sql_db.cc: table_charset -> default_table_charset sql/sql_delete.cc: table_charset -> default_table_charset sql/sql_lex.cc: CLIENT_MULTI_QUERIES -> CLIENT_MULTI_STATEMENTS sql/sql_lex.h: New option to store a name and length sql/sql_parse.cc: Support for mysql_set_server_option() Reset "default" keycache status variables in 'FLUSH STATUS' (Need to be improved later) sql/sql_show.cc: Add DEFAULT before CHARSET (for table character sets) Fetch key cache variables from 'sql_key_cache' sql/sql_table.cc: table_charset -> default_table_charset New multi-key-cache handling sql/sql_test.cc: Write information from all key caches sql/sql_yacc.yy: Changed syntax for CACHE INDEX ... Force user to use DEFAULT before database/table level character sets sql/structs.h: Added SHOW_KEY_CACHE_LONG (to get values from sql_key_cache) sql/table.cc: table_charset -> default_table_charset sql/table.h: New key cache handling (this is now done in mysys/mf_keycaches.c) sql/unireg.h: A
599 lines
20 KiB
C++
599 lines
20 KiB
C++
/* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
|
|
|
|
This program is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation; either version 2 of the License, or
|
|
(at your option) any later version.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
|
|
|
|
|
|
/* YACC and LEX Definitions */
|
|
|
|
/* These may not be declared yet */
|
|
class Table_ident;
|
|
class sql_exchange;
|
|
class LEX_COLUMN;
|
|
|
|
/*
|
|
The following hack is needed because mysql_yacc.cc does not define
|
|
YYSTYPE before including this file
|
|
*/
|
|
|
|
#include "set_var.h"
|
|
|
|
#ifdef MYSQL_YACC
|
|
#define LEX_YYSTYPE void *
|
|
#else
|
|
#include "lex_symbol.h"
|
|
#include "sql_yacc.h"
|
|
#define LEX_YYSTYPE YYSTYPE *
|
|
#endif
|
|
|
|
/*
|
|
When a command is added here, be sure it's also added in mysqld.cc
|
|
in "struct show_var_st status_vars[]= {" ...
|
|
*/
|
|
|
|
enum enum_sql_command {
|
|
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,
|
|
SQLCOM_SHOW_KEYS, SQLCOM_SHOW_VARIABLES, SQLCOM_SHOW_LOGS, SQLCOM_SHOW_STATUS,
|
|
SQLCOM_SHOW_INNODB_STATUS,
|
|
SQLCOM_SHOW_PROCESSLIST, SQLCOM_SHOW_MASTER_STAT, SQLCOM_SHOW_SLAVE_STAT,
|
|
SQLCOM_SHOW_GRANTS, SQLCOM_SHOW_CREATE, SQLCOM_SHOW_CHARSETS,
|
|
SQLCOM_SHOW_COLLATIONS, SQLCOM_SHOW_CREATE_DB,
|
|
|
|
SQLCOM_LOAD,SQLCOM_SET_OPTION,SQLCOM_LOCK_TABLES,SQLCOM_UNLOCK_TABLES,
|
|
SQLCOM_GRANT,
|
|
SQLCOM_CHANGE_DB, SQLCOM_CREATE_DB, SQLCOM_DROP_DB, SQLCOM_ALTER_DB,
|
|
SQLCOM_REPAIR, SQLCOM_REPLACE, SQLCOM_REPLACE_SELECT,
|
|
SQLCOM_CREATE_FUNCTION, SQLCOM_DROP_FUNCTION,
|
|
SQLCOM_REVOKE,SQLCOM_OPTIMIZE, SQLCOM_CHECK,
|
|
SQLCOM_ASSIGN_TO_KEYCACHE, SQLCOM_PRELOAD_KEYS,
|
|
SQLCOM_FLUSH, SQLCOM_KILL, SQLCOM_ANALYZE,
|
|
SQLCOM_ROLLBACK, SQLCOM_ROLLBACK_TO_SAVEPOINT,
|
|
SQLCOM_COMMIT, SQLCOM_SAVEPOINT,
|
|
SQLCOM_SLAVE_START, SQLCOM_SLAVE_STOP,
|
|
SQLCOM_BEGIN, SQLCOM_LOAD_MASTER_TABLE, SQLCOM_CHANGE_MASTER,
|
|
SQLCOM_RENAME_TABLE, SQLCOM_BACKUP_TABLE, SQLCOM_RESTORE_TABLE,
|
|
SQLCOM_RESET, SQLCOM_PURGE, SQLCOM_PURGE_BEFORE, SQLCOM_SHOW_BINLOGS,
|
|
SQLCOM_SHOW_OPEN_TABLES, SQLCOM_LOAD_MASTER_DATA,
|
|
SQLCOM_HA_OPEN, SQLCOM_HA_CLOSE, SQLCOM_HA_READ,
|
|
SQLCOM_SHOW_SLAVE_HOSTS, SQLCOM_DELETE_MULTI, SQLCOM_UPDATE_MULTI,
|
|
SQLCOM_SHOW_BINLOG_EVENTS, SQLCOM_SHOW_NEW_MASTER, SQLCOM_DO,
|
|
SQLCOM_SHOW_WARNS, SQLCOM_EMPTY_QUERY, SQLCOM_SHOW_ERRORS,
|
|
SQLCOM_SHOW_COLUMN_TYPES, SQLCOM_SHOW_TABLE_TYPES, SQLCOM_SHOW_PRIVILEGES,
|
|
SQLCOM_HELP, SQLCOM_DROP_USER, SQLCOM_REVOKE_ALL, SQLCOM_CHECKSUM,
|
|
|
|
/* This should be the last !!! */
|
|
SQLCOM_END
|
|
};
|
|
|
|
// describe/explain types
|
|
#define DESCRIBE_NORMAL 1
|
|
#define DESCRIBE_EXTENDED 2
|
|
|
|
typedef List<Item> List_item;
|
|
|
|
typedef struct st_lex_master_info
|
|
{
|
|
char *host, *user, *password, *log_file_name;
|
|
uint port, connect_retry;
|
|
ulonglong pos;
|
|
ulong server_id;
|
|
/*
|
|
Variable for MASTER_SSL option.
|
|
MASTER_SSL=0 in CHANGE MASTER TO corresponds to SSL_DISABLE
|
|
MASTER_SSL=1 corresponds to SSL_ENABLE
|
|
*/
|
|
enum {SSL_UNCHANGED=0, SSL_DISABLE, SSL_ENABLE} ssl;
|
|
char *ssl_key, *ssl_cert, *ssl_ca, *ssl_capath, *ssl_cipher;
|
|
char *relay_log_name;
|
|
ulong relay_log_pos;
|
|
} LEX_MASTER_INFO;
|
|
|
|
|
|
enum sub_select_type
|
|
{
|
|
UNSPECIFIED_TYPE,UNION_TYPE, INTERSECT_TYPE,
|
|
EXCEPT_TYPE, GLOBAL_OPTIONS_TYPE, DERIVED_TABLE_TYPE, OLAP_TYPE
|
|
};
|
|
|
|
enum olap_type
|
|
{
|
|
UNSPECIFIED_OLAP_TYPE, CUBE_TYPE, ROLLUP_TYPE
|
|
};
|
|
|
|
enum tablespace_op_type
|
|
{
|
|
NO_TABLESPACE_OP, DISCARD_TABLESPACE, IMPORT_TABLESPACE
|
|
};
|
|
|
|
/*
|
|
The state of the lex parsing for selects
|
|
|
|
All select describing structures linked with following pointers:
|
|
- list of neighbors (next/prev) (prev of first element point to slave
|
|
pointer of upper structure)
|
|
- one level units for unit (union) structure
|
|
- member of one union(unit) for ordinary select_lex
|
|
- pointer to master
|
|
- outer select_lex for unit (union)
|
|
- unit structure for ordinary select_lex
|
|
- pointer to slave
|
|
- first list element of select_lex belonged to this unit for unit
|
|
- first unit in list of units that belong to this select_lex (as
|
|
subselects or derived tables) for ordinary select_lex
|
|
- list of all select_lex (for group operation like correcting list of opened
|
|
tables)
|
|
- if unit contain several selects (union) then it have special
|
|
select_lex called fake_select_lex. It used for storing global parameters
|
|
and executing union. subqueries of global ORDER BY clause will be
|
|
attached to this fake_select_lex, which will allow them correctly
|
|
resolve fields of 'upper' union and other more outer selects.
|
|
|
|
for example for following query:
|
|
|
|
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:
|
|
|
|
|
|
main unit
|
|
fake0
|
|
select1 select2 select3
|
|
|^^ |^
|
|
s||| ||master
|
|
l||| |+---------------------------------+
|
|
a||| +---------------------------------+|
|
|
v|||master slave ||
|
|
e||+-------------------------+ ||
|
|
V| neighbor | V|
|
|
unit1.1<+==================>unit1.2 unit2.1
|
|
fake1.1 fake2.1
|
|
select1.1.1 select 1.1.2 select1.2.1 select2.1.1 select2.1.2
|
|
|^
|
|
||
|
|
V|
|
|
unit2.1.1.1
|
|
select2.1.1.1.1
|
|
|
|
|
|
relation in main unit will be following:
|
|
|
|
main unit
|
|
|^^^^|fake_select_lex
|
|
|||||+--------------------------------------------+
|
|
||||+--------------------------------------------+|
|
|
|||+------------------------------+ ||
|
|
||+--------------+ | ||
|
|
slave||master | | ||
|
|
V| neighbor | neighbor | master|V
|
|
select1<========>select2<========>select3 fake0
|
|
|
|
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)
|
|
*/
|
|
struct st_lex;
|
|
class st_select_lex;
|
|
class st_select_lex_unit;
|
|
class st_select_lex_node {
|
|
protected:
|
|
st_select_lex_node *next, **prev, /* neighbor list */
|
|
*master, *slave, /* vertical links */
|
|
*link_next, **link_prev; /* list of whole SELECT_LEX */
|
|
public:
|
|
enum enum_parsing_place
|
|
{
|
|
NO_MATTER,
|
|
IN_HAVING,
|
|
SELECT_LIST
|
|
};
|
|
|
|
ulong options;
|
|
enum sub_select_type linkage;
|
|
bool dependent; /* dependent from outer select subselect */
|
|
bool uncacheable; /* result of this query can't be cached */
|
|
bool no_table_names_allowed; /* used for global order by */
|
|
bool no_error; /* suppress error message (convert it to warnings) */
|
|
|
|
static void *operator new(size_t size)
|
|
{
|
|
return (void*) sql_alloc((uint) size);
|
|
}
|
|
static void *operator new(size_t size, MEM_ROOT *mem_root)
|
|
{ return (void*) alloc_root(mem_root, (uint) size); }
|
|
static void operator delete(void *ptr,size_t size) {}
|
|
st_select_lex_node(): linkage(UNSPECIFIED_TYPE) {}
|
|
virtual ~st_select_lex_node() {}
|
|
inline st_select_lex_node* get_master() { return master; }
|
|
virtual void init_query();
|
|
virtual void init_select();
|
|
void include_down(st_select_lex_node *upper);
|
|
void include_neighbour(st_select_lex_node *before);
|
|
void include_standalone(st_select_lex_node *sel, st_select_lex_node **ref);
|
|
void include_global(st_select_lex_node **plink);
|
|
void exclude();
|
|
|
|
virtual st_select_lex_unit* master_unit()= 0;
|
|
virtual st_select_lex* outer_select()= 0;
|
|
virtual st_select_lex* return_after_parsing()= 0;
|
|
|
|
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();
|
|
virtual List<String>* get_use_index();
|
|
virtual List<String>* get_ignore_index();
|
|
virtual ulong get_table_join_options();
|
|
virtual TABLE_LIST *add_table_to_list(THD *thd, Table_ident *table,
|
|
LEX_STRING *alias,
|
|
ulong table_options,
|
|
thr_lock_type flags= TL_UNLOCK,
|
|
List<String> *use_index= 0,
|
|
List<String> *ignore_index= 0,
|
|
LEX_STRING *option= 0);
|
|
virtual void set_lock_for_tables(thr_lock_type lock_type) {}
|
|
|
|
friend class st_select_lex_unit;
|
|
friend bool mysql_new_select(struct st_lex *lex, bool move_down);
|
|
private:
|
|
void fast_exclude();
|
|
};
|
|
typedef class st_select_lex_node SELECT_LEX_NODE;
|
|
|
|
/*
|
|
SELECT_LEX_UNIT - unit of selects (UNION, INTERSECT, ...) group
|
|
SELECT_LEXs
|
|
*/
|
|
struct st_lex;
|
|
class THD;
|
|
class select_result;
|
|
class JOIN;
|
|
class select_union;
|
|
class st_select_lex_unit: public st_select_lex_node {
|
|
protected:
|
|
List<Item> item_list;
|
|
TABLE_LIST result_table_list;
|
|
select_union *union_result;
|
|
TABLE *table; /* temporary table using for appending UNION results */
|
|
|
|
select_result *result;
|
|
int res;
|
|
ulong found_rows_for_union;
|
|
bool prepared, // prepare phase already performed for UNION (unit)
|
|
optimized, // optimize phase already performed for UNION (unit)
|
|
executed, // already executed
|
|
t_and_f; // used for transferring tables_and_fields_initied UNIT:: methods
|
|
public:
|
|
/*
|
|
Pointer to 'last' select or pointer to unit where stored
|
|
global parameters for union
|
|
*/
|
|
st_select_lex *global_parameters;
|
|
//node on wich we should return current_select pointer after parsing subquery
|
|
st_select_lex *return_to;
|
|
/* LIMIT clause runtime counters */
|
|
ha_rows select_limit_cnt, offset_limit_cnt;
|
|
/* not NULL if unit used in subselect, point to subselect item */
|
|
Item_subselect *item;
|
|
/* thread handler */
|
|
THD *thd;
|
|
/* fake SELECT_LEX for union processing */
|
|
st_select_lex *fake_select_lex;
|
|
|
|
uint union_option;
|
|
|
|
void init_query();
|
|
bool create_total_list(THD *thd, st_lex *lex, TABLE_LIST **result,
|
|
bool check_current_derived);
|
|
st_select_lex_unit* master_unit();
|
|
st_select_lex* outer_select();
|
|
st_select_lex* first_select() { return (st_select_lex*) slave; }
|
|
st_select_lex* first_select_in_union()
|
|
{
|
|
return (st_select_lex*) slave;
|
|
}
|
|
st_select_lex_unit* next_unit() { return (st_select_lex_unit*) next; }
|
|
st_select_lex* return_after_parsing() { return return_to; }
|
|
void exclude_level();
|
|
void exclude_tree();
|
|
|
|
/* UNION methods */
|
|
int prepare(THD *thd, select_result *result, bool tables_and_fields_initied);
|
|
int exec();
|
|
int cleanup();
|
|
|
|
void print(String *str);
|
|
|
|
friend void mysql_init_query(THD *thd);
|
|
friend int subselect_union_engine::exec();
|
|
private:
|
|
bool create_total_list_n_last_return(THD *thd, st_lex *lex,
|
|
TABLE_LIST ***result,
|
|
bool check_current_derived);
|
|
};
|
|
typedef class st_select_lex_unit SELECT_LEX_UNIT;
|
|
|
|
/*
|
|
SELECT_LEX - store information of parsed SELECT_LEX statment
|
|
*/
|
|
class st_select_lex: public st_select_lex_node
|
|
{
|
|
public:
|
|
char *db, *db1, *table1, *db2, *table2; /* For outer join using .. */
|
|
Item *where, *having; /* WHERE & HAVING clauses */
|
|
Item *prep_where; /* saved WHERE clause for prepared statement processing */
|
|
enum olap_type olap;
|
|
SQL_LIST table_list, group_list; /* FROM & GROUP BY clauses */
|
|
List<Item> item_list; /* list of fields & expressions */
|
|
List<String> interval_list, use_index, *use_index_ptr,
|
|
ignore_index, *ignore_index_ptr;
|
|
/*
|
|
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;
|
|
JOIN *join; /* after JOIN::prepare it is pointer to corresponding JOIN */
|
|
const char *type; /* type of select for EXPLAIN */
|
|
|
|
SQL_LIST order_list; /* ORDER clause */
|
|
List<List_item> expr_list;
|
|
List<List_item> when_list; /* WHEN clause (expression) */
|
|
ha_rows select_limit, offset_limit; /* LIMIT clause parameters */
|
|
// Arrays of pointers to top elements of all_fields list
|
|
Item **ref_pointer_array;
|
|
|
|
/*
|
|
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;
|
|
uint cond_count; /* number of arguments of and/or/xor in where/having */
|
|
enum_parsing_place parsing_place; /* where we are parsing expression */
|
|
bool with_sum_func; /* sum function indicator */
|
|
|
|
ulong table_join_options;
|
|
uint in_sum_expr;
|
|
uint select_number; /* number of select (used for EXPLAIN) */
|
|
uint with_wild; /* item list contain '*' */
|
|
bool braces; /* SELECT ... UNION (SELECT ... ) <- this braces */
|
|
/* TRUE when having fix field called in processing of this SELECT */
|
|
bool having_fix_field;
|
|
|
|
/*
|
|
SELECT for SELECT command st_select_lex. Used to privent scaning
|
|
item_list of non-SELECT st_select_lex (no sense find to finding
|
|
reference in it (all should be in tables, it is dangerouse due
|
|
to order of fix_fields calling for non-SELECTs commands (item list
|
|
can be not fix_fieldsd)). This value will be assigned for
|
|
primary select (sql_yac.yy) and for any subquery and
|
|
UNION SELECT (sql_parse.cc mysql_new_select())
|
|
|
|
|
|
INSERT for primary st_select_lex structure of simple INSERT/REPLACE
|
|
(used for name resolution, see Item_fiels & Item_ref fix_fields,
|
|
FALSE for INSERT/REPLACE ... SELECT, because it's
|
|
st_select_lex->table_list will be preprocessed (first table removed)
|
|
before passing to handle_select)
|
|
|
|
NOMATTER for other
|
|
*/
|
|
enum {NOMATTER_MODE, SELECT_MODE, INSERT_MODE} resolve_mode;
|
|
|
|
|
|
void init_query();
|
|
void init_select();
|
|
st_select_lex_unit* master_unit();
|
|
st_select_lex_unit* first_inner_unit()
|
|
{
|
|
return (st_select_lex_unit*) slave;
|
|
}
|
|
st_select_lex* outer_select();
|
|
st_select_lex* next_select() { return (st_select_lex*) next; }
|
|
st_select_lex* next_select_in_list()
|
|
{
|
|
return (st_select_lex*) link_next;
|
|
}
|
|
st_select_lex_node** next_select_in_list_addr()
|
|
{
|
|
return &link_next;
|
|
}
|
|
st_select_lex* return_after_parsing()
|
|
{
|
|
return master_unit()->return_after_parsing();
|
|
}
|
|
|
|
void mark_as_dependent(st_select_lex *last);
|
|
|
|
bool set_braces(bool value);
|
|
bool inc_in_sum_expr();
|
|
uint get_in_sum_expr();
|
|
|
|
bool add_item_to_list(THD *thd, Item *item);
|
|
bool add_group_to_list(THD *thd, Item *item, bool asc);
|
|
bool add_ftfunc_to_list(Item_func_match *func);
|
|
bool add_order_to_list(THD *thd, Item *item, bool asc);
|
|
TABLE_LIST* add_table_to_list(THD *thd, Table_ident *table,
|
|
LEX_STRING *alias,
|
|
ulong table_options,
|
|
thr_lock_type flags= TL_UNLOCK,
|
|
List<String> *use_index= 0,
|
|
List<String> *ignore_index= 0,
|
|
LEX_STRING *option= 0);
|
|
TABLE_LIST* get_table_list();
|
|
List<Item>* get_item_list();
|
|
List<String>* get_use_index();
|
|
List<String>* get_ignore_index();
|
|
ulong get_table_join_options();
|
|
void set_lock_for_tables(thr_lock_type lock_type);
|
|
inline void init_order()
|
|
{
|
|
order_list.elements= 0;
|
|
order_list.first= 0;
|
|
order_list.next= (byte**) &order_list.first;
|
|
}
|
|
|
|
bool test_limit();
|
|
|
|
friend void mysql_init_query(THD *thd);
|
|
st_select_lex() {}
|
|
void make_empty_select()
|
|
{
|
|
init_query();
|
|
init_select();
|
|
}
|
|
bool setup_ref_array(THD *thd, uint order_group_num);
|
|
void print(THD *thd, String *str);
|
|
static void print_order(String *str, ORDER *order);
|
|
void print_limit(THD *thd, String *str);
|
|
};
|
|
typedef class st_select_lex SELECT_LEX;
|
|
|
|
|
|
/* The state of the lex parsing. This is saved in the THD struct */
|
|
|
|
typedef struct st_lex
|
|
{
|
|
uint yylineno,yytoklen; /* Simulate lex */
|
|
LEX_YYSTYPE yylval;
|
|
SELECT_LEX_UNIT unit; /* most upper unit */
|
|
SELECT_LEX select_lex; /* first SELECT_LEX */
|
|
/* current SELECT_LEX in parsing */
|
|
SELECT_LEX *current_select;
|
|
/* list of all SELECT_LEX */
|
|
SELECT_LEX *all_selects_list;
|
|
uchar *ptr,*tok_start,*tok_end,*end_of_query;
|
|
char *length,*dec,*change,*name;
|
|
char *help_arg;
|
|
char *backup_dir; /* For RESTORE/BACKUP */
|
|
char* to_log; /* For PURGE MASTER LOGS TO */
|
|
time_t purge_time; /* For PURGE MASTER LOGS BEFORE */
|
|
char* x509_subject,*x509_issuer,*ssl_cipher;
|
|
char* found_colon; /* For multi queries - next query */
|
|
String *wild;
|
|
sql_exchange *exchange;
|
|
select_result *result;
|
|
Item *default_value;
|
|
LEX_STRING *comment, name_and_length;
|
|
LEX_USER *grant_user;
|
|
gptr yacc_yyss,yacc_yyvs;
|
|
THD *thd;
|
|
CHARSET_INFO *charset;
|
|
SQL_LIST *gorder_list;
|
|
|
|
List<key_part_spec> col_list;
|
|
List<key_part_spec> ref_list;
|
|
List<Alter_drop> drop_list;
|
|
List<Alter_column> alter_list;
|
|
List<String> interval_list;
|
|
List<LEX_USER> users_list;
|
|
List<LEX_COLUMN> columns;
|
|
List<Key> key_list;
|
|
List<create_field> create_list;
|
|
List<Item> *insert_list,field_list,value_list;
|
|
List<List_item> many_values;
|
|
List<set_var_base> var_list;
|
|
List<Item> param_list;
|
|
SQL_LIST proc_list, auxilliary_table_list, save_list;
|
|
TYPELIB *interval;
|
|
create_field *last_field;
|
|
char *savepoint_name; // Transaction savepoint id
|
|
udf_func udf;
|
|
HA_CHECK_OPT check_opt; // check/repair options
|
|
HA_CREATE_INFO create_info;
|
|
LEX_MASTER_INFO mi; // used by CHANGE MASTER
|
|
USER_RESOURCES mqh;
|
|
ulong thread_id,type;
|
|
enum_sql_command sql_command;
|
|
thr_lock_type lock_option;
|
|
enum SSL_type ssl_type; /* defined in violite.h */
|
|
enum my_lex_states next_state;
|
|
enum enum_duplicates duplicates;
|
|
enum enum_tx_isolation tx_isolation;
|
|
enum enum_ha_read_modes ha_read_mode;
|
|
enum ha_rkey_function ha_rkey_mode;
|
|
enum enum_enable_or_disable alter_keys_onoff;
|
|
enum enum_var_type option_type;
|
|
enum tablespace_op_type tablespace_op;
|
|
uint uint_geom_type;
|
|
uint grant, grant_tot_col, which_columns;
|
|
uint fk_delete_opt, fk_update_opt, fk_match_option;
|
|
uint param_count;
|
|
uint slave_thd_opt;
|
|
uint8 describe;
|
|
bool drop_primary, drop_if_exists, drop_temporary, local_file;
|
|
bool in_comment, ignore_space, verbose, simple_alter, no_write_to_binlog;
|
|
bool derived_tables;
|
|
bool safe_to_cache_query;
|
|
st_lex() {}
|
|
inline void uncacheable()
|
|
{
|
|
safe_to_cache_query= 0;
|
|
|
|
/*
|
|
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
|
|
*/
|
|
SELECT_LEX *sl;
|
|
SELECT_LEX_UNIT *un;
|
|
for (sl= current_select, un= sl->master_unit();
|
|
un != &unit;
|
|
sl= sl->outer_select(), un= sl->master_unit())
|
|
{
|
|
sl->uncacheable = un->uncacheable= 1;
|
|
}
|
|
}
|
|
} LEX;
|
|
|
|
|
|
void lex_init(void);
|
|
void lex_free(void);
|
|
LEX *lex_start(THD *thd, uchar *buf,uint length);
|
|
void lex_end(LEX *lex);
|
|
|
|
extern pthread_key(LEX*,THR_LEX);
|
|
|
|
extern LEX_STRING tmp_table_alias;
|
|
|
|
#define current_lex (¤t_thd->lex)
|