Lines Matching refs:dbh
73 int _pdo_pgsql_error(pdo_dbh_t *dbh, pdo_stmt_t *stmt, int errcode, const char *sqlstate, const cha… in _pdo_pgsql_error() argument
75 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in _pdo_pgsql_error()
76 pdo_error_type *pdo_err = stmt ? &stmt->error_code : &dbh->error_code; in _pdo_pgsql_error()
85 pefree(einfo->errmsg, dbh->is_persistent); in _pdo_pgsql_error()
100 einfo->errmsg = _pdo_pgsql_trim_message(errmsg, dbh->is_persistent); in _pdo_pgsql_error()
103 if (!dbh->methods) { in _pdo_pgsql_error()
111 static void _pdo_pgsql_notice(pdo_dbh_t *dbh, const char *message) /* {{{ */ in _pdo_pgsql_notice() argument
117 static int pdo_pgsql_fetch_error_func(pdo_dbh_t *dbh, pdo_stmt_t *stmt, zval *info) /* {{{ */ in pdo_pgsql_fetch_error_func() argument
119 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_fetch_error_func()
151 zval_ptr_dtor(&self->dbh); in pgsql_lob_close()
186 php_stream *pdo_pgsql_create_lob_stream(zval *dbh, int lfd, Oid oid) in pdo_pgsql_create_lob_stream() argument
190 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)(Z_PDO_DBH_P(dbh))->driver_data; in pdo_pgsql_create_lob_stream()
192 ZVAL_COPY_VALUE(&self->dbh, dbh); in pdo_pgsql_create_lob_stream()
200 Z_ADDREF_P(dbh); in pdo_pgsql_create_lob_stream()
209 static int pgsql_handle_closer(pdo_dbh_t *dbh) /* {{{ */ in pgsql_handle_closer() argument
211 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_closer()
218 pefree(H->einfo.errmsg, dbh->is_persistent); in pgsql_handle_closer()
221 pefree(H, dbh->is_persistent); in pgsql_handle_closer()
222 dbh->driver_data = NULL; in pgsql_handle_closer()
228 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
230 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()
297 static zend_long pgsql_handle_doer(pdo_dbh_t *dbh, const char *sql, size_t sql_len) in pgsql_handle_doer() argument
299 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_doer()
306 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsql_handle_doer()
311 pdo_pgsql_error(dbh, qs, pdo_pgsql_sqlstate(res)); in pgsql_handle_doer()
326 static int pgsql_handle_quoter(pdo_dbh_t *dbh, const char *unquoted, size_t unquotedlen, char **quo… in pgsql_handle_quoter() argument
329 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_quoter()
355 static char *pdo_pgsql_last_insert_id(pdo_dbh_t *dbh, const char *name, size_t *len) in pdo_pgsql_last_insert_id() argument
357 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_last_insert_id()
376 pdo_pgsql_error(dbh, status, pdo_pgsql_sqlstate(res)); in pdo_pgsql_last_insert_id()
386 static int pdo_pgsql_get_attribute(pdo_dbh_t *dbh, zend_long attr, zval *return_value) in pdo_pgsql_get_attribute() argument
388 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_get_attribute()
478 static int pdo_pgsql_check_liveness(pdo_dbh_t *dbh) in pdo_pgsql_check_liveness() argument
480 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_check_liveness()
488 static int pgsql_handle_in_transaction(pdo_dbh_t *dbh) in pgsql_handle_in_transaction() argument
492 H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_in_transaction()
497 static int pdo_pgsql_transaction_cmd(const char *cmd, pdo_dbh_t *dbh) in pdo_pgsql_transaction_cmd() argument
499 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_transaction_cmd()
506 pdo_pgsql_error(dbh, PQresultStatus(res), pdo_pgsql_sqlstate(res)); in pdo_pgsql_transaction_cmd()
514 static int pgsql_handle_begin(pdo_dbh_t *dbh) in pgsql_handle_begin() argument
516 return pdo_pgsql_transaction_cmd("BEGIN", dbh); in pgsql_handle_begin()
519 static int pgsql_handle_commit(pdo_dbh_t *dbh) in pgsql_handle_commit() argument
521 int ret = pdo_pgsql_transaction_cmd("COMMIT", dbh); in pgsql_handle_commit()
526 dbh->in_txn = pgsql_handle_in_transaction(dbh); in pgsql_handle_commit()
532 static int pgsql_handle_rollback(pdo_dbh_t *dbh) in pgsql_handle_rollback() argument
534 return pdo_pgsql_transaction_cmd("ROLLBACK", dbh); in pgsql_handle_rollback()
541 pdo_dbh_t *dbh; in PHP_METHOD() local
564 dbh = Z_PDO_DBH_P(getThis()); in PHP_METHOD()
576 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
614 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
624 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
631 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in PHP_METHOD()
640 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in PHP_METHOD()
652 pdo_dbh_t *dbh; in PHP_METHOD() local
669 dbh = Z_PDO_DBH_P(getThis()); in PHP_METHOD()
675 pdo_pgsql_error_msg(dbh, PGRES_FATAL_ERROR, "Unable to open the file"); in PHP_METHOD()
687 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
711 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
721 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
728 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in PHP_METHOD()
738 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in PHP_METHOD()
751 pdo_dbh_t *dbh; in PHP_METHOD() local
769 dbh = Z_PDO_DBH_P(getThis()); in PHP_METHOD()
773 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
777 pdo_pgsql_error_msg(dbh, PGRES_FATAL_ERROR, "Unable to open the file for writing"); in PHP_METHOD()
811 pdo_pgsql_error_msg(dbh, PGRES_FATAL_ERROR, "Unable to write to file"); in PHP_METHOD()
820 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
834 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in PHP_METHOD()
846 pdo_dbh_t *dbh; in PHP_METHOD() local
862 dbh = Z_PDO_DBH_P(getThis()); in PHP_METHOD()
866 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
900 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
910 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in PHP_METHOD()
923 pdo_dbh_t *dbh; in PHP_METHOD() local
927 dbh = Z_PDO_DBH_P(getThis()); in PHP_METHOD()
931 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
940 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
950 pdo_dbh_t *dbh; in PHP_METHOD() local
975 dbh = Z_PDO_DBH_P(getThis()); in PHP_METHOD()
979 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
990 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
1002 pdo_dbh_t *dbh; in PHP_METHOD() local
1018 dbh = Z_PDO_DBH_P(getThis()); in PHP_METHOD()
1022 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
1028 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
1038 pdo_dbh_t *dbh; in PHP_METHOD() local
1049 dbh = Z_PDO_DBH_P(getThis()); in PHP_METHOD()
1053 result_type = dbh->default_fetch_type; in PHP_METHOD()
1071 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
1074 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
1084 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in PHP_METHOD()
1119 pdo_dbh_t *dbh; in PHP_METHOD() local
1122 dbh = Z_PDO_DBH_P(getThis()); in PHP_METHOD()
1125 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
1145 static const zend_function_entry *pdo_pgsql_get_driver_methods(pdo_dbh_t *dbh, int kind) in pdo_pgsql_get_driver_methods() argument
1155 static int pdo_pgsql_set_attr(pdo_dbh_t *dbh, zend_long attr, zval *val) in pdo_pgsql_set_attr() argument
1158 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_set_attr()
1190 static int pdo_pgsql_handle_factory(pdo_dbh_t *dbh, zval *driver_options) /* {{{ */ in pdo_pgsql_handle_factory() argument
1198 H = pecalloc(1, sizeof(pdo_pgsql_db_handle), dbh->is_persistent); in pdo_pgsql_handle_factory()
1199 dbh->driver_data = H; in pdo_pgsql_handle_factory()
1201 dbh->skip_param_evt = in pdo_pgsql_handle_factory()
1212 e = (char *) dbh->data_source + strlen(dbh->data_source); in pdo_pgsql_handle_factory()
1213 p = (char *) dbh->data_source; in pdo_pgsql_handle_factory()
1223 tmp_user = _pdo_pgsql_escape_credentials(dbh->username); in pdo_pgsql_handle_factory()
1224 tmp_pass = _pdo_pgsql_escape_credentials(dbh->password); in pdo_pgsql_handle_factory()
1228 …spprintf(&conn_str, 0, "%s user='%s' password='%s' connect_timeout=" ZEND_LONG_FMT, (char *) dbh->… in pdo_pgsql_handle_factory()
1230 …spprintf(&conn_str, 0, "%s user='%s' connect_timeout=" ZEND_LONG_FMT, (char *) dbh->data_source, Z… in pdo_pgsql_handle_factory()
1232 …spprintf(&conn_str, 0, "%s password='%s' connect_timeout=" ZEND_LONG_FMT, (char *) dbh->data_sourc… in pdo_pgsql_handle_factory()
1234 …spprintf(&conn_str, 0, "%s connect_timeout=" ZEND_LONG_FMT, (char *) dbh->data_source, connect_tim… in pdo_pgsql_handle_factory()
1249 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, PHP_PDO_PGSQL_CONNECTION_FAILURE_SQLSTATE); in pdo_pgsql_handle_factory()
1253 PQsetNoticeProcessor(H->server, (void(*)(void*,const char*))_pdo_pgsql_notice, (void *)&dbh); in pdo_pgsql_handle_factory()
1258 dbh->methods = &pgsql_methods; in pdo_pgsql_handle_factory()
1259 dbh->alloc_own_columns = 1; in pdo_pgsql_handle_factory()
1260 dbh->max_escaped_char_length = 2; in pdo_pgsql_handle_factory()
1265 dbh->methods = &pgsql_methods; in pdo_pgsql_handle_factory()
1267 pgsql_handle_closer(dbh); in pdo_pgsql_handle_factory()
