mysql_com.h 12.3 KB
Newer Older
unknown's avatar
unknown committed
1 2 3 4 5 6 7 8
/* Copyright (C) 2000 MySQL AB

   This program is free software; you can redistribute it and/or modify
   it under the terms of the GNU General Public License as published by
   the Free Software Foundation; either version 2 of the License, or
   (at your option) any later version.

   This program is distributed in the hope that it will be useful,
unknown's avatar
unknown committed
9
   but WITHOUT ANY WARRANTY; without even the implied warranty of
unknown's avatar
unknown committed
10 11 12 13 14 15
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   GNU General Public License for more details.

   You should have received a copy of the GNU General Public License
   along with this program; if not, write to the Free Software
   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
unknown's avatar
unknown committed
16 17 18 19 20 21 22 23 24 25 26

/*
** Common definition between mysql server & client
*/

#ifndef _mysql_com_h
#define _mysql_com_h

#define NAME_LEN	64		/* Field/table name length */
#define HOSTNAME_LENGTH 60
#define USERNAME_LENGTH 16
unknown's avatar
unknown committed
27
#define SERVER_VERSION_LENGTH 60
unknown's avatar
unknown committed
28 29 30 31

#define LOCAL_HOST	"localhost"
#define LOCAL_HOST_NAMEDPIPE "."

unknown's avatar
unknown committed
32

unknown's avatar
unknown committed
33 34 35 36 37
#if defined(__WIN__) && !defined( _CUSTOMCONFIG_)
#define MYSQL_NAMEDPIPE "MySQL"
#define MYSQL_SERVICENAME "MySql"
#endif /* __WIN__ */

38 39 40 41 42 43 44
enum enum_server_command
{
  COM_SLEEP, COM_QUIT, COM_INIT_DB, COM_QUERY, COM_FIELD_LIST,
  COM_CREATE_DB, COM_DROP_DB, COM_REFRESH, COM_SHUTDOWN, COM_STATISTICS,
  COM_PROCESS_INFO, COM_CONNECT, COM_PROCESS_KILL, COM_DEBUG, COM_PING,
  COM_TIME, COM_DELAYED_INSERT, COM_CHANGE_USER, COM_BINLOG_DUMP,
  COM_TABLE_DUMP, COM_CONNECT_OUT, COM_REGISTER_SLAVE,
unknown's avatar
unknown committed
45 46
  COM_PREPARE, COM_EXECUTE, COM_LONG_DATA, COM_CLOSE_STMT,
  COM_END				/* Must be last */
47
};
unknown's avatar
unknown committed
48

unknown's avatar
unknown committed
49 50 51 52 53

#define SCRAMBLE_LENGTH   8
#define SCRAMBLE41_LENGTH 20


unknown's avatar
unknown committed
54 55 56 57 58 59 60
#define NOT_NULL_FLAG	1		/* Field can't be NULL */
#define PRI_KEY_FLAG	2		/* Field is part of a primary key */
#define UNIQUE_KEY_FLAG 4		/* Field is part of a unique key */
#define MULTIPLE_KEY_FLAG 8		/* Field is part of a key */
#define BLOB_FLAG	16		/* Field is a blob */
#define UNSIGNED_FLAG	32		/* Field is unsigned */
#define ZEROFILL_FLAG	64		/* Field is zerofill */
unknown's avatar
unknown committed
61
#define BINARY_FLAG	128		/* Field is binary   */
62

unknown's avatar
unknown committed
63 64 65 66 67
/* The following are only sent to new clients */
#define ENUM_FLAG	256		/* field is an enum */
#define AUTO_INCREMENT_FLAG 512		/* field is a autoincrement field */
#define TIMESTAMP_FLAG	1024		/* Field is a timestamp */
#define SET_FLAG	2048		/* field is a set */
68
#define NUM_FLAG	32768		/* Field is num (for clients) */
unknown's avatar
unknown committed
69 70 71 72 73 74 75 76 77
#define PART_KEY_FLAG	16384		/* Intern; Part of some key */
#define GROUP_FLAG	32768		/* Intern: Group field */
#define UNIQUE_FLAG	65536		/* Intern: Used by sql_yacc */

#define REFRESH_GRANT		1	/* Refresh grant tables */
#define REFRESH_LOG		2	/* Start on new log file */
#define REFRESH_TABLES		4	/* close all tables */
#define REFRESH_HOSTS		8	/* Flush host cache */
#define REFRESH_STATUS		16	/* Flush status variables */
unknown's avatar
unknown committed
78
#define REFRESH_THREADS		32	/* Flush thread cache */
unknown's avatar
unknown committed
79 80 81 82 83 84 85 86 87
#define REFRESH_SLAVE           64      /* Reset master info and restart slave
					   thread */
#define REFRESH_MASTER          128     /* Remove all bin logs in the index
					   and truncate the index */

/* The following can't be set with mysql_refresh() */
#define REFRESH_READ_LOCK	16384	/* Lock tables for read */
#define REFRESH_FAST		32768	/* Intern flag */

unknown's avatar
unknown committed
88 89 90
/* RESET (remove all queries) from query cache */
#define REFRESH_QUERY_CACHE	65536
#define REFRESH_QUERY_CACHE_FREE 0x20000L /* pack query cache */
unknown's avatar
unknown committed
91
#define REFRESH_DES_KEY_FILE	0x40000L
92
#define REFRESH_USER_RESOURCES	0x80000L
unknown's avatar
unknown committed
93

unknown's avatar
unknown committed
94 95 96 97 98 99 100 101 102 103 104 105
#define CLIENT_LONG_PASSWORD	1	/* new more secure passwords */
#define CLIENT_FOUND_ROWS	2	/* Found instead of affected rows */
#define CLIENT_LONG_FLAG	4	/* Get all column flags */
#define CLIENT_CONNECT_WITH_DB	8	/* One can specify db on connect */
#define CLIENT_NO_SCHEMA	16	/* Don't allow database.table.column */
#define CLIENT_COMPRESS		32	/* Can use compression protocol */
#define CLIENT_ODBC		64	/* Odbc client */
#define CLIENT_LOCAL_FILES	128	/* Can use LOAD DATA LOCAL */
#define CLIENT_IGNORE_SPACE	256	/* Ignore spaces before '(' */
#define CLIENT_INTERACTIVE	1024	/* This is an interactive client */
#define CLIENT_SSL              2048     /* Switch to SSL after handshake */
#define CLIENT_IGNORE_SIGPIPE   4096     /* IGNORE sigpipes */
unknown's avatar
unknown committed
106
#define CLIENT_TRANSACTIONS	8192	/* Client knows about transactions */
107
#define CLIENT_PROTOCOL_41       16384   /* New 4.1 protocol  */
108
#define CLIENT_SECURE_CONNECTION 32768   /* New 4.1 authentication */
109
#define CLIENT_MULTI_QUERIES     65536   /* Enable/disable multi query support */
unknown's avatar
unknown committed
110

111 112 113
#define SERVER_STATUS_IN_TRANS     1	/* Transaction has started */
#define SERVER_STATUS_AUTOCOMMIT   2	/* Server in auto_commit mode */
#define SERVER_STATUS_MORE_RESULTS 4	/* More results on server */
114
#define SERVER_MORE_RESULTS_EXISTS 8    /* Multi query - next query exists */
unknown's avatar
unknown committed
115 116 117 118 119 120 121 122 123

#define MYSQL_ERRMSG_SIZE	200
#define NET_READ_TIMEOUT	30		/* Timeout on read */
#define NET_WRITE_TIMEOUT	60		/* Timeout on write */
#define NET_WAIT_TIMEOUT	8*60*60		/* Wait for new query */

struct st_vio;					/* Only C */
typedef struct st_vio Vio;

unknown's avatar
unknown committed
124 125
#define MAX_CHAR_WIDTH		255	/* Max length for a CHAR colum */
#define MAX_BLOB_WIDTH		8192	/* Default width for blob */
126

unknown's avatar
unknown committed
127
typedef struct st_net {
128
#ifndef EMBEDDED_LIBRARY
unknown's avatar
unknown committed
129
  Vio* vio;
unknown's avatar
unknown committed
130
  unsigned char *buff,*buff_end,*write_pos,*read_pos;
unknown's avatar
unknown committed
131
  my_socket fd;					/* For Perl DBI/dbd */
unknown's avatar
unknown committed
132
  unsigned long max_packet,max_packet_size;
133
  unsigned int pkt_nr,compress_pkt_nr;
134
  unsigned int write_timeout, read_timeout, retry_count;
unknown's avatar
unknown committed
135
  int fcntl;
136
  my_bool compress;
137 138 139 140 141
  /*
    The following variable is set if we are doing several queries in one
    command ( as in LOAD TABLE ... FROM MASTER ),
    and do not want to confuse the client with OK at the wrong time
  */
unknown's avatar
unknown committed
142 143 144 145
  unsigned long remain_in_buf,length, buf_length, where_b;
  unsigned int *return_status;
  unsigned char reading_or_writing;
  char save_char;
unknown's avatar
unknown committed
146
  my_bool no_send_ok;
147 148 149
  /*
    Pointer to query object in query cache, do not equal NULL (0) for
    queries in cache that have not stored its results yet
unknown's avatar
unknown committed
150
  */
151 152 153 154
#endif
  char last_error[MYSQL_ERRMSG_SIZE];
  unsigned int last_errno;
  unsigned char error;
155
  gptr query_cache_query;
156 157
  my_bool report_error; /* We should report error (we have unreported error) */
  my_bool return_errno;
unknown's avatar
unknown committed
158 159
} NET;

unknown's avatar
unknown committed
160
#define packet_error (~(unsigned long) 0)
unknown's avatar
unknown committed
161

162 163 164 165 166 167 168
enum enum_field_types { MYSQL_TYPE_DECIMAL, MYSQL_TYPE_TINY,
			MYSQL_TYPE_SHORT,  MYSQL_TYPE_LONG,
			MYSQL_TYPE_FLOAT,  MYSQL_TYPE_DOUBLE,
			MYSQL_TYPE_NULL,   MYSQL_TYPE_TIMESTAMP,
			MYSQL_TYPE_LONGLONG,MYSQL_TYPE_INT24,
			MYSQL_TYPE_DATE,   MYSQL_TYPE_TIME,
			MYSQL_TYPE_DATETIME, MYSQL_TYPE_YEAR,
169
			MYSQL_TYPE_NEWDATE,
170 171 172 173 174 175 176 177 178 179
			MYSQL_TYPE_ENUM=247,
			MYSQL_TYPE_SET=248,
			MYSQL_TYPE_TINY_BLOB=249,
			MYSQL_TYPE_MEDIUM_BLOB=250,
			MYSQL_TYPE_LONG_BLOB=251,
			MYSQL_TYPE_BLOB=252,
			MYSQL_TYPE_VAR_STRING=253,
			MYSQL_TYPE_STRING=254,
			MYSQL_TYPE_GEOMETRY=255

unknown's avatar
unknown committed
180 181
};

182
/* For backward compatibility */
183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201
#define FIELD_TYPE_DECIMAL     MYSQL_TYPE_DECIMAL
#define FIELD_TYPE_TINY        MYSQL_TYPE_TINY
#define FIELD_TYPE_SHORT       MYSQL_TYPE_SHORT
#define FIELD_TYPE_LONG        MYSQL_TYPE_LONG
#define FIELD_TYPE_FLOAT       MYSQL_TYPE_FLOAT
#define FIELD_TYPE_DOUBLE      MYSQL_TYPE_DOUBLE
#define FIELD_TYPE_NULL        MYSQL_TYPE_NULL
#define FIELD_TYPE_TIMESTAMP   MYSQL_TYPE_TIMESTAMP
#define FIELD_TYPE_LONGLONG    MYSQL_TYPE_LONGLONG
#define FIELD_TYPE_INT24       MYSQL_TYPE_INT24
#define FIELD_TYPE_DATE        MYSQL_TYPE_DATE
#define FIELD_TYPE_TIME        MYSQL_TYPE_TIME
#define FIELD_TYPE_DATETIME    MYSQL_TYPE_DATETIME
#define FIELD_TYPE_YEAR        MYSQL_TYPE_YEAR
#define FIELD_TYPE_NEWDATE     MYSQL_TYPE_NEWDATE
#define FIELD_TYPE_ENUM        MYSQL_TYPE_ENUM
#define FIELD_TYPE_SET         MYSQL_TYPE_SET
#define FIELD_TYPE_TINY_BLOB   MYSQL_TYPE_TINY_BLOB
#define FIELD_TYPE_MEDIUM_BLOB MYSQL_TYPE_MEDIUM_BLOB
202
#define FIELD_TYPE_LONG_BLOB   MYSQL_TYPE_LONG_BLOB
203 204 205 206
#define FIELD_TYPE_BLOB        MYSQL_TYPE_BLOB
#define FIELD_TYPE_VAR_STRING  MYSQL_TYPE_VAR_STRING
#define FIELD_TYPE_STRING      MYSQL_TYPE_STRING
#define FIELD_TYPE_CHAR        MYSQL_TYPE_TINY
207
#define FIELD_TYPE_INTERVAL    MYSQL_TYPE_ENUM
208
#define FIELD_TYPE_GEOMETRY    MYSQL_TYPE_GEOMETRY
209 210 211 212 213 214 215 216 217 218 219

#if TO_BE_INCLUDED_LATER
/* For bind applications, to indicate unsigned buffers */
#define MYSQL_TYPE_UTINY     -10
#define MYSQL_TYPE_USHORT    -9
#define MYSQL_TYPE_ULONG     -8
#define MYSQL_TYPE_UFLOAT    -7
#define MYSQL_TYPE_UDOUBLE   -6
#define MYSQL_TYPE_ULONGLONG -5
#define MYSQL_TYPE_UINT24    -4
#endif
unknown's avatar
unknown committed
220 221 222

#define net_new_transaction(net) ((net)->pkt_nr=0)

unknown's avatar
unknown committed
223 224 225 226
#ifdef __cplusplus
extern "C" {
#endif

227
my_bool	my_net_init(NET *net, Vio* vio);
unknown's avatar
unknown committed
228
void	my_net_local_init(NET *net);
unknown's avatar
unknown committed
229 230
void	net_end(NET *net);
void	net_clear(NET *net);
231
my_bool net_realloc(NET *net, unsigned long length);
unknown's avatar
SCRUM  
unknown committed
232
#ifndef EMBEDDED_LIBRARY
233
my_bool	net_flush(NET *net);
unknown's avatar
SCRUM  
unknown committed
234
#else
235
#define net_flush(A)
unknown's avatar
SCRUM  
unknown committed
236 237
#endif

238 239 240 241
my_bool	my_net_write(NET *net,const char *packet,unsigned long len);
my_bool	net_write_command(NET *net,unsigned char command,
			  const char *header, unsigned long head_len,
			  const char *packet, unsigned long len);
unknown's avatar
unknown committed
242
int	net_real_write(NET *net,const char *packet,unsigned long len);
243
unsigned long my_net_read(NET *net);
unknown's avatar
unknown committed
244

245 246 247 248
/*
  The following function is not meant for normal usage
  Currently it's used internally by manager.c
*/
unknown's avatar
unknown committed
249
struct sockaddr;
250 251
my_bool my_connect(my_socket s, const struct sockaddr *name,
		   unsigned int namelen, unsigned int timeout);
unknown's avatar
unknown committed
252 253 254 255 256 257

struct rand_struct {
  unsigned long seed1,seed2,max_value;
  double max_value_dbl;
};

unknown's avatar
unknown committed
258 259 260 261
#ifdef __cplusplus
}
#endif

unknown's avatar
unknown committed
262 263
  /* The following is for user defined functions */

unknown's avatar
unknown committed
264
enum Item_result {STRING_RESULT, REAL_RESULT, INT_RESULT, ROW_RESULT};
unknown's avatar
unknown committed
265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280

typedef struct st_udf_args
{
  unsigned int arg_count;		/* Number of arguments */
  enum Item_result *arg_type;		/* Pointer to item_results */
  char **args;				/* Pointer to argument */
  unsigned long *lengths;		/* Length of string arguments */
  char *maybe_null;			/* Set to 1 for all maybe_null args */
} UDF_ARGS;

  /* This holds information about the result */

typedef struct st_udf_init
{
  my_bool maybe_null;			/* 1 if function can return NULL */
  unsigned int decimals;		/* for real functions */
281
  unsigned long max_length;		/* For string functions */
unknown's avatar
unknown committed
282 283 284 285 286 287 288 289 290 291 292 293 294
  char	  *ptr;				/* free pointer for function data */
  my_bool const_item;			/* 0 if result is independent of arguments */
} UDF_INIT;

  /* Constants when using compression */
#define NET_HEADER_SIZE 4		/* standard header size */
#define COMP_HEADER_SIZE 3		/* compression header extra size */

  /* Prototypes to password functions */

#ifdef __cplusplus
extern "C" {
#endif
unknown's avatar
unknown committed
295

296 297 298
extern unsigned long max_allowed_packet;
extern unsigned long net_buffer_length;

unknown's avatar
unknown committed
299 300
void randominit(struct rand_struct *,unsigned long seed1,
		unsigned long seed2);
301
double my_rnd(struct rand_struct *);
unknown's avatar
unknown committed
302 303
void make_scrambled_password(char *to,const char *password,
     my_bool force_old_scramble,struct rand_struct *rand_st);
304 305
int get_password_length(my_bool force_old_scramble);
char get_password_version(const char* password);
306
void create_random_string(int length,struct rand_struct *rand_st,char* target);
unknown's avatar
unknown committed
307
my_bool validate_password(const char* password, const char* message,
unknown's avatar
unknown committed
308
        unsigned long* salt);
309 310 311
void password_hash_stage1(char *to, const char *password);
void password_hash_stage2(char *to,const char *salt);
void password_crypt(const char* from,char* to, const char* password,int length);
unknown's avatar
unknown committed
312
void get_hash_and_password(unsigned long* salt, unsigned char  pversion,char* hash,
unknown's avatar
unknown committed
313
     unsigned char* bin_password);
unknown's avatar
unknown committed
314
void get_salt_from_password(unsigned long *res,const char *password);
315
void create_key_from_old_password(const char* password,char* key);
316
void make_password_from_salt(char *to, unsigned long *hash_res,
unknown's avatar
unknown committed
317
     unsigned char  password_version);
unknown's avatar
unknown committed
318 319 320 321 322 323 324 325 326 327 328 329
char *scramble(char *to,const char *message,const char *password,
	       my_bool old_ver);
my_bool check_scramble(const char *, const char *message,
		       unsigned long *salt,my_bool old_ver);
char *get_tty_password(char *opt_message);
void hash_password(unsigned long *result, const char *password);

/* Some other useful functions */

void my_init(void);
void load_defaults(const char *conf_file, const char **groups,
		   int *argc, char ***argv);
unknown's avatar
unknown committed
330
my_bool my_thread_init(void);
331
void my_thread_end(void);
unknown's avatar
unknown committed
332

unknown's avatar
SCRUM  
unknown committed
333 334 335 336
#ifdef _global_h
ulong STDCALL net_field_length(uchar **packet);
#endif

unknown's avatar
unknown committed
337 338 339 340
#ifdef __cplusplus
}
#endif

unknown's avatar
unknown committed
341
#define NULL_LENGTH ((unsigned long) ~0) /* For net_store_length */
unknown's avatar
unknown committed
342
#define MYSQL_STMT_HEADER       4
unknown's avatar
unknown committed
343
#define	MYSQL_LONG_DATA_HEADER	6
unknown's avatar
unknown committed
344 345

#endif