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
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
#ifndef DRIZZLED_PLUGIN_OLDLIBDRIZZLE_H
21
#define DRIZZLED_PLUGIN_OLDLIBDRIZZLE_H
23
#include <drizzled/plugin/protocol.h>
28
class ProtocolOldLibdrizzle: public Protocol
1
/* Copyright (C) 2002-2006 MySQL 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; version 2 of the License.
7
This program is distributed in the hope that it will be useful,
8
but WITHOUT ANY WARRANTY; without even the implied warranty of
9
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
10
GNU General Public License for more details.
12
You should have received a copy of the GNU General Public License
13
along with this program; if not, write to the Free Software
14
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
16
#ifdef USE_PRAGMA_INTERFACE
17
#pragma interface /* gcc class implementation */
23
typedef struct st_mysql_field MYSQL_FIELD;
24
typedef struct st_mysql_rows MYSQL_ROWS;
33
struct rand_struct rand;
34
char scramble[SCRAMBLE_LENGTH+1];
39
bool netStoreData(const unsigned char *from, size_t length);
40
bool netStoreData(const unsigned char *from, size_t length,
41
const CHARSET_INFO * const fromcs,
42
const CHARSET_INFO * const tocs);
43
bool storeString(const char *from, size_t length,
44
const CHARSET_INFO * const fromcs,
45
const CHARSET_INFO * const tocs);
48
* Performs handshake with client and authorizes user.
50
* Returns true is the connection is valid and the
51
* user is authorized, otherwise false.
53
bool checkConnection(void);
34
bool net_store_data(const uchar *from, size_t length);
35
bool net_store_data(const uchar *from, size_t length,
36
CHARSET_INFO *fromcs, CHARSET_INFO *tocs);
37
bool store_string_aux(const char *from, size_t length,
38
CHARSET_INFO *fromcs, CHARSET_INFO *tocs);
56
ProtocolOldLibdrizzle();
57
virtual void setSession(Session *session_arg);
58
virtual bool isConnected();
59
virtual void setReadTimeout(uint32_t timeout);
60
virtual void setWriteTimeout(uint32_t timeout);
61
virtual void setRetryCount(uint32_t count);
62
virtual void setError(char error);
63
virtual bool haveError(void);
64
virtual bool wasAborted(void);
65
virtual void enableCompression(void);
66
virtual bool haveMoreData(void);
67
virtual bool isReading(void);
68
virtual bool isWriting(void);
69
virtual bool setFileDescriptor(int fd);
70
virtual int fileDescriptor(void);
71
virtual void setRandom(uint64_t seed1, uint64_t seed2);
72
virtual bool authenticate(void);
73
virtual bool readCommand(char **packet, uint32_t *packet_length);
74
virtual void sendOK();
75
virtual void sendEOF();
76
virtual void sendError(uint32_t sql_errno, const char *err);
78
virtual void forceClose();
79
virtual void prepareForResend();
41
Protocol(THD *thd_arg) { init(thd_arg); }
42
virtual ~Protocol() {}
43
void init(THD* thd_arg);
45
enum { SEND_NUM_ROWS= 1, SEND_DEFAULTS= 2, SEND_EOF= 4 };
46
virtual bool send_fields(List<Item> *list, uint flags);
48
bool store(I_List<i_string> *str_list);
49
bool store(const char *from, CHARSET_INFO *cs);
50
String *storage_packet() { return packet; }
51
inline void free() { packet->free(); }
81
52
virtual bool write();
83
virtual bool sendFields(List<Item> *list, uint32_t flags);
85
using Protocol::store;
86
virtual bool store(Field *from);
87
virtual bool store(void);
88
virtual bool store(int32_t from);
89
virtual bool store(uint32_t from);
90
virtual bool store(int64_t from);
91
virtual bool store(uint64_t from);
92
virtual bool store(double from, uint32_t decimals, String *buffer);
93
virtual bool store(const DRIZZLE_TIME *from);
53
inline bool store(int from)
54
{ return store_long((longlong) from); }
55
inline bool store(uint32 from)
56
{ return store_long((longlong) from); }
57
inline bool store(longlong from)
58
{ return store_longlong((longlong) from, 0); }
59
inline bool store(ulonglong from)
60
{ return store_longlong((longlong) from, 1); }
61
inline bool store(String *str)
62
{ return store((char*) str->ptr(), str->length(), str->charset()); }
64
virtual bool prepare_for_send(List<Item> *item_list)
66
field_count=item_list->elements;
70
virtual void end_partial_result_set(THD *thd);
71
virtual void prepare_for_resend()=0;
73
virtual bool store_null()=0;
74
virtual bool store_tiny(longlong from)=0;
75
virtual bool store_short(longlong from)=0;
76
virtual bool store_long(longlong from)=0;
77
virtual bool store_longlong(longlong from, bool unsigned_flag)=0;
78
virtual bool store_decimal(const my_decimal *)=0;
79
virtual bool store(const char *from, size_t length, CHARSET_INFO *cs)=0;
80
virtual bool store(const char *from, size_t length,
81
CHARSET_INFO *fromcs, CHARSET_INFO *tocs)=0;
82
virtual bool store(float from, uint32 decimals, String *buffer)=0;
83
virtual bool store(double from, uint32 decimals, String *buffer)=0;
84
virtual bool store(MYSQL_TIME *time)=0;
85
virtual bool store_date(MYSQL_TIME *time)=0;
86
virtual bool store_time(MYSQL_TIME *time)=0;
87
virtual bool store(Field *field)=0;
88
void remove_last_row() {}
89
enum enum_protocol_type
91
PROTOCOL_TEXT= 0, PROTOCOL_BINARY= 1
93
before adding here or change the values, consider that it is cast to a
97
virtual enum enum_protocol_type type()= 0;
101
/** Class used for the old (MySQL 4.0 protocol). */
103
class Protocol_text :public Protocol
107
Protocol_text(THD *thd_arg) :Protocol(thd_arg) {}
108
virtual void prepare_for_resend();
109
virtual bool store_null();
110
virtual bool store_tiny(longlong from);
111
virtual bool store_short(longlong from);
112
virtual bool store_long(longlong from);
113
virtual bool store_longlong(longlong from, bool unsigned_flag);
114
virtual bool store_decimal(const my_decimal *);
115
virtual bool store(const char *from, size_t length, CHARSET_INFO *cs);
94
116
virtual bool store(const char *from, size_t length,
95
const CHARSET_INFO * const cs);
98
class ProtocolFactoryOldLibdrizzle: public ProtocolFactory
101
ProtocolFactoryOldLibdrizzle() : ProtocolFactory("oldlibdrizzle") {}
102
Protocol *operator()(void)
104
return new ProtocolOldLibdrizzle;
108
#endif /* DRIZZLED_PLUGIN_OLDLIBDRIZZLE_H */
117
CHARSET_INFO *fromcs, CHARSET_INFO *tocs);
118
virtual bool store(MYSQL_TIME *time);
119
virtual bool store_date(MYSQL_TIME *time);
120
virtual bool store_time(MYSQL_TIME *time);
121
virtual bool store(float nr, uint32 decimals, String *buffer);
122
virtual bool store(double from, uint32 decimals, String *buffer);
123
virtual bool store(Field *field);
124
virtual enum enum_protocol_type type() { return PROTOCOL_TEXT; };
127
void send_warning(THD *thd, uint sql_errno, const char *err=0);
128
void net_send_error(THD *thd, uint sql_errno=0, const char *err=0);
129
void net_end_statement(THD *thd);
130
uchar *net_store_data(uchar *to,const uchar *from, size_t length);
131
uchar *net_store_data(uchar *to,int32 from);
132
uchar *net_store_data(uchar *to,longlong from);