开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
mysql.h
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：27k
源码类别：

MySQL数据库

开发平台：

Visual C++

mysql.h：源码内容
  1. /* Copyright (C) 2000-2003 MySQL AB
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  17. #ifndef _mysql_h
  18. #define _mysql_h
  20. #ifdef __CYGWIN__     /* CYGWIN implements a UNIX API */
  21. #undef WIN
  22. #undef _WIN
  23. #undef _WIN32
  24. #undef _WIN64
  25. #undef __WIN__
  26. #endif
  28. #ifdef __cplusplus
  29. extern "C" {
  30. #endif
  32. #ifndef _global_h /* If not standard header */
  33. #include <sys/types.h>
  34. #ifdef __LCC__
  35. #include <winsock.h> /* For windows */
  36. #endif
  37. typedef char my_bool;
  38. #if (defined(_WIN32) || defined(_WIN64)) && !defined(__WIN__)
  39. #define __WIN__
  40. #endif
  41. #if !defined(__WIN__)
  42. #define STDCALL
  43. #else
  44. #define STDCALL __stdcall
  45. #endif
  46. typedef char * gptr;
  48. #ifndef my_socket_defined
  49. #ifdef __WIN__
  50. #define my_socket SOCKET
  51. #else
  52. typedef int my_socket;
  53. #endif /* __WIN__ */
  54. #endif /* my_socket_defined */
  55. #endif /* _global_h */
  57. #include "mysql_com.h"
  58. #include "mysql_time.h"
  59. #include "mysql_version.h"
  60. #include "typelib.h"
  62. #include "my_list.h" /* for LISTs used in 'MYSQL' and 'MYSQL_STMT' */
  64. extern unsigned int mysql_port;
  65. extern char *mysql_unix_port;
  67. #define CLIENT_NET_READ_TIMEOUT 365*24*3600 /* Timeout on read */
  68. #define CLIENT_NET_WRITE_TIMEOUT 365*24*3600 /* Timeout on write */
  70. #ifdef __NETWARE__
  71. #pragma pack(push, 8) /* 8 byte alignment */
  72. #endif
  74. #define IS_PRI_KEY(n) ((n) & PRI_KEY_FLAG)
  75. #define IS_NOT_NULL(n) ((n) & NOT_NULL_FLAG)
  76. #define IS_BLOB(n) ((n) & BLOB_FLAG)
  77. #define IS_NUM(t) ((t) <= FIELD_TYPE_INT24 || (t) == FIELD_TYPE_YEAR)
  78. #define IS_NUM_FIELD(f)  ((f)->flags & NUM_FLAG)
  79. #define INTERNAL_NUM_FIELD(f) (((f)->type <= FIELD_TYPE_INT24 && ((f)->type != FIELD_TYPE_TIMESTAMP || (f)->length == 14 || (f)->length == 8)) || (f)->type == FIELD_TYPE_YEAR)
  82. typedef struct st_mysql_field {
  83.   char *name;                 /* Name of column */
  84.   char *org_name;             /* Original column name, if an alias */ 
  85.   char *table;                /* Table of column if column was a field */
  86.   char *org_table;            /* Org table name, if table was an alias */
  87.   char *db;                   /* Database for table */
  88.   char *catalog;       /* Catalog for table */
  89.   char *def;                  /* Default value (set by mysql_list_fields) */
  90.   unsigned long length;       /* Width of column (create length) */
  91.   unsigned long max_length;   /* Max width for selected set */
  92.   unsigned int name_length;
  93.   unsigned int org_name_length;
  94.   unsigned int table_length;
  95.   unsigned int org_table_length;
  96.   unsigned int db_length;
  97.   unsigned int catalog_length;
  98.   unsigned int def_length;
  99.   unsigned int flags;         /* Div flags */
  100.   unsigned int decimals;      /* Number of decimals in field */
  101.   unsigned int charsetnr;     /* Character set */
  102.   enum enum_field_types type; /* Type of field. See mysql_com.h for types */
  103. } MYSQL_FIELD;
  105. typedef char **MYSQL_ROW; /* return data as array of strings */
  106. typedef unsigned int MYSQL_FIELD_OFFSET; /* offset to current field */
  108. #ifndef _global_h
  109. #if defined(NO_CLIENT_LONG_LONG)
  110. typedef unsigned long my_ulonglong;
  111. #elif defined (__WIN__)
  112. typedef unsigned __int64 my_ulonglong;
  113. #else
  114. typedef unsigned long long my_ulonglong;
  115. #endif
  116. #endif
  118. #define MYSQL_COUNT_ERROR (~(my_ulonglong) 0)
  120. typedef struct st_mysql_rows {
  121.   struct st_mysql_rows *next; /* list of rows */
  122.   MYSQL_ROW data;
  123.   unsigned long length;
  124. } MYSQL_ROWS;
  126. typedef MYSQL_ROWS *MYSQL_ROW_OFFSET; /* offset to current row */
  128. #include "my_alloc.h"
  130. typedef struct st_mysql_data {
  131.   my_ulonglong rows;
  132.   unsigned int fields;
  133.   MYSQL_ROWS *data;
  134.   MEM_ROOT alloc;
  135. #if !defined(CHECK_EMBEDDED_DIFFERENCES) || defined(EMBEDDED_LIBRARY)
  136.   MYSQL_ROWS **prev_ptr;
  137. #endif
  138. } MYSQL_DATA;
  140. enum mysql_option 
  141. {
  142.   MYSQL_OPT_CONNECT_TIMEOUT, MYSQL_OPT_COMPRESS, MYSQL_OPT_NAMED_PIPE,
  143.   MYSQL_INIT_COMMAND, MYSQL_READ_DEFAULT_FILE, MYSQL_READ_DEFAULT_GROUP,
  144.   MYSQL_SET_CHARSET_DIR, MYSQL_SET_CHARSET_NAME, MYSQL_OPT_LOCAL_INFILE,
  145.   MYSQL_OPT_PROTOCOL, MYSQL_SHARED_MEMORY_BASE_NAME, MYSQL_OPT_READ_TIMEOUT,
  146.   MYSQL_OPT_WRITE_TIMEOUT, MYSQL_OPT_USE_RESULT,
  147.   MYSQL_OPT_USE_REMOTE_CONNECTION, MYSQL_OPT_USE_EMBEDDED_CONNECTION,
  148.   MYSQL_OPT_GUESS_CONNECTION, MYSQL_SET_CLIENT_IP, MYSQL_SECURE_AUTH
  149. };
  151. struct st_mysql_options {
  152.   unsigned int connect_timeout, read_timeout, write_timeout;
  153.   unsigned int port, protocol;
  154.   unsigned long client_flag;
  155.   char *host,*user,*password,*unix_socket,*db;
  156.   struct st_dynamic_array *init_commands;
  157.   char *my_cnf_file,*my_cnf_group, *charset_dir, *charset_name;
  158.   char *ssl_key; /* PEM key file */
  159.   char *ssl_cert; /* PEM cert file */
  160.   char *ssl_ca; /* PEM CA file */
  161.   char *ssl_capath; /* PEM directory of CA-s? */
  162.   char *ssl_cipher; /* cipher to use */
  163.   char *shared_memory_base_name;
  164.   unsigned long max_allowed_packet;
  165.   my_bool use_ssl; /* if to use SSL or not */
  166.   my_bool compress,named_pipe;
  167.  /*
  168.    On connect, find out the replication role of the server, and
  169.    establish connections to all the peers
  170.  */
  171.   my_bool rpl_probe;
  172.  /*
  173.    Each call to mysql_real_query() will parse it to tell if it is a read
  174.    or a write, and direct it to the slave or the master
  175.  */
  176.   my_bool rpl_parse;
  177.  /*
  178.    If set, never read from a master, only from slave, when doing
  179.    a read that is replication-aware
  180.  */
  181.   my_bool no_master_reads;
  182. #if !defined(CHECK_EMBEDDED_DIFFERENCES) || defined(EMBEDDED_LIBRARY)
  183.   my_bool separate_thread;
  184. #endif
  185.   enum mysql_option methods_to_use;
  186.   char *client_ip;
  187.   /* Refuse client connecting to server if it uses old (pre-4.1.1) protocol */
  188.   my_bool secure_auth;
  190.   /* function pointers for local infile support */
  191.   int (*local_infile_init)(void **, const char *, void *);
  192.   int (*local_infile_read)(void *, char *, unsigned int);
  193.   void (*local_infile_end)(void *);
  194.   int (*local_infile_error)(void *, char *, unsigned int);
  195.   void *local_infile_userdata;
  196. };
  198. enum mysql_status 
  199. {
  200.   MYSQL_STATUS_READY,MYSQL_STATUS_GET_RESULT,MYSQL_STATUS_USE_RESULT
  201. };
  203. enum mysql_protocol_type 
  204. {
  205.   MYSQL_PROTOCOL_DEFAULT, MYSQL_PROTOCOL_TCP, MYSQL_PROTOCOL_SOCKET,
  206.   MYSQL_PROTOCOL_PIPE, MYSQL_PROTOCOL_MEMORY
  207. };
  208. /*
  209.   There are three types of queries - the ones that have to go to
  210.   the master, the ones that go to a slave, and the adminstrative
  211.   type which must happen on the pivot connectioin
  212. */
  213. enum mysql_rpl_type 
  214. {
  215.   MYSQL_RPL_MASTER, MYSQL_RPL_SLAVE, MYSQL_RPL_ADMIN
  216. };
  218. struct st_mysql_methods;
  220. typedef struct st_mysql
  221. {
  222.   NET net; /* Communication parameters */
  223.   gptr connector_fd; /* ConnectorFd for SSL */
  224.   char *host,*user,*passwd,*unix_socket,*server_version,*host_info,*info;
  225.   char          *db;
  226.   struct charset_info_st *charset;
  227.   MYSQL_FIELD *fields;
  228.   MEM_ROOT field_alloc;
  229.   my_ulonglong affected_rows;
  230.   my_ulonglong insert_id; /* id if insert on table with NEXTNR */
  231.   my_ulonglong extra_info; /* Used by mysqlshow */
  232.   unsigned long thread_id; /* Id for connection in server */
  233.   unsigned long packet_length;
  234.   unsigned int port;
  235.   unsigned long client_flag,server_capabilities;
  236.   unsigned int protocol_version;
  237.   unsigned int field_count;
  238.   unsigned int  server_status;
  239.   unsigned int  server_language;
  240.   unsigned int warning_count;
  241.   struct st_mysql_options options;
  242.   enum mysql_status status;
  243.   my_bool free_me; /* If free in mysql_close */
  244.   my_bool reconnect; /* set to 1 if automatic reconnect */
  246.   /* session-wide random string */
  247.   char         scramble[SCRAMBLE_LENGTH+1];
  249.  /*
  250.    Set if this is the original connection, not a master or a slave we have
  251.    added though mysql_rpl_probe() or mysql_set_master()/ mysql_add_slave()
  252.  */
  253.   my_bool rpl_pivot;
  254.   /*
  255.     Pointers to the master, and the next slave connections, points to
  256.     itself if lone connection.
  257.   */
  258.   struct st_mysql* master, *next_slave;
  260.   struct st_mysql* last_used_slave; /* needed for round-robin slave pick */
  261.  /* needed for send/read/store/use result to work correctly with replication */
  262.   struct st_mysql* last_used_con;
  264.   LIST  *stmts;                     /* list of all statements */
  265.   const struct st_mysql_methods *methods;
  266.   void *thd;
  267.   /*
  268.     Points to boolean flag in MYSQL_RES  or MYSQL_STMT. We set this flag 
  269.     from mysql_stmt_close if close had to cancel result set of this object.
  270.   */
  271.   my_bool *unbuffered_fetch_owner;
  272. } MYSQL;
  274. typedef struct st_mysql_res {
  275.   my_ulonglong row_count;
  276.   MYSQL_FIELD *fields;
  277.   MYSQL_DATA *data;
  278.   MYSQL_ROWS *data_cursor;
  279.   unsigned long *lengths; /* column lengths of current row */
  280.   MYSQL *handle; /* for unbuffered reads */
  281.   MEM_ROOT field_alloc;
  282.   unsigned int field_count, current_field;
  283.   MYSQL_ROW row; /* If unbuffered read */
  284.   MYSQL_ROW current_row; /* buffer to current row */
  285.   my_bool eof; /* Used by mysql_fetch_row */
  286.   /* mysql_stmt_close() had to cancel this result */
  287.   my_bool       unbuffered_fetch_cancelled;  
  288.   const struct st_mysql_methods *methods;
  289. } MYSQL_RES;
  291. #define MAX_MYSQL_MANAGER_ERR 256  
  292. #define MAX_MYSQL_MANAGER_MSG 256
  294. #define MANAGER_OK           200
  295. #define MANAGER_INFO         250
  296. #define MANAGER_ACCESS       401
  297. #define MANAGER_CLIENT_ERR   450
  298. #define MANAGER_INTERNAL_ERR 500
  300. #if !defined(MYSQL_SERVER) && !defined(MYSQL_CLIENT)
  301. #define MYSQL_CLIENT
  302. #endif
  305. typedef struct st_mysql_manager
  306. {
  307.   NET net;
  308.   char *host,*user,*passwd;
  309.   unsigned int port;
  310.   my_bool free_me;
  311.   my_bool eof;
  312.   int cmd_status;
  313.   int last_errno;
  314.   char* net_buf,*net_buf_pos,*net_data_end;
  315.   int net_buf_size;
  316.   char last_error[MAX_MYSQL_MANAGER_ERR];
  317. } MYSQL_MANAGER;
  319. typedef struct st_mysql_parameters
  320. {
  321.   unsigned long *p_max_allowed_packet;
  322.   unsigned long *p_net_buffer_length;
  323. } MYSQL_PARAMETERS;
  325. #if !defined(MYSQL_SERVER) && !defined(EMBEDDED_LIBRARY)
  326. #define max_allowed_packet (*mysql_get_parameters()->p_max_allowed_packet)
  327. #define net_buffer_length (*mysql_get_parameters()->p_net_buffer_length)
  328. #endif
  330. /*
  331.   Set up and bring down the server; to ensure that applications will
  332.   work when linked against either the standard client library or the
  333.   embedded server library, these functions should be called.
  334. */
  335. int STDCALL mysql_server_init(int argc, char **argv, char **groups);
  336. void STDCALL mysql_server_end(void);
  337. /*
  338.   mysql_server_init/end need to be called when using libmysqld or
  339.   libmysqlclient (exactly, mysql_server_init() is called by mysql_init() so
  340.   you don't need to call it explicitely; but you need to call
  341.   mysql_server_end() to free memory). The names are a bit misleading
  342.   (mysql_SERVER* to be used when using libmysqlCLIENT). So we add more general
  343.   names which suit well whether you're using libmysqld or libmysqlclient. We
  344.   intend to promote these aliases over the mysql_server* ones.
  345. */
  346. #define mysql_library_init mysql_server_init
  347. #define mysql_library_end mysql_server_end
  349. MYSQL_PARAMETERS *STDCALL mysql_get_parameters(void);
  351. /*
  352.   Set up and bring down a thread; these function should be called
  353.   for each thread in an application which opens at least one MySQL
  354.   connection.  All uses of the connection(s) should be between these
  355.   function calls.
  356. */
  357. my_bool STDCALL mysql_thread_init(void);
  358. void STDCALL mysql_thread_end(void);
  360. /*
  361.   Functions to get information from the MYSQL and MYSQL_RES structures
  362.   Should definitely be used if one uses shared libraries.
  363. */
  365. my_ulonglong STDCALL mysql_num_rows(MYSQL_RES *res);
  366. unsigned int STDCALL mysql_num_fields(MYSQL_RES *res);
  367. my_bool STDCALL mysql_eof(MYSQL_RES *res);
  368. MYSQL_FIELD *STDCALL mysql_fetch_field_direct(MYSQL_RES *res,
  369.       unsigned int fieldnr);
  370. MYSQL_FIELD * STDCALL mysql_fetch_fields(MYSQL_RES *res);
  371. MYSQL_ROW_OFFSET STDCALL mysql_row_tell(MYSQL_RES *res);
  372. MYSQL_FIELD_OFFSET STDCALL mysql_field_tell(MYSQL_RES *res);
  374. unsigned int STDCALL mysql_field_count(MYSQL *mysql);
  375. my_ulonglong STDCALL mysql_affected_rows(MYSQL *mysql);
  376. my_ulonglong STDCALL mysql_insert_id(MYSQL *mysql);
  377. unsigned int STDCALL mysql_errno(MYSQL *mysql);
  378. const char * STDCALL mysql_error(MYSQL *mysql);
  379. const char *STDCALL mysql_sqlstate(MYSQL *mysql);
  380. unsigned int STDCALL mysql_warning_count(MYSQL *mysql);
  381. const char * STDCALL mysql_info(MYSQL *mysql);
  382. unsigned long STDCALL mysql_thread_id(MYSQL *mysql);
  383. const char * STDCALL mysql_character_set_name(MYSQL *mysql);
  384. int STDCALL mysql_set_character_set(MYSQL *mysql, const char *csname);
  386. MYSQL * STDCALL mysql_init(MYSQL *mysql);
  387. my_bool STDCALL mysql_ssl_set(MYSQL *mysql, const char *key,
  388.       const char *cert, const char *ca,
  389.       const char *capath, const char *cipher);
  390. my_bool STDCALL mysql_change_user(MYSQL *mysql, const char *user, 
  391.   const char *passwd, const char *db);
  392. MYSQL * STDCALL mysql_real_connect(MYSQL *mysql, const char *host,
  393.    const char *user,
  394.    const char *passwd,
  395.    const char *db,
  396.    unsigned int port,
  397.    const char *unix_socket,
  398.    unsigned long clientflag);
  399. int STDCALL mysql_select_db(MYSQL *mysql, const char *db);
  400. int STDCALL mysql_query(MYSQL *mysql, const char *q);
  401. int STDCALL mysql_send_query(MYSQL *mysql, const char *q,
  402.  unsigned long length);
  403. int STDCALL mysql_real_query(MYSQL *mysql, const char *q,
  404. unsigned long length);
  405. MYSQL_RES *     STDCALL mysql_store_result(MYSQL *mysql);
  406. MYSQL_RES *     STDCALL mysql_use_result(MYSQL *mysql);
  408. /* perform query on master */
  409. my_bool STDCALL mysql_master_query(MYSQL *mysql, const char *q,
  410.    unsigned long length);
  411. my_bool STDCALL mysql_master_send_query(MYSQL *mysql, const char *q,
  412. unsigned long length);
  413. /* perform query on slave */  
  414. my_bool STDCALL mysql_slave_query(MYSQL *mysql, const char *q,
  415.   unsigned long length);
  416. my_bool STDCALL mysql_slave_send_query(MYSQL *mysql, const char *q,
  417.        unsigned long length);
  419. /* local infile support */
  421. #define LOCAL_INFILE_ERROR_LEN 512
  423. void
  424. mysql_set_local_infile_handler(MYSQL *mysql,
  425.                                int (*local_infile_init)(void **, const char *,
  426.                             void *),
  427.                                int (*local_infile_read)(void *, char *,
  428. unsigned int),
  429.                                void (*local_infile_end)(void *),
  430.                                int (*local_infile_error)(void *, char*,
  431.  unsigned int),
  432.                                void *);
  434. void
  435. mysql_set_local_infile_default(MYSQL *mysql);
  438. /*
  439.   enable/disable parsing of all queries to decide if they go on master or
  440.   slave
  441. */
  442. void            STDCALL mysql_enable_rpl_parse(MYSQL* mysql);
  443. void            STDCALL mysql_disable_rpl_parse(MYSQL* mysql);
  444. /* get the value of the parse flag */  
  445. int             STDCALL mysql_rpl_parse_enabled(MYSQL* mysql);
  447. /*  enable/disable reads from master */
  448. void            STDCALL mysql_enable_reads_from_master(MYSQL* mysql);
  449. void            STDCALL mysql_disable_reads_from_master(MYSQL* mysql);
  450. /* get the value of the master read flag */  
  451. my_bool STDCALL mysql_reads_from_master_enabled(MYSQL* mysql);
  453. enum mysql_rpl_type     STDCALL mysql_rpl_query_type(const char* q, int len);  
  455. /* discover the master and its slaves */  
  456. my_bool STDCALL mysql_rpl_probe(MYSQL* mysql);
  458. /* set the master, close/free the old one, if it is not a pivot */
  459. int             STDCALL mysql_set_master(MYSQL* mysql, const char* host,
  460.  unsigned int port,
  461.  const char* user,
  462.  const char* passwd);
  463. int             STDCALL mysql_add_slave(MYSQL* mysql, const char* host,
  464. unsigned int port,
  465. const char* user,
  466. const char* passwd);
  468. int STDCALL mysql_shutdown(MYSQL *mysql,
  469.                                        enum mysql_enum_shutdown_level
  470.                                        shutdown_level);
  471. int STDCALL mysql_dump_debug_info(MYSQL *mysql);
  472. int STDCALL mysql_refresh(MYSQL *mysql,
  473.      unsigned int refresh_options);
  474. int STDCALL mysql_kill(MYSQL *mysql,unsigned long pid);
  475. int STDCALL mysql_set_server_option(MYSQL *mysql,
  476. enum enum_mysql_set_option
  477. option);
  478. int STDCALL mysql_ping(MYSQL *mysql);
  479. const char * STDCALL mysql_stat(MYSQL *mysql);
  480. const char * STDCALL mysql_get_server_info(MYSQL *mysql);
  481. const char * STDCALL mysql_get_client_info(void);
  482. unsigned long STDCALL mysql_get_client_version(void);
  483. const char * STDCALL mysql_get_host_info(MYSQL *mysql);
  484. unsigned long STDCALL mysql_get_server_version(MYSQL *mysql);
  485. unsigned int STDCALL mysql_get_proto_info(MYSQL *mysql);
  486. MYSQL_RES * STDCALL mysql_list_dbs(MYSQL *mysql,const char *wild);
  487. MYSQL_RES * STDCALL mysql_list_tables(MYSQL *mysql,const char *wild);
  488. MYSQL_RES * STDCALL mysql_list_processes(MYSQL *mysql);
  489. int STDCALL mysql_options(MYSQL *mysql,enum mysql_option option,
  490.       const char *arg);
  491. void STDCALL mysql_free_result(MYSQL_RES *result);
  492. void STDCALL mysql_data_seek(MYSQL_RES *result,
  493. my_ulonglong offset);
  494. MYSQL_ROW_OFFSET STDCALL mysql_row_seek(MYSQL_RES *result,
  495. MYSQL_ROW_OFFSET offset);
  496. MYSQL_FIELD_OFFSET STDCALL mysql_field_seek(MYSQL_RES *result,
  497.    MYSQL_FIELD_OFFSET offset);
  498. MYSQL_ROW STDCALL mysql_fetch_row(MYSQL_RES *result);
  499. unsigned long * STDCALL mysql_fetch_lengths(MYSQL_RES *result);
  500. MYSQL_FIELD * STDCALL mysql_fetch_field(MYSQL_RES *result);
  501. MYSQL_RES *     STDCALL mysql_list_fields(MYSQL *mysql, const char *table,
  502.   const char *wild);
  503. unsigned long STDCALL mysql_escape_string(char *to,const char *from,
  504.     unsigned long from_length);
  505. unsigned long STDCALL mysql_hex_string(char *to,const char *from,
  506.                                          unsigned long from_length);
  507. unsigned long STDCALL mysql_real_escape_string(MYSQL *mysql,
  508.        char *to,const char *from,
  509.        unsigned long length);
  510. void STDCALL mysql_debug(const char *debug);
  511. char * STDCALL mysql_odbc_escape_string(MYSQL *mysql,
  512.  char *to,
  513.  unsigned long to_length,
  514.  const char *from,
  515.  unsigned long from_length,
  516.  void *param,
  517.  char *
  518.  (*extend_buffer)
  519.  (void *, char *to,
  520.   unsigned long *length));
  521. void  STDCALL myodbc_remove_escape(MYSQL *mysql,char *name);
  522. unsigned int STDCALL mysql_thread_safe(void);
  523. my_bool STDCALL mysql_embedded(void);
  524. MYSQL_MANAGER*  STDCALL mysql_manager_init(MYSQL_MANAGER* con);  
  525. MYSQL_MANAGER*  STDCALL mysql_manager_connect(MYSQL_MANAGER* con,
  526.       const char* host,
  527.       const char* user,
  528.       const char* passwd,
  529.       unsigned int port);
  530. void            STDCALL mysql_manager_close(MYSQL_MANAGER* con);
  531. int             STDCALL mysql_manager_command(MYSQL_MANAGER* con,
  532. const char* cmd, int cmd_len);
  533. int             STDCALL mysql_manager_fetch_line(MYSQL_MANAGER* con,
  534.   char* res_buf,
  535.  int res_buf_size);
  536. my_bool         STDCALL mysql_read_query_result(MYSQL *mysql);
  539. /*
  540.   The following definitions are added for the enhanced 
  541.   client-server protocol
  542. */
  544. /* statement state */
  545. enum enum_mysql_stmt_state
  546. {
  547.   MYSQL_STMT_INIT_DONE= 1, MYSQL_STMT_PREPARE_DONE, MYSQL_STMT_EXECUTE_DONE,
  548.   MYSQL_STMT_FETCH_DONE
  549. };
  552. /* bind structure */
  553. typedef struct st_mysql_bind
  554. {
  555.   unsigned long *length;          /* output length pointer */
  556.   my_bool       *is_null;   /* Pointer to null indicator */
  557.   void *buffer;   /* buffer to get/put data */
  558.   enum enum_field_types buffer_type; /* buffer type */
  559.   unsigned long buffer_length;    /* buffer length, must be set for str/binary */  
  561.   /* Following are for internal use. Set by mysql_stmt_bind_param */
  562.   unsigned char *inter_buffer;    /* for the current data position */
  563.   unsigned long offset;           /* offset position for char/binary fetch */
  564.   unsigned long internal_length;  /* Used if length is 0 */
  565.   unsigned int param_number;   /* For null count and error messages */
  566.   unsigned int  pack_length;   /* Internal length for packed data */
  567.   my_bool       is_unsigned;      /* set if integer type is unsigned */
  568.   my_bool long_data_used;   /* If used with mysql_send_long_data */
  569.   my_bool internal_is_null; /* Used if is_null is 0 */
  570.   void (*store_param_func)(NET *net, struct st_mysql_bind *param);
  571.   void (*fetch_result)(struct st_mysql_bind *, unsigned char **row);
  572.   void (*skip_result)(struct st_mysql_bind *, MYSQL_FIELD *,
  573.       unsigned char **row);
  574. } MYSQL_BIND;
  577. /* statement handler */
  578. typedef struct st_mysql_stmt
  579. {
  580.   MEM_ROOT       mem_root;             /* root allocations */
  581.   LIST           list;                 /* list to keep track of all stmts */
  582.   MYSQL          *mysql;               /* connection handle */
  583.   MYSQL_BIND     *params;              /* input parameters */
  584.   MYSQL_BIND     *bind;                /* output parameters */
  585.   MYSQL_FIELD    *fields;              /* result set metadata */
  586.   MYSQL_DATA     result;               /* cached result set */
  587.   MYSQL_ROWS     *data_cursor;         /* current row in cached result */
  588.   /* copy of mysql->affected_rows after statement execution */
  589.   my_ulonglong   affected_rows;
  590.   my_ulonglong   insert_id;            /* copy of mysql->insert_id */
  591.   /*
  592.     mysql_stmt_fetch() calls this function to fetch one row (it's different
  593.     for buffered, unbuffered and cursor fetch).
  594.   */
  595.   int            (*read_row_func)(struct st_mysql_stmt *stmt, 
  596.                                   unsigned char **row);
  597.   unsigned long  stmt_id;        /* Id for prepared statement */
  598.   unsigned int  last_errno;        /* error code */
  599.   unsigned int   param_count;          /* input parameter count */
  600.   unsigned int   field_count;          /* number of columns in result set */
  601.   enum enum_mysql_stmt_state state;    /* statement state */
  602.   char  last_error[MYSQL_ERRMSG_SIZE]; /* error message */
  603.   char  sqlstate[SQLSTATE_LENGTH+1];
  604.   /* Types of input parameters should be sent to server */
  605.   my_bool        send_types_to_server;
  606.   my_bool        bind_param_done;      /* input buffers were supplied */
  607.   my_bool        bind_result_done;     /* output buffers were supplied */
  608.   /* mysql_stmt_close() had to cancel this result */
  609.   my_bool       unbuffered_fetch_cancelled;  
  610.   /*
  611.     Is set to true if we need to calculate field->max_length for 
  612.     metadata fields when doing mysql_stmt_store_result.
  613.   */
  614.   my_bool       update_max_length;     
  615. } MYSQL_STMT;
  617. enum enum_stmt_attr_type
  618. {
  619.   /*
  620.     When doing mysql_stmt_store_result calculate max_length attribute
  621.     of statement metadata. This is to be consistent with the old API, 
  622.     where this was done automatically.
  623.     In the new API we do that only by request because it slows down
  624.     mysql_stmt_store_result sufficiently.
  625.   */
  626.   STMT_ATTR_UPDATE_MAX_LENGTH
  627. };
  630. typedef struct st_mysql_methods
  631. {
  632.   my_bool (*read_query_result)(MYSQL *mysql);
  633.   my_bool (*advanced_command)(MYSQL *mysql,
  634.       enum enum_server_command command,
  635.       const char *header,
  636.       unsigned long header_length,
  637.       const char *arg,
  638.       unsigned long arg_length,
  639.       my_bool skip_check);
  640.   MYSQL_DATA *(*read_rows)(MYSQL *mysql,MYSQL_FIELD *mysql_fields,
  641.    unsigned int fields);
  642.   MYSQL_RES * (*use_result)(MYSQL *mysql);
  643.   void (*fetch_lengths)(unsigned long *to, 
  644. MYSQL_ROW column, unsigned int field_count);
  645.   void (*flush_use_result)(MYSQL *mysql);
  646. #if !defined(MYSQL_SERVER) || defined(EMBEDDED_LIBRARY)
  647.   MYSQL_FIELD * (*list_fields)(MYSQL *mysql);
  648.   my_bool (*read_prepare_result)(MYSQL *mysql, MYSQL_STMT *stmt);
  649.   int (*stmt_execute)(MYSQL_STMT *stmt);
  650.   int (*read_binary_rows)(MYSQL_STMT *stmt);
  651.   int (*unbuffered_fetch)(MYSQL *mysql, char **row);
  652.   void (*free_embedded_thd)(MYSQL *mysql);
  653.   const char *(*read_statistics)(MYSQL *mysql);
  654.   my_bool (*next_result)(MYSQL *mysql);
  655.   int (*read_change_user_result)(MYSQL *mysql, char *buff, const char *passwd);
  656. #endif
  657. } MYSQL_METHODS;
  660. MYSQL_STMT * STDCALL mysql_stmt_init(MYSQL *mysql);
  661. int STDCALL mysql_stmt_prepare(MYSQL_STMT *stmt, const char *query,
  662.                                unsigned long length);
  663. int STDCALL mysql_stmt_execute(MYSQL_STMT *stmt);
  664. int STDCALL mysql_stmt_fetch(MYSQL_STMT *stmt);
  665. int STDCALL mysql_stmt_fetch_column(MYSQL_STMT *stmt, MYSQL_BIND *bind, 
  666.                                     unsigned int column,
  667.                                     unsigned long offset);
  668. int STDCALL mysql_stmt_store_result(MYSQL_STMT *stmt);
  669. unsigned long STDCALL mysql_stmt_param_count(MYSQL_STMT * stmt);
  670. my_bool STDCALL mysql_stmt_attr_set(MYSQL_STMT *stmt,
  671.                                     enum enum_stmt_attr_type attr_type,
  672.                                     const void *attr);
  673. my_bool STDCALL mysql_stmt_attr_get(MYSQL_STMT *stmt,
  674.                                     enum enum_stmt_attr_type attr_type,
  675.                                     void *attr);
  676. my_bool STDCALL mysql_stmt_bind_param(MYSQL_STMT * stmt, MYSQL_BIND * bnd);
  677. my_bool STDCALL mysql_stmt_bind_result(MYSQL_STMT * stmt, MYSQL_BIND * bnd);
  678. my_bool STDCALL mysql_stmt_close(MYSQL_STMT * stmt);
  679. my_bool STDCALL mysql_stmt_reset(MYSQL_STMT * stmt);
  680. my_bool STDCALL mysql_stmt_free_result(MYSQL_STMT *stmt);
  681. my_bool STDCALL mysql_stmt_send_long_data(MYSQL_STMT *stmt, 
  682.                                           unsigned int param_number,
  683.                                           const char *data, 
  684.                                           unsigned long length);
  685. MYSQL_RES *STDCALL mysql_stmt_result_metadata(MYSQL_STMT *stmt);
  686. MYSQL_RES *STDCALL mysql_stmt_param_metadata(MYSQL_STMT *stmt);
  687. unsigned int STDCALL mysql_stmt_errno(MYSQL_STMT * stmt);
  688. const char *STDCALL mysql_stmt_error(MYSQL_STMT * stmt);
  689. const char *STDCALL mysql_stmt_sqlstate(MYSQL_STMT * stmt);
  690. MYSQL_ROW_OFFSET STDCALL mysql_stmt_row_seek(MYSQL_STMT *stmt, 
  691.                                              MYSQL_ROW_OFFSET offset);
  692. MYSQL_ROW_OFFSET STDCALL mysql_stmt_row_tell(MYSQL_STMT *stmt);
  693. void STDCALL mysql_stmt_data_seek(MYSQL_STMT *stmt, my_ulonglong offset);
  694. my_ulonglong STDCALL mysql_stmt_num_rows(MYSQL_STMT *stmt);
  695. my_ulonglong STDCALL mysql_stmt_affected_rows(MYSQL_STMT *stmt);
  696. my_ulonglong STDCALL mysql_stmt_insert_id(MYSQL_STMT *stmt);
  697. unsigned int STDCALL mysql_stmt_field_count(MYSQL_STMT *stmt);
  699. my_bool STDCALL mysql_commit(MYSQL * mysql);
  700. my_bool STDCALL mysql_rollback(MYSQL * mysql);
  701. my_bool STDCALL mysql_autocommit(MYSQL * mysql, my_bool auto_mode);
  702. my_bool STDCALL mysql_more_results(MYSQL *mysql);
  703. int STDCALL mysql_next_result(MYSQL *mysql);
  704. void STDCALL mysql_close(MYSQL *sock);
  707. /* status return codes */
  708. #define MYSQL_NO_DATA      100
  710. #define mysql_reload(mysql) mysql_refresh((mysql),REFRESH_GRANT)
  712. #ifdef USE_OLD_FUNCTIONS
  713. MYSQL * STDCALL mysql_connect(MYSQL *mysql, const char *host,
  714.       const char *user, const char *passwd);
  715. int STDCALL mysql_create_db(MYSQL *mysql, const char *DB);
  716. int STDCALL mysql_drop_db(MYSQL *mysql, const char *DB);
  717. #define  mysql_reload(mysql) mysql_refresh((mysql),REFRESH_GRANT)
  718. #endif
  719. #define HAVE_MYSQL_REAL_CONNECT
  721. /*
  722.   The following functions are mainly exported because of mysqlbinlog;
  723.   They are not for general usage
  724. */
  726. #define simple_command(mysql, command, arg, length, skip_check) 
  727.   (*(mysql)->methods->advanced_command)(mysql, command,         
  728. NullS, 0, arg, length, skip_check)
  729. unsigned long net_safe_read(MYSQL* mysql);
  731. #ifdef __NETWARE__
  732. #pragma pack(pop) /* restore alignment */
  733. #endif
  735. #ifdef __cplusplus
  736. }
  737. #endif
  739. #endif /* _mysql_h */