1
/* Copyright (C) 2000-2004 DRIZZLE 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.
7
There are special exceptions to the terms and conditions of the GPL as it
8
is applied to this software. View the full text of the exception in file
9
EXCEPTIONS-CLIENT in the directory of this software distribution.
11
This program is distributed in the hope that it will be useful,
12
but WITHOUT ANY WARRANTY; without even the implied warranty of
13
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14
GNU General Public License for more details.
16
You should have received a copy of the GNU General Public License
17
along with this program; if not, write to the Free Software
18
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
20
#include <drizzled/global.h>
21
#include <mysys/my_sys.h>
1
/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
2
* vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
4
* Copyright (C) 2008 Sun Microsystems, Inc.
6
* This program is free software; you can redistribute it and/or modify
7
* it under the terms of the GNU General Public License as published by
8
* the Free Software Foundation; version 2 of the License.
10
* This program is distributed in the hope that it will be useful,
11
* but WITHOUT ANY WARRANTY; without even the implied warranty of
12
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13
* GNU General Public License for more details.
15
* You should have received a copy of the GNU General Public License
16
* along with this program; if not, write to the Free Software
17
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
20
#include "libdrizzle.h"
21
#include "libdrizzle_priv.h"
23
22
#include "errmsg.h"
24
23
#include <sys/stat.h>
25
24
#include <signal.h>
49
48
#define INADDR_NONE -1
52
54
#include <sql_common.h>
53
#include "client_settings.h"
54
55
#include <drizzled/version.h>
57
/* Borrowed from libicu header */
59
#define U8_IS_SINGLE(c) (((c)&0x80)==0)
60
#define U8_LENGTH(c) \
61
((uint32_t)(c)<=0x7f ? 1 : \
62
((uint32_t)(c)<=0x7ff ? 2 : \
63
((uint32_t)(c)<=0xd7ff ? 3 : \
64
((uint32_t)(c)<=0xdfff || (uint32_t)(c)>0x10ffff ? 0 : \
65
((uint32_t)(c)<=0xffff ? 3 : 4)\
56
72
#undef net_buffer_length
57
73
#undef max_allowed_packet
59
75
uint32_t net_buffer_length= 8192;
60
76
uint32_t max_allowed_packet= 1024L*1024L*1024L;
78
unsigned int drizzle_port=0;
63
81
#define SOCKET_ERROR -1
78
96
return &drizzle_internal_parameters;
81
bool drizzle_thread_init()
83
return my_thread_init();
86
void drizzle_thread_end()
99
unsigned int drizzle_get_default_port(void)
104
void drizzle_set_default_port(unsigned int port)
93
110
Expand wildcard to a sql string
118
135
/**************************************************************************
119
Ignore SIGPIPE handler
121
**************************************************************************/
124
my_pipe_sig_handler(int sig __attribute__((unused)))
126
#ifdef DONT_REMEMBER_SIGNAL
127
(void) signal(SIGPIPE, my_pipe_sig_handler);
132
/**************************************************************************
133
136
Change user and database
134
137
**************************************************************************/
151
154
char buff[USERNAME_LENGTH+SCRAMBLED_PASSWORD_CHAR_LENGTH+NAME_LEN+2];
154
const CHARSET_INFO *saved_cs= drizzle->charset;
156
/* Get the connection-default character set. */
158
if (drizzle_init_character_set(drizzle))
160
drizzle->charset= saved_cs;
164
158
/* Use an empty string instead of NULL. */
185
179
end= strncpy(end, db ? db : "", NAME_LEN) + NAME_LEN + 1;
187
181
/* Add character set number. */
189
182
if (drizzle->server_capabilities & CLIENT_SECURE_CONNECTION)
191
int2store(end, (ushort) drizzle->charset->number);
184
int2store(end, (uint16_t) 45); // utf8mb4 number from mystrings/ctype-utf8.c
195
188
/* Write authentication package */
196
(void)simple_command(drizzle,COM_CHANGE_USER, (uchar*) buff, (uint32_t) (end-buff), 1);
189
(void)simple_command(drizzle,COM_CHANGE_USER, (unsigned char*) buff, (uint32_t) (end-buff), 1);
198
191
rc= (*drizzle->methods->read_change_user_result)(drizzle);
234
223
drizzle_query(DRIZZLE *drizzle, const char *query)
236
return drizzle_real_query(drizzle,query, (uint) strlen(query));
225
return drizzle_real_query(drizzle,query, (uint32_t) strlen(query));
315
304
if (!(query= cli_read_rows(drizzle,(DRIZZLE_FIELD*) 0, 8)))
318
drizzle->field_count= (uint) query->rows;
319
return unpack_fields(query,&drizzle->field_alloc, drizzle->field_count, 1);
307
drizzle->field_count= (uint32_t) query->rows;
308
return unpack_fields(query, drizzle->field_count, 1);
338
327
end= strncpy(end+1, wild ? wild : "", 128) + 128;
340
329
free_old_query(drizzle);
341
if (simple_command(drizzle, COM_FIELD_LIST, (uchar*) buff,
330
if (simple_command(drizzle, COM_FIELD_LIST, (unsigned char*) buff,
342
331
(uint32_t) (end-buff), 1) ||
343
332
!(fields= (*drizzle->methods->list_fields)(drizzle)))
349
338
memset(result, 0, sizeof(DRIZZLE_RES));
351
340
result->methods= drizzle->methods;
352
result->field_alloc=drizzle->field_alloc;
353
341
drizzle->fields=0;
354
342
result->field_count = drizzle->field_count;
355
343
result->fields= fields;
363
351
drizzle_list_processes(DRIZZLE *drizzle)
365
353
DRIZZLE_DATA *fields;
354
uint32_t field_count;
369
357
if (simple_command(drizzle,COM_PROCESS_INFO,0,0,0))
371
359
free_old_query(drizzle);
372
pos=(uchar*) drizzle->net.read_pos;
373
field_count=(uint) net_field_length(&pos);
360
pos=(unsigned char*) drizzle->net.read_pos;
361
field_count=(uint32_t) net_field_length(&pos);
374
362
if (!(fields = (*drizzle->methods->read_rows)(drizzle,(DRIZZLE_FIELD*) 0, 7)))
376
if (!(drizzle->fields=unpack_fields(fields,&drizzle->field_alloc,field_count,0)))
364
if (!(drizzle->fields=unpack_fields(fields, field_count, 0)))
378
366
drizzle->status=DRIZZLE_STATUS_GET_RESULT;
379
367
drizzle->field_count=field_count;
385
drizzle_shutdown(DRIZZLE *drizzle, enum drizzle_enum_shutdown_level shutdown_level)
373
drizzle_shutdown(DRIZZLE *drizzle)
388
level[0]= (uchar) shutdown_level;
389
return(simple_command(drizzle, COM_SHUTDOWN, level, 1, 0));
375
return(simple_command(drizzle, COM_SHUTDOWN, 0, 0, 0));
394
drizzle_refresh(DRIZZLE *drizzle,uint options)
380
drizzle_refresh(DRIZZLE *drizzle, uint32_t options)
397
bits[0]= (uchar) options;
382
unsigned char bits[1];
383
bits[0]= (unsigned char) options;
398
384
return(simple_command(drizzle, COM_REFRESH, bits, 1, 0));
412
398
drizzle_set_server_option(DRIZZLE *drizzle, enum enum_drizzle_set_option option)
415
int2store(buff, (uint) option);
400
unsigned char buff[2];
401
int2store(buff, (uint32_t) option);
416
402
return(simple_command(drizzle, COM_SET_OPTION, buff, sizeof(buff), 0));
422
408
drizzle->net.read_pos[drizzle->packet_length]=0; /* End of stat string */
423
409
if (!drizzle->net.read_pos[0])
425
set_drizzle_error(drizzle, CR_WRONG_HOST_INFO, unknown_sqlstate);
411
drizzle_set_error(drizzle, CR_WRONG_HOST_INFO, sqlstate_get_unknown());
426
412
return drizzle->net.last_error;
428
414
return (char*) drizzle->net.read_pos;
533
519
return drizzle->thread_id;
536
const char * drizzle_character_set_name(const DRIZZLE *drizzle)
538
return drizzle->charset->csname;
541
void drizzle_get_character_set_info(const DRIZZLE *drizzle, MY_CHARSET_INFO *csinfo)
543
csinfo->number = drizzle->charset->number;
544
csinfo->state = drizzle->charset->state;
545
csinfo->csname = drizzle->charset->csname;
546
csinfo->name = drizzle->charset->name;
547
csinfo->comment = drizzle->charset->comment;
548
csinfo->mbminlen = drizzle->charset->mbminlen;
549
csinfo->mbmaxlen = drizzle->charset->mbmaxlen;
551
if (drizzle->options.charset_dir)
552
csinfo->dir = drizzle->options.charset_dir;
554
csinfo->dir = charsets_dir;
557
uint drizzle_thread_safe(void)
563
bool drizzle_embedded(void)
568
522
/****************************************************************************
569
523
Some support functions
570
524
****************************************************************************/
576
530
void my_net_local_init(NET *net)
578
net->max_packet= (uint) net_buffer_length;
532
net->max_packet= (uint32_t) net_buffer_length;
579
533
my_net_set_read_timeout(net, CLIENT_NET_READ_TIMEOUT);
580
534
my_net_set_write_timeout(net, CLIENT_NET_WRITE_TIMEOUT);
581
535
net->retry_count= 1;
582
net->max_packet_size= max(net_buffer_length, max_allowed_packet);
536
net->max_packet_size= (net_buffer_length > max_allowed_packet) ?
537
net_buffer_length : max_allowed_packet;
596
551
Each character needs two bytes, and you need room for the terminating
597
552
null byte. When drizzle_hex_string() returns, the contents of "to" will
598
553
be a null-terminated string. The return value is the length of the
599
encoded string, not including the terminating null character.
601
The return value does not contain any leading 0x or a leading X' and
554
encoded string, not including the terminating null character. The return value does not contain any leading 0x or a leading X' and
602
555
trailing '. The caller must supply whichever of those is desired.
627
580
drizzle_escape_string(char *to,const char *from, uint32_t length)
629
return escape_string_for_drizzle(default_charset_info, to, 0, from, length);
633
drizzle_real_escape_string(DRIZZLE *drizzle, char *to,const char *from,
636
if (drizzle->server_status & SERVER_STATUS_NO_BACKSLASH_ESCAPES)
637
return escape_quotes_for_drizzle(drizzle->charset, to, 0, from, length);
638
return escape_string_for_drizzle(drizzle->charset, to, 0, from, length);
642
myodbc_remove_escape(const DRIZZLE *drizzle, char *name)
646
bool use_mb_flag= use_mb(drizzle->charset);
649
for (end=name; *end ; end++) ;
652
for (to=name ; *name ; name++)
582
const char *to_start= to;
583
const char *end, *to_end=to_start + 2*length;
584
bool overflow= false;
585
for (end= from + length; from < end; from++)
656
if (use_mb_flag && (l = my_ismbchar( drizzle->charset, name , end ) ) )
589
if (!U8_IS_SINGLE(*from))
591
tmp_length= U8_LENGTH(*from);
592
if (to + tmp_length > to_end)
664
if (*name == '\\' && name[1])
603
case 0: /* Must be escaped for 'mysql' */
606
case '\n': /* Must be escaped for logs */
618
case '"': /* Better safe than sorry */
621
case '\032': /* This gives problems on Win32 */
646
return overflow ? (size_t) -1 : (size_t) (to - to_start);
671
649
int cli_unbuffered_fetch(DRIZZLE *drizzle, char **row)
736
714
if (drizzle->status != DRIZZLE_STATUS_READY)
738
set_drizzle_error(drizzle, CR_COMMANDS_OUT_OF_SYNC, unknown_sqlstate);
716
drizzle_set_error(drizzle, CR_COMMANDS_OUT_OF_SYNC, sqlstate_get_unknown());