001package gudusoft.gsqlparser.sqlcmds;
002
003import gudusoft.gsqlparser.*;
004import gudusoft.gsqlparser.stmt.*;
005import gudusoft.gsqlparser.stmt.mysql.*;
006
007/**
008 * MySQL SQL command resolver.
009 * Handles MySQL-specific statement detection and command resolution.
010 *
011 * @since 3.1.0.9
012 */
013public class TSqlCmdsMysql extends AbstractSqlCmds {
014
015    public TSqlCmdsMysql() {
016        super(EDbVendor.dbvmysql);
017    }
018
019    @Override
020    protected void initializeCommands() {
021        // MySQL commands - sorted alphabetically by first token
022        // Note: Longer patterns should come before shorter ones with same prefix
023
024        addCmd(TBaseType.rrw_alter, "algorithm", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlalterview);
025        addCmd(TBaseType.rrw_alter, "database", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlalterdatabase);
026        addCmd(TBaseType.rrw_alter, "definer", "=", "current_user", "event", " ", " ", ESqlStatementType.sstmysqlalterevent);
027        addCmd(TBaseType.rrw_alter, "definer", "=", "*", "*", "*", "event", ESqlStatementType.sstmysqlalterevent);
028        addCmd(TBaseType.rrw_alter, "definer", "=", "*", "event", " ", " ", ESqlStatementType.sstmysqlalterevent);
029        addCmd(TBaseType.rrw_alter, "event", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlalterevent);
030        addCmd(TBaseType.rrw_alter, "function", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlalterfunction);
031        addCmd(TBaseType.rrw_alter, "procedure", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlalterprocedure);
032        addCmd(TBaseType.rrw_alter, "sql", "security", "definer", "view", " ", " ", ESqlStatementType.sstmysqlalterview);
033        addCmd(TBaseType.rrw_alter, "sql", "security", "invoker", "view", " ", " ", ESqlStatementType.sstmysqlalterview);
034        addCmd(TBaseType.rrw_alter, "table", " ", " ", " ", " ", " ", ESqlStatementType.sstaltertable);
035        addCmd(TBaseType.rrw_alter, "view", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlalterview);
036        addCmd(TBaseType.rrw_analyze, "table", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlanalyzetable);
037        addCmd(TBaseType.rrw_backup, "table", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlbackuptable);
038        addCmd(TBaseType.rrw_begin, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlstarttransaction);
039        addCmd(TBaseType.rrw_cache, "index", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlcacheindex);
040        addCmd(TBaseType.rrw_call, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlcall);
041        addCmd(TBaseType.rrw_case, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlcase);
042        addCmd(TBaseType.rrw_change, "master", "to", " ", " ", " ", " ", ESqlStatementType.sstmysqlchangemasterto);
043        addCmd(TBaseType.rrw_check, "table", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlchecktable);
044        addCmd(TBaseType.rrw_check, "tables", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlchecktable);
045        addCmd(TBaseType.rrw_checksum, "table", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlchecksumtable);
046        addCmd(TBaseType.rrw_close, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlclose);
047        addCmd(TBaseType.rrw_commit, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlcommit);
048        addCmd(TBaseType.rrw_create, "aggregate", "function", " ", " ", " ", " ", ESqlStatementType.sstmysqlcreatefunction);
049        addCmd(TBaseType.rrw_create, "database", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlcreatedatabase);
050        addCmd(TBaseType.rrw_create, "definer", "=", "current_user", "event", " ", " ", ESqlStatementType.sstmysqlcreateevent);
051        addCmd(TBaseType.rrw_create, "definer", "=", "current_user", "function", " ", " ", ESqlStatementType.sstmysqlcreatefunction);
052        addCmd(TBaseType.rrw_create, "definer", "=", "current_user", "procedure", " ", " ", ESqlStatementType.sstmysqlcreateprocedure);
053        addCmd(TBaseType.rrw_create, "definer", "=", "current_user", "trigger", " ", " ", ESqlStatementType.sstcreatetrigger);
054        addCmd(TBaseType.rrw_create, "definer", "=", "*", "*", "*", "event", ESqlStatementType.sstmysqlcreateevent);
055        addCmd(TBaseType.rrw_create, "definer", "=", "*", "*", "*", "function", ESqlStatementType.sstmysqlcreatefunction);
056        addCmd(TBaseType.rrw_create, "definer", "=", "*", "*", "*", "procedure", ESqlStatementType.sstmysqlcreateprocedure);
057        addCmd(TBaseType.rrw_create, "definer", "=", "*", "*", "*", "trigger", ESqlStatementType.sstcreatetrigger);
058        addCmd(TBaseType.rrw_create, "definer", "=", "*", "event", " ", " ", ESqlStatementType.sstmysqlcreateevent);
059        addCmd(TBaseType.rrw_create, "definer", "=", "*", "procedure", " ", " ", ESqlStatementType.sstmysqlcreateprocedure);
060        addCmd(TBaseType.rrw_create, "definer", "=", "*", "function", " ", " ", ESqlStatementType.sstmysqlcreatefunction);
061        addCmd(TBaseType.rrw_create, "definer", "=", "*", "trigger", " ", " ", ESqlStatementType.sstcreatetrigger);
062        addCmd(TBaseType.rrw_create, "event", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlcreateevent);
063        addCmd(TBaseType.rrw_create, "fulltext", "index", " ", " ", " ", " ", ESqlStatementType.sstmysqlcreateindex);
064        addCmd(TBaseType.rrw_create, "function", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlcreatefunction);
065        addCmd(TBaseType.rrw_create, "index", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlcreateindex);
066        addCmd(TBaseType.rrw_create, "or", "replace", "sequence", " ", " ", " ", ESqlStatementType.sstcreatesequence);
067        addCmd(TBaseType.rrw_create, "or", "replace", "table", " ", " ", " ", ESqlStatementType.sstcreatetable);
068        addCmd(TBaseType.rrw_create, "or", "replace", "*", "*", "*", "view", ESqlStatementType.sstcreateview);
069        addCmd(TBaseType.rrw_create, "or", "replace", "view", " ", " ", " ", ESqlStatementType.sstcreateview);
070        addCmd(TBaseType.rrw_create, "procedure", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlcreateprocedure);
071        addCmd(TBaseType.rrw_create, "spatial", "index", " ", " ", " ", " ", ESqlStatementType.sstmysqlcreateindex);
072        addCmd(TBaseType.rrw_create, "spatial", "reference", " ", " ", " ", " ", ESqlStatementType.sstmysqlcreatespatialrefsys);
073        addCmd(TBaseType.rrw_create, "or", "replace", "spatial", "reference", " ", " ", ESqlStatementType.sstmysqlcreatespatialrefsys);
074        addCmd(TBaseType.rrw_create, "schema", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlcreatedatabase);
075        addCmd(TBaseType.rrw_create, "sequence", " ", " ", " ", " ", " ", ESqlStatementType.sstcreatesequence);
076        addCmd(TBaseType.rrw_create, "temporary", "table", " ", " ", " ", " ", ESqlStatementType.sstcreatetable);
077        addCmd(TBaseType.rrw_create, "temp", "table", " ", " ", " ", " ", ESqlStatementType.sstcreatetable);
078        addCmd(TBaseType.rrw_create, "table", " ", " ", " ", " ", " ", ESqlStatementType.sstcreatetable);
079        addCmd(TBaseType.rrw_create, "trigger", " ", " ", " ", " ", " ", ESqlStatementType.sstcreatetrigger);
080        addCmd(TBaseType.rrw_create, "unique", "index", " ", " ", " ", " ", ESqlStatementType.sstmysqlcreateindex);
081        addCmd(TBaseType.rrw_create, "user", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlcreateuser);
082        addCmd(TBaseType.rrw_create, "*", "*", "*", "*", "*", "view", ESqlStatementType.sstcreateview);
083        addCmd(TBaseType.rrw_create, "view", " ", " ", " ", " ", " ", ESqlStatementType.sstcreateview);
084        addCmd(TBaseType.rrw_deallocate, "prepare", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldeallocateprepare);
085        addCmd(TBaseType.rrw_declare, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldeclare);
086        addCmd(TBaseType.rrw_delete, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstdelete);
087        addCmd(TBaseType.rrw_mysql_delimiter, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldelimiter);
088        addCmd(TBaseType.rrw_mysql_desc, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstdescribe);
089        addCmd(TBaseType.rrw_describe, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstdescribe);
090        addCmd(TBaseType.rrw_do, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldo);
091        addCmd(TBaseType.rrw_drop, "spatial", "reference", " ", " ", " ", " ", ESqlStatementType.sstmysqldropspatialrefsys);
092        addCmd(TBaseType.rrw_drop, "database", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldropdatabase);
093        addCmd(TBaseType.rrw_drop, "event", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldropevent);
094        addCmd(TBaseType.rrw_drop, "function", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldropfunction);
095        addCmd(TBaseType.rrw_drop, "index", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldropindex);
096        addCmd(TBaseType.rrw_drop, "prepare", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldropprepare);
097        addCmd(TBaseType.rrw_drop, "procedure", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldropprocedure);
098        addCmd(TBaseType.rrw_drop, "schema", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldropdatabase);
099        addCmd(TBaseType.rrw_drop, "sequence", " ", " ", " ", " ", " ", ESqlStatementType.sstdropsequence);
100        addCmd(TBaseType.rrw_drop, "temporary", "table", " ", " ", " ", " ", ESqlStatementType.sstmysqldroptable);
101        addCmd(TBaseType.rrw_drop, "tables", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldroptable);
102        addCmd(TBaseType.rrw_drop, "table", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldroptable);
103        addCmd(TBaseType.rrw_drop, "trigger", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldroptrigger);
104        addCmd(TBaseType.rrw_drop, "user", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldropuser);
105        addCmd(TBaseType.rrw_drop, "view", " ", " ", " ", " ", " ", ESqlStatementType.sstdropview);
106        addCmd(TBaseType.rrw_execute, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlexecute);
107        addCmd(TBaseType.rrw_explain, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstExplain);
108        addCmd(TBaseType.rrw_fetch, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlfetch);
109        addCmd(TBaseType.rrw_flush, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlflush);
110        addCmd(TBaseType.rrw_grant, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlgrant);
111        addCmd(TBaseType.rrw_handler, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlhandler);
112        addCmd(TBaseType.rrw_if, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlifstmt);
113        addCmd(TBaseType.rrw_insert, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstinsert);
114        addCmd(TBaseType.rrw_iterate, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqliterate);
115        addCmd(TBaseType.rrw_kill, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlkill);
116        addCmd(TBaseType.rrw_leave, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlleave);
117        addCmd(TBaseType.rrw_load, "data", "from", "master", " ", " ", " ", ESqlStatementType.sstmysqlloaddatafrommaster);
118        addCmd(TBaseType.rrw_load, "data", "local", "infile", " ", " ", " ", ESqlStatementType.sstmysqlloaddatainfile);
119        addCmd(TBaseType.rrw_load, "data", "infile", " ", " ", " ", " ", ESqlStatementType.sstmysqlloaddatainfile);
120        addCmd(TBaseType.rrw_load, "index", "into", "cache", " ", " ", " ", ESqlStatementType.sstmysqlloadindexintocache);
121        addCmd(TBaseType.rrw_load, "table", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlloadtable);
122        addCmd(TBaseType.rrw_load, "xml", "local", "infile", " ", " ", " ", ESqlStatementType.sstmysqlloaddatainfile);
123        addCmd(TBaseType.rrw_load, "xml", "infile", " ", " ", " ", " ", ESqlStatementType.sstmysqlloaddatainfile);
124        addCmd(TBaseType.rrw_lock, "tables", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqllocktable);
125        addCmd(TBaseType.rrw_lock, "table", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqllocktable);
126        addCmd(TBaseType.rrw_loop, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlloop);
127        addCmd(TBaseType.rrw_open, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlopen);
128        addCmd(TBaseType.rrw_optimize, "no_write_to_binlog", "table", " ", " ", " ", " ", ESqlStatementType.sstmysqloptimizetable);
129        addCmd(TBaseType.rrw_optimize, "local", "table", " ", " ", " ", " ", ESqlStatementType.sstmysqloptimizetable);
130        addCmd(TBaseType.rrw_optimize, "table", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqloptimizetable);
131        addCmd(TBaseType.rrw_prepare, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlprepare);
132        addCmd(TBaseType.rrw_purge, "binary", "logs", " ", " ", " ", " ", ESqlStatementType.sstmysqlpurgelogs);
133        addCmd(TBaseType.rrw_purge, "master", "logs", " ", " ", " ", " ", ESqlStatementType.sstmysqlpurgelogs);
134        addCmd(TBaseType.rrw_purge, "logs", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlpurgelogs);
135        addCmd(TBaseType.rrw_release, "savepoint", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlreleasesavepoint);
136        addCmd(TBaseType.rrw_rename, "table", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlrenametable);
137        addCmd(TBaseType.rrw_rename, "user", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlrenameuser);
138        addCmd(TBaseType.rrw_repair, "no_write_to_binlog", "table", " ", " ", " ", " ", ESqlStatementType.sstmysqlrepairtable);
139        addCmd(TBaseType.rrw_repair, "local", "table", " ", " ", " ", " ", ESqlStatementType.sstmysqlrepairtable);
140        addCmd(TBaseType.rrw_repair, "table", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlrepairtable);
141        addCmd(TBaseType.rrw_repeat, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlrepeat);
142        addCmd(TBaseType.rrw_replace, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlreplace);
143        addCmd(TBaseType.rrw_reset, "master", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlresetmaster);
144        addCmd(TBaseType.rrw_reset, "slave", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlresetslave);
145        addCmd(TBaseType.rrw_reset, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlreset);
146        addCmd(TBaseType.rrw_restore, "table", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlrestoretable);
147        addCmd(TBaseType.rrw_revoke, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlrevoke);
148        addCmd(TBaseType.rrw_rollback, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlrollback);
149        addCmd(TBaseType.rrw_savepoint, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlsavepoint);
150        addCmd(TBaseType.rrw_select, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstselect);
151        addCmd(TBaseType.rrw_table, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstselect);  // MySQL TABLE stmt = SELECT * FROM table
152        addCmd(TBaseType.rrw_set, "global", "sql_slave_skip_counter", " ", " ", " ", " ", ESqlStatementType.sstmysqlsetglobalsql_slave_skip_counter);
153        addCmd(TBaseType.rrw_set, "global", "transaction", " ", " ", " ", " ", ESqlStatementType.sstmysqlsettransaction);
154        addCmd(TBaseType.rrw_set, "session", "transaction", " ", " ", " ", " ", ESqlStatementType.sstmysqlsettransaction);
155        addCmd(TBaseType.rrw_set, "autocommit", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlsetautocommit);
156        addCmd(TBaseType.rrw_set, "delimiter", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqldelimiter);
157        addCmd(TBaseType.rrw_set, "PASSWORD", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlset);
158        addCmd(TBaseType.rrw_set, "sql_log_bin", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlsetsql_log_bin);
159        addCmd(TBaseType.rrw_set, "transaction", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlsettransaction);
160        addCmd(TBaseType.rrw_set, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlset);
161        addCmd(TBaseType.rrw_show, "bdb", "logs", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowlogs);
162        addCmd(TBaseType.rrw_show, "binlog", "events", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowbinlogevents);
163        addCmd(TBaseType.rrw_show, "character", "set", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowcharacterset);
164        addCmd(TBaseType.rrw_show, "charset", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowcharacterset);
165        addCmd(TBaseType.rrw_show, "collation", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowcollation);
166        addCmd(TBaseType.rrw_show, "columns", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowcolumns);
167        addCmd(TBaseType.rrw_show, "count", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowwarnings);
168        addCmd(TBaseType.rrw_show, "create", "schema", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowcreateschema);
169        addCmd(TBaseType.rrw_show, "create", "database", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowcreatedatabase);
170        addCmd(TBaseType.rrw_show, "create", "function", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowcreatefunction);
171        addCmd(TBaseType.rrw_show, "create", "procedure", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowcreateprocedure);
172        addCmd(TBaseType.rrw_show, "create", "table", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowcreatetable);
173        addCmd(TBaseType.rrw_show, "create", "view", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowcreateview);
174        addCmd(TBaseType.rrw_show, "create", "trigger", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowcreatetrigger);
175        addCmd(TBaseType.rrw_show, "create", "event", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowcreateevent);
176        addCmd(TBaseType.rrw_show, "create", "user", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowcreateuser);
177        addCmd(TBaseType.rrw_show, "databases", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowdatabases);
178        addCmd(TBaseType.rrw_show, "engine", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowengine);
179        addCmd(TBaseType.rrw_show, "engines", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowengines);
180        addCmd(TBaseType.rrw_show, "errors", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowerrors);
181        addCmd(TBaseType.rrw_show, "extend", "indexes", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowindex);
182        addCmd(TBaseType.rrw_show, "extend", "index", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowindex);
183        addCmd(TBaseType.rrw_show, "extend", "keys", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowindex);
184        addCmd(TBaseType.rrw_show, "fields", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowfields);
185        addCmd(TBaseType.rrw_show, "full", "columns", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowcolumns);
186        addCmd(TBaseType.rrw_show, "full", "fields", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowfields);
187        addCmd(TBaseType.rrw_show, "full", "processlist", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowprocesslist);
188        addCmd(TBaseType.rrw_show, "full", "tables", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowtables);
189        addCmd(TBaseType.rrw_show, "function", "status", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowfunctionstatus);
190        addCmd(TBaseType.rrw_show, "global", "status", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowstatus);
191        addCmd(TBaseType.rrw_show, "global", "variables", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowvariables);
192        addCmd(TBaseType.rrw_show, "grants", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowgrants);
193        addCmd(TBaseType.rrw_show, "indexes", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowindex);
194        addCmd(TBaseType.rrw_show, "index", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowindex);
195        addCmd(TBaseType.rrw_show, "innodb", "status", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowinnodbstatus);
196        addCmd(TBaseType.rrw_show, "keys", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowindex);
197        addCmd(TBaseType.rrw_show, "logs", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowlogs);
198        addCmd(TBaseType.rrw_show, "master", "logs", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowmasterlogs);
199        addCmd(TBaseType.rrw_show, "master", "status", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowmasterstatus);
200        addCmd(TBaseType.rrw_show, "open", "tables", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowtables);
201        addCmd(TBaseType.rrw_show, "plugins", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowplugins);
202        addCmd(TBaseType.rrw_show, "privileges", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowprivileges);
203        addCmd(TBaseType.rrw_show, "procedure", "status", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowfunctionstatus);
204        addCmd(TBaseType.rrw_show, "processlist", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowprocesslist);
205        addCmd(TBaseType.rrw_show, "profile", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowprofile);
206        addCmd(TBaseType.rrw_show, "profiles", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowprofiles);
207        addCmd(TBaseType.rrw_show, "replica", "status", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowreplicaStatus);
208        addCmd(TBaseType.rrw_show, "session", "status", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowstatus);
209        addCmd(TBaseType.rrw_show, "session", "variables", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowvariables);
210        addCmd(TBaseType.rrw_show, "slave", "hosts", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowslavehosts);
211        addCmd(TBaseType.rrw_show, "slave", "status", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowslavestatus);
212        addCmd(TBaseType.rrw_show, "status", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowstatus);
213        addCmd(TBaseType.rrw_show, "storage", "engines", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowengines);
214        addCmd(TBaseType.rrw_show, "table", "status", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowtablestatus);
215        addCmd(TBaseType.rrw_show, "tables", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowtables);
216        addCmd(TBaseType.rrw_show, "triggers", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowtriggers);
217        addCmd(TBaseType.rrw_show, "variables", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowvariables);
218        addCmd(TBaseType.rrw_show, "warnings", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlshowwarnings);
219        addCmd(TBaseType.rrw_signal, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlsignal);
220        addCmd(TBaseType.rrw_start, "slave", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlstartslave);
221        addCmd(TBaseType.rrw_start, "transaction", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlstarttransaction);
222        addCmd(TBaseType.rrw_stop, "slave", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlstopslave);
223        addCmd(TBaseType.rrw_truncate, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqltruncate);
224        addCmd(TBaseType.rrw_values, "row", " ", " ", " ", " ", " ", ESqlStatementType.sstselect);  // MySQL VALUES ROW() stmt
225        addCmd(TBaseType.rrw_unlock, "tables", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlunlocktable);
226        addCmd(TBaseType.rrw_update, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstupdate);
227        addCmd(TBaseType.rrw_use, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqluse);
228        addCmd(TBaseType.rrw_while, " ", " ", " ", " ", " ", " ", ESqlStatementType.sstmysqlwhile);
229    }
230
231    @Override
232    protected String getToken1Str(int token1) {
233        // Handle MySQL vendor-specific reserved words
234        switch (token1) {
235            case TBaseType.rrw_mysql_delimiter:
236                return "delimiter";
237            case TBaseType.rrw_mysql_desc:
238                return "desc";
239            default:
240                return null;
241        }
242    }
243
244    @Override
245    public TCustomSqlStatement issql(TSourceToken pcst, EFindSqlStateType pstate, TCustomSqlStatement psqlstatement) {
246        TCustomSqlStatement ret = null;
247        int k;
248        boolean lcisnewsql;
249        TSourceToken lcpprevsolidtoken, lcnextsolidtoken;
250
251        gnewsqlstatementtype = ESqlStatementType.sstinvalid;
252
253        if ((pcst.tokencode == TBaseType.cmtdoublehyphen)
254                || (pcst.tokencode == TBaseType.cmtslashstar)
255                || (pcst.tokencode == TBaseType.lexspace)
256                || (pcst.tokencode == TBaseType.lexnewline)
257                || (pcst.tokentype == ETokenType.ttsemicolon)) {
258            return ret;
259        }
260
261        int lcpos = pcst.posinlist;
262        TSourceTokenList lcsourcetokenlist = pcst.container;
263        TCustomSqlStatement lccurrentsqlstatement = psqlstatement;
264
265        // subquery after semicolon || at first line
266        if ((pstate == EFindSqlStateType.stnormal) && (pcst.tokentype == ETokenType.ttleftparenthesis)) // (
267        {
268            k = lcsourcetokenlist.solidtokenafterpos(lcpos, TBaseType.rrw_select, 1, "(");
269            if (k > 0) {
270                ret = new TSelectSqlStatement(vendor);
271            } else {
272                // Also recognize (TABLE ...) and (VALUES ...) as parenthesized query expressions
273                k = lcsourcetokenlist.solidtokenafterpos(lcpos, TBaseType.rrw_table, 1, "(");
274                if (k > 0) {
275                    ret = new TSelectSqlStatement(vendor);
276                } else {
277                    k = lcsourcetokenlist.solidtokenafterpos(lcpos, TBaseType.rrw_values, 1, "(");
278                    if (k > 0) {
279                        ret = new TSelectSqlStatement(vendor);
280                    }
281                }
282            }
283
284            return ret;
285        }
286
287        // cte
288        if ((pstate == EFindSqlStateType.stnormal) && (pcst.tokencode == TBaseType.rrw_with)) {
289            ret = findcte(pcst);
290            if ((ret != null)) return ret;
291        }
292
293        gnewsqlstatementtype = getStatementTypeForToken(pcst);
294
295        TSourceToken lcprevsolidtoken = lcsourcetokenlist.solidtokenbefore(lcpos);
296
297        if ((gnewsqlstatementtype == ESqlStatementType.sstinvalid) && (pcst.tokencode == TBaseType.rrw_create)) {
298            TSourceToken viewToken = pcst.container.searchToken(TBaseType.rrw_view, "", pcst, 15);
299            if (viewToken != null) {
300                gnewsqlstatementtype = ESqlStatementType.sstcreateview;
301            }
302        }
303        switch (gnewsqlstatementtype) {
304            case sstinvalid: {
305                ret = null;
306                break;
307            }
308            case sstselect: {
309                lcisnewsql = true;
310
311                if (pstate != EFindSqlStateType.stnormal) {
312                    if (TBaseType.assigned(lcprevsolidtoken)) {
313                        if (lcprevsolidtoken.tokentype == ETokenType.ttleftparenthesis)
314                            lcisnewsql = false; // subquery
315                        else if (lcprevsolidtoken.tokencode == TBaseType.rrw_union)
316                            lcisnewsql = false;
317                        else if (lcprevsolidtoken.tokencode == TBaseType.rrw_intersect)
318                            lcisnewsql = false;
319                        else if (lcprevsolidtoken.tokencode == TBaseType.rrw_minus)
320                            lcisnewsql = false;
321                        else if (lcprevsolidtoken.tokencode == TBaseType.rrw_except)
322                            lcisnewsql = false;
323                        else if (lcprevsolidtoken.tokencode == TBaseType.rrw_return)
324                            lcisnewsql = false;
325                        else if (lcprevsolidtoken.tokencode == TBaseType.rrw_as) {
326                            if (lccurrentsqlstatement.sqlstatementtype == ESqlStatementType.sstcreatetable)
327                                lcisnewsql = false;
328                            if (lccurrentsqlstatement.sqlstatementtype == ESqlStatementType.sstcreateview)
329                                lcisnewsql = false;
330                        }
331
332                        if (lcisnewsql && (lcprevsolidtoken.tokencode == TBaseType.rrw_all)) {
333                            lcpprevsolidtoken = lcsourcetokenlist.solidtokenbefore(lcprevsolidtoken.posinlist);
334                            if (TBaseType.assigned(lcpprevsolidtoken)) {
335                                if (lcpprevsolidtoken.tokencode == TBaseType.rrw_union)
336                                    lcisnewsql = false;
337                            }
338                        }
339
340                    }
341
342
343                    if (TBaseType.assigned(lccurrentsqlstatement)) {
344                        if (lccurrentsqlstatement.sqlstatementtype == ESqlStatementType.sstinsert)
345                            lcisnewsql = false;
346                    }
347
348                }
349
350                if (lcisnewsql)
351                    ret = new TSelectSqlStatement(vendor);
352                break;
353            }
354            case sstinsert:
355            case sstmysqlreplace: {
356                lcisnewsql = true;
357                if (pstate != EFindSqlStateType.stnormal) {
358                    if (TBaseType.assigned(lccurrentsqlstatement)) {
359
360                    }
361                }
362
363                if (lcisnewsql)
364                    ret = new TInsertSqlStatement(vendor);
365                ret.sqlstatementtype = gnewsqlstatementtype;
366                break;
367            }
368            case sstupdate: {
369                lcisnewsql = true;
370                if (pstate != EFindSqlStateType.stnormal) {
371                    lcprevsolidtoken = lcsourcetokenlist.solidtokenbefore(lcpos);
372                    if (TBaseType.assigned(lcprevsolidtoken)) {
373                        if (lcprevsolidtoken.tokencode == TBaseType.rrw_on)
374                            lcisnewsql = false;
375                        else if (lcprevsolidtoken.tokencode == TBaseType.rrw_for)
376                            lcisnewsql = false;
377                    }
378
379                    lcnextsolidtoken = lcsourcetokenlist.nextsolidtoken(lcpos, 1, false);
380                    if (TBaseType.assigned(lcnextsolidtoken)) {
381                        if (lcnextsolidtoken.tokentype == ETokenType.ttleftparenthesis) {
382                            k = lcsourcetokenlist.solidtokenafterpos(lcnextsolidtoken.posinlist, TBaseType.rrw_select, 1, "(");
383                            if (k == 0) lcisnewsql = false;
384                        }
385                    }
386
387
388                    if (TBaseType.assigned(lccurrentsqlstatement)) {
389                    }
390                }
391
392                if (lcisnewsql) {
393                    ret = new TUpdateSqlStatement(vendor);
394                    ret.dummytag = 1; // means set clause in update is not found yet, used to separate set clause from set statement
395                }
396                break;
397            }
398            case sstdelete: {
399                lcisnewsql = true;
400
401                if (pstate != EFindSqlStateType.stnormal) {
402                    lcprevsolidtoken = lcsourcetokenlist.solidtokenbefore(lcpos);
403                    if (TBaseType.assigned(lcprevsolidtoken)) {
404                        if (lcprevsolidtoken.tokencode == TBaseType.rrw_on)
405                            lcisnewsql = false;
406                    }
407
408                    if (TBaseType.assigned(lccurrentsqlstatement)) {
409                    }
410                }
411
412                if (lcisnewsql)
413                    ret = new TDeleteSqlStatement(vendor);
414                break;
415            }
416            case sstmerge: {
417                ret = new TMergeSqlStatement(vendor);
418                ret.sqlstatementtype = gnewsqlstatementtype;
419                break;
420            }
421            case sstcommit: {
422                ret = new TUnknownSqlStatement(vendor);
423                ret.sqlstatementtype = gnewsqlstatementtype;
424                break;
425            }
426            case sstrollback: {
427                ret = new TUnknownSqlStatement(vendor);
428                ret.sqlstatementtype = gnewsqlstatementtype;
429                break;
430            }
431            case sstsavepoint: {
432                ret = new TUnknownSqlStatement(vendor);
433                ret.sqlstatementtype = gnewsqlstatementtype;
434                break;
435            }
436            case sstRevoke: {
437                ret = new TUnknownSqlStatement(vendor);
438                ret.sqlstatementtype = gnewsqlstatementtype;
439                break;
440            }
441            case sstcreatetable: {
442                ret = new TCreateTableSqlStatement(vendor);
443                break;
444            }
445            case sstcreateview: {
446                ret = new TCreateViewSqlStatement(vendor);
447                break;
448            }
449            case sstmysqlcreateindex: {
450                ret = new TCreateIndexSqlStatement(vendor);
451                break;
452            }
453            case sstcreatedatabase: {
454                ret = new TCreateDatabaseSqlStatement(vendor);
455                break;
456            }
457            case sstmysqldroptable:
458            case sstdroptable: {
459                ret = new TDropTableSqlStatement(vendor);
460                break;
461            }
462            case sstdropview: {
463                ret = new TDropViewSqlStatement(vendor);
464                break;
465            }
466            case sstdropindex: {
467                ret = new TDropIndexSqlStatement(vendor);
468                break;
469            }
470            case sstaltertable: {
471                ret = new TAlterTableStatement(vendor);
472                break;
473            }
474            case sstaltersession: {
475                ret = new TAlterSessionStatement(vendor);
476                break;
477            }
478            case sstmysqlset: {
479                ret = new TSetStmt(vendor);
480                break;
481            }
482            case sstmysqlcreateprocedure: {
483                ret = new TCreateProcedureStmt(vendor);
484                break;
485            }
486            case sstmysqlcreatefunction: {
487                ret = new TCreateFunctionStmt(vendor);
488                break;
489            }
490            case sstcreatetrigger: {
491                ret = new TCreateTriggerStmt(vendor);
492                break;
493            }
494            case sstmysqlcreateevent: {
495                ret = new TUnknownSqlStatement(vendor);
496                ret.sqlstatementtype = gnewsqlstatementtype;
497                break;
498            }
499            case sstmysqlalterevent: {
500                ret = new TUnknownSqlStatement(vendor);
501                ret.sqlstatementtype = gnewsqlstatementtype;
502                break;
503            }
504            case sstmysqldropevent: {
505                ret = new TUnknownSqlStatement(vendor);
506                ret.sqlstatementtype = gnewsqlstatementtype;
507                break;
508            }
509            case sstmysqlcall: {
510                ret = new TCallStatement(vendor);
511                break;
512            }
513            case sstmysqltruncate: {
514                ret = new TTruncateStatement(vendor);
515                break;
516            }
517            case sstmysqlprepare: {
518                ret = new TPrepareStmt(vendor);
519                break;
520            }
521            case sstdescribe: {
522                ret = new TDescribeStmt(vendor);
523                break;
524            }
525            case sstExplain: {
526                ret = new TExplainPlan(vendor);
527                break;
528            }
529            case sstmysqldropindex: {
530                ret = new TDropIndexSqlStatement(vendor);
531                break;
532            }
533            case sstmysqldropprocedure: {
534                ret = new TDropProcedureStmt(vendor);
535                break;
536            }
537            case sstmysqlsignal: {
538                ret = new TMySQLSignal(vendor);
539                break;
540            }
541            case sstmysqlstarttransaction: {
542                if (pstate == EFindSqlStateType.stnormal) {
543                    ret = new TUnknownSqlStatement(vendor);
544                    ret.sqlstatementtype = gnewsqlstatementtype;
545                }
546                break;
547            }
548            case sstmysqluse: {
549                ret = new TUseDatabase(vendor);
550                break;
551            }
552            case sstmysqlexecute: {
553                ret = new TExecuteSqlStatement(vendor);
554                ret.sqlstatementtype = gnewsqlstatementtype;
555                break;
556            }
557            case sstmysqlcreatedatabase: {
558                ret = new TCreateDatabaseSqlStatement(vendor);
559                break;
560            }
561            case sstmysqlrenametable: {
562                ret = new TRenameStmt(vendor);
563                break;
564            }
565            case sstmysqlshowindex:
566                ret = new TShowIndexStmt(vendor);
567                break;
568            case sstmysqlloaddatainfile:
569                ret = new TLoadDataStmt(vendor);
570                break;
571            case sstmysqlshowlogs:
572            case sstmysqlshowbinlogevents:
573            case sstmysqlshowcharacterset:
574            case sstmysqlshowcollation:
575            case sstmysqlshowcolumns:
576            case sstmysqlshowwarnings:
577            case sstmysqlshowcreatedatabase:
578            case sstmysqlshowcreatefunction:
579            case sstmysqlshowcreateprocedure:
580            case sstmysqlshowcreatetable:
581            case sstmysqlshowcreateview:
582            case sstmysqlshowdatabases:
583            case sstmysqlshowerrors:
584            case sstmysqlshowfields:
585            case sstmysqlshowprocesslist:
586            case sstmysqlshowtables:
587            case sstmysqlshowfunctionstatus:
588            case sstmysqlshowstatus:
589            case sstmysqlshowvariables:
590            case sstmysqlshowgrants:
591            case sstmysqlshowinnodbstatus:
592            case sstmysqlshowmasterlogs:
593            case sstmysqlshowplugins:
594            case sstmysqlshowprivileges:
595            case sstmysqlshowprofile:
596            case sstmysqlshowprofiles:
597            case sstmysqlshowslavehosts:
598            case sstmysqlshowslavestatus:
599            case sstmysqlshowtablestatus:
600            case sstmysqlshowtriggers:
601            case sstmysqlshowcreateschema:
602            case sstmysqlshowcreatetrigger:
603            case sstmysqlshowcreateevent:
604            case sstmysqlshowcreateuser:
605            case sstmysqlshowengines:
606                ret = new TMySQLShowStmt(vendor);
607                ret.sqlstatementtype = gnewsqlstatementtype;
608                break;
609            case sstmysqlshowengine:
610                ret = new TShowEngineStmt(vendor);
611                break;
612            case sstmysqlshowreplicaStatus:
613                ret = new TShowStmt(vendor);
614                ret.sqlstatementtype = gnewsqlstatementtype;
615                break;
616            case sstmysqlalterfunction:
617                ret = new TAlterFunctionStmt(vendor);
618                break;
619            case sstmysqlalterprocedure:
620                ret = new TAlterProcedureStmt(vendor);
621                break;
622            case sstmysqldropfunction:
623                ret = new TDropFunctionStmt(vendor);
624                break;
625            case sstmysqldroptrigger:
626                ret = new TDropTriggerSqlStatement(vendor);
627                break;
628            case sstmysqloptimizetable:
629                ret = new TMySQLOptimizeTableStmt(vendor);
630                break;
631            case sstmysqlalterview:
632                ret = new TAlterViewStatement(vendor);
633                break;
634            case sstcreatesequence:
635            case sstdropsequence: {
636                ret = new TUnknownSqlStatement(vendor);
637                ret.sqlstatementtype = gnewsqlstatementtype;
638                break;
639            }
640            default: {
641                ret = new TUnknownSqlStatement(vendor);
642                ret.sqlstatementtype = gnewsqlstatementtype;
643                break;
644            }
645        }    // case
646
647        return ret;
648    }
649}