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
21
#include "libdrizzle_priv.h"
23
#include <libdrizzle/libdrizzle.h>
24
#include <libdrizzle/pack.h>
25
#include <libdrizzle/errmsg.h>
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>
26
25
#include <sys/stat.h>
27
26
#include <signal.h>
51
50
#define INADDR_NONE -1
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)\
53
#include <sql_common.h>
54
#include "client_settings.h"
55
#include <drizzled/version.h>
72
57
#undef net_buffer_length
73
58
#undef max_allowed_packet
75
60
uint32_t net_buffer_length= 8192;
76
61
uint32_t max_allowed_packet= 1024L*1024L*1024L;
78
unsigned int drizzle_port=0;
64
#define SOCKET_ERROR -1
67
If allowed through some configuration, then this needs to
70
#define MAX_LONG_DATA_LENGTH 8192
71
#define unsigned_field(A) ((A)->flags & UNSIGNED_FLAG)
83
74
static DRIZZLE_PARAMETERS drizzle_internal_parameters=
88
79
return &drizzle_internal_parameters;
91
unsigned int drizzle_get_default_port(void)
96
void drizzle_set_default_port(unsigned int port)
82
bool drizzle_thread_init()
84
return my_thread_init();
87
void drizzle_thread_end()
102
94
Expand wildcard to a sql string
127
119
/**************************************************************************
120
Ignore SIGPIPE handler
122
**************************************************************************/
125
my_pipe_sig_handler(int sig __attribute__((unused)))
127
#ifdef DONT_REMEMBER_SIGNAL
128
(void) signal(SIGPIPE, my_pipe_sig_handler);
133
/**************************************************************************
128
134
Change user and database
129
135
**************************************************************************/
146
152
char buff[USERNAME_LENGTH+SCRAMBLED_PASSWORD_CHAR_LENGTH+NAME_LEN+2];
155
const CHARSET_INFO *saved_cs= drizzle->charset;
157
/* Get the connection-default character set. */
159
if (drizzle_init_character_set(drizzle))
161
drizzle->charset= saved_cs;
150
165
/* Use an empty string instead of NULL. */
171
186
end= strncpy(end, db ? db : "", NAME_LEN) + NAME_LEN + 1;
173
188
/* Add character set number. */
174
190
if (drizzle->server_capabilities & CLIENT_SECURE_CONNECTION)
176
int2store(end, (uint16_t) 45); // utf8mb4 number from mystrings/ctype-utf8.c
192
int2store(end, (ushort) drizzle->charset->number);
180
196
/* Write authentication package */
181
(void)simple_command(drizzle,COM_CHANGE_USER, (unsigned char*) buff, (uint32_t) (end-buff), 1);
197
(void)simple_command(drizzle,COM_CHANGE_USER, (uchar*) buff, (uint32_t) (end-buff), 1);
183
199
rc= (*drizzle->methods->read_change_user_result)(drizzle);
215
235
drizzle_query(DRIZZLE *drizzle, const char *query)
217
return drizzle_real_query(drizzle,query, (uint32_t) strlen(query));
237
return drizzle_real_query(drizzle,query, (uint) strlen(query));
296
316
if (!(query= cli_read_rows(drizzle,(DRIZZLE_FIELD*) 0, 8)))
299
drizzle->field_count= (uint32_t) query->rows;
300
return unpack_fields(query, drizzle->field_count, 1);
319
drizzle->field_count= (uint) query->rows;
320
return unpack_fields(query,&drizzle->field_alloc, drizzle->field_count, 1);
319
339
end= strncpy(end+1, wild ? wild : "", 128) + 128;
321
341
free_old_query(drizzle);
322
if (simple_command(drizzle, COM_FIELD_LIST, (unsigned char*) buff,
342
if (simple_command(drizzle, COM_FIELD_LIST, (uchar*) buff,
323
343
(uint32_t) (end-buff), 1) ||
324
344
!(fields= (*drizzle->methods->list_fields)(drizzle)))
343
364
drizzle_list_processes(DRIZZLE *drizzle)
345
366
DRIZZLE_DATA *fields;
346
uint32_t field_count;
349
370
if (simple_command(drizzle,COM_PROCESS_INFO,0,0,0))
351
372
free_old_query(drizzle);
352
pos=(unsigned char*) drizzle->net.read_pos;
353
field_count=(uint32_t) net_field_length(&pos);
373
pos=(uchar*) drizzle->net.read_pos;
374
field_count=(uint) net_field_length(&pos);
354
375
if (!(fields = (*drizzle->methods->read_rows)(drizzle,(DRIZZLE_FIELD*) 0, 7)))
356
if (!(drizzle->fields=unpack_fields(fields, field_count, 0)))
377
if (!(drizzle->fields=unpack_fields(fields,&drizzle->field_alloc,field_count,0)))
358
379
drizzle->status=DRIZZLE_STATUS_GET_RESULT;
359
380
drizzle->field_count=field_count;
365
drizzle_shutdown(DRIZZLE *drizzle)
386
drizzle_shutdown(DRIZZLE *drizzle, enum drizzle_enum_shutdown_level shutdown_level)
367
return(simple_command(drizzle, COM_SHUTDOWN, 0, 0, 0));
389
level[0]= (uchar) shutdown_level;
390
return(simple_command(drizzle, COM_SHUTDOWN, level, 1, 0));
372
drizzle_refresh(DRIZZLE *drizzle, uint32_t options)
395
drizzle_refresh(DRIZZLE *drizzle,uint options)
374
unsigned char bits[1];
375
bits[0]= (unsigned char) options;
398
bits[0]= (uchar) options;
376
399
return(simple_command(drizzle, COM_REFRESH, bits, 1, 0));
390
413
drizzle_set_server_option(DRIZZLE *drizzle, enum enum_drizzle_set_option option)
392
unsigned char buff[2];
393
int2store(buff, (uint32_t) option);
416
int2store(buff, (uint) option);
394
417
return(simple_command(drizzle, COM_SET_OPTION, buff, sizeof(buff), 0));
400
423
drizzle->net.read_pos[drizzle->packet_length]=0; /* End of stat string */
401
424
if (!drizzle->net.read_pos[0])
403
drizzle_set_error(drizzle, CR_WRONG_HOST_INFO, sqlstate_get_unknown());
426
set_drizzle_error(drizzle, CR_WRONG_HOST_INFO, unknown_sqlstate);
404
427
return drizzle->net.last_error;
406
429
return (char*) drizzle->net.read_pos;
511
534
return drizzle->thread_id;
537
const char * drizzle_character_set_name(const DRIZZLE *drizzle)
539
return drizzle->charset->csname;
542
void drizzle_get_character_set_info(const DRIZZLE *drizzle, MY_CHARSET_INFO *csinfo)
544
csinfo->number = drizzle->charset->number;
545
csinfo->state = drizzle->charset->state;
546
csinfo->csname = drizzle->charset->csname;
547
csinfo->name = drizzle->charset->name;
548
csinfo->comment = drizzle->charset->comment;
549
csinfo->mbminlen = drizzle->charset->mbminlen;
550
csinfo->mbmaxlen = drizzle->charset->mbmaxlen;
552
if (drizzle->options.charset_dir)
553
csinfo->dir = drizzle->options.charset_dir;
555
csinfo->dir = charsets_dir;
558
uint drizzle_thread_safe(void)
564
bool drizzle_embedded(void)
566
#ifdef EMBEDDED_LIBRARY
514
573
/****************************************************************************
515
574
Some support functions
516
575
****************************************************************************/
522
581
void my_net_local_init(NET *net)
524
net->max_packet= (uint32_t) net_buffer_length;
583
net->max_packet= (uint) net_buffer_length;
525
584
my_net_set_read_timeout(net, CLIENT_NET_READ_TIMEOUT);
526
585
my_net_set_write_timeout(net, CLIENT_NET_WRITE_TIMEOUT);
527
586
net->retry_count= 1;
528
net->max_packet_size= (net_buffer_length > max_allowed_packet) ?
529
net_buffer_length : max_allowed_packet;
587
net->max_packet_size= max(net_buffer_length, max_allowed_packet);
543
601
Each character needs two bytes, and you need room for the terminating
544
602
null byte. When drizzle_hex_string() returns, the contents of "to" will
545
603
be a null-terminated string. The return value is the length of the
546
encoded string, not including the terminating null character. The return value does not contain any leading 0x or a leading X' and
604
encoded string, not including the terminating null character.
606
The return value does not contain any leading 0x or a leading X' and
547
607
trailing '. The caller must supply whichever of those is desired.
572
632
drizzle_escape_string(char *to,const char *from, uint32_t length)
574
const char *to_start= to;
575
const char *end, *to_end=to_start + 2*length;
576
bool overflow= false;
577
for (end= from + length; from < end; from++)
634
return escape_string_for_drizzle(default_charset_info, to, 0, from, length);
638
drizzle_real_escape_string(DRIZZLE *drizzle, char *to,const char *from,
641
if (drizzle->server_status & SERVER_STATUS_NO_BACKSLASH_ESCAPES)
642
return escape_quotes_for_drizzle(drizzle->charset, to, 0, from, length);
643
return escape_string_for_drizzle(drizzle->charset, to, 0, from, length);
647
myodbc_remove_escape(const DRIZZLE *drizzle, char *name)
651
bool use_mb_flag= use_mb(drizzle->charset);
654
for (end=name; *end ; end++) ;
657
for (to=name ; *name ; name++)
581
if (!U8_IS_SINGLE(*from))
661
if (use_mb_flag && (l = my_ismbchar( drizzle->charset, name , end ) ) )
583
tmp_length= U8_LENGTH(*from);
584
if (to + tmp_length > to_end)
595
case 0: /* Must be escaped for 'mysql' */
598
case '\n': /* Must be escaped for logs */
610
case '"': /* Better safe than sorry */
613
case '\032': /* This gives problems on Win32 */
669
if (*name == '\\' && name[1])
638
return overflow ? (size_t) -1 : (size_t) (to - to_start);
641
676
int cli_unbuffered_fetch(DRIZZLE *drizzle, char **row)
706
741
if (drizzle->status != DRIZZLE_STATUS_READY)
708
drizzle_set_error(drizzle, CR_COMMANDS_OUT_OF_SYNC, sqlstate_get_unknown());
743
set_drizzle_error(drizzle, CR_COMMANDS_OUT_OF_SYNC, unknown_sqlstate);