Skip navigation links

The world's most popular open source database

Contact a MySQL Representative

Login | Register

• MySQL.com
• Developer Zone
• Partners & Solutions
• Customer Login

• DevZone
• Downloads
• Documentation
• Articles
• Forums
• Bugs
• Forge
• Blogs

 

---

Learn about new MySQL releases, technical articles, events and more.

Subscribe Now »

mysql/src/5.1-dbg/client/mysqltest.c File Reference

#include <my_global.h>
#include <mysql_embed.h>
#include <my_sys.h>
#include <m_string.h>
#include <mysql.h>
#include <mysql_version.h>
#include <mysqld_error.h>
#include <m_ctype.h>
#include <my_dir.h>
#include <errmsg.h>
#include <hash.h>
#include <my_getopt.h>
#include <stdarg.h>
#include <sys/stat.h>
#include <violite.h>
#include "my_regex.h"
#include <mysqld_ername.h>
#include "sslopt-vars.h"
#include "sslopt-longopts.h"
#include <help_start.h>
#include <help_end.h>
#include <sslopt-case.h>

Include dependency graph for mysqltest.c:

Go to the source code of this file.

Classes
struct	match_err
struct	st_error
struct	test_file
struct	st_regex
struct	st_replace_regex
struct	BLOCK
struct	MASTER_POS
struct	connection
struct	PARSER
struct	VAR
struct	st_query
struct	st_pointer_array
struct	st_replace
struct	st_replace_found
struct	st_rep_set
struct	st_rep_sets
struct	st_found_set
struct	st_follow
Defines
#define	MTEST_VERSION   "2.6"
#define	WEXITSTATUS(stat_val)   ((unsigned)(stat_val) >> 8)
#define	MAX_QUERY   (256*1024)
#define	MAX_VAR_NAME   256
#define	MAX_COLUMNS   256
#define	MAX_CONS   128
#define	MAX_INCLUDE_DEPTH   16
#define	INIT_Q_LINES   1024
#define	MIN_VAR_ALLOC   32
#define	BLOCK_STACK_DEPTH   32
#define	MAX_EXPECTED_ERRORS   10
#define	QUERY_SEND   1
#define	QUERY_REAP   2
#define	MAX_SERVER_ARGS   64
#define	SLAVE_POLL_INTERVAL   300000
#define	DEFAULT_DELIMITER   ";"
#define	MAX_DELIMITER   16
#define	RESULT_OK   0
#define	RESULT_CONTENT_MISMATCH   1
#define	RESULT_LENGTH_MISMATCH   2
#define	PARSE_REGEX_ARG
#define	SECURE_REG_BUF
#define	PC_MALLOC   256
#define	PS_MALLOC   512
#define	SPACE_CHAR   256
#define	START_OF_LINE   257
#define	END_OF_LINE   258
#define	LAST_CHAR_CODE   259
#define	WORD_BIT   (8*sizeof(uint))
#define	SET_MALLOC_HUNC   64
Typedefs
typedef st_pointer_array	POINTER_ARRAY
typedef st_replace	REPLACE
typedef st_replace_found	REPLACE_STRING
typedef st_rep_set	REP_SET
typedef st_rep_sets	REP_SETS
typedef st_found_set	FOUND_SET
typedef st_follow	FOLLOWS
Enumerations
enum	{   OPT_SKIP_SAFEMALLOC = 256, OPT_SSL_SSL, OPT_SSL_KEY, OPT_SSL_CERT,   OPT_SSL_CA, OPT_SSL_CAPATH, OPT_SSL_CIPHER, OPT_PS_PROTOCOL,   OPT_SP_PROTOCOL, OPT_CURSOR_PROTOCOL, OPT_VIEW_PROTOCOL, OPT_SSL_VERIFY_SERVER_CERT,   OPT_MAX_CONNECT_RETRIES, OPT_MARK_PROGRESS }
enum	match_err_type { ERR_EMPTY = 0, ERR_ERRNO, ERR_SQLSTATE }
enum	block_cmd { cmd_none, cmd_if, cmd_while }
enum	enum_commands {   Q_CONNECTION = 1, Q_QUERY, Q_CONNECT, Q_SLEEP,   Q_REAL_SLEEP, Q_INC, Q_DEC, Q_SOURCE,   Q_DISCONNECT, Q_LET, Q_ECHO, Q_WHILE,   Q_END_BLOCK, Q_SYSTEM, Q_RESULT, Q_REQUIRE,   Q_SAVE_MASTER_POS, Q_SYNC_WITH_MASTER, Q_SYNC_SLAVE_WITH_MASTER, Q_ERROR,   Q_SEND, Q_REAP, Q_DIRTY_CLOSE, Q_REPLACE,   Q_REPLACE_COLUMN, Q_PING, Q_EVAL, Q_RPL_PROBE,   Q_ENABLE_RPL_PARSE, Q_DISABLE_RPL_PARSE, Q_EVAL_RESULT, Q_ENABLE_QUERY_LOG,   Q_DISABLE_QUERY_LOG, Q_ENABLE_RESULT_LOG, Q_DISABLE_RESULT_LOG, Q_WAIT_FOR_SLAVE_TO_STOP,   Q_ENABLE_WARNINGS, Q_DISABLE_WARNINGS, Q_ENABLE_PS_WARNINGS, Q_DISABLE_PS_WARNINGS,   Q_ENABLE_INFO, Q_DISABLE_INFO, Q_ENABLE_METADATA, Q_DISABLE_METADATA,   Q_EXEC, Q_DELIMITER, Q_DISABLE_ABORT_ON_ERROR, Q_ENABLE_ABORT_ON_ERROR,   Q_DISPLAY_VERTICAL_RESULTS, Q_DISPLAY_HORIZONTAL_RESULTS, Q_QUERY_VERTICAL, Q_QUERY_HORIZONTAL,   Q_START_TIMER, Q_END_TIMER, Q_CHARACTER_SET, Q_DISABLE_PS_PROTOCOL,   Q_ENABLE_PS_PROTOCOL, Q_DISABLE_RECONNECT, Q_ENABLE_RECONNECT, Q_IF,   Q_DISABLE_PARSING, Q_ENABLE_PARSING, Q_REPLACE_REGEX, Q_DIE,   Q_UNKNOWN, Q_COMMENT, Q_COMMENT_WITH_COMMAND }
enum	enum_operator { DO_DEC, DO_INC }
Functions
static void	timer_output (void)
static ulonglong	timer_now (void)
static void	init_re (void)
static int	match_re (my_regex_t *, char *)
static void	free_re (void)
static int	reg_replace (char **buf_p, int *buf_len_p, char *pattern, char *replace, char *string, int icase)
static void	die (const char *fmt,...)
static void	init_var_hash ()
static VAR *	var_from_env (const char *, const char *)
static byte *	get_var_key (const byte *rec, uint *len, my_bool t)
static VAR *	var_init (VAR *v, const char *name, int name_len, const char *val, int val_len)
static void	var_free (void *v)
void	dump_result_to_reject_file (const char *record_file, char *buf, int size)
void	dump_result_to_log_file (const char *record_file, char *buf, int size)
int	close_connection (struct st_query *)
static void	set_charset (struct st_query *)
VAR *	var_get (const char *var_name, const char **var_name_end, my_bool raw, my_bool ignore_not_existing)
int	eval_expr (VAR *v, const char *p, const char **p_end)
static int	read_server_arguments (const char *name)
st_replace *	init_replace (my_string *from, my_string *to, uint count, my_string word_end_chars)
void	free_replace ()
static void	free_replace_regex ()
static int	insert_pointer_name (reg1 POINTER_ARRAY *pa, my_string name)
static void	replace_strings_append (struct st_replace *rep, DYNAMIC_STRING *ds, const char *from, int len)
void	free_pointer_array (POINTER_ARRAY *pa)
static void	do_eval (DYNAMIC_STRING *query_eval, const char *query, my_bool pass_through_escape_chars)
static void	str_to_file (const char *fname, char *str, int size)
static void	get_replace_column (struct st_query *q)
static void	free_replace_column ()
void	mysql_enable_rpl_parse (MYSQL *mysql __attribute__((unused)))
void	mysql_disable_rpl_parse (MYSQL *mysql __attribute__((unused)))
int	mysql_rpl_parse_enabled (MYSQL *mysql __attribute__((unused)))
my_bool	mysql_rpl_probe (MYSQL *mysql __attribute__((unused)))
static void	replace_dynstr_append_mem (DYNAMIC_STRING *ds, const char *val, int len)
static void	replace_dynstr_append (DYNAMIC_STRING *ds, const char *val)
static void	handle_error (const char *query, struct st_query *q, unsigned int err_errno, const char *err_error, const char *err_sqlstate, DYNAMIC_STRING *ds)
static void	handle_no_error (struct st_query *q)
static void	close_cons ()
static void	close_files ()
static void	free_used_memory ()
static void	abort_not_supported_test (const char *fmt,...)
static void	verbose_msg (const char *fmt,...)
void	init_parser ()
static int	dyn_string_cmp (DYNAMIC_STRING *ds, const char *fname)
static void	check_result (DYNAMIC_STRING *ds, const char *fname, my_bool require_option)
static VAR *	var_obtain (const char *name, int len)
int	var_set (const char *var_name, const char *var_name_end, const char *var_val, const char *var_val_end)
int	open_file (const char *name)
int	check_eol_junk (const char *eol)
int	do_wait_for_slave_to_stop (struct st_query *q __attribute__((unused)))
int	do_source (struct st_query *query)
FILE *	my_popen (DYNAMIC_STRING *ds_cmd, const char *mode)
static void	do_exec (struct st_query *query)
int	var_query_set (VAR *var, const char *query, const char **query_end)
void	var_copy (VAR *dest, VAR *src)
int	do_modify_var (struct st_query *query, enum enum_operator operator)
int	my_system (DYNAMIC_STRING *ds_cmd)
void	do_system (struct st_query *command)
int	do_echo (struct st_query *command)
int	do_sync_with_master2 (long offset)
int	do_sync_with_master (struct st_query *query)
int	do_save_master_pos ()
int	do_let (struct st_query *query)
int	var_set_errno (int sql_errno)
int	do_rpl_probe (struct st_query *query __attribute__((unused)))
int	do_enable_rpl_parse (struct st_query *query __attribute__((unused)))
int	do_disable_rpl_parse (struct st_query *query __attribute__((unused)))
int	do_sleep (struct st_query *query, my_bool real_sleep)
static void	get_file_name (char *filename, struct st_query *q)
static uint	get_errcodes (match_err *to, struct st_query *q)
static char *	get_string (char **to_ptr, char **from_ptr, struct st_query *q)
static struct st_replace_regex *	init_replace_regex (char *expr)
static int	multi_reg_replace (struct st_replace_regex *r, char *val)
static void	get_replace_regex (struct st_query *q)
static void	get_replace (struct st_query *q)
connection *	find_connection_by_name (const char *name)
int	select_connection_name (const char *name)
int	select_connection (struct st_query *query)
char *	safe_get_param (char *str, char **arg, const char *msg)
int	safe_connect (MYSQL *mysql, const char *host, const char *user, const char *pass, const char *db, int port, const char *sock)
int	connect_n_handle_errors (struct st_query *q, MYSQL *con, const char *host, const char *user, const char *pass, const char *db, int port, const char *sock, int *create_conn)
int	do_connect (struct st_query *q)
int	do_done (struct st_query *q)
void	do_block (enum block_cmd cmd, struct st_query *q)
int	my_getc (FILE *file)
void	my_ungetc (int c)
my_bool	end_of_query (int c)
int	read_line (char *buf, int size)
int	read_query (struct st_query **q_ptr)
static void	print_version (void)
void	usage ()
static my_bool	get_one_option (int optid, const struct my_option *opt __attribute__((unused)), char *argument)
int	parse_args (int argc, char **argv)
void	dump_progress (const char *record_file)
static void	check_regerr (my_regex_t *r, int err)
static void	append_field (DYNAMIC_STRING *ds, uint col_idx, MYSQL_FIELD *field, const char *val, ulonglong len, bool is_null)
static void	append_result (DYNAMIC_STRING *ds, MYSQL_RES *res)
static void	append_stmt_result (DYNAMIC_STRING *ds, MYSQL_STMT *stmt, MYSQL_FIELD *fields, uint num_fields)
static void	append_metadata (DYNAMIC_STRING *ds, MYSQL_FIELD *field, uint num_fields)
static void	append_info (DYNAMIC_STRING *ds, ulonglong affected_rows, const char *info)
static void	append_table_headings (DYNAMIC_STRING *ds, MYSQL_FIELD *field, uint num_fields)
static int	append_warnings (DYNAMIC_STRING *ds, MYSQL *mysql)
static void	run_query_normal (MYSQL *mysql, struct st_query *command, int flags, char *query, int query_len, DYNAMIC_STRING *ds, DYNAMIC_STRING *ds_warnings)
static void	run_query_stmt (MYSQL *mysql, struct st_query *command, char *query, int query_len, DYNAMIC_STRING *ds, DYNAMIC_STRING *ds_warnings)
static int	util_query (MYSQL *org_mysql, const char *query)
static void	run_query (MYSQL *mysql, struct st_query *command, int flags)
static char *	re_eprint (int err)
static void	init_re_comp (my_regex_t *re, const char *str)
void	get_query_type (struct st_query *q)
static byte *	get_var_key (const byte *var, uint *len, my_bool __attribute__((unused)) t)
static void	init_var_hash (MYSQL *mysql)
static void	mark_progress (struct st_query *q __attribute__((unused)), int line)
int	main (int argc, char **argv)
static int	init_sets (REP_SETS *sets, uint states)
static REP_SET *	make_new_set (REP_SETS *sets)
static void	make_sets_invisible (REP_SETS *sets)
static void	free_last_set (REP_SETS *sets)
static void	free_sets (REP_SETS *sets)
static void	internal_set_bit (REP_SET *set, uint bit)
static void	internal_clear_bit (REP_SET *set, uint bit)
static void	or_bits (REP_SET *to, REP_SET *from)
static void	copy_bits (REP_SET *to, REP_SET *from)
static int	cmp_bits (REP_SET *set1, REP_SET *set2)
static int	get_next_bit (REP_SET *set, uint lastpos)
static int	find_set (REP_SETS *sets, REP_SET *find)
static int	find_found (FOUND_SET *found_set, uint table_offset, int found_offset)
static uint	start_at_word (my_string pos)
static uint	end_of_word (my_string pos)
static uint	replace_len (my_string pos)
Variables
static st_error	global_error []
static match_err	global_expected_errno [MAX_EXPECTED_ERRORS]
static uint	global_expected_errors
static int	record = 0
static int	opt_sleep = -1
static char *	db = 0
static char *	pass = 0
const char *	user = 0
const char *	host = 0
const char *	unix_sock = 0
const char *	opt_basedir = "./"
const char *	opt_include = 0
static int	port = 0
static int	opt_max_connect_retries
static my_bool	opt_big_test = 0
static my_bool	opt_compress = 0
static my_bool	silent = 0
static my_bool	verbose = 0
static my_bool	tty_password = 0
static my_bool	opt_mark_progress = 0
static my_bool	ps_protocol = 0
static my_bool	ps_protocol_enabled = 0
static my_bool	sp_protocol = 0
static my_bool	sp_protocol_enabled = 0
static my_bool	view_protocol = 0
static my_bool	view_protocol_enabled = 0
static my_bool	cursor_protocol = 0
static my_bool	cursor_protocol_enabled = 0
static int	parsing_disabled = 0
static char **	default_argv
static const char *	load_default_groups [] = { "mysqltest","client",0 }
static char	line_buffer [MAX_DELIMITER]
static char *	line_buffer_pos = line_buffer
static test_file	file_stack [MAX_INCLUDE_DEPTH]
static test_file *	cur_file
static test_file *	file_stack_end
uint	start_lineno = 0
st_replace_regex *	glob_replace_regex = 0
static char	TMPDIR [FN_REFLEN]
static char	delimiter [MAX_DELIMITER] = DEFAULT_DELIMITER
static uint	delimiter_length = 1
static BLOCK	block_stack [BLOCK_STACK_DEPTH]
static BLOCK *	cur_block
static BLOCK *	block_stack_end
static CHARSET_INFO *	charset_info = &my_charset_latin1
static const char *	charset_name = "latin1"
static int	embedded_server_arg_count = 0
static char *	embedded_server_args [MAX_SERVER_ARGS]
static my_bool	display_result_vertically = FALSE
static my_bool	display_metadata = FALSE
static char *	timer_file = NULL
static ulonglong	timer_start
static ulonglong	progress_start = 0
static int	got_end_timer = FALSE
static my_regex_t	ps_re
static my_regex_t	sp_re
static my_regex_t	view_re
static const char *	embedded_server_groups []
DYNAMIC_ARRAY	q_lines
PARSER	parser
MASTER_POS	master_pos
const char *	result_file = 0
VAR	var_reg [10]
HASH	var_hash
my_bool	disable_query_log = 0
my_bool	disable_result_log = 0
my_bool	disable_warnings = 0
my_bool	disable_ps_warnings = 0
my_bool	disable_info = 1
my_bool	abort_on_error = 1
connection	cons [MAX_CONS]
connection *	cur_con
connection *	next_con
connection *	cons_end
const char *	command_names []
TYPELIB	command_typelib
DYNAMIC_STRING	ds_res
DYNAMIC_STRING	ds_progress
st_replace *	glob_replace
static int	eval_result = 0
char *	replace_column [MAX_COLUMNS]
uint	max_replace_column = 0
static char	read_query_buf [MAX_QUERY]
static struct my_option	my_long_options []
static uint	found_sets = 0

---

Define Documentation

#define BLOCK_STACK_DEPTH   32

Definition at line 81 of file mysqltest.c.

Referenced by main().

#define DEFAULT_DELIMITER   ";"

Definition at line 89 of file mysqltest.c.

#define END_OF_LINE   258

Definition at line 5640 of file mysqltest.c.

Referenced by init_replace().

#define INIT_Q_LINES   1024

Definition at line 79 of file mysqltest.c.

Referenced by main().

#define LAST_CHAR_CODE   259

Definition at line 5641 of file mysqltest.c.

Referenced by init_replace(), and make_new_set().

#define MAX_COLUMNS   256

Definition at line 76 of file mysqltest.c.

Referenced by get_replace_column().

#define MAX_CONS   128

Definition at line 77 of file mysqltest.c.

Referenced by main().

#define MAX_DELIMITER   16

Definition at line 90 of file mysqltest.c.

Referenced by end_of_query().

#define MAX_EXPECTED_ERRORS   10

Definition at line 82 of file mysqltest.c.

#define MAX_INCLUDE_DEPTH   16

Definition at line 78 of file mysqltest.c.

Referenced by main().

#define MAX_QUERY   (256*1024)

Definition at line 74 of file mysqltest.c.

#define MAX_SERVER_ARGS   64

Definition at line 85 of file mysqltest.c.

Referenced by get_one_option(), and read_server_arguments().

#define MAX_VAR_NAME   256

Definition at line 75 of file mysqltest.c.

Referenced by var_get(), and var_query_set().

#define MIN_VAR_ALLOC   32

Definition at line 80 of file mysqltest.c.

Referenced by eval_expr().

#define MTEST_VERSION   "2.6"

Definition at line 45 of file mysqltest.c.

Referenced by print_version().

#define PARSE_REGEX_ARG

Value:

while (p < expr_end) \
  {\
    char c= *p;\
    if (c == '/')\
    {\
      if (last_c == '\\')\
      {\
        buf_p[-1]= '/';\
      }\
      else\
      {\
        *buf_p++ = 0;\
        break;\
      }  \
    }  \
    else\
      *buf_p++ = c;\
       \
    last_c= c;\
    p++;\
  }  \

Definition at line 2039 of file mysqltest.c.

Referenced by init_replace_regex().

#define PC_MALLOC   256

Definition at line 5635 of file mysqltest.c.

Referenced by insert_pointer_name().

#define PS_MALLOC   512

Definition at line 5636 of file mysqltest.c.

Referenced by insert_pointer_name().

#define QUERY_REAP   2

Definition at line 84 of file mysqltest.c.

Referenced by main(), run_query(), and run_query_normal().

#define QUERY_SEND   1

Definition at line 83 of file mysqltest.c.

Referenced by main(), run_query(), and run_query_normal().

#define RESULT_CONTENT_MISMATCH   1

Definition at line 93 of file mysqltest.c.

Referenced by check_result(), and dyn_string_cmp().

#define RESULT_LENGTH_MISMATCH   2

Definition at line 94 of file mysqltest.c.

Referenced by check_result(), and dyn_string_cmp().

#define RESULT_OK   0

Definition at line 92 of file mysqltest.c.

Referenced by check_result(), and dyn_string_cmp().

#define SECURE_REG_BUF

Value:

if (buf_len < need_buf_len)\
  {\
    int off= res_p - buf;\
    buf= (char*)my_realloc(buf,need_buf_len,MYF(MY_WME+MY_FAE));\
    res_p= buf + off;\
    buf_len= need_buf_len;\
  }\

Definition at line 3505 of file mysqltest.c.

Referenced by reg_replace().

#define SET_MALLOC_HUNC   64

Definition at line 5747 of file mysqltest.c.

Referenced by init_sets(), and make_new_set().

#define SLAVE_POLL_INTERVAL   300000

Definition at line 88 of file mysqltest.c.

Referenced by do_wait_for_slave_to_stop().

#define SPACE_CHAR   256

Definition at line 5638 of file mysqltest.c.

Referenced by init_replace().

#define START_OF_LINE   257

Definition at line 5639 of file mysqltest.c.

Referenced by init_replace().

#define WEXITSTATUS

(

stat_val

)

((unsigned)(stat_val) >> 8)

Definition at line 70 of file mysqltest.c.

Referenced by do_exec(), and main().

#define WORD_BIT   (8*sizeof(uint))

Definition at line 5656 of file mysqltest.c.

Referenced by get_next_bit(), internal_clear_bit(), and internal_set_bit().

---

Typedef Documentation

typedef struct st_follow FOLLOWS

typedef struct st_found_set FOUND_SET

typedef struct st_pointer_array POINTER_ARRAY

typedef struct st_rep_set REP_SET