Lines Matching refs:dbh
75 int _pdo_pgsql_error(pdo_dbh_t *dbh, pdo_stmt_t *stmt, int errcode, const char *sqlstate, const cha… in _pdo_pgsql_error() argument
77 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in _pdo_pgsql_error()
78 pdo_error_type *pdo_err = stmt ? &stmt->error_code : &dbh->error_code; in _pdo_pgsql_error()
87 pefree(einfo->errmsg, dbh->is_persistent); in _pdo_pgsql_error()
99 einfo->errmsg = _pdo_pgsql_trim_message(errmsg, dbh->is_persistent); in _pdo_pgsql_error()
102 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 TSRMLS_DC) /* {{… 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()
147 pdo_dbh_t *dbh = self->dbh; in pgsql_lob_close() local
153 php_pdo_dbh_delref(dbh TSRMLS_CC); in pgsql_lob_close()
183 php_stream *pdo_pgsql_create_lob_stream(pdo_dbh_t *dbh, int lfd, Oid oid TSRMLS_DC) in pdo_pgsql_create_lob_stream() argument
187 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_create_lob_stream()
189 self->dbh = dbh; in pdo_pgsql_create_lob_stream()
197 php_pdo_dbh_addref(dbh TSRMLS_CC); in pdo_pgsql_create_lob_stream()
206 static int pgsql_handle_closer(pdo_dbh_t *dbh TSRMLS_DC) /* {{{ */ in pgsql_handle_closer()
208 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_closer()
215 pefree(H->einfo.errmsg, dbh->is_persistent); in pgsql_handle_closer()
218 pefree(H, dbh->is_persistent); in pgsql_handle_closer()
219 dbh->driver_data = NULL; in pgsql_handle_closer()
225 static int pgsql_handle_preparer(pdo_dbh_t *dbh, const char *sql, long sql_len, pdo_stmt_t *stmt, z… in pgsql_handle_preparer() argument
227 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()
295 static long pgsql_handle_doer(pdo_dbh_t *dbh, const char *sql, long sql_len TSRMLS_DC) in pgsql_handle_doer() argument
297 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_doer()
304 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, NULL); in pgsql_handle_doer()
309 pdo_pgsql_error(dbh, qs, pdo_pgsql_sqlstate(res)); in pgsql_handle_doer()
320 static int pgsql_handle_quoter(pdo_dbh_t *dbh, const char *unquoted, int unquotedlen, char **quoted… in pgsql_handle_quoter() argument
323 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_quoter()
357 static char *pdo_pgsql_last_insert_id(pdo_dbh_t *dbh, const char *name, unsigned int *len TSRMLS_DC) in pdo_pgsql_last_insert_id() argument
359 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_last_insert_id()
379 pdo_pgsql_error(dbh, status, pdo_pgsql_sqlstate(res)); in pdo_pgsql_last_insert_id()
389 static int pdo_pgsql_get_attribute(pdo_dbh_t *dbh, long attr, zval *return_value TSRMLS_DC) in pdo_pgsql_get_attribute() argument
391 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 TSRMLS_DC) in pdo_pgsql_check_liveness()
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 TSRMLS_DC) in pgsql_handle_in_transaction()
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 TSRMLS_DC) in pdo_pgsql_transaction_cmd()
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 TSRMLS_DC) in pgsql_handle_begin()
516 return pdo_pgsql_transaction_cmd("BEGIN", dbh TSRMLS_CC); in pgsql_handle_begin()
519 static int pgsql_handle_commit(pdo_dbh_t *dbh TSRMLS_DC) in pgsql_handle_commit()
521 int ret = pdo_pgsql_transaction_cmd("COMMIT", dbh TSRMLS_CC); in pgsql_handle_commit()
526 dbh->in_txn = pgsql_handle_in_transaction(dbh TSRMLS_CC); in pgsql_handle_commit()
532 static int pgsql_handle_rollback(pdo_dbh_t *dbh TSRMLS_DC) in pgsql_handle_rollback()
534 return pdo_pgsql_transaction_cmd("ROLLBACK", dbh TSRMLS_CC); in pgsql_handle_rollback()
541 pdo_dbh_t *dbh; in PHP_METHOD() local
564 dbh = zend_object_store_get_object(getThis() TSRMLS_CC); in PHP_METHOD()
574 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
614 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "copy failed"); in PHP_METHOD()
624 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "putcopyend failed"); in PHP_METHOD()
630 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "Copy command failed"); in PHP_METHOD()
639 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "Copy command failed"); in PHP_METHOD()
649 pdo_dbh_t *dbh; in PHP_METHOD() local
666 dbh = zend_object_store_get_object(getThis() TSRMLS_CC); in PHP_METHOD()
671 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "Unable to open the file"); in PHP_METHOD()
681 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
705 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "copy failed"); in PHP_METHOD()
714 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "putcopyend failed"); in PHP_METHOD()
720 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "Copy command failed"); in PHP_METHOD()
730 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "Copy command failed"); in PHP_METHOD()
741 pdo_dbh_t *dbh; in PHP_METHOD() local
759 dbh = zend_object_store_get_object(getThis() TSRMLS_CC); in PHP_METHOD()
762 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
766 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "Unable to open the file for writing"); in PHP_METHOD()
798 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "Unable to write to file"); in PHP_METHOD()
806 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "Copy command failed: getline failed"); in PHP_METHOD()
820 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "Copy command failed"); in PHP_METHOD()
830 pdo_dbh_t *dbh; in PHP_METHOD() local
846 dbh = zend_object_store_get_object(getThis() TSRMLS_CC); in PHP_METHOD()
849 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
882 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "Copy command failed: getline failed"); in PHP_METHOD()
892 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "Copy command failed"); in PHP_METHOD()
903 pdo_dbh_t *dbh; in PHP_METHOD() local
907 dbh = zend_object_store_get_object(getThis() TSRMLS_CC); in PHP_METHOD()
910 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
919 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "HY000"); in PHP_METHOD()
928 pdo_dbh_t *dbh; in PHP_METHOD() local
953 dbh = zend_object_store_get_object(getThis() TSRMLS_CC); in PHP_METHOD()
956 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
961 php_stream *stream = pdo_pgsql_create_lob_stream(dbh, lfd, oid TSRMLS_CC); in PHP_METHOD()
967 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "HY000"); in PHP_METHOD()
977 pdo_dbh_t *dbh; in PHP_METHOD() local
993 dbh = zend_object_store_get_object(getThis() TSRMLS_CC); in PHP_METHOD()
996 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
1001 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, "HY000"); in PHP_METHOD()
1018 static const zend_function_entry *pdo_pgsql_get_driver_methods(pdo_dbh_t *dbh, int kind TSRMLS_DC) in pdo_pgsql_get_driver_methods() argument
1028 static int pdo_pgsql_set_attr(pdo_dbh_t *dbh, long attr, zval *val TSRMLS_DC) in pdo_pgsql_set_attr() argument
1030 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_set_attr()
1065 static int pdo_pgsql_handle_factory(pdo_dbh_t *dbh, zval *driver_options TSRMLS_DC) /* {{{ */ in pdo_pgsql_handle_factory() argument
1073 H = pecalloc(1, sizeof(pdo_pgsql_db_handle), dbh->is_persistent); in pdo_pgsql_handle_factory()
1074 dbh->driver_data = H; in pdo_pgsql_handle_factory()
1082 e = (char *) dbh->data_source + strlen(dbh->data_source); in pdo_pgsql_handle_factory()
1083 p = (char *) dbh->data_source; in pdo_pgsql_handle_factory()
1093 tmp_user = _pdo_pgsql_escape_credentials(dbh->username TSRMLS_CC); in pdo_pgsql_handle_factory()
1094 tmp_pass = _pdo_pgsql_escape_credentials(dbh->password TSRMLS_CC); in pdo_pgsql_handle_factory()
1098 …spprintf(&conn_str, 0, "%s user='%s' password='%s' connect_timeout=%ld", dbh->data_source, tmp_use… in pdo_pgsql_handle_factory()
1100 …spprintf(&conn_str, 0, "%s user='%s' connect_timeout=%ld", dbh->data_source, tmp_user, connect_tim… in pdo_pgsql_handle_factory()
1102 …spprintf(&conn_str, 0, "%s password='%s' connect_timeout=%ld", dbh->data_source, tmp_pass, connect… in pdo_pgsql_handle_factory()
1104 spprintf(&conn_str, 0, "%s connect_timeout=%ld", (char *) dbh->data_source, connect_timeout); in pdo_pgsql_handle_factory()
1119 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, PHP_PDO_PGSQL_CONNECTION_FAILURE_SQLSTATE); in pdo_pgsql_handle_factory()
1123 PQsetNoticeProcessor(H->server, (void(*)(void*,const char*))_pdo_pgsql_notice, (void *)&dbh); in pdo_pgsql_handle_factory()
1128 dbh->methods = &pgsql_methods; in pdo_pgsql_handle_factory()
1129 dbh->alloc_own_columns = 1; in pdo_pgsql_handle_factory()
1130 dbh->max_escaped_char_length = 2; in pdo_pgsql_handle_factory()
1135 dbh->methods = &pgsql_methods; in pdo_pgsql_handle_factory()
1137 pgsql_handle_closer(dbh TSRMLS_CC); in pdo_pgsql_handle_factory()
