~drizzle-trunk/drizzle/development

#define INTERNAL_NUM_FIELD(f) (((f)->type <= DRIZZLE_TYPE_LONGLONG && ((f)->type != DRIZZLE_TYPE_TIMESTAMP || (f)->length == 14 || (f)->length == 8)))

#define IS_LONGDATA(t) ((t) == DRIZZLE_TYPE_TINY_BLOB)

typedef struct st_drizzle_field {

char *name; /* Name of column */

char *org_name; /* Original column name, if an alias */

char *table; /* Table of column if column was a field */

char *org_table; /* Org table name, if table was an alias */

char *db; /* Database for table */

char *catalog; /* Catalog for table */

char *def; /* Default value (set by drizzle_list_fields) */

uint32_t length; /* Width of column (create length) */

uint32_t max_length; /* Max width for selected set */

unsigned int name_length;

unsigned int org_name_length;

unsigned int table_length;

unsigned int org_table_length;

unsigned int db_length;

unsigned int catalog_length;

unsigned int def_length;

unsigned int flags; /* Div flags */

unsigned int decimals; /* Number of decimals in field */

unsigned int charsetnr; /* Character set */

enum enum_field_types type; /* Type of field. See drizzle_com.h for types */

void *extension;

} DRIZZLE_FIELD;

typedef char **DRIZZLE_ROW; /* return data as array of strings */

typedef unsigned int DRIZZLE_FIELD_OFFSET; /* offset to current field */

#define DRIZZLE_COUNT_ERROR (~(uint64_t) 0)

typedef struct st_drizzle_rows {

struct st_drizzle_rows *next; /* list of rows */

DRIZZLE_ROW data;

unsigned long length;

} DRIZZLE_ROWS;

typedef DRIZZLE_ROWS *DRIZZLE_ROW_OFFSET; /* offset to current row */

100

typedef struct st_drizzle_data {

101

DRIZZLE_ROWS *data;

102

struct embedded_query_result *embedded_info;

103

uint64_t rows;

104

unsigned int fields;

105

/* extra info for embedded library */

106

void *extension;

107

} DRIZZLE_DATA;

108

109

enum drizzle_option

110

{

111

DRIZZLE_OPT_CONNECT_TIMEOUT, DRIZZLE_OPT_COMPRESS, DRIZZLE_OPT_NAMED_PIPE,

112

DRIZZLE_INIT_COMMAND, DRIZZLE_READ_DEFAULT_FILE, DRIZZLE_READ_DEFAULT_GROUP,

113

DRIZZLE_OPT_LOCAL_INFILE,

114

DRIZZLE_OPT_PROTOCOL, DRIZZLE_SHARED_MEMORY_BASE_NAME, DRIZZLE_OPT_READ_TIMEOUT,

115

DRIZZLE_OPT_WRITE_TIMEOUT, DRIZZLE_OPT_USE_RESULT,

116

DRIZZLE_OPT_USE_REMOTE_CONNECTION,

117

DRIZZLE_OPT_GUESS_CONNECTION, DRIZZLE_SET_CLIENT_IP, DRIZZLE_SECURE_AUTH,

118

DRIZZLE_REPORT_DATA_TRUNCATION, DRIZZLE_OPT_RECONNECT,

119

DRIZZLE_OPT_SSL_VERIFY_SERVER_CERT

120

};

121

122

struct st_drizzle_options {

123

unsigned int connect_timeout, read_timeout, write_timeout;

124

unsigned int port, protocol;

125

unsigned long client_flag;

126

char *host,*user,*password,*db;

127

char *my_cnf_file,*my_cnf_group;

128

char *ssl_key; /* PEM key file */

129

char *ssl_cert; /* PEM cert file */

130

char *ssl_ca; /* PEM CA file */

131

char *ssl_capath; /* PEM directory of CA-s? */

132

char *ssl_cipher; /* cipher to use */

133

char *shared_memory_base_name;

134

unsigned long max_allowed_packet;

135

bool use_ssl; /* if to use SSL or not */

136

bool compress,named_pipe;

137

bool unused1;

138

bool unused2;

139

bool unused3;

140

bool unused4;

141

enum drizzle_option methods_to_use;

142

char *client_ip;

143

/* Refuse client connecting to server if it uses old (pre-4.1.1) protocol */

144

bool secure_auth;

145

/* 0 - never report, 1 - always report (default) */

146

bool report_data_truncation;

147

148

/* function pointers for local infile support */

149

int (*local_infile_init)(void **, const char *, void *);

150

int (*local_infile_read)(void *, char *, unsigned int);

151

void (*local_infile_end)(void *);

152

int (*local_infile_error)(void *, char *, unsigned int);

153

void *local_infile_userdata;

154

void *extension;

155

};

156

157

enum drizzle_status

158

{

159

DRIZZLE_STATUS_READY,DRIZZLE_STATUS_GET_RESULT,DRIZZLE_STATUS_USE_RESULT

160

};

161

162

enum drizzle_protocol_type

163

{

164

DRIZZLE_PROTOCOL_TCP

165

};

166

167

struct st_drizzle_methods;

168

struct st_drizzle_stmt;

169

170

typedef struct st_drizzle

171

{

172

NET net; /* Communication parameters */

173

unsigned char *connector_fd; /* ConnectorFd for SSL */

174

char *host,*user,*passwd,*unix_socket,*server_version,*host_info;

175

char *info, *db;

176

DRIZZLE_FIELD *fields;

177

uint64_t affected_rows;

178

uint64_t insert_id; /* id if insert on table with NEXTNR */

179

uint64_t extra_info; /* Not used */

180

uint32_t thread_id; /* Id for connection in server */

181

uint32_t packet_length;

182

uint32_t port;

183

uint32_t client_flag,server_capabilities;

184

uint32_t protocol_version;

185

uint32_t field_count;

186

uint32_t server_status;

187

uint32_t server_language;

188

uint32_t warning_count;

189

struct st_drizzle_options options;

190

enum drizzle_status status;

191

bool free_me; /* If free in drizzle_close */

192

bool reconnect; /* set to 1 if automatic reconnect */

193

194

/* session-wide random string */

195

char scramble[SCRAMBLE_LENGTH+1];

196

bool unused1;

197

void *unused2, *unused3, *unused4, *unused5;

198

199

const struct st_drizzle_methods *methods;

200

void *thd;

201

202

Points to boolean flag in DRIZZLE_RES or DRIZZLE_STMT. We set this flag

203

from drizzle_stmt_close if close had to cancel result set of this object.

204

205

bool *unbuffered_fetch_owner;

206

/* needed for embedded server - no net buffer to store the 'info' */

207

char *info_buffer;

208

void *extension;

209

} DRIZZLE;

210

211

212

typedef struct st_drizzle_res {

213

uint64_t row_count;

214

DRIZZLE_FIELD *fields;

215

DRIZZLE_DATA *data;

216

DRIZZLE_ROWS *data_cursor;

217

uint32_t *lengths; /* column lengths of current row */

218

DRIZZLE *handle; /* for unbuffered reads */

219

const struct st_drizzle_methods *methods;

220

DRIZZLE_ROW row; /* If unbuffered read */

221

DRIZZLE_ROW current_row; /* buffer to current row */

222

uint32_t field_count, current_field;

223

bool eof; /* Used by drizzle_fetch_row */

224

/* drizzle_stmt_close() had to cancel this result */

225

bool unbuffered_fetch_cancelled;

226

void *extension;

227

} DRIZZLE_RES;

228

229

230

#if !defined(DRIZZLE_SERVER) && !defined(DRIZZLE_CLIENT)

231

#define DRIZZLE_CLIENT

232

#endif

233

234

235

typedef struct st_drizzle_parameters

236

{

237

uint32_t *p_max_allowed_packet;

238

uint32_t *p_net_buffer_length;

239

void *extension;

240

} DRIZZLE_PARAMETERS;

241

242

#if !defined(DRIZZLE_SERVER)

243

#define max_allowed_packet (*drizzle_get_parameters()->p_max_allowed_packet)

244

#define net_buffer_length (*drizzle_get_parameters()->p_net_buffer_length)

245

#endif

#include <stdint.h>

#include <libdrizzle/drizzle_field.h>

#include <libdrizzle/drizzle_rows.h>

#include <libdrizzle/drizzle_data.h>

#include <libdrizzle/drizzle_options.h>

#include <libdrizzle/drizzle.h>

#include <libdrizzle/drizzle_parameters.h>

#include <libdrizzle/drizzle_methods.h>

const char * drizzle_get_client_info(void);

uint32_t drizzle_get_client_version(void);

uint32_t drizzle_escape_string(char *to,const char *from,

uint32_t from_length);

uint32_t drizzle_hex_string(char *to,const char *from,

uint32_t from_length);

246

247

248

Set up and bring down the server; to ensure that applications will

251

252

void drizzle_server_end(void);

253

254

255

drizzle_server_init/end need to be called when using libdrizzle or

256

libdrizzleclient (exactly, drizzle_server_init() is called by drizzle_init() so

257

you don't need to call it explicitely; but you need to call

258

drizzle_server_end() to free memory). The names are a bit misleading

259

(drizzle_SERVER* to be used when using libdrizzleCLIENT). So we add more general

260

names which suit well whether you're using libdrizzled or libdrizzleclient. We

261

intend to promote these aliases over the drizzle_server* ones.

262

263

#define drizzle_library_end drizzle_server_end

264

265

const DRIZZLE_PARAMETERS * drizzle_get_parameters(void);

266

267

268

269

Functions to get information from the DRIZZLE and DRIZZLE_RES structures

270

Should definitely be used if one uses shared libraries.

271

272

273

uint64_t drizzle_num_rows(const DRIZZLE_RES *res);

274

unsigned int drizzle_num_fields(const DRIZZLE_RES *res);

275

bool drizzle_eof(const DRIZZLE_RES *res);

276

const DRIZZLE_FIELD * drizzle_fetch_field_direct(const DRIZZLE_RES *res,

277

unsigned int fieldnr);

278

const DRIZZLE_FIELD * drizzle_fetch_fields(const DRIZZLE_RES *res);

279

DRIZZLE_ROW_OFFSET drizzle_row_tell(const DRIZZLE_RES *res);

280

DRIZZLE_FIELD_OFFSET drizzle_field_tell(const DRIZZLE_RES *res);

281

282

uint32_t drizzle_field_count(const DRIZZLE *drizzle);

283

uint64_t drizzle_affected_rows(const DRIZZLE *drizzle);

284

uint64_t drizzle_insert_id(const DRIZZLE *drizzle);

285

uint32_t drizzle_errno(const DRIZZLE *drizzle);

286

const char * drizzle_error(const DRIZZLE *drizzle);

287

const char * drizzle_sqlstate(const DRIZZLE *drizzle);

288

uint32_t drizzle_warning_count(const DRIZZLE *drizzle);

289

const char * drizzle_info(const DRIZZLE *drizzle);

290

uint32_t drizzle_thread_id(const DRIZZLE *drizzle);

291

const char * drizzle_character_set_name(const DRIZZLE *drizzle);

292

int32_t drizzle_set_character_set(DRIZZLE *drizzle, const char *csname);

293

294

DRIZZLE * drizzle_create(DRIZZLE *drizzle);

295

bool drizzle_change_user(DRIZZLE *drizzle, const char *user,

296

const char *passwd, const char *db);

297

DRIZZLE * drizzle_connect(DRIZZLE *drizzle, const char *host,

298

const char *user,

299

const char *passwd,

300

const char *db,

301

uint32_t port,

302

const char *unix_socket,

303

uint32_t clientflag);

304

int32_t drizzle_select_db(DRIZZLE *drizzle, const char *db);

305

int32_t drizzle_query(DRIZZLE *drizzle, const char *q);

306

int32_t drizzle_send_query(DRIZZLE *drizzle, const char *q, uint32_t length);

307

int32_t drizzle_real_query(DRIZZLE *drizzle, const char *q, uint32_t length);

308

DRIZZLE_RES * drizzle_store_result(DRIZZLE *drizzle);

309

DRIZZLE_RES * drizzle_use_result(DRIZZLE *drizzle);

310

311

/* local infile support */

312

313

#define LOCAL_INFILE_ERROR_LEN 512

314

315

void

316

drizzle_set_local_infile_handler(DRIZZLE *drizzle,

317

int (*local_infile_init)(void **, const char *, void *),

318

int (*local_infile_read)(void *, char *, unsigned int),

319

void (*local_infile_end)(void *),int (*local_infile_error)

320

(void *, char*, unsigned int), void *);

321

322

void

323

drizzle_set_local_infile_default(DRIZZLE *drizzle);

324

325

int32_t drizzle_shutdown(DRIZZLE *drizzle, enum drizzle_enum_shutdown_level shutdown_level);

326

int32_t drizzle_dump_debug_info(DRIZZLE *drizzle);

327

int32_t drizzle_refresh(DRIZZLE *drizzle, uint32_t refresh_options);

328

int32_t drizzle_kill(DRIZZLE *drizzle, uint32_t pid);

329

int32_t drizzle_set_server_option(DRIZZLE *drizzle, enum enum_drizzle_set_option option);

330

int32_t drizzle_ping(DRIZZLE *drizzle);

331

const char * drizzle_stat(DRIZZLE *drizzle);

332

const char * drizzle_get_server_info(const DRIZZLE *drizzle);

333

const char * drizzle_get_client_info(void);

334

uint32_t drizzle_get_client_version(void);

335

const char * drizzle_get_host_info(const DRIZZLE *drizzle);

336

uint32_t drizzle_get_server_version(const DRIZZLE *drizzle);

337

uint32_t drizzle_get_proto_info(const DRIZZLE *drizzle);

338

DRIZZLE_RES * drizzle_list_tables(DRIZZLE *drizzle,const char *wild);

339

DRIZZLE_RES * drizzle_list_processes(DRIZZLE *drizzle);

340

int32_t drizzle_options(DRIZZLE *drizzle,enum drizzle_option option, const void *arg);

341

void drizzle_free_result(DRIZZLE_RES *result);

342

void drizzle_data_seek(DRIZZLE_RES *result, uint64_t offset);

343

DRIZZLE_ROW_OFFSET drizzle_row_seek(DRIZZLE_RES *result, DRIZZLE_ROW_OFFSET offset);

344

DRIZZLE_FIELD_OFFSET drizzle_field_seek(DRIZZLE_RES *result, DRIZZLE_FIELD_OFFSET offset);

345

DRIZZLE_ROW drizzle_fetch_row(DRIZZLE_RES *result);

346

uint32_t * drizzle_fetch_lengths(DRIZZLE_RES *result);

347

DRIZZLE_FIELD * drizzle_fetch_field(DRIZZLE_RES *result);

348

DRIZZLE_RES * drizzle_list_fields(DRIZZLE *drizzle, const char *table, const char *wild);

349

uint32_t drizzle_escape_string(char *to,const char *from, uint32_t from_length);

350

uint32_t drizzle_hex_string(char *to,const char *from, uint32_t from_length);

351

bool drizzle_read_query_result(DRIZZLE *drizzle);

352

353

354

355

typedef struct st_drizzle_methods

356

{

357

bool (*read_query_result)(DRIZZLE *drizzle);

358

bool (*advanced_command)(DRIZZLE *drizzle,

359

enum enum_server_command command,

360

const unsigned char *header,

361

uint32_t header_length,

362

const unsigned char *arg,

363

uint32_t arg_length,

364

bool skip_check);

365

DRIZZLE_DATA *(*read_rows)(DRIZZLE *drizzle,DRIZZLE_FIELD *drizzle_fields, uint32_t fields);

366

DRIZZLE_RES * (*use_result)(DRIZZLE *drizzle);

367

void (*fetch_lengths)(uint32_t *to, DRIZZLE_ROW column, uint32_t field_count);

368

void (*flush_use_result)(DRIZZLE *drizzle);

369

DRIZZLE_FIELD * (*list_fields)(DRIZZLE *drizzle);

370

int32_t (*unbuffered_fetch)(DRIZZLE *drizzle, char **row);

371

const char *(*read_statistics)(DRIZZLE *drizzle);

372

bool (*next_result)(DRIZZLE *drizzle);

373

int32_t (*read_change_user_result)(DRIZZLE *drizzle);

374

} DRIZZLE_METHODS;

375

376

377

bool drizzle_commit(DRIZZLE *drizzle);

378

bool drizzle_rollback(DRIZZLE *drizzle);

379

bool drizzle_autocommit(DRIZZLE *drizzle, bool auto_mode);

380

bool drizzle_more_results(const DRIZZLE *drizzle);

381

int drizzle_next_result(DRIZZLE *drizzle);

382

void drizzle_close(DRIZZLE *sock);

383

384

385

/* status return codes */

386

#define DRIZZLE_NO_DATA 100

387

#define DRIZZLE_DATA_TRUNCATED 101

388

389

390

#define drizzle_reload(drizzle) drizzle_refresh((drizzle),REFRESH_GRANT)

391

392

393

The following functions are mainly exported because of binlog;

394

They are not for general usage

395

396

397

#define simple_command(drizzle, command, arg, length, skip_check) \

398

(*(drizzle)->methods->advanced_command)(drizzle, command, 0, \

399

0, arg, length, skip_check)

400

401

#ifdef __cplusplus

402

}

403

#endif

404

405

#endif /* _libdrizzle_drizzle_h */

#endif /* _libdrizzle_libdrizzle_h */

Older »