1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23 #ifndef PHP_PDO_PGSQL_INT_H
24 #define PHP_PDO_PGSQL_INT_H
25
26 #include <libpq-fe.h>
27 #include <libpq/libpq-fs.h>
28 #include <php.h>
29
30 #define PHP_PDO_PGSQL_CONNECTION_FAILURE_SQLSTATE "08006"
31
32 typedef struct {
33 const char *file;
34 int line;
35 unsigned int errcode;
36 char *errmsg;
37 } pdo_pgsql_error_info;
38
39
40 typedef struct {
41 PGconn *server;
42 unsigned attached:1;
43 unsigned _reserved:31;
44 pdo_pgsql_error_info einfo;
45 Oid pgoid;
46
47
48 int emulate_prepares;
49 int disable_native_prepares;
50 int disable_prepares;
51 unsigned int stmt_counter;
52 } pdo_pgsql_db_handle;
53
54 typedef struct {
55 char *def;
56 Oid pgsql_type;
57 long intval;
58 zend_bool boolval;
59 } pdo_pgsql_column;
60
61 typedef struct {
62 pdo_pgsql_db_handle *H;
63 PGresult *result;
64 int current_row;
65 pdo_pgsql_column *cols;
66 char *cursor_name;
67 char *stmt_name;
68 char *query;
69 char **param_values;
70 int *param_lengths;
71 int *param_formats;
72 Oid *param_types;
73 zend_bool is_prepared;
74 } pdo_pgsql_stmt;
75
76 typedef struct {
77 Oid oid;
78 } pdo_pgsql_bound_param;
79
80 extern pdo_driver_t pdo_pgsql_driver;
81
82 extern int _pdo_pgsql_error(pdo_dbh_t *dbh, pdo_stmt_t *stmt, int errcode, const char *sqlstate, const char *msg, const char *file, int line TSRMLS_DC);
83 #define pdo_pgsql_error(d,e,z) _pdo_pgsql_error(d, NULL, e, z, NULL, __FILE__, __LINE__ TSRMLS_CC)
84 #define pdo_pgsql_error_msg(d,e,m) _pdo_pgsql_error(d, NULL, e, NULL, m, __FILE__, __LINE__ TSRMLS_CC)
85 #define pdo_pgsql_error_stmt(s,e,z) _pdo_pgsql_error(s->dbh, s, e, z, NULL, __FILE__, __LINE__ TSRMLS_CC)
86 #define pdo_pgsql_error_stmt_msg(s,e,m) _pdo_pgsql_error(s->dbh, s, e, NULL, m, __FILE__, __LINE__ TSRMLS_CC)
87
88 extern struct pdo_stmt_methods pgsql_stmt_methods;
89
90 #define pdo_pgsql_sqlstate(r) PQresultErrorField(r, PG_DIAG_SQLSTATE)
91
92 enum {
93 PDO_PGSQL_ATTR_DISABLE_NATIVE_PREPARED_STATEMENT = PDO_ATTR_DRIVER_SPECIFIC,
94 PDO_PGSQL_ATTR_DISABLE_PREPARES,
95 };
96
97 struct pdo_pgsql_lob_self {
98 pdo_dbh_t *dbh;
99 PGconn *conn;
100 int lfd;
101 Oid oid;
102 };
103
104 enum pdo_pgsql_specific_constants {
105 PGSQL_TRANSACTION_IDLE = PQTRANS_IDLE,
106 PGSQL_TRANSACTION_ACTIVE = PQTRANS_ACTIVE,
107 PGSQL_TRANSACTION_INTRANS = PQTRANS_INTRANS,
108 PGSQL_TRANSACTION_INERROR = PQTRANS_INERROR,
109 PGSQL_TRANSACTION_UNKNOWN = PQTRANS_UNKNOWN
110 };
111
112 php_stream *pdo_pgsql_create_lob_stream(pdo_dbh_t *stmt, int lfd, Oid oid TSRMLS_DC);
113 extern php_stream_ops pdo_pgsql_lob_stream_ops;
114
115 #endif
116
117
118
119
120
121
122
123
124