Lines Matching refs:dbh
38 static bool pgsql_handle_in_transaction(pdo_dbh_t *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()
92 einfo->errmsg = pestrdup(msg, 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()
108 pdo_dbh_t * dbh = (pdo_dbh_t *)context; in _pdo_pgsql_notice() local
109 zend_fcall_info_cache *fc = ((pdo_pgsql_db_handle *)dbh->driver_data)->notice_callback; in _pdo_pgsql_notice()
119 static void pdo_pgsql_fetch_error_func(pdo_dbh_t *dbh, pdo_stmt_t *stmt, zval *info) /* {{{ */ in pdo_pgsql_fetch_error_func() argument
121 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_fetch_error_func()
162 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)(Z_PDO_DBH_P(&self->dbh))->driver_data; in pgsql_lob_close()
168 zval_ptr_dtor(&self->dbh); in pgsql_lob_close()
203 php_stream *pdo_pgsql_create_lob_stream(zval *dbh, int lfd, Oid oid) in pdo_pgsql_create_lob_stream() argument
207 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)(Z_PDO_DBH_P(dbh))->driver_data; in pdo_pgsql_create_lob_stream()
209 ZVAL_COPY_VALUE(&self->dbh, dbh); in pdo_pgsql_create_lob_stream()
217 Z_ADDREF_P(dbh); in pdo_pgsql_create_lob_stream()
227 void pdo_pgsql_close_lob_streams(pdo_dbh_t *dbh) in pdo_pgsql_close_lob_streams() argument
230 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_close_lob_streams()
240 static void pgsql_handle_closer(pdo_dbh_t *dbh) /* {{{ */ in pgsql_handle_closer() argument
242 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_closer()
245 pdo_pgsql_close_lob_streams(dbh); in pgsql_handle_closer()
247 pefree(H->lob_streams, dbh->is_persistent); in pgsql_handle_closer()
256 pefree(H->einfo.errmsg, dbh->is_persistent); in pgsql_handle_closer()
259 pefree(H, dbh->is_persistent); in pgsql_handle_closer()
260 dbh->driver_data = NULL; in pgsql_handle_closer()
265 static bool pgsql_handle_preparer(pdo_dbh_t *dbh, zend_string *sql, pdo_stmt_t *stmt, zval *driver_… in pgsql_handle_preparer() argument
267 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_preparer()
321 strcpy(dbh->error_code, stmt->error_code); in pgsql_handle_preparer()
339 static zend_long pgsql_handle_doer(pdo_dbh_t *dbh, const zend_string *sql) in pgsql_handle_doer() argument
341 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_doer()
346 bool in_trans = pgsql_handle_in_transaction(dbh); in pgsql_handle_doer()
350 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsql_handle_doer()
355 pdo_pgsql_error(dbh, qs, pdo_pgsql_sqlstate(res)); in pgsql_handle_doer()
366 if (in_trans && !pgsql_handle_in_transaction(dbh)) { in pgsql_handle_doer()
367 pdo_pgsql_close_lob_streams(dbh); in pgsql_handle_doer()
373 static zend_string* pgsql_handle_quoter(pdo_dbh_t *dbh, const zend_string *unquoted, enum pdo_param… in pgsql_handle_quoter() argument
379 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_quoter()
408 static zend_string *pdo_pgsql_last_insert_id(pdo_dbh_t *dbh, const zend_string *name) in pdo_pgsql_last_insert_id() argument
410 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_last_insert_id()
428 pdo_pgsql_error(dbh, status, pdo_pgsql_sqlstate(res)); in pdo_pgsql_last_insert_id()
452 static int pdo_pgsql_get_attribute(pdo_dbh_t *dbh, zend_long attr, zval *return_value) in pdo_pgsql_get_attribute() argument
454 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_get_attribute()
555 static zend_result pdo_pgsql_check_liveness(pdo_dbh_t *dbh) in pdo_pgsql_check_liveness() argument
557 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_check_liveness()
565 static bool pgsql_handle_in_transaction(pdo_dbh_t *dbh) in pgsql_handle_in_transaction() argument
567 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_in_transaction()
572 static bool pdo_pgsql_transaction_cmd(const char *cmd, pdo_dbh_t *dbh) in pdo_pgsql_transaction_cmd() argument
574 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_transaction_cmd()
581 pdo_pgsql_error(dbh, PQresultStatus(res), pdo_pgsql_sqlstate(res)); in pdo_pgsql_transaction_cmd()
589 static bool pgsql_handle_begin(pdo_dbh_t *dbh) in pgsql_handle_begin() argument
591 return pdo_pgsql_transaction_cmd("BEGIN", dbh); in pgsql_handle_begin()
594 static bool pgsql_handle_commit(pdo_dbh_t *dbh) in pgsql_handle_commit() argument
596 bool ret = pdo_pgsql_transaction_cmd("COMMIT", dbh); in pgsql_handle_commit()
601 pdo_pgsql_close_lob_streams(dbh); in pgsql_handle_commit()
603 dbh->in_txn = pgsql_handle_in_transaction(dbh); in pgsql_handle_commit()
609 static bool pgsql_handle_rollback(pdo_dbh_t *dbh) in pgsql_handle_rollback() argument
611 int ret = pdo_pgsql_transaction_cmd("ROLLBACK", dbh); in pgsql_handle_rollback()
614 pdo_pgsql_close_lob_streams(dbh); in pgsql_handle_rollback()
648 pdo_dbh_t *dbh; in pgsqlCopyFromArray_internal() local
671 dbh = Z_PDO_DBH_P(ZEND_THIS); in pgsqlCopyFromArray_internal()
683 H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsqlCopyFromArray_internal()
709 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsqlCopyFromArray_internal()
724 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsqlCopyFromArray_internal()
733 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsqlCopyFromArray_internal()
740 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in pgsqlCopyFromArray_internal()
749 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in pgsqlCopyFromArray_internal()
765 pdo_dbh_t *dbh; in pgsqlCopyFromFile_internal() local
782 dbh = Z_PDO_DBH_P(ZEND_THIS); in pgsqlCopyFromFile_internal()
788 pdo_pgsql_error_msg(dbh, PGRES_FATAL_ERROR, "Unable to open the file"); in pgsqlCopyFromFile_internal()
800 H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsqlCopyFromFile_internal()
824 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsqlCopyFromFile_internal()
834 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsqlCopyFromFile_internal()
841 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in pgsqlCopyFromFile_internal()
851 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in pgsqlCopyFromFile_internal()
867 pdo_dbh_t *dbh; in pgsqlCopyToFile_internal() local
885 dbh = Z_PDO_DBH_P(ZEND_THIS); in pgsqlCopyToFile_internal()
889 H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsqlCopyToFile_internal()
893 pdo_pgsql_error_msg(dbh, PGRES_FATAL_ERROR, "Unable to open the file for writing"); in pgsqlCopyToFile_internal()
927 pdo_pgsql_error_msg(dbh, PGRES_FATAL_ERROR, "Unable to write to file"); in pgsqlCopyToFile_internal()
936 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsqlCopyToFile_internal()
950 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in pgsqlCopyToFile_internal()
967 pdo_dbh_t *dbh; in pgsqlCopyToArray_internal() local
983 dbh = Z_PDO_DBH_P(ZEND_THIS); in pgsqlCopyToArray_internal()
987 H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsqlCopyToArray_internal()
1021 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsqlCopyToArray_internal()
1031 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in pgsqlCopyToArray_internal()
1047 pdo_dbh_t *dbh; in pgsqlLOBCreate_internal() local
1053 dbh = Z_PDO_DBH_P(ZEND_THIS); in pgsqlLOBCreate_internal()
1057 H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsqlLOBCreate_internal()
1066 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsqlLOBCreate_internal()
1080 pdo_dbh_t *dbh; in pgsqlLOBOpen_internal() local
1105 dbh = Z_PDO_DBH_P(ZEND_THIS); in pgsqlLOBOpen_internal()
1109 H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsqlLOBOpen_internal()
1120 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsqlLOBOpen_internal()
1136 pdo_dbh_t *dbh; in pgsqlLOBUnlink_internal() local
1152 dbh = Z_PDO_DBH_P(ZEND_THIS); in pgsqlLOBUnlink_internal()
1156 H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsqlLOBUnlink_internal()
1162 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsqlLOBUnlink_internal()
1176 pdo_dbh_t *dbh; in pgsqlGetNotify_internal() local
1187 dbh = Z_PDO_DBH_P(ZEND_THIS); in pgsqlGetNotify_internal()
1191 result_type = dbh->default_fetch_type; in pgsqlGetNotify_internal()
1209 H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsqlGetNotify_internal()
1212 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsqlGetNotify_internal()
1222 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsqlGetNotify_internal()
1261 pdo_dbh_t *dbh; in pgsqlGetPid_internal() local
1266 dbh = Z_PDO_DBH_P(ZEND_THIS); in pgsqlGetPid_internal()
1269 H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsqlGetPid_internal()
1290 pdo_dbh_t *dbh = Z_PDO_DBH_P(ZEND_THIS); in PHP_METHOD() local
1293 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
1312 static const zend_function_entry *pdo_pgsql_get_driver_methods(pdo_dbh_t *dbh, int kind) in pdo_pgsql_get_driver_methods() argument
1322 static bool pdo_pgsql_set_attr(pdo_dbh_t *dbh, zend_long attr, zval *val) in pdo_pgsql_set_attr() argument
1325 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_set_attr()
1371 static int pdo_pgsql_handle_factory(pdo_dbh_t *dbh, zval *driver_options) /* {{{ */ in pdo_pgsql_handle_factory() argument
1380 H = pecalloc(1, sizeof(pdo_pgsql_db_handle), dbh->is_persistent); in pdo_pgsql_handle_factory()
1381 dbh->driver_data = H; in pdo_pgsql_handle_factory()
1383 dbh->skip_param_evt = in pdo_pgsql_handle_factory()
1394 e = (char *) dbh->data_source + strlen(dbh->data_source); in pdo_pgsql_handle_factory()
1395 p = (char *) dbh->data_source; in pdo_pgsql_handle_factory()
1405 …tmp_user = !strstr((char *) dbh->data_source, "user=") ? _pdo_pgsql_escape_credentials(dbh->userna… in pdo_pgsql_handle_factory()
1406 …tmp_pass = !strstr((char *) dbh->data_source, "password=") ? _pdo_pgsql_escape_credentials(dbh->pa… in pdo_pgsql_handle_factory()
1408 smart_str_appends(&conn_str, dbh->data_source); in pdo_pgsql_handle_factory()
1422 H->lob_streams = (HashTable *) pemalloc(sizeof(HashTable), dbh->is_persistent); in pdo_pgsql_handle_factory()
1435 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, PHP_PDO_PGSQL_CONNECTION_FAILURE_SQLSTATE); in pdo_pgsql_handle_factory()
1439 PQsetNoticeProcessor(H->server, _pdo_pgsql_notice, (void *)dbh); in pdo_pgsql_handle_factory()
1444 dbh->methods = &pgsql_methods; in pdo_pgsql_handle_factory()
1445 dbh->alloc_own_columns = 1; in pdo_pgsql_handle_factory()
1446 dbh->max_escaped_char_length = 2; in pdo_pgsql_handle_factory()
1451 dbh->methods = &pgsql_methods; in pdo_pgsql_handle_factory()
1453 pgsql_handle_closer(dbh); in pdo_pgsql_handle_factory()
