Skip navigation links

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

Subscribe Now »
MySQL 5.1: mysql/src/5.1-dbg/libmysql_r/libmysql.c File Reference

mysql/src/5.1-dbg/libmysql_r/libmysql.c File Reference

#include <my_global.h>
#include <my_sys.h>
#include <my_time.h>
#include <mysys_err.h>
#include <m_string.h>
#include <m_ctype.h>
#include "mysql.h"
#include "mysql_version.h"
#include "mysqld_error.h"
#include "errmsg.h"
#include <violite.h>
#include <sys/stat.h>
#include <signal.h>
#include <time.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <sql_common.h>
#include "client_settings.h"
#include <errno.h>

Include dependency graph for libmysql.c:

Go to the source code of this file.


Classes

struct  st_default_local_infile

Defines

#define INADDR_NONE   -1
#define SOCKET_ERROR   -1
#define MAX_LONG_DATA_LENGTH   8192
#define unsigned_field(A)   ((A)->flags & UNSIGNED_FLAG)
#define DEFAULT_PREFETCH_ROWS   (ulong) 1
#define RESET_SERVER_SIDE   1
#define RESET_LONG_DATA   2
#define RESET_STORE_RESULT   4
#define MAX_DATE_REP_LENGTH   5
#define MAX_TIME_REP_LENGTH   13
#define MAX_DATETIME_REP_LENGTH   12
#define MAX_DOUBLE_STRING_REP_LENGTH   331
#define IS_TRUNCATED(value, is_unsigned, min, max, umax)
#define BIND_RESULT_DONE   1
#define REPORT_DATA_TRUNCATION   2
#define NOT_FIXED_DEC   31

Typedefs

typedef st_default_local_infile default_local_infile_data

Functions

static void append_wild (char *to, char *end, const char *wild)
sig_handler my_pipe_sig_handler (int sig)
int STDCALL mysql_server_init (int argc __attribute__((unused)), char **argv __attribute__((unused)), char **groups __attribute__((unused)))
void STDCALL mysql_server_end ()
MYSQL_PARAMETERS *STDCALL mysql_get_parameters (void)
my_bool STDCALL mysql_thread_init ()
void STDCALL mysql_thread_end ()
static MYSQL * spawn_init (MYSQL *parent, const char *host, unsigned int port, const char *user, const char *passwd)
void STDCALL mysql_debug (const char *debug __attribute__((unused)))
sig_handler my_pipe_sig_handler (int sig __attribute__((unused)))
my_bool STDCALL mysql_master_query (MYSQL *mysql, const char *q, unsigned long length)
my_bool STDCALL mysql_master_send_query (MYSQL *mysql, const char *q, unsigned long length)
my_bool STDCALL mysql_slave_query (MYSQL *mysql, const char *q, unsigned long length)
my_bool STDCALL mysql_slave_send_query (MYSQL *mysql, const char *q, unsigned long length)
void STDCALL mysql_enable_rpl_parse (MYSQL *mysql)
void STDCALL mysql_disable_rpl_parse (MYSQL *mysql)
int STDCALL mysql_rpl_parse_enabled (MYSQL *mysql)
void STDCALL mysql_enable_reads_from_master (MYSQL *mysql)
void STDCALL mysql_disable_reads_from_master (MYSQL *mysql)
my_bool STDCALL mysql_reads_from_master_enabled (MYSQL *mysql)
static void expand_error (MYSQL *mysql, int error)
static my_bool get_master (MYSQL *mysql, MYSQL_RES *res, MYSQL_ROW row)
static my_bool get_slaves_from_master (MYSQL *mysql)
my_bool STDCALL mysql_rpl_probe (MYSQL *mysql)
enum mysql_rpl_type STDCALL mysql_rpl_query_type (const char *q, int len)
int cli_read_change_user_result (MYSQL *mysql, char *buff, const char *passwd)
my_bool STDCALL mysql_change_user (MYSQL *mysql, const char *user, const char *passwd, const char *db)
void read_user_name (char *name)
my_bool handle_local_infile (MYSQL *mysql, const char *net_filename)
static int default_local_infile_init (void **ptr, const char *filename, void *userdata __attribute__((unused)))
static int default_local_infile_read (void *ptr, char *buf, uint buf_len)
static void default_local_infile_end (void *ptr)
static int default_local_infile_error (void *ptr, char *error_msg, uint error_msg_len)
void mysql_set_local_infile_handler (MYSQL *mysql, int(*local_infile_init)(void **, const char *, void *), int(*local_infile_read)(void *, char *, uint), void(*local_infile_end)(void *), int(*local_infile_error)(void *, char *, uint), void *userdata)
void mysql_set_local_infile_default (MYSQL *mysql)
int STDCALL mysql_query (MYSQL *mysql, const char *query)
int STDCALL mysql_set_master (MYSQL *mysql, const char *host, unsigned int port, const char *user, const char *passwd)
int STDCALL mysql_add_slave (MYSQL *mysql, const char *host, unsigned int port, const char *user, const char *passwd)
MYSQL_FIELD *STDCALL mysql_fetch_field (MYSQL_RES *result)
void STDCALL mysql_data_seek (MYSQL_RES *result, my_ulonglong row)
MYSQL_ROW_OFFSET STDCALL mysql_row_seek (MYSQL_RES *result, MYSQL_ROW_OFFSET row)
MYSQL_FIELD_OFFSET STDCALL mysql_field_seek (MYSQL_RES *result, MYSQL_FIELD_OFFSET field_offset)
MYSQL_RES *STDCALL mysql_list_dbs (MYSQL *mysql, const char *wild)
MYSQL_RES *STDCALL mysql_list_tables (MYSQL *mysql, const char *wild)
MYSQL_FIELD * cli_list_fields (MYSQL *mysql)
MYSQL_RES *STDCALL mysql_list_fields (MYSQL *mysql, const char *table, const char *wild)
MYSQL_RES *STDCALL mysql_list_processes (MYSQL *mysql)
int STDCALL mysql_shutdown (MYSQL *mysql, enum mysql_enum_shutdown_level shutdown_level)
int STDCALL mysql_refresh (MYSQL *mysql, uint options)
int STDCALL mysql_kill (MYSQL *mysql, ulong pid)
int STDCALL mysql_set_server_option (MYSQL *mysql, enum enum_mysql_set_option option)
int STDCALL mysql_dump_debug_info (MYSQL *mysql)
const char * cli_read_statistics (MYSQL *mysql)
const char *STDCALL mysql_stat (MYSQL *mysql)
int STDCALL mysql_ping (MYSQL *mysql)
const char *STDCALL mysql_get_server_info (MYSQL *mysql)
const char *STDCALL mysql_get_host_info (MYSQL *mysql)
uint STDCALL mysql_get_proto_info (MYSQL *mysql)
const char *STDCALL mysql_get_client_info (void)
ulong STDCALL mysql_get_client_version (void)
my_bool STDCALL mysql_eof (MYSQL_RES *res)
MYSQL_FIELD *STDCALL mysql_fetch_field_direct (MYSQL_RES *res, uint fieldnr)
MYSQL_FIELD *STDCALL mysql_fetch_fields (MYSQL_RES *res)
MYSQL_ROW_OFFSET STDCALL mysql_row_tell (MYSQL_RES *res)
MYSQL_FIELD_OFFSET STDCALL mysql_field_tell (MYSQL_RES *res)
unsigned int STDCALL mysql_field_count (MYSQL *mysql)
my_ulonglong STDCALL mysql_affected_rows (MYSQL *mysql)
my_ulonglong STDCALL mysql_insert_id (MYSQL *mysql)
const char *STDCALL mysql_sqlstate (MYSQL *mysql)
uint STDCALL mysql_warning_count (MYSQL *mysql)
const char *STDCALL mysql_info (MYSQL *mysql)
ulong STDCALL mysql_thread_id (MYSQL *mysql)
const char *STDCALL mysql_character_set_name (MYSQL *mysql)
void STDCALL mysql_get_character_set_info (MYSQL *mysql, MY_CHARSET_INFO *csinfo)
uint STDCALL mysql_thread_safe (void)
my_bool STDCALL mysql_embedded (void)
void my_net_local_init (NET *net)
ulong STDCALL mysql_hex_string (char *to, const char *from, ulong length)
ulong STDCALL mysql_escape_string (char *to, const char *from, ulong length)
ulong STDCALL mysql_real_escape_string (MYSQL *mysql, char *to, const char *from, ulong length)
char *STDCALL mysql_odbc_escape_string (MYSQL *mysql, char *to, ulong to_length, const char *from, ulong from_length, void *param, char *(*extend_buffer)(void *, char *, ulong *))
void STDCALL myodbc_remove_escape (MYSQL *mysql, char *name)
static int stmt_read_row_unbuffered (MYSQL_STMT *stmt, unsigned char **row)
static int stmt_read_row_buffered (MYSQL_STMT *stmt, unsigned char **row)
static int stmt_read_row_from_cursor (MYSQL_STMT *stmt, unsigned char **row)
static int stmt_read_row_no_data (MYSQL_STMT *stmt, unsigned char **row)
static int stmt_read_row_no_result_set (MYSQL_STMT *stmt, unsigned char **row)
static void stmt_update_metadata (MYSQL_STMT *stmt, MYSQL_ROWS *data)
static my_bool setup_one_fetch_function (MYSQL_BIND *bind, MYSQL_FIELD *field)
static my_bool reset_stmt_handle (MYSQL_STMT *stmt, uint flags)
static my_bool my_realloc_str (NET *net, ulong length)
static void net_clear_error (NET *net)
static void stmt_clear_error (MYSQL_STMT *stmt)
static void set_stmt_error (MYSQL_STMT *stmt, int errcode, const char *sqlstate)
void set_stmt_errmsg (MYSQL_STMT *stmt, const char *err, int errcode, const char *sqlstate)
my_bool cli_read_prepare_result (MYSQL *mysql, MYSQL_STMT *stmt)
MYSQL_STMT *STDCALL mysql_stmt_init (MYSQL *mysql)
int STDCALL mysql_stmt_prepare (MYSQL_STMT *stmt, const char *query, ulong length)
static unsigned int alloc_stmt_fields (MYSQL_STMT *stmt)
static void update_stmt_fields (MYSQL_STMT *stmt)
MYSQL_RES *STDCALL mysql_stmt_result_metadata (MYSQL_STMT *stmt)
MYSQL_RES *STDCALL mysql_stmt_param_metadata (MYSQL_STMT *stmt)
static void store_param_type (char **pos, MYSQL_BIND *param)
static void store_param_tinyint (NET *net, MYSQL_BIND *param)
static void store_param_short (NET *net, MYSQL_BIND *param)
static void store_param_int32 (NET *net, MYSQL_BIND *param)
static void store_param_int64 (NET *net, MYSQL_BIND *param)
static void store_param_float (NET *net, MYSQL_BIND *param)
static void store_param_double (NET *net, MYSQL_BIND *param)
static void store_param_time (NET *net, MYSQL_BIND *param)
static void net_store_datetime (NET *net, MYSQL_TIME *tm)
static void store_param_date (NET *net, MYSQL_BIND *param)
static void store_param_datetime (NET *net, MYSQL_BIND *param)
static void store_param_str (NET *net, MYSQL_BIND *param)
static void store_param_null (NET *net, MYSQL_BIND *param)
static my_bool store_param (MYSQL_STMT *stmt, MYSQL_BIND *param)
static my_bool execute (MYSQL_STMT *stmt, char *packet, ulong length)
int cli_stmt_execute (MYSQL_STMT *stmt)
static int stmt_read_row_no_data (MYSQL_STMT *stmt __attribute__((unused)), unsigned char **row __attribute__((unused)))
static int stmt_read_row_no_result_set (MYSQL_STMT *stmt __attribute__((unused)), unsigned char **row __attribute__((unused)))
my_bool STDCALL mysql_stmt_attr_set (MYSQL_STMT *stmt, enum enum_stmt_attr_type attr_type, const void *value)
my_bool STDCALL mysql_stmt_attr_get (MYSQL_STMT *stmt, enum enum_stmt_attr_type attr_type, void *value)
int STDCALL mysql_stmt_execute (MYSQL_STMT *stmt)
ulong STDCALL mysql_stmt_param_count (MYSQL_STMT *stmt)
my_ulonglong STDCALL mysql_stmt_affected_rows (MYSQL_STMT *stmt)
unsigned int STDCALL mysql_stmt_field_count (MYSQL_STMT *stmt)
my_ulonglong STDCALL mysql_stmt_insert_id (MYSQL_STMT *stmt)
my_bool STDCALL mysql_stmt_bind_param (MYSQL_STMT *stmt, MYSQL_BIND *bind)
my_bool STDCALL mysql_stmt_send_long_data (MYSQL_STMT *stmt, uint param_number, const char *data, ulong length)
static void read_binary_time (MYSQL_TIME *tm, uchar **pos)
static void read_binary_datetime (MYSQL_TIME *tm, uchar **pos)
static void read_binary_date (MYSQL_TIME *tm, uchar **pos)
static void fetch_string_with_conversion (MYSQL_BIND *param, char *value, uint length)
static void fetch_long_with_conversion (MYSQL_BIND *param, MYSQL_FIELD *field, longlong value, my_bool is_unsigned)
static void fetch_float_with_conversion (MYSQL_BIND *param, MYSQL_FIELD *field, double value, int width)
static void fetch_datetime_with_conversion (MYSQL_BIND *param, MYSQL_FIELD *field, MYSQL_TIME *time)
static void fetch_result_with_conversion (MYSQL_BIND *param, MYSQL_FIELD *field, uchar **row)
static void fetch_result_tinyint (MYSQL_BIND *param, MYSQL_FIELD *field, uchar **row)
static void fetch_result_short (MYSQL_BIND *param, MYSQL_FIELD *field, uchar **row)
static void fetch_result_int32 (MYSQL_BIND *param, MYSQL_FIELD *field __attribute__((unused)), uchar **row)
static void fetch_result_int64 (MYSQL_BIND *param, MYSQL_FIELD *field __attribute__((unused)), uchar **row)
static void fetch_result_float (MYSQL_BIND *param, MYSQL_FIELD *field __attribute__((unused)), uchar **row)
static void fetch_result_double (MYSQL_BIND *param, MYSQL_FIELD *field __attribute__((unused)), uchar **row)
static void fetch_result_time (MYSQL_BIND *param, MYSQL_FIELD *field __attribute__((unused)), uchar **row)
static void fetch_result_date (MYSQL_BIND *param, MYSQL_FIELD *field __attribute__((unused)), uchar **row)
static void fetch_result_datetime (MYSQL_BIND *param, MYSQL_FIELD *field __attribute__((unused)), uchar **row)
static void fetch_result_bin (MYSQL_BIND *param, MYSQL_FIELD *field __attribute__((unused)), uchar **row)
static void fetch_result_str (MYSQL_BIND *param, MYSQL_FIELD *field __attribute__((unused)), uchar **row)
static void skip_result_fixed (MYSQL_BIND *param, MYSQL_FIELD *field __attribute__((unused)), uchar **row)
static void skip_result_with_length (MYSQL_BIND *param __attribute__((unused)), MYSQL_FIELD *field __attribute__((unused)), uchar **row)
static void skip_result_string (MYSQL_BIND *param __attribute__((unused)), MYSQL_FIELD *field, uchar **row)
static my_bool is_binary_compatible (enum enum_field_types type1, enum enum_field_types type2)
my_bool STDCALL mysql_stmt_bind_result (MYSQL_STMT *stmt, MYSQL_BIND *bind)
static int stmt_fetch_row (MYSQL_STMT *stmt, uchar *row)
int cli_unbuffered_fetch (MYSQL *mysql, char **row)
int STDCALL mysql_stmt_fetch (MYSQL_STMT *stmt)
int STDCALL mysql_stmt_fetch_column (MYSQL_STMT *stmt, MYSQL_BIND *bind, uint column, ulong offset)
int cli_read_binary_rows (MYSQL_STMT *stmt)
int STDCALL mysql_stmt_store_result (MYSQL_STMT *stmt)
MYSQL_ROW_OFFSET STDCALL mysql_stmt_row_seek (MYSQL_STMT *stmt, MYSQL_ROW_OFFSET row)
MYSQL_ROW_OFFSET STDCALL mysql_stmt_row_tell (MYSQL_STMT *stmt)
void STDCALL mysql_stmt_data_seek (MYSQL_STMT *stmt, my_ulonglong row)
my_ulonglong STDCALL mysql_stmt_num_rows (MYSQL_STMT *stmt)
my_bool STDCALL mysql_stmt_free_result (MYSQL_STMT *stmt)
my_bool STDCALL mysql_stmt_close (MYSQL_STMT *stmt)
my_bool STDCALL mysql_stmt_reset (MYSQL_STMT *stmt)
uint STDCALL mysql_stmt_errno (MYSQL_STMT *stmt)
const char *STDCALL mysql_stmt_sqlstate (MYSQL_STMT *stmt)
const char *STDCALL mysql_stmt_error (MYSQL_STMT *stmt)
my_bool STDCALL mysql_commit (MYSQL *mysql)
my_bool STDCALL mysql_rollback (MYSQL *mysql)
my_bool STDCALL mysql_autocommit (MYSQL *mysql, my_bool auto_mode)
my_bool STDCALL mysql_more_results (MYSQL *mysql)
int STDCALL mysql_next_result (MYSQL *mysql)
MYSQL_RES *STDCALL mysql_use_result (MYSQL *mysql)
my_bool STDCALL mysql_read_query_result (MYSQL *mysql)

Variables

ulong net_buffer_length = 8192
ulong max_allowed_packet = 1024L*1024L*1024L
ulong net_read_timeout = CLIENT_NET_READ_TIMEOUT
ulong net_write_timeout = CLIENT_NET_WRITE_TIMEOUT
static my_bool mysql_client_init = 0
static my_bool org_my_init_done = 0
static MYSQL_PARAMETERS mysql_internal_parameters
static my_bool int_is_null_true = 1
static my_bool int_is_null_false = 0

Define Documentation

#define BIND_RESULT_DONE   1

Definition at line 1761 of file libmysql.c.

#define DEFAULT_PREFETCH_ROWS   (ulong) 1

Definition at line 1702 of file libmysql.c.

#define INADDR_NONE   -1

Definition at line 59 of file libmysql.c.

#define IS_TRUNCATED ( value,
is_unsigned,
min,
max,
umax   ) 

Value:

((is_unsigned) ? (((value) > (umax) || (value) < 0) ? 1 : 0) : \
                         (((value) > (max)  || (value) < (min)) ? 1 : 0))

Definition at line 1757 of file libmysql.c.

#define MAX_DATE_REP_LENGTH   5

Definition at line 1739 of file libmysql.c.

#define MAX_DATETIME_REP_LENGTH   12

Definition at line 1751 of file libmysql.c.

#define MAX_DOUBLE_STRING_REP_LENGTH   331

Definition at line 1753 of file libmysql.c.

#define MAX_LONG_DATA_LENGTH   8192

Definition at line 91 of file libmysql.c.

#define MAX_TIME_REP_LENGTH   13

Definition at line 1745 of file libmysql.c.

#define NOT_FIXED_DEC   31

#define REPORT_DATA_TRUNCATION   2

Definition at line 1767 of file libmysql.c.

#define RESET_LONG_DATA   2

Definition at line 1728 of file libmysql.c.

#define RESET_SERVER_SIDE   1

Definition at line 1727 of file libmysql.c.

#define RESET_STORE_RESULT   4

Definition at line 1729 of file libmysql.c.

#define SOCKET_ERROR   -1

Definition at line 84 of file libmysql.c.

#define unsigned_field ( A   )     ((A)->flags & UNSIGNED_FLAG)

Definition at line 92 of file libmysql.c.

Typedef Documentation

typedef struct st_default_local_infile default_local_infile_data

Function Documentation

static unsigned int alloc_stmt_fields ( MYSQL_STMT *  stmt  )  [static]

Definition at line 2108 of file libmysql.c.

References alloc_root(), st_mysql_stmt::bind, st_mysql_field::charsetnr, st_mysql_field::db, st_mysql_field::decimals, st_mysql_field::def, st_mysql::field_count, st_mysql_stmt::field_count, st_mysql::fields, st_mysql_stmt::fields, st_mysql_field::flags, st_mysql::last_used_con, st_mysql_field::length, st_mysql_field::max_length, st_mysql_stmt::mem_root, st_mysql_stmt::mysql, mysql, st_mysql_field::name, st_mysql_field::org_name, st_mysql_field::org_table, strdup_root(), st_mysql_field::table, and st_mysql_field::type.

02109 {
02110   MYSQL_FIELD *fields, *field, *end;
02111   MEM_ROOT *alloc= &stmt->mem_root;
02112   MYSQL *mysql= stmt->mysql->last_used_con;
02113 
02114   stmt->field_count= mysql->field_count;
02115 
02116   /*
02117     Get the field information for non-select statements
02118     like SHOW and DESCRIBE commands
02119   */
02120   if (!(stmt->fields= (MYSQL_FIELD *) alloc_root(alloc,
02121                                                  sizeof(MYSQL_FIELD) *
02122                                                  stmt->field_count)) ||
02123       !(stmt->bind= (MYSQL_BIND *) alloc_root(alloc,
02124                                               sizeof(MYSQL_BIND) *
02125                                               stmt->field_count)))
02126     return 0;
02127 
02128   for (fields= mysql->fields, end= fields+stmt->field_count,
02129          field= stmt->fields;
02130        field && fields < end; fields++, field++)
02131   {
02132     field->db       = strdup_root(alloc,fields->db);
02133     field->table    = strdup_root(alloc,fields->table);
02134     field->org_table= strdup_root(alloc,fields->org_table);
02135     field->name     = strdup_root(alloc,fields->name);
02136     field->org_name = strdup_root(alloc,fields->org_name);
02137     field->charsetnr= fields->charsetnr;
02138     field->length   = fields->length;
02139     field->type     = fields->type;
02140     field->flags    = fields->flags;
02141     field->decimals = fields->decimals;
02142     field->def      = fields->def ? strdup_root(alloc,fields->def): 0;
02143     field->max_length= 0;
02144   }
02145   return stmt->field_count;
02146 }

Here is the call graph for this function:

static void append_wild ( char *  to,
char *  end,
const char *  wild 
) [static]

Definition at line 240 of file libmysql.c.

References strmov().

00241 {
00242   end-=5;                                       /* Some extra */
00243   if (wild && wild[0])
00244   {
00245     to=strmov(to," like '");
00246     while (*wild && to < end)
00247     {
00248       if (*wild == '\\' || *wild == '\'')
00249         *to++='\\';
00250       *to++= *wild++;
00251     }
00252     if (*wild)                                  /* Too small buffer */
00253       *to++='%';                                /* Nicer this way */
00254     to[0]='\'';
00255     to[1]=0;
00256   }
00257 }

Here is the call graph for this function:

MYSQL_FIELD* cli_list_fields ( MYSQL *  mysql  ) 

Definition at line 1197 of file libmysql.c.

References cli_read_rows(), st_mysql::field_alloc, st_mysql::field_count, mysql, NULL, protocol_41, query, st_mysql::server_capabilities, and unpack_fields().

01198 {
01199   MYSQL_DATA *query;
01200   if (!(query= cli_read_rows(mysql,(MYSQL_FIELD*) 0, 
01201                              protocol_41(mysql) ? 8 : 6)))
01202     return NULL;
01203 
01204   mysql->field_count= (uint) query->rows;
01205   return unpack_fields(query,&mysql->field_alloc,
01206                        mysql->field_count, 1, mysql->server_capabilities);
01207 }

Here is the call graph for this function:

int cli_read_binary_rows ( MYSQL_STMT *  stmt  ) 

Definition at line 4628 of file libmysql.c.

References st_mysql_data::alloc, alloc_root(), cli_safe_read(), CR_OUT_OF_MEMORY, st_mysql_rows::data, st_mysql_data::data, DBUG_ENTER, DBUG_PRINT, DBUG_RETURN, err, st_net::last_errno, st_net::last_error, st_mysql::last_used_con, st_mysql_rows::length, memcpy, st_mysql_stmt::mysql, mysql, st_mysql::net, st_mysql_rows::next, packet_error, st_net::read_pos, st_mysql_stmt::result, st_mysql_data::rows, st_mysql::server_status, set_stmt_errmsg(), set_stmt_error(), st_net::sqlstate, uint2korr, unknown_sqlstate, and st_mysql::warning_count.

04629 {
04630   ulong      pkt_len;
04631   uchar      *cp;
04632   MYSQL      *mysql= stmt->mysql;
04633   MYSQL_DATA *result= &stmt->result;
04634   MYSQL_ROWS *cur, **prev_ptr= &result->data;
04635   NET        *net = &mysql->net;
04636   DBUG_ENTER("cli_read_binary_rows");
04637 
04638   mysql= mysql->last_used_con;
04639 
04640   while ((pkt_len= cli_safe_read(mysql)) != packet_error)
04641   {
04642     cp= net->read_pos;
04