sql_common.h File Reference

#include <mysql.h>
#include <stddef.h>
#include <sys/types.h>
#include "errmsg.h"
#include "my_command.h"
#include "my_compiler.h"
#include "my_inttypes.h"
#include "my_list.h"
#include "mysql_com.h"
#include "mysql_com_server.h"

Go to the source code of this file.

Classes
struct	STATE_INFO_NODE
	The structure is used to hold the state change information received from the server. More...
struct	STATE_INFO
	Store the change info received from the server in an array of linked lists with STATE_INFO_NODE elements (one per state type). More...
struct	MYSQL_EXTENSION
struct	client_authentication_info
struct	st_mysql_options_extention
struct	MYSQL_METHODS

Macros
#define	MYSQL_EXTENSION_PTR(H)
#define	ASYNC_DATA(M)    (NULL != (M) ? (MYSQL_EXTENSION_PTR(M)->mysql_async_context) : NULL)
#define	MAX_AUTHENTICATION_FACTOR   3
#define	simple_command(mysql, command, arg, length, skip_check)
#define	simple_command_nonblocking(mysql, command, arg, length, skip_check, error)
#define	stmt_command(mysql, command, arg, length, stmt)
#define	protocol_41(A)   ((A)->server_capabilities & CLIENT_PROTOCOL_41)
#define	AUTH_NEXT_FACTOR_PACKETTYPE   2

Functions
void	mysql_close_free (MYSQL *mysql)
void	mysql_close_free_options (MYSQL *mysql)
MYSQL_EXTENSION *	mysql_extension_init (MYSQL *)
void	mysql_extension_free (MYSQL_EXTENSION *)
void	mysql_extension_bind_free (MYSQL_EXTENSION *ext)
void	mysql_extension_set_server_extn (MYSQL *mysql, NET_SERVER *extn)
	Sets the MYSQL_EXTENSION::server_extn attribute by the use of NET_SERVER which contains information about compression context and compression attributes. More...
MYSQL_FIELD *	unpack_fields (MYSQL *mysql, MYSQL_ROWS *data, MEM_ROOT *alloc, uint fields, bool default_value, uint server_capabilities)
MYSQL_FIELD *	cli_read_metadata_ex (MYSQL *mysql, MEM_ROOT *alloc, unsigned long field_count, unsigned int fields)
MYSQL_FIELD *	cli_read_metadata (MYSQL *mysql, unsigned long field_count, unsigned int fields)
MYSQL_RES *	use_result (MYSQL *mysql)
MYSQL *	connect_helper (mysql_async_connect *ctx)
void	free_rows (MYSQL_DATA *cur)
void	free_old_query (MYSQL *mysql)
void	end_server (MYSQL *mysql)
bool	mysql_reconnect (MYSQL *mysql)
void	mysql_read_default_options (struct st_mysql_options *options, const char *filename, const char *group)
bool	cli_advanced_command (MYSQL *mysql, enum enum_server_command command, const unsigned char *header, size_t header_length, const unsigned char *arg, size_t arg_length, bool skip_check, MYSQL_STMT *stmt)
unsigned long	cli_safe_read (MYSQL *mysql, bool *is_data_packet)
	Read a packet from server. More...
enum net_async_status	cli_safe_read_nonblocking (MYSQL *mysql, bool *is_data_packet, ulong *res)
	Its a non blocking version of cli_safe_read. More...
unsigned long	cli_safe_read_with_ok (MYSQL *mysql, bool parse_ok, bool *is_data_packet)
	Read a packet from server. More...
void	net_clear_error (NET *net)
	Clear possible error state of struct NET. More...
void	set_stmt_errmsg (MYSQL_STMT *stmt, NET *net)
	Set statement error code, sqlstate, and error message from NET. More...
void	set_stmt_error (MYSQL_STMT *stmt, int errcode, const char *sqlstate)
	Set statement error code, sqlstate, and error message from given errcode and sqlstate. More...
void	set_stmt_extended_error (MYSQL_STMT *stmt, int errcode, const char *sqlstate, const char *format,...)
	Set statement error code, sqlstate, and error message from given errcode and sqlstate. More...
void	set_mysql_error (MYSQL *mysql, int errcode, const char *sqlstate)
	Set the internal error message to mysql handler. More...
void	set_mysql_extended_error (MYSQL *mysql, int errcode, const char *sqlstate, const char *format,...)
	Set an error message on the client. More...
void	mpvio_info (MYSQL_VIO vio, MYSQL_PLUGIN_VIO_INFO *info)
int	run_plugin_auth (MYSQL *mysql, char *data, uint data_len, const char *data_plugin, const char *db)
	Client side of the plugin driver authentication. More...
int	mysql_client_plugin_init ()
	Initializes the client plugin layer. More...
void	mysql_client_plugin_deinit ()
	Deinitializes the client plugin layer. More...
uchar *	send_client_connect_attrs (MYSQL *mysql, uchar *buf)
int	is_file_or_dir_world_writable (const char *filepath)
	Check if a file/dir is world-writable (only on non-Windows platforms) More...
void	read_ok_ex (MYSQL *mysql, unsigned long len)
bool	fix_param_bind (MYSQL_BIND *param, uint idx)
bool	mysql_int_serialize_param_data (NET *net, unsigned int param_count, MYSQL_BIND *params, const char **names, unsigned long n_param_sets, uchar **ret_data, ulong *ret_length, uchar send_types_to_server, bool send_named_params, bool send_parameter_set_count, bool send_parameter_count_when_zero)
	Serialize the query parameters. More...

Variables
const char *	unknown_sqlstate
const char *	cant_connect_sqlstate
const char *	not_error_sqlstate
CHARSET_INFO *	default_client_charset_info
struct st_mysql_client_plugin *	mysql_client_builtins []
bool	libmysql_cleartext_plugin_enabled

Macro Definition Documentation

ASYNC_DATA

#define ASYNC_DATA

(

M

)

(NULL != (M) ? (MYSQL_EXTENSION_PTR(M)->mysql_async_context) : NULL)

AUTH_NEXT_FACTOR_PACKETTYPE

#define AUTH_NEXT_FACTOR_PACKETTYPE   2

MAX_AUTHENTICATION_FACTOR

#define MAX_AUTHENTICATION_FACTOR   3

MYSQL_EXTENSION_PTR

#define MYSQL_EXTENSION_PTR

(

H

)

Value:

  ((MYSQL_EXTENSION *)((H)->extension       \
                           ? (H)->extension \
                           : ((H)->extension = mysql_extension_init(H))))

protocol_41

#define protocol_41

(

A

)

((A)->server_capabilities & CLIENT_PROTOCOL_41)

simple_command

#define simple_command	(		mysql,
			command,
			arg,
			length,
			skip_check
	)

Value:

  ((mysql)->methods                                                          \
       ? (*(mysql)->methods->advanced_command)(mysql, command, 0, 0, arg,    \
                                               length, skip_check, NULL)     \
       : (set_mysql_error(mysql, CR_COMMANDS_OUT_OF_SYNC, unknown_sqlstate), \
          1))

simple_command_nonblocking

#define simple_command_nonblocking	(		mysql,
			command,
			arg,
			length,
			skip_check,
			error
	)

Value:

  (*(mysql)->methods->advanced_command_nonblocking)(                        \
      mysql, command, 0, 0, arg, length, skip_check, NULL, error)

stmt_command

#define stmt_command	(		mysql,
			command,
			arg,
			length,
			stmt
	)

Value:

  ((mysql)->methods                                                          \
       ? (*(mysql)->methods->advanced_command)(mysql, command, 0, 0, arg,    \
                                               length, 1, stmt)              \
       : (set_mysql_error(mysql, CR_COMMANDS_OUT_OF_SYNC, unknown_sqlstate), \
          1))

Function Documentation

cli_advanced_command()

bool cli_advanced_command	(	MYSQL *	mysql,
		enum enum_server_command	command,
		const unsigned char *	header,
		size_t	header_length,
		const unsigned char *	arg,
		size_t	arg_length,
		bool	skip_check,
		MYSQL_STMT *	stmt
	)

cli_read_metadata()

MYSQL_FIELD * cli_read_metadata	(	MYSQL *	mysql,
		unsigned long	field_count,
		unsigned int	fields
	)

cli_read_metadata_ex()

MYSQL_FIELD * cli_read_metadata_ex	(	MYSQL *	mysql,
		MEM_ROOT *	alloc,
		unsigned long	field_count,
		unsigned int	fields
	)

cli_safe_read()

unsigned long cli_safe_read	(	MYSQL *	mysql,
		bool *	is_data_packet
	)

Read a packet from server.

Give error message if connection was broken or ERR packet was received. Detect if the packet received was an OK, ERR or something else (a "data packet").

Parameters

[in]	mysql	connection handle
[out]	is_data_packet	if set to true then the packet received was a "data packet".

Return values

The	length of the packet that was read or packet_error in case of error. In case of error its description is stored in mysql handle.

cli_safe_read_nonblocking()

enum net_async_status cli_safe_read_nonblocking	(	MYSQL *	mysql,
		bool *	is_data_packet,
		ulong *	res
	)

Its a non blocking version of cli_safe_read.

cli_safe_read_with_ok()

unsigned long cli_safe_read_with_ok	(	MYSQL *	mysql,
		bool	parse_ok,
		bool *	is_data_packet
	)

Read a packet from server.

Give error message if socket was down or packet is an error message

Parameters

[in]	mysql	connection handle
[in]	parse_ok	if set to true then parse OK packet if it is received
[out]	is_data_packet	if set to true then packet received is a "data packet", that is not OK or ERR packet or EOF in case of old servers

Returns

The length of the packet that was read or packet_error in case of error. In case of error its description is stored in mysql handle.

connect_helper()

MYSQL * connect_helper

(

mysql_async_connect *

ctx

)

end_server()

void end_server

(

MYSQL *

mysql

)

fix_param_bind()

bool fix_param_bind	(	MYSQL_BIND *	param,
		uint	idx
	)

free_old_query()

void free_old_query

(

MYSQL *

mysql

)

free_rows()

void free_rows

(

MYSQL_DATA *

cur

)

is_file_or_dir_world_writable()

int is_file_or_dir_world_writable

(

const char *

path

)

Check if a file/dir is world-writable (only on non-Windows platforms)

Parameters

[in]

path

Path of the file/dir to be checked

Returns

Status of the file/dir check

Return values

-2	Permission denied to check attributes of file/dir
-1	Error in reading file/dir
0	File/dir is not world-writable
1	File/dir is world-writable

mpvio_info()

void mpvio_info	(	MYSQL_VIO	vio,
		MYSQL_PLUGIN_VIO_INFO *	info
	)

mysql_client_plugin_deinit()

void mysql_client_plugin_deinit

(

)

Deinitializes the client plugin layer.

Unloades all client plugins and frees any associated resources.

mysql_client_plugin_init()

int mysql_client_plugin_init

(

)

Initializes the client plugin layer.

This function must be called before any other client plugin function.

Return values

0	successful
!=	0 error occurred

mysql_close_free()

void mysql_close_free

(

MYSQL *

mysql

)

mysql_close_free_options()

void mysql_close_free_options

(

MYSQL *

mysql

)

mysql_extension_bind_free()

void mysql_extension_bind_free

(

MYSQL_EXTENSION *

ext

)

mysql_extension_free()

void mysql_extension_free

(

MYSQL_EXTENSION *

ext

)

mysql_extension_init()

MYSQL_EXTENSION * mysql_extension_init

(

MYSQL *

mysql

)

mysql_extension_set_server_extn()

void mysql_extension_set_server_extn ( MYSQL *  mysql, NET_SERVER *  extn  )

inline

Sets the MYSQL_EXTENSION::server_extn attribute by the use of NET_SERVER which contains information about compression context and compression attributes.

This attribute needs to be set each time mysql_real_connect() is called to make a connection. When a connection attempt fails or when a connection is closed, as part of the MYSQL handle cleanup, mysql_close_free() is called and that will free MYSQL_EXTENSION::server_extn.

mysql_close_free() will free all the memory allocated in the MYSQL handle but preserves MYSQL::options. These options are later free'd by mysql_close_free_options() unless the client flag CLIENT_REMEMBER_OPTIONS is set.

Parameters

mysql	The MYSQL handle
extn	The NET_SERVER handle that contains compression context info.

mysql_int_serialize_param_data()

bool mysql_int_serialize_param_data	(	NET *	net,
		unsigned int	param_count,
		MYSQL_BIND *	params,
		const char **	names,
		unsigned long	n_param_sets,
		uchar **	ret_data,
		ulong *	ret_length,
		uchar	send_types_to_server,
		bool	send_named_params,
		bool	send_parameter_set_count,
		bool	send_parameter_count_when_zero
	)

Serialize the query parameters.

Used by mysql_real_query, mysql_real_query_nonblocking and mysql_stmt_execute()

Must be called on connected sessions only.

Parameters

	net	the NET to use as a string buffer serializing the params. It's cleared at start.
	param_count	the number of parameters to send
	params	the filled in MYSQL_BIND structure to retrieve the values from
	names	the names of the parameters in the params argument
	n_param_sets	the number of sets of values to set
[out]	ret_data	the buffer to the serialized parameter representation
[out]	ret_length	the number of bytes stored into the buffer
	send_types_to_server	: whether to send the parameter types to the server or not
	send_named_params	: whether the names of the parameters should be sent
	send_parameter_set_count	: whether to send 1 as parameter count or not
	send_parameter_count_when_zero	ON to send the param count even when it's zero

Return values

true	execution failed. Error in NET
false	execution succeeded

mysql_read_default_options()

void mysql_read_default_options	(	struct st_mysql_options *	options,
		const char *	filename,
		const char *	group
	)

mysql_reconnect()

bool mysql_reconnect

(

MYSQL *

mysql

)

net_clear_error()

void net_clear_error

(

NET *

net

)

Clear possible error state of struct NET.

Parameters

net	clear the state of the argument

read_ok_ex()

void read_ok_ex	(	MYSQL *	mysql,
		unsigned long	len
	)

run_plugin_auth()

int run_plugin_auth	(	MYSQL *	mysql,
		char *	data,
		uint	data_len,
		const char *	data_plugin,
		const char *	db
	)

Client side of the plugin driver authentication.

Note

this is used by both the mysql_real_connect and mysql_change_user

Parameters

mysql	mysql
data	pointer to the plugin auth data (scramble) in the handshake packet
data_len	the length of the data
data_plugin	a plugin that data were prepared for or 0 if it's mysql_change_user()
db	initial db to use, can be 0

Return values

0	ok
1	error

send_client_connect_attrs()

uchar * send_client_connect_attrs	(	MYSQL *	mysql,
		uchar *	buf
	)

set_mysql_error()

void set_mysql_error	(	MYSQL *	mysql,
		int	errcode,
		const char *	sqlstate
	)

Set the internal error message to mysql handler.

Parameters

mysql	connection handle (client side)
errcode	CR_ error code, passed to ER macro to get error text
sqlstate	SQL standard sqlstate

set_mysql_extended_error()

void set_mysql_extended_error	(	MYSQL *	mysql,
		int	errcode,
		const char *	sqlstate,
		const char *	format,
			...
	)

Set an error message on the client.

Parameters

mysql	connection handle
errcode	CR_* errcode, for client errors
sqlstate	SQL standard sql state, unknown_sqlstate for the majority of client errors.
format	error message template, in sprintf format
...	variable number of arguments

set_stmt_errmsg()

void set_stmt_errmsg	(	MYSQL_STMT *	stmt,
		NET *	net
	)

Set statement error code, sqlstate, and error message from NET.

Parameters

stmt	a statement handle. Copy the error here.
net	mysql->net. Source of the error.

set_stmt_error()

void set_stmt_error	(	MYSQL_STMT *	stmt,
		int	errcode,
		const char *	sqlstate
	)

Set statement error code, sqlstate, and error message from given errcode and sqlstate.

set_stmt_extended_error()

void set_stmt_extended_error	(	MYSQL_STMT *	stmt,
		int	errcode,
		const char *	sqlstate,
		const char *	format,
			...
	)

Set statement error code, sqlstate, and error message from given errcode and sqlstate.

unpack_fields()

MYSQL_FIELD * unpack_fields	(	MYSQL *	mysql,
		MYSQL_ROWS *	data,
		MEM_ROOT *	alloc,
		uint	fields,
		bool	default_value,
		uint	server_capabilities
	)

use_result()

MYSQL_RES * use_result

(

MYSQL *

mysql

)

Variable Documentation

cant_connect_sqlstate

const char* cant_connect_sqlstate

extern

default_client_charset_info

CHARSET_INFO* default_client_charset_info

extern

libmysql_cleartext_plugin_enabled

bool libmysql_cleartext_plugin_enabled

extern

mysql_client_builtins

struct st_mysql_client_plugin* mysql_client_builtins[]

extern

not_error_sqlstate

const char* not_error_sqlstate

extern

unknown_sqlstate

const char* unknown_sqlstate

extern