forked from EnterpriseDB/mysql_fdw
-
Notifications
You must be signed in to change notification settings - Fork 3
/
Copy pathmysql_fdw.h
209 lines (174 loc) · 8.02 KB
/
mysql_fdw.h
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
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
/*-------------------------------------------------------------------------
*
* mysql_fdw.h
* Foreign-data wrapper for remote MySQL servers
*
* Portions Copyright (c) 2012-2014, PostgreSQL Global Development Group
*
* Portions Copyright (c) 2004-2014, EnterpriseDB Corporation.
*
* IDENTIFICATION
* mysql_fdw.h
*
*-------------------------------------------------------------------------
*/
#ifndef MYSQL_FDW_H
#define MYSQL_FDW_H
#define list_length mysql_list_length
#define list_delete mysql_list_delete
#define list_free mysql_list_free
#include <mysql.h>
#undef list_length
#undef list_delete
#undef list_free
#include "access/tupdesc.h"
#include "foreign/foreign.h"
#include "lib/stringinfo.h"
#if PG_VERSION_NUM < 120000
#include "nodes/relation.h"
#else
#include "nodes/pathnodes.h"
#endif
#include "utils/rel.h"
#define MYSQL_PREFETCH_ROWS 100
#define MYSQL_BLKSIZ (1024 * 4)
#define MYSQL_PORT 3306
#define MAXDATALEN 1024 * 64
#define WAIT_TIMEOUT 0
#define INTERACTIVE_TIMEOUT 0
#define CR_NO_ERROR 0
/*
* Options structure to store the MySQL
* server information
*/
typedef struct mysql_opt
{
int svr_port; /* MySQL port number */
char *svr_address; /* MySQL server ip address */
char *svr_username; /* MySQL user name */
char *svr_password; /* MySQL password */
char *svr_database; /* MySQL database name */
char *svr_table; /* MySQL table name */
bool svr_sa; /* MySQL secure authentication */
char *svr_init_command; /* MySQL SQL statement to execute when connecting to the MySQL server. */
unsigned long max_blob_size; /* Max blob size to read without truncation */
bool use_remote_estimate; /* use remote estimate for rows */
// SSL parameters; unused options may be given as NULL
char *ssl_key; /* MySQL SSL: path to the key file */
char *ssl_cert; /* MySQL SSL: path to the certificate file */
char *ssl_ca; /* MySQL SSL: path to the certificate authority file */
char *ssl_capath; /* MySQL SSL: path to a directory that contains trusted SSL CA certificates in PEM format */
char *ssl_cipher; /* MySQL SSL: list of permissible ciphers to use for SSL encryption */
} mysql_opt;
typedef struct mysql_column
{
Datum value;
unsigned long length;
bool is_null;
bool error;
MYSQL_BIND *_mysql_bind;
} mysql_column;
typedef struct mysql_table
{
MYSQL_RES *_mysql_res;
MYSQL_FIELD *_mysql_fields;
mysql_column *column;
MYSQL_BIND *_mysql_bind;
} mysql_table;
/*
* FDW-specific information for ForeignScanState
* fdw_state.
*/
typedef struct MySQLFdwExecState
{
MYSQL *conn; /* MySQL connection handle */
MYSQL_STMT *stmt; /* MySQL prepared stament handle */
mysql_table *table;
char *query; /* Query string */
Relation rel; /* relcache entry for the foreign table */
List *retrieved_attrs; /* list of target attribute numbers */
bool cursor_exists; /* have we created the cursor? */
int numParams; /* number of parameters passed to query */
FmgrInfo *param_flinfo; /* output conversion functions for them */
List *param_exprs; /* executable expressions for param values */
const char **param_values; /* textual values of query parameters */
Oid *param_types; /* type of query parameters */
int p_nums; /* number of parameters to transmit */
FmgrInfo *p_flinfo; /* output conversion functions for them */
mysql_opt *mysqlFdwOptions; /* MySQL FDW options */
List *attr_list; /* query attribute list */
List *column_list; /* Column list of MySQL Column structures */
/* working memory context */
MemoryContext temp_cxt; /* context for per-tuple temporary data */
} MySQLFdwExecState;
/* MySQL Column List */
typedef struct MySQLColumn
{
int attnum; /* Attribute number */
char *attname; /* Attribute name */
int atttype; /* Attribute type */
} MySQLColumn;
extern bool is_foreign_expr(PlannerInfo *root,
RelOptInfo *baserel,
Expr *expr);
extern int ((*_mysql_options)(MYSQL *mysql,enum mysql_option option, const void *arg));
extern int ((*_mysql_stmt_prepare)(MYSQL_STMT *stmt, const char *query, unsigned long length));
extern int ((*_mysql_stmt_execute)(MYSQL_STMT *stmt));
extern int ((*_mysql_stmt_fetch)(MYSQL_STMT *stmt));
extern int ((*_mysql_query)(MYSQL *mysql, const char *q));
extern bool ((*_mysql_stmt_attr_set)(MYSQL_STMT *stmt, enum enum_stmt_attr_type attr_type, const void *attr));
extern bool ((*_mysql_stmt_close)(MYSQL_STMT * stmt));
extern bool ((*_mysql_stmt_reset)(MYSQL_STMT * stmt));
extern bool ((*_mysql_free_result)(MYSQL_RES *result));
extern bool ((*_mysql_stmt_bind_param)(MYSQL_STMT *stmt, MYSQL_BIND * bnd));
extern bool ((*_mysql_stmt_bind_result)(MYSQL_STMT *stmt, MYSQL_BIND * bnd));
extern MYSQL_STMT *((*_mysql_stmt_init)(MYSQL *mysql));
extern MYSQL_RES *((*_mysql_stmt_result_metadata)(MYSQL_STMT *stmt));
extern int ((*_mysql_stmt_store_result)(MYSQL *mysql));
extern MYSQL_ROW ((*_mysql_fetch_row)(MYSQL_RES *result));
extern MYSQL_FIELD *((*_mysql_fetch_field)(MYSQL_RES *result));
extern MYSQL_FIELD *((*_mysql_fetch_fields)(MYSQL_RES *result));
extern const char *((*_mysql_error)(MYSQL *mysql));
extern void ((*_mysql_close)(MYSQL *sock));
extern MYSQL_RES* ((*_mysql_store_result)(MYSQL *mysql));
extern MYSQL *((*_mysql_init)(MYSQL *mysql));
extern bool ((*_mysql_ssl_set)(MYSQL *mysql, const char *key, const char *cert, const char *ca, const char *capath, const char *cipher));
extern MYSQL *((*_mysql_real_connect)(MYSQL *mysql,
const char *host,
const char *user,
const char *passwd,
const char *db,
unsigned int port,
const char *unix_socket,
unsigned long clientflag));
extern const char *((*_mysql_get_host_info)(MYSQL *mysql));
extern const char *((*_mysql_get_server_info)(MYSQL *mysql));
extern int ((*_mysql_get_proto_info)(MYSQL *mysql));
extern unsigned int ((*_mysql_stmt_errno)(MYSQL_STMT *stmt));
extern unsigned int ((*_mysql_errno)(MYSQL *mysql));
extern unsigned int ((*_mysql_num_fields)(MYSQL_RES *result));
extern unsigned int ((*_mysql_num_rows)(MYSQL_RES *result));
/* option.c headers */
extern bool mysql_is_valid_option(const char *option, Oid context);
extern mysql_opt *mysql_get_options(Oid foreigntableid);
/* depare.c headers */
extern void mysql_deparse_select(StringInfo buf, PlannerInfo *root, RelOptInfo *baserel,
Bitmapset *attrs_used, char *svr_table, List **retrieved_attrs);
extern void mysql_deparse_insert(StringInfo buf, PlannerInfo *root, Index rtindex, Relation rel, List *targetAttrs);
extern void mysql_deparse_update(StringInfo buf, PlannerInfo *root, Index rtindex, Relation rel, List *targetAttrs, char *attname);
extern void mysql_deparse_delete(StringInfo buf, PlannerInfo *root, Index rtindex, Relation rel, char *name);
extern void mysql_append_where_clause(StringInfo buf, PlannerInfo *root, RelOptInfo *baserel, List *exprs,
bool is_first,List **params);
extern void mysql_deparse_analyze(StringInfo buf, char *dbname, char *relname);
/* connection.c headers */
extern MYSQL *mysql_get_connection(ForeignServer *server, UserMapping *user, mysql_opt *opt);
extern MYSQL *mysql_connect(char *svr_address, char *svr_username, char *svr_password, char *svr_database,
int svr_port, bool svr_sa, char *svr_init_command,
char *ssl_key, char *ssl_cert, char *ssl_ca, char *ssl_capath,
char *ssl_cipher);
extern void mysql_cleanup_connection(void);
extern void mysql_rel_connection(MYSQL *conn);
#if PG_VERSION_NUM < 110000 /* TupleDescAttr is defined from PG version 11 */
#define TupleDescAttr(tupdesc, i) ((tupdesc)->attrs[(i)])
#endif
#endif /* MYSQL_FDW_H */