Lines Matching refs:dbh
68 int _pdo_pgsql_error(pdo_dbh_t *dbh, pdo_stmt_t *stmt, int errcode, const char *sqlstate, const cha… in _pdo_pgsql_error() argument
70 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in _pdo_pgsql_error()
71 pdo_error_type *pdo_err = stmt ? &stmt->error_code : &dbh->error_code; in _pdo_pgsql_error()
80 pefree(einfo->errmsg, dbh->is_persistent); in _pdo_pgsql_error()
95 einfo->errmsg = _pdo_pgsql_trim_message(errmsg, dbh->is_persistent); in _pdo_pgsql_error()
98 if (!dbh->methods) { in _pdo_pgsql_error()
106 static void _pdo_pgsql_notice(pdo_dbh_t *dbh, const char *message) /* {{{ */ in _pdo_pgsql_notice() argument
112 static int pdo_pgsql_fetch_error_func(pdo_dbh_t *dbh, pdo_stmt_t *stmt, zval *info) /* {{{ */ in pdo_pgsql_fetch_error_func() argument
114 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_fetch_error_func()
146 zval_ptr_dtor(&self->dbh); in pgsql_lob_close()
181 php_stream *pdo_pgsql_create_lob_stream(zval *dbh, int lfd, Oid oid) in pdo_pgsql_create_lob_stream() argument
185 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)(Z_PDO_DBH_P(dbh))->driver_data; in pdo_pgsql_create_lob_stream()
187 ZVAL_COPY_VALUE(&self->dbh, dbh); in pdo_pgsql_create_lob_stream()
195 Z_ADDREF_P(dbh); in pdo_pgsql_create_lob_stream()
204 static int pgsql_handle_closer(pdo_dbh_t *dbh) /* {{{ */ in pgsql_handle_closer() argument
206 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_closer()
213 pefree(H->einfo.errmsg, dbh->is_persistent); in pgsql_handle_closer()
216 pefree(H, dbh->is_persistent); in pgsql_handle_closer()
217 dbh->driver_data = NULL; in pgsql_handle_closer()
223 static int pgsql_handle_preparer(pdo_dbh_t *dbh, const char *sql, size_t sql_len, pdo_stmt_t *stmt,… in pgsql_handle_preparer() argument
225 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_preparer()
274 strcpy(dbh->error_code, stmt->error_code); in pgsql_handle_preparer()
292 static zend_long pgsql_handle_doer(pdo_dbh_t *dbh, const char *sql, size_t sql_len) in pgsql_handle_doer() argument
294 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_doer()
301 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsql_handle_doer()
306 pdo_pgsql_error(dbh, qs, pdo_pgsql_sqlstate(res)); in pgsql_handle_doer()
321 static int pgsql_handle_quoter(pdo_dbh_t *dbh, const char *unquoted, size_t unquotedlen, char **quo… in pgsql_handle_quoter() argument
324 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_quoter()
350 static char *pdo_pgsql_last_insert_id(pdo_dbh_t *dbh, const char *name, size_t *len) in pdo_pgsql_last_insert_id() argument
352 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_last_insert_id()
371 pdo_pgsql_error(dbh, status, pdo_pgsql_sqlstate(res)); in pdo_pgsql_last_insert_id()
381 static int pdo_pgsql_get_attribute(pdo_dbh_t *dbh, zend_long attr, zval *return_value) in pdo_pgsql_get_attribute() argument
383 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_get_attribute()
473 static int pdo_pgsql_check_liveness(pdo_dbh_t *dbh) in pdo_pgsql_check_liveness() argument
475 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_check_liveness()
483 static int pgsql_handle_in_transaction(pdo_dbh_t *dbh) in pgsql_handle_in_transaction() argument
487 H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_in_transaction()
492 static int pdo_pgsql_transaction_cmd(const char *cmd, pdo_dbh_t *dbh) in pdo_pgsql_transaction_cmd() argument
494 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_transaction_cmd()
501 pdo_pgsql_error(dbh, PQresultStatus(res), pdo_pgsql_sqlstate(res)); in pdo_pgsql_transaction_cmd()
509 static int pgsql_handle_begin(pdo_dbh_t *dbh) in pgsql_handle_begin() argument
511 return pdo_pgsql_transaction_cmd("BEGIN", dbh); in pgsql_handle_begin()
514 static int pgsql_handle_commit(pdo_dbh_t *dbh) in pgsql_handle_commit() argument
516 int ret = pdo_pgsql_transaction_cmd("COMMIT", dbh); in pgsql_handle_commit()
521 dbh->in_txn = pgsql_handle_in_transaction(dbh); in pgsql_handle_commit()
527 static int pgsql_handle_rollback(pdo_dbh_t *dbh) in pgsql_handle_rollback() argument
529 return pdo_pgsql_transaction_cmd("ROLLBACK", dbh); in pgsql_handle_rollback()
536 pdo_dbh_t *dbh; in PHP_METHOD() local
559 dbh = Z_PDO_DBH_P(ZEND_THIS); in PHP_METHOD()
571 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
612 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
622 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
629 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in PHP_METHOD()
638 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in PHP_METHOD()
650 pdo_dbh_t *dbh; in PHP_METHOD() local
667 dbh = Z_PDO_DBH_P(ZEND_THIS); in PHP_METHOD()
673 pdo_pgsql_error_msg(dbh, PGRES_FATAL_ERROR, "Unable to open the file"); in PHP_METHOD()
685 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
709 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
719 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
726 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in PHP_METHOD()
736 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in PHP_METHOD()
749 pdo_dbh_t *dbh; in PHP_METHOD() local
767 dbh = Z_PDO_DBH_P(ZEND_THIS); in PHP_METHOD()
771 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
775 pdo_pgsql_error_msg(dbh, PGRES_FATAL_ERROR, "Unable to open the file for writing"); in PHP_METHOD()
809 pdo_pgsql_error_msg(dbh, PGRES_FATAL_ERROR, "Unable to write to file"); in PHP_METHOD()
818 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
832 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in PHP_METHOD()
844 pdo_dbh_t *dbh; in PHP_METHOD() local
860 dbh = Z_PDO_DBH_P(ZEND_THIS); in PHP_METHOD()
864 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
898 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
908 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in PHP_METHOD()
921 pdo_dbh_t *dbh; in PHP_METHOD() local
925 dbh = Z_PDO_DBH_P(ZEND_THIS); in PHP_METHOD()
929 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
938 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
948 pdo_dbh_t *dbh; in PHP_METHOD() local
973 dbh = Z_PDO_DBH_P(ZEND_THIS); in PHP_METHOD()
977 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
988 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
1000 pdo_dbh_t *dbh; in PHP_METHOD() local
1016 dbh = Z_PDO_DBH_P(ZEND_THIS); in PHP_METHOD()
1020 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
1026 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
1036 pdo_dbh_t *dbh; in PHP_METHOD() local
1047 dbh = Z_PDO_DBH_P(ZEND_THIS); in PHP_METHOD()
1051 result_type = dbh->default_fetch_type; in PHP_METHOD()
1069 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
1072 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
1082 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
1117 pdo_dbh_t *dbh; in PHP_METHOD() local
1120 dbh = Z_PDO_DBH_P(ZEND_THIS); in PHP_METHOD()
1123 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
1143 static const zend_function_entry *pdo_pgsql_get_driver_methods(pdo_dbh_t *dbh, int kind) in pdo_pgsql_get_driver_methods() argument
1153 static int pdo_pgsql_set_attr(pdo_dbh_t *dbh, zend_long attr, zval *val) in pdo_pgsql_set_attr() argument
1156 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_set_attr()
1188 static int pdo_pgsql_handle_factory(pdo_dbh_t *dbh, zval *driver_options) /* {{{ */ in pdo_pgsql_handle_factory() argument
1196 H = pecalloc(1, sizeof(pdo_pgsql_db_handle), dbh->is_persistent); in pdo_pgsql_handle_factory()
1197 dbh->driver_data = H; in pdo_pgsql_handle_factory()
1199 dbh->skip_param_evt = in pdo_pgsql_handle_factory()
1210 e = (char *) dbh->data_source + strlen(dbh->data_source); in pdo_pgsql_handle_factory()
1211 p = (char *) dbh->data_source; in pdo_pgsql_handle_factory()
1221 tmp_user = _pdo_pgsql_escape_credentials(dbh->username); in pdo_pgsql_handle_factory()
1222 tmp_pass = _pdo_pgsql_escape_credentials(dbh->password); in pdo_pgsql_handle_factory()
1226 …spprintf(&conn_str, 0, "%s user='%s' password='%s' connect_timeout=" ZEND_LONG_FMT, (char *) dbh->… in pdo_pgsql_handle_factory()
1228 …spprintf(&conn_str, 0, "%s user='%s' connect_timeout=" ZEND_LONG_FMT, (char *) dbh->data_source, Z… in pdo_pgsql_handle_factory()
1230 …spprintf(&conn_str, 0, "%s password='%s' connect_timeout=" ZEND_LONG_FMT, (char *) dbh->data_sourc… in pdo_pgsql_handle_factory()
1232 …spprintf(&conn_str, 0, "%s connect_timeout=" ZEND_LONG_FMT, (char *) dbh->data_source, connect_tim… in pdo_pgsql_handle_factory()
1247 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, PHP_PDO_PGSQL_CONNECTION_FAILURE_SQLSTATE); in pdo_pgsql_handle_factory()
1251 PQsetNoticeProcessor(H->server, (void(*)(void*,const char*))_pdo_pgsql_notice, (void *)&dbh); in pdo_pgsql_handle_factory()
1256 dbh->methods = &pgsql_methods; in pdo_pgsql_handle_factory()
1257 dbh->alloc_own_columns = 1; in pdo_pgsql_handle_factory()
1258 dbh->max_escaped_char_length = 2; in pdo_pgsql_handle_factory()
1263 dbh->methods = &pgsql_methods; in pdo_pgsql_handle_factory()
1265 pgsql_handle_closer(dbh); in pdo_pgsql_handle_factory()
