hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Formatted query_classifier

Browse Source 
Query_classifier formatted according to the style guide.
This commit is contained in:
Markus Makela
2015-12-02 09:55:19 +02:00
parent 9da0c206bb
commit 93f10fdb7b
2 changed files with 1431 additions and 1330 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2627
query_classifier/query_classifier.cc
View File

File diff suppressed because it is too large Load Diff

134
query_classifier/query_classifier.h
View File

@ -17,7 +17,7 @@ Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
Copyright MariaDB Corporation Ab Copyright MariaDB Corporation Ab
*/ */
/** getpid */ /** getpid */
#include <my_config.h> #include <my_config.h>
@ -33,90 +33,96 @@ EXTERN_C_BLOCK_BEGIN
* The meaninful difference is where operation is done and whether master data * The meaninful difference is where operation is done and whether master data
* is modified * is modified
*/ */
typedef enum { typedef enum
QUERY_TYPE_UNKNOWN = 0x000000, /*< Initial value, can't be tested bitwisely */ {
QUERY_TYPE_LOCAL_READ = 0x000001, /*< Read non-database data, execute in MaxScale:any */ QUERY_TYPE_UNKNOWN = 0x000000, /*< Initial value, can't be tested bitwisely */
QUERY_TYPE_READ = 0x000002, /*< Read database data:any */ QUERY_TYPE_LOCAL_READ = 0x000001, /*< Read non-database data, execute in MaxScale:any */
QUERY_TYPE_WRITE = 0x000004, /*< Master data will be modified:master */ QUERY_TYPE_READ = 0x000002, /*< Read database data:any */
QUERY_TYPE_MASTER_READ = 0x000008, /*< Read from the master:master */ QUERY_TYPE_WRITE = 0x000004, /*< Master data will be modified:master */
QUERY_TYPE_SESSION_WRITE = 0x000010, /*< Session data will be modified:master or all */ QUERY_TYPE_MASTER_READ = 0x000008, /*< Read from the master:master */
QUERY_TYPE_SESSION_WRITE = 0x000010, /*< Session data will be modified:master or all */
/** Not implemented yet */ /** Not implemented yet */
// QUERY_TYPE_USERVAR_WRITE = 0x000020, /*< Write a user variable:master or all */ // QUERY_TYPE_USERVAR_WRITE = 0x000020, /*< Write a user variable:master or all */
QUERY_TYPE_USERVAR_READ = 0x000040, /*< Read a user variable:master or any */ QUERY_TYPE_USERVAR_READ = 0x000040, /*< Read a user variable:master or any */
QUERY_TYPE_SYSVAR_READ = 0x000080, /*< Read a system variable:master or any */ QUERY_TYPE_SYSVAR_READ = 0x000080, /*< Read a system variable:master or any */
/** Not implemented yet */ /** Not implemented yet */
// QUERY_TYPE_SYSVAR_WRITE = 0x000100, /*< Write a system variable:master or all */ // QUERY_TYPE_SYSVAR_WRITE = 0x000100, /*< Write a system variable:master or all */
QUERY_TYPE_GSYSVAR_READ = 0x000200, /*< Read global system variable:master or any */ QUERY_TYPE_GSYSVAR_READ = 0x000200, /*< Read global system variable:master or any */
QUERY_TYPE_GSYSVAR_WRITE = 0x000400, /*< Write global system variable:master or all */ QUERY_TYPE_GSYSVAR_WRITE = 0x000400, /*< Write global system variable:master or all */
QUERY_TYPE_BEGIN_TRX = 0x000800, /*< BEGIN or START TRANSACTION */ QUERY_TYPE_BEGIN_TRX = 0x000800, /*< BEGIN or START TRANSACTION */
QUERY_TYPE_ENABLE_AUTOCOMMIT = 0x001000, /*< SET autocommit=1 */ QUERY_TYPE_ENABLE_AUTOCOMMIT = 0x001000, /*< SET autocommit=1 */
QUERY_TYPE_DISABLE_AUTOCOMMIT = 0x002000, /*< SET autocommit=0 */ QUERY_TYPE_DISABLE_AUTOCOMMIT = 0x002000, /*< SET autocommit=0 */
QUERY_TYPE_ROLLBACK = 0x004000, /*< ROLLBACK */ QUERY_TYPE_ROLLBACK = 0x004000, /*< ROLLBACK */
QUERY_TYPE_COMMIT = 0x008000, /*< COMMIT */ QUERY_TYPE_COMMIT = 0x008000, /*< COMMIT */
QUERY_TYPE_PREPARE_NAMED_STMT = 0x010000, /*< Prepared stmt with name from user:all */ QUERY_TYPE_PREPARE_NAMED_STMT = 0x010000, /*< Prepared stmt with name from user:all */
QUERY_TYPE_PREPARE_STMT = 0x020000, /*< Prepared stmt with id provided by server:all */ QUERY_TYPE_PREPARE_STMT = 0x020000, /*< Prepared stmt with id provided by server:all */
QUERY_TYPE_EXEC_STMT = 0x040000, /*< Execute prepared statement:master or any */ QUERY_TYPE_EXEC_STMT = 0x040000, /*< Execute prepared statement:master or any */
QUERY_TYPE_CREATE_TMP_TABLE = 0x080000, /*< Create temporary table:master (could be all) */ QUERY_TYPE_CREATE_TMP_TABLE = 0x080000, /*< Create temporary table:master (could be all) */
QUERY_TYPE_READ_TMP_TABLE = 0x100000, /*< Read temporary table:master (could be any) */ QUERY_TYPE_READ_TMP_TABLE = 0x100000, /*< Read temporary table:master (could be any) */
QUERY_TYPE_SHOW_DATABASES = 0x200000, /*< Show list of databases */ QUERY_TYPE_SHOW_DATABASES = 0x200000, /*< Show list of databases */
QUERY_TYPE_SHOW_TABLES = 0x400000 /*< Show list of tables */ QUERY_TYPE_SHOW_TABLES = 0x400000 /*< Show list of tables */
} skygw_query_type_t; } skygw_query_type_t;
typedef enum { typedef enum
QUERY_OP_UNDEFINED = 0, {
QUERY_OP_SELECT = 1, QUERY_OP_UNDEFINED = 0,
QUERY_OP_UPDATE = (1 << 1), QUERY_OP_SELECT = 1,
QUERY_OP_INSERT = (1 << 2), QUERY_OP_UPDATE = (1 << 1),
QUERY_OP_DELETE = (1 << 3), QUERY_OP_INSERT = (1 << 2),
QUERY_OP_INSERT_SELECT = (1 << 4), QUERY_OP_DELETE = (1 << 3),
QUERY_OP_TRUNCATE = (1 << 5), QUERY_OP_INSERT_SELECT = (1 << 4),
QUERY_OP_ALTER_TABLE = (1 << 6), QUERY_OP_TRUNCATE = (1 << 5),
QUERY_OP_CREATE_TABLE = (1 << 7), QUERY_OP_ALTER_TABLE = (1 << 6),
QUERY_OP_CREATE_INDEX = (1 << 8), QUERY_OP_CREATE_TABLE = (1 << 7),
QUERY_OP_DROP_TABLE = (1 << 9), QUERY_OP_CREATE_INDEX = (1 << 8),
QUERY_OP_DROP_INDEX = (1 << 10), QUERY_OP_DROP_TABLE = (1 << 9),
QUERY_OP_CHANGE_DB = (1 << 11), QUERY_OP_DROP_INDEX = (1 << 10),
QUERY_OP_LOAD = (1 << 12) QUERY_OP_CHANGE_DB = (1 << 11),
}skygw_query_op_t; QUERY_OP_LOAD = (1 << 12)
} skygw_query_op_t;
typedef struct parsing_info_st { typedef struct parsing_info_st
{
#if defined(SS_DEBUG) #if defined(SS_DEBUG)
skygw_chk_t pi_chk_top; skygw_chk_t pi_chk_top;
#endif #endif
void* pi_handle; /*< parsing info object pointer */ void* pi_handle; /*< parsing info object pointer */
char* pi_query_plain_str; /*< query as plain string */ char* pi_query_plain_str; /*< query as plain string */
void (*pi_done_fp)(void *); /*< clean-up function for parsing info */ void (*pi_done_fp)(void *); /*< clean-up function for parsing info */
#if defined(SS_DEBUG) #if defined(SS_DEBUG)
skygw_chk_t pi_chk_tail; skygw_chk_t pi_chk_tail;
#endif #endif
} parsing_info_t; } parsing_info_t;
#define QUERY_IS_TYPE(mask,type) ((mask & type) == type) #define QUERY_IS_TYPE(mask,type) ((mask & type) == type)
/** /**
* Create THD and use it for creating parse tree. Examine parse tree and * Create THD and use it for creating parse tree. Examine parse tree and
* classify the query. * classify the query.
*/ */
skygw_query_type_t query_classifier_get_type(GWBUF* querybuf); skygw_query_type_t query_classifier_get_type(GWBUF* querybuf);
skygw_query_op_t query_classifier_get_operation(GWBUF* querybuf); skygw_query_op_t query_classifier_get_operation(GWBUF* querybuf);
/** Free THD context and close MYSQL */
#if defined(NOT_USED) #if defined(NOT_USED)
char* skygw_query_classifier_get_stmtname(GWBUF* buf); char* skygw_query_classifier_get_stmtname(GWBUF* buf);
#endif #endif
char* skygw_get_created_table_name(GWBUF* querybuf);
bool is_drop_table_query(GWBUF* querybuf); char* skygw_get_created_table_name(GWBUF* querybuf);
bool skygw_is_real_query(GWBUF* querybuf); bool is_drop_table_query(GWBUF* querybuf);
char** skygw_get_table_names(GWBUF* querybuf, int* tblsize, bool fullnames); bool skygw_is_real_query(GWBUF* querybuf);
char* skygw_get_canonical(GWBUF* querybuf); char** skygw_get_table_names(GWBUF* querybuf, int* tblsize, bool fullnames);
bool parse_query (GWBUF* querybuf); char* skygw_get_canonical(GWBUF* querybuf);
bool parse_query(GWBUF* querybuf);
parsing_info_t* parsing_info_init(void (*donefun)(void *)); parsing_info_t* parsing_info_init(void (*donefun)(void *));
void parsing_info_done(void* ptr);
bool query_is_parsed(GWBUF* buf); /** Free THD context and close MYSQL */
bool skygw_query_has_clause(GWBUF* buf); void parsing_info_done(void* ptr);
char* skygw_get_qtype_str(skygw_query_type_t qtype); bool query_is_parsed(GWBUF* buf);
char* skygw_get_affected_fields(GWBUF* buf); bool skygw_query_has_clause(GWBUF* buf);
char** skygw_get_database_names(GWBUF* querybuf,int* size); char* skygw_get_qtype_str(skygw_query_type_t qtype);
char* skygw_get_affected_fields(GWBUF* buf);
char** skygw_get_database_names(GWBUF* querybuf, int* size);
EXTERN_C_BLOCK_END EXTERN_C_BLOCK_END