1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
|
/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
* vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
*
* Copyright (C) 2008 Sun Microsystems, Inc.
*
* 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; version 2 of the License.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* 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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*/
#ifndef LIBDRIZZLECLIENT_DRIZZLE_H
#define LIBDRIZZLECLIENT_DRIZZLE_H
#include <drizzled/common.h>
#include "drizzle_field.h"
#include "options.h"
#include "drizzle_res.h"
#include "net_serv.h"
#include <stdint.h>
#if !defined(__cplusplus)
# include <stdbool.h>
#endif
#ifdef __cplusplus
extern "C" {
#endif
struct st_drizzle_methods;
enum drizzle_status
{
DRIZZLE_STATUS_READY,DRIZZLE_STATUS_GET_RESULT,DRIZZLE_STATUS_USE_RESULT
};
typedef struct st_drizzle
{
NET net; /* Communication parameters */
unsigned char *connector_fd; /* ConnectorFd for SSL */
char *host,*user,*passwd,*unix_socket,*server_version,*host_info;
char *info, *db;
DRIZZLE_FIELD *fields;
uint64_t affected_rows;
uint64_t insert_id; /* id if insert on table with NEXTNR */
uint64_t extra_info; /* Not used */
uint32_t thread_id; /* Id for connection in server */
uint32_t packet_length;
uint32_t port;
uint32_t client_flag,server_capabilities;
uint32_t protocol_version;
uint32_t field_count;
uint32_t server_status;
uint32_t server_language;
uint32_t warning_count;
struct st_drizzleclient_options options;
enum drizzle_status status;
bool free_me; /* If free in drizzleclient_close */
bool reconnect; /* set to 1 if automatic reconnect */
/* session-wide random string */
char scramble[SCRAMBLE_LENGTH+1];
bool unused1;
void *unused2, *unused3, *unused4, *unused5;
const struct st_drizzle_methods *methods;
void *thd;
/*
Points to boolean flag in DRIZZLE_RES or DRIZZLE_STMT. We set this flag
from drizzle_stmt_close if close had to cancel result set of this object.
*/
bool *unbuffered_fetch_owner;
/* needed for embedded server - no net buffer to store the 'info' */
char *info_buffer;
void *extension;
} DRIZZLE;
DRIZZLE * drizzleclient_create(DRIZZLE *drizzle);
DRIZZLE * drizzleclient_connect(DRIZZLE *drizzle, const char *host,
const char *user,
const char *passwd,
const char *db,
uint32_t port,
const char *unix_socket,
uint32_t clientflag);
int32_t drizzleclient_select_db(DRIZZLE *drizzle, const char *db);
int32_t drizzleclient_query(DRIZZLE *drizzle, const char *q);
int32_t drizzleclient_send_query(DRIZZLE *drizzle, const char *q, uint32_t length);
int32_t drizzleclient_real_query(DRIZZLE *drizzle, const char *q, uint32_t length);
DRIZZLE_RES * drizzleclient_store_result(DRIZZLE *drizzle);
DRIZZLE_RES * drizzleclient_use_result(DRIZZLE *drizzle);
uint32_t drizzleclient_field_count(const DRIZZLE *drizzle);
uint64_t drizzleclient_affected_rows(const DRIZZLE *drizzle);
uint64_t drizzleclient_insert_id(const DRIZZLE *drizzle);
uint32_t drizzleclient_errno(const DRIZZLE *drizzle);
const char * drizzleclient_error(const DRIZZLE *drizzle);
const char * drizzleclient_sqlstate(const DRIZZLE *drizzle);
uint32_t drizzleclient_warning_count(const DRIZZLE *drizzle);
const char * drizzleclient_info(const DRIZZLE *drizzle);
uint32_t drizzleclient_thread_id(const DRIZZLE *drizzle);
const char * drizzle_character_set_name(const DRIZZLE *drizzle);
bool drizzleclient_change_user(DRIZZLE *drizzle, const char *user,
const char *passwd, const char *db);
/* local infile support */
#define LOCAL_INFILE_ERROR_LEN 512
void
drizzleclient_set_local_infile_handler(DRIZZLE *drizzle,
int (*local_infile_init)(void **, const char *, void *),
int (*local_infile_read)(void *, char *, unsigned int),
void (*local_infile_end)(void *),int (*local_infile_error)
(void *, char*, unsigned int), void *);
void
drizzleclient_set_local_infile_default(DRIZZLE *drizzle);
int32_t drizzleclient_shutdown(DRIZZLE *drizzle);
int32_t drizzle_dump_debug_info(DRIZZLE *drizzle);
int32_t drizzleclient_refresh(DRIZZLE *drizzle, uint32_t refresh_options);
int32_t drizzleclient_ping(DRIZZLE *drizzle);
const char * drizzle_stat(DRIZZLE *drizzle);
const char * drizzleclient_get_server_info(const DRIZZLE *drizzle);
const char * drizzleclient_get_host_info(const DRIZZLE *drizzle);
uint32_t drizzleclient_get_server_version(const DRIZZLE *drizzle);
uint32_t drizzleclient_get_proto_info(const DRIZZLE *drizzle);
DRIZZLE_RES * drizzleclient_list_tables(DRIZZLE *drizzle,const char *wild);
DRIZZLE_RES * drizzleclient_list_processes(DRIZZLE *drizzle);
int32_t drizzleclient_options(DRIZZLE *drizzle, enum drizzle_option option,
const void *arg);
bool drizzleclient_read_query_result(DRIZZLE *drizzle);
bool drizzleclient_commit(DRIZZLE *drizzle);
bool drizzleclient_rollback(DRIZZLE *drizzle);
bool drizzleclient_autocommit(DRIZZLE *drizzle, bool auto_mode);
bool drizzleclient_more_results(const DRIZZLE *drizzle);
int drizzleclient_next_result(DRIZZLE *drizzle);
void drizzleclient_close(DRIZZLE *drizzle);
bool drizzleclient_reconnect(DRIZZLE *drizzle);
void drizzleclient_disconnect(DRIZZLE *drizzle);
bool
drizzleclient_cli_advanced_command(DRIZZLE *drizzle, enum enum_server_command command,
const unsigned char *header, uint32_t header_length,
const unsigned char *arg, uint32_t arg_length,
bool skip_check);
uint32_t drizzleclient_cli_safe_read(DRIZZLE *drizzle);
DRIZZLE_FIELD * drizzleclient_cli_list_fields(DRIZZLE *drizzle);
DRIZZLE_DATA * drizzleclient_cli_read_rows(DRIZZLE *drizzle,DRIZZLE_FIELD *drizzle_fields,
unsigned int fields);
int drizzleclient_cli_unbuffered_fetch(DRIZZLE *drizzle, char **row);
const char * drizzleclient_cli_read_statistics(DRIZZLE *drizzle);
typedef bool (*safe_read_error_hook_func)(NET *net);
extern safe_read_error_hook_func safe_read_error_hook;
#ifdef __cplusplus
}
#endif
#endif /* LIBDRIZZLECLIENT_DRIZZLE_H */
|