hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

New version compatible with prepared statements

Browse Source
This commit is contained in:
Massimiliano Pinto
2012-12-14 16:40:34 +01:00
parent 063af3684e
commit fa0b97ac61
2 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
protocol_1.0/skysql_client.h
View File

@ -121,9 +121,11 @@ typedef enum
#define SMALL_CHUNK 1024 #define SMALL_CHUNK 1024
#define MAX_CHUNK SMALL_CHUNK * 16 #define MAX_CHUNK SMALL_CHUNK * 8 * 2
#define ToHex(Y) (Y>='0'&&Y<='9'?Y-'0':Y-'A'+10) #define ToHex(Y) (Y>='0'&&Y<='9'?Y-'0':Y-'A'+10)
//#define MYSQL_CONN_DEBUG
typedef struct { typedef struct {
apr_socket_t *socket; apr_socket_t *socket;
char scramble[33]; char scramble[33];
@ -132,3 +134,4 @@ typedef struct {
unsigned long tid; unsigned long tid;
apr_pool_t *pool; apr_pool_t *pool;
} MYSQL_conn; } MYSQL_conn;

2
protocol_1.0/skysql_gw.h
View File

@ -102,7 +102,7 @@ apr_status_t skysql_send_handshake(conn_rec *c, uint8_t *scramble, int *scramble
apr_status_t skysql_send_error (conn_rec *c, uint8_t packet_number, MYSQL_conn *conn); apr_status_t skysql_send_error (conn_rec *c, uint8_t packet_number, MYSQL_conn *conn);
//apr_status_t skysql_prepare_ok(conn_rec *c, uint8_t packet_number, MYSQL_STMT *statement, MYSQL_conn *conn); //apr_status_t skysql_prepare_ok(conn_rec *c, uint8_t packet_number, MYSQL_STMT *statement, MYSQL_conn *conn);
apr_status_t skysql_send_ok(conn_rec *c, apr_pool_t *p, uint8_t packet_number, uint8_t in_affected_rows, const char* skysql_message); apr_status_t skysql_send_ok(conn_rec *c, apr_pool_t *p, uint8_t packet_number, uint8_t in_affected_rows, const char* skysql_message);
apr_status_t skysql_send_eof(conn_rec *c, uint8_t packet_number); apr_status_t skysql_send_eof(conn_rec *c, apr_pool_t *p, uint8_t packet_number);
apr_status_t skysql_send_result(conn_rec *c, uint8_t *data, uint8_t len); apr_status_t skysql_send_result(conn_rec *c, uint8_t *data, uint8_t len);
int select_random_slave_server(int nslaves); int select_random_slave_server(int nslaves);
apr_status_t gateway_send_error (conn_rec *c, apr_pool_t *p, uint8_t packet_number); apr_status_t gateway_send_error (conn_rec *c, apr_pool_t *p, uint8_t packet_number);