mysql_com.h
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:10k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
  2.    
  3.    This library is free software; you can redistribute it and/or
  4.    modify it under the terms of the GNU Library General Public
  5.    License as published by the Free Software Foundation; either
  6.    version 2 of the License, or (at your option) any later version.
  7.    
  8.    This library 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 GNU
  11.    Library General Public License for more details.
  12.    
  13.    You should have received a copy of the GNU Library General Public
  14.    License along with this library; if not, write to the Free
  15.    Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
  16.    MA 02111-1307, USA */
  17. /*
  18. ** Common definition between mysql server & client
  19. */
  20. #ifndef _mysql_com_h
  21. #define _mysql_com_h
  22. #define NAME_LEN 64 /* Field/table name length */
  23. #define HOSTNAME_LENGTH 60
  24. #define USERNAME_LENGTH 16
  25. #define LOCAL_HOST "localhost"
  26. #define LOCAL_HOST_NAMEDPIPE "."
  27. #if defined(__EMX__) || defined(__OS2__)
  28. #undef MYSQL_UNIX_ADDR
  29. #define MYSQL_OS2_ADDR "\socket\MySQL"
  30. #define MYSQL_UNIX_ADDR MYSQL_OS2_ADDR
  31. #endif
  32. #if defined(__WIN__) && !defined( _CUSTOMCONFIG_)
  33. #define MYSQL_NAMEDPIPE "MySQL"
  34. #define MYSQL_SERVICENAME "MySql"
  35. #endif /* __WIN__ */
  36. enum enum_server_command {COM_SLEEP,COM_QUIT,COM_INIT_DB,COM_QUERY,
  37.   COM_FIELD_LIST,COM_CREATE_DB,COM_DROP_DB,COM_REFRESH,
  38.   COM_SHUTDOWN,COM_STATISTICS,
  39.   COM_PROCESS_INFO,COM_CONNECT,COM_PROCESS_KILL,
  40.   COM_DEBUG,COM_PING,COM_TIME,COM_DELAYED_INSERT,
  41.   COM_CHANGE_USER, COM_BINLOG_DUMP,
  42.                           COM_TABLE_DUMP};
  43. #define NOT_NULL_FLAG 1 /* Field can't be NULL */
  44. #define PRI_KEY_FLAG 2 /* Field is part of a primary key */
  45. #define UNIQUE_KEY_FLAG 4 /* Field is part of a unique key */
  46. #define MULTIPLE_KEY_FLAG 8 /* Field is part of a key */
  47. #define BLOB_FLAG 16 /* Field is a blob */
  48. #define UNSIGNED_FLAG 32 /* Field is unsigned */
  49. #define ZEROFILL_FLAG 64 /* Field is zerofill */
  50. #define BINARY_FLAG 128
  51. /* The following are only sent to new clients */
  52. #define ENUM_FLAG 256 /* field is an enum */
  53. #define AUTO_INCREMENT_FLAG 512 /* field is a autoincrement field */
  54. #define TIMESTAMP_FLAG 1024 /* Field is a timestamp */
  55. #define SET_FLAG 2048 /* field is a set */
  56. #define PART_KEY_FLAG 16384 /* Intern; Part of some key */
  57. #define GROUP_FLAG 32768 /* Intern: Group field */
  58. #define UNIQUE_FLAG 65536 /* Intern: Used by sql_yacc */
  59. #define REFRESH_GRANT 1 /* Refresh grant tables */
  60. #define REFRESH_LOG 2 /* Start on new log file */
  61. #define REFRESH_TABLES 4 /* close all tables */
  62. #define REFRESH_HOSTS 8 /* Flush host cache */
  63. #define REFRESH_STATUS 16 /* Flush status variables */
  64. #define REFRESH_THREADS 32 /* Flush status variables */
  65. #define REFRESH_SLAVE           64      /* Reset master info and restart slave
  66.    thread */
  67. #define REFRESH_MASTER          128     /* Remove all bin logs in the index
  68.    and truncate the index */
  69. /* The following can't be set with mysql_refresh() */
  70. #define REFRESH_READ_LOCK 16384 /* Lock tables for read */
  71. #define REFRESH_FAST 32768 /* Intern flag */
  72. #define CLIENT_LONG_PASSWORD 1 /* new more secure passwords */
  73. #define CLIENT_FOUND_ROWS 2 /* Found instead of affected rows */
  74. #define CLIENT_LONG_FLAG 4 /* Get all column flags */
  75. #define CLIENT_CONNECT_WITH_DB 8 /* One can specify db on connect */
  76. #define CLIENT_NO_SCHEMA 16 /* Don't allow database.table.column */
  77. #define CLIENT_COMPRESS 32 /* Can use compression protocol */
  78. #define CLIENT_ODBC 64 /* Odbc client */
  79. #define CLIENT_LOCAL_FILES 128 /* Can use LOAD DATA LOCAL */
  80. #define CLIENT_IGNORE_SPACE 256 /* Ignore spaces before '(' */
  81. #define CLIENT_CHANGE_USER 512 /* Support the mysql_change_user() */
  82. #define CLIENT_INTERACTIVE 1024 /* This is an interactive client */
  83. #define CLIENT_SSL              2048     /* Switch to SSL after handshake */
  84. #define CLIENT_IGNORE_SIGPIPE   4096     /* IGNORE sigpipes */
  85. #define CLIENT_TRANSACTIONS 8196 /* Client knows about transactions */
  86. #define SERVER_STATUS_IN_TRANS  1 /* Transaction has started */
  87. #define SERVER_STATUS_AUTOCOMMIT 2 /* Server in auto_commit mode */
  88. #define MYSQL_ERRMSG_SIZE 200
  89. #define NET_READ_TIMEOUT 30 /* Timeout on read */
  90. #define NET_WRITE_TIMEOUT 60 /* Timeout on write */
  91. #define NET_WAIT_TIMEOUT 8*60*60 /* Wait for new query */
  92. #ifndef Vio_defined
  93. #define Vio_defined
  94. #ifdef HAVE_VIO
  95. class Vio; /* Fill Vio class in C++ */
  96. #else
  97. struct st_vio; /* Only C */
  98. typedef struct st_vio Vio;
  99. #endif
  100. #endif
  101. typedef struct st_net {
  102.   Vio* vio;
  103.   my_socket fd; /* For Perl DBI/dbd */
  104.   int fcntl;
  105.   unsigned char *buff,*buff_end,*write_pos,*read_pos;
  106.   char last_error[MYSQL_ERRMSG_SIZE];
  107.   unsigned int last_errno,max_packet,timeout,pkt_nr;
  108.   unsigned char error;
  109.   my_bool return_errno,compress;
  110.   my_bool no_send_ok; /* needed if we are doing several
  111.    queries in one command ( as in LOAD TABLE ... FROM MASTER ),
  112.    and do not want to confuse the client with OK at the wrong time
  113.       */
  114.   unsigned long remain_in_buf,length, buf_length, where_b;
  115.   unsigned int *return_status;
  116.   unsigned char reading_or_writing;
  117.   char save_char;
  118. } NET;
  119. #define packet_error ((unsigned int) -1)
  120. enum enum_field_types { FIELD_TYPE_DECIMAL, FIELD_TYPE_TINY,
  121. FIELD_TYPE_SHORT,  FIELD_TYPE_LONG,
  122. FIELD_TYPE_FLOAT,  FIELD_TYPE_DOUBLE,
  123. FIELD_TYPE_NULL,   FIELD_TYPE_TIMESTAMP,
  124. FIELD_TYPE_LONGLONG,FIELD_TYPE_INT24,
  125. FIELD_TYPE_DATE,   FIELD_TYPE_TIME,
  126. FIELD_TYPE_DATETIME, FIELD_TYPE_YEAR,
  127. FIELD_TYPE_NEWDATE,
  128. FIELD_TYPE_ENUM=247,
  129. FIELD_TYPE_SET=248,
  130. FIELD_TYPE_TINY_BLOB=249,
  131. FIELD_TYPE_MEDIUM_BLOB=250,
  132. FIELD_TYPE_LONG_BLOB=251,
  133. FIELD_TYPE_BLOB=252,
  134. FIELD_TYPE_VAR_STRING=253,
  135. FIELD_TYPE_STRING=254
  136. };
  137. #define FIELD_TYPE_CHAR FIELD_TYPE_TINY /* For compability */
  138. #define FIELD_TYPE_INTERVAL FIELD_TYPE_ENUM /* For compability */
  139. /* Shutdown/kill enums and constants */ 
  140. /* Bits for THD::killable. */
  141. #define MYSQL_SHUTDOWN_KILLABLE_CONNECT    (unsigned char)(1 << 0)
  142. #define MYSQL_SHUTDOWN_KILLABLE_TRANS      (unsigned char)(1 << 1)
  143. #define MYSQL_SHUTDOWN_KILLABLE_LOCK_TABLE (unsigned char)(1 << 2)
  144. #define MYSQL_SHUTDOWN_KILLABLE_UPDATE     (unsigned char)(1 << 3)
  145. enum mysql_enum_shutdown_level {
  146.   /*
  147.     We want levels to be in growing order of hardness (because we use number
  148.     comparisons). Note that DEFAULT does not respect the growing property, but
  149.     it's ok.
  150.   */
  151.   DEFAULT= 0,
  152.   /* wait for existing connections to finish */
  153.   WAIT_CONNECTIONS= MYSQL_SHUTDOWN_KILLABLE_CONNECT,
  154.   /* wait for existing trans to finish */
  155.   WAIT_TRANSACTIONS= MYSQL_SHUTDOWN_KILLABLE_TRANS,
  156.   /* wait for existing updates to finish (=> no partial MyISAM update) */
  157.   WAIT_UPDATES= MYSQL_SHUTDOWN_KILLABLE_UPDATE,
  158.   /* flush InnoDB buffers and other storage engines' buffers*/
  159.   WAIT_ALL_BUFFERS= (MYSQL_SHUTDOWN_KILLABLE_UPDATE << 1),
  160.   /* don't flush InnoDB buffers, flush other storage engines' buffers*/
  161.   WAIT_CRITICAL_BUFFERS= (MYSQL_SHUTDOWN_KILLABLE_UPDATE << 1) + 1,
  162.   /* Now the 2 levels of the KILL command */
  163. #if MYSQL_VERSION_ID >= 50000
  164.   KILL_QUERY= 254,
  165. #endif
  166.   KILL_CONNECTION= 255
  167. };
  168. extern unsigned long max_allowed_packet;
  169. extern unsigned long net_buffer_length;
  170. #define net_new_transaction(net) ((net)->pkt_nr=0)
  171. int my_net_init(NET *net, Vio* vio);
  172. void net_end(NET *net);
  173. void net_clear(NET *net);
  174. int net_flush(NET *net);
  175. int my_net_write(NET *net,const char *packet,unsigned long len);
  176. int net_write_command(NET *net,unsigned char command,const char *packet,
  177.   unsigned long len);
  178. int net_real_write(NET *net,const char *packet,unsigned long len);
  179. unsigned int my_net_read(NET *net);
  180. struct rand_struct {
  181.   unsigned long seed1,seed2,max_value;
  182.   double max_value_dbl;
  183. };
  184.   /* The following is for user defined functions */
  185. enum Item_result {STRING_RESULT,REAL_RESULT,INT_RESULT};
  186. typedef struct st_udf_args
  187. {
  188.   unsigned int arg_count; /* Number of arguments */
  189.   enum Item_result *arg_type; /* Pointer to item_results */
  190.   char **args; /* Pointer to argument */
  191.   unsigned long *lengths; /* Length of string arguments */
  192.   char *maybe_null; /* Set to 1 for all maybe_null args */
  193. } UDF_ARGS;
  194.   /* This holds information about the result */
  195. typedef struct st_udf_init
  196. {
  197.   my_bool maybe_null; /* 1 if function can return NULL */
  198.   unsigned int decimals; /* for real functions */
  199.   unsigned int max_length; /* For string functions */
  200.   char   *ptr; /* free pointer for function data */
  201.   my_bool const_item; /* 0 if result is independent of arguments */
  202. } UDF_INIT;
  203.   /* Constants when using compression */
  204. #define NET_HEADER_SIZE 4 /* standard header size */
  205. #define COMP_HEADER_SIZE 3 /* compression header extra size */
  206.   /* Prototypes to password functions */
  207. #ifdef __cplusplus
  208. extern "C" {
  209. #endif
  210.   
  211. void randominit(struct rand_struct *,unsigned long seed1,
  212. unsigned long seed2);
  213. double rnd(struct rand_struct *);
  214. void make_scrambled_password(char *to,const char *password);
  215. void get_salt_from_password(unsigned long *res,const char *password);
  216. void make_password_from_salt(char *to, unsigned long *hash_res);
  217. char *scramble(char *to,const char *message,const char *password,
  218.        my_bool old_ver);
  219. my_bool check_scramble(const char *, const char *message,
  220.        unsigned long *salt,my_bool old_ver);
  221. char *get_tty_password(char *opt_message);
  222. void hash_password(unsigned long *result, const char *password);
  223. #ifdef __cplusplus
  224. }
  225. #endif
  226. /* Some other useful functions */
  227. void my_init(void);
  228. void load_defaults(const char *conf_file, const char **groups,
  229.    int *argc, char ***argv);
  230. #define NULL_LENGTH ((unsigned long) ~0) /* For net_store_length */
  231. #ifdef __WIN__
  232. #define socket_errno WSAGetLastError()
  233. #else
  234. #define socket_errno errno
  235. #endif
  236. #endif