Lines Matching refs:H
77 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in _pdo_pgsql_error() local
79 pdo_pgsql_error_info *einfo = &H->einfo; in _pdo_pgsql_error()
80 char *errmsg = PQerrorMessage(H->server); in _pdo_pgsql_error()
119 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_fetch_error_func() local
120 pdo_pgsql_error_info *einfo = &H->einfo; in pdo_pgsql_fetch_error_func()
187 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_create_lob_stream() local
192 self->conn = H->server; in pdo_pgsql_create_lob_stream()
208 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_closer() local
209 if (H) { in pgsql_handle_closer()
210 if (H->server) { in pgsql_handle_closer()
211 PQfinish(H->server); in pgsql_handle_closer()
212 H->server = NULL; in pgsql_handle_closer()
214 if (H->einfo.errmsg) { in pgsql_handle_closer()
215 pefree(H->einfo.errmsg, dbh->is_persistent); in pgsql_handle_closer()
216 H->einfo.errmsg = NULL; in pgsql_handle_closer()
218 pefree(H, dbh->is_persistent); in pgsql_handle_closer()
227 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_preparer() local
237 S->H = H; in pgsql_handle_preparer()
248 spprintf(&S->cursor_name, 0, "pdo_crsr_%08x", ++H->stmt_counter); in pgsql_handle_preparer()
256 …if (pdo_attr_lval(driver_options, PDO_PGSQL_ATTR_DISABLE_NATIVE_PREPARED_STATEMENT, H->disable_nat… in pgsql_handle_preparer()
257 pdo_attr_lval(driver_options, PDO_ATTR_EMULATE_PREPARES, H->emulate_prepares TSRMLS_CC) == 1) { in pgsql_handle_preparer()
261 emulate = H->disable_native_prepares || H->emulate_prepares; in pgsql_handle_preparer()
264 if (!emulate && PQprotocolVersion(H->server) > 2) { in pgsql_handle_preparer()
278 spprintf(&S->stmt_name, 0, "pdo_stmt_%08x", ++H->stmt_counter); in pgsql_handle_preparer()
297 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_doer() local
302 if (!(res = PQexec(H->server, sql))) { in pgsql_handle_doer()
313 H->pgoid = PQoidValue(res); in pgsql_handle_doer()
323 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_quoter() local
330 escaped = PQescapeByteaConn(H->server, (unsigned char *)unquoted, (size_t)unquotedlen, &tmp_len); in pgsql_handle_quoter()
348 *quotedlen = PQescapeStringConn(H->server, *quoted + 1, unquoted, (size_t)unquotedlen, NULL); in pgsql_handle_quoter()
359 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_last_insert_id() local
363 if (H->pgoid == InvalidOid) { in pdo_pgsql_last_insert_id()
366 *len = spprintf(&id, 0, "%ld", (long) H->pgoid); in pdo_pgsql_last_insert_id()
372 res = PQexecParams(H->server, "SELECT CURRVAL($1)", 1, NULL, q, NULL, NULL, 0); in pdo_pgsql_last_insert_id()
391 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_get_attribute() local
395 ZVAL_BOOL(return_value, H->emulate_prepares); in pdo_pgsql_get_attribute()
399 ZVAL_BOOL(return_value, H->disable_native_prepares); in pdo_pgsql_get_attribute()
407 if (PQprotocolVersion(H->server) >= 3) { /* PostgreSQL 7.4 or later */ in pdo_pgsql_get_attribute()
408 ZVAL_STRING(return_value, (char*)PQparameterStatus(H->server, "server_version"), 1); in pdo_pgsql_get_attribute()
411 PGresult *res = PQexec(H->server, "SELECT VERSION()"); in pdo_pgsql_get_attribute()
423 switch (PQstatus(H->server)) { in pdo_pgsql_get_attribute()
457 int spid = PQbackendPID(H->server); in pdo_pgsql_get_attribute()
462 (char*)PQparameterStatus(H->server, "client_encoding"), in pdo_pgsql_get_attribute()
463 (char*)PQparameterStatus(H->server, "is_superuser"), in pdo_pgsql_get_attribute()
464 (char*)PQparameterStatus(H->server, "session_authorization"), in pdo_pgsql_get_attribute()
465 (char*)PQparameterStatus(H->server, "DateStyle")); in pdo_pgsql_get_attribute()
480 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_check_liveness() local
481 if (PQstatus(H->server) == CONNECTION_BAD) { in pdo_pgsql_check_liveness()
482 PQreset(H->server); in pdo_pgsql_check_liveness()
484 return (PQstatus(H->server) == CONNECTION_OK) ? SUCCESS : FAILURE; in pdo_pgsql_check_liveness()
490 pdo_pgsql_db_handle *H; in pgsql_handle_in_transaction() local
492 H = (pdo_pgsql_db_handle *)dbh->driver_data; in pgsql_handle_in_transaction()
494 return PQtransactionStatus(H->server) > PQTRANS_IDLE; in pgsql_handle_in_transaction()
499 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_transaction_cmd() local
503 res = PQexec(H->server, cmd); in pdo_pgsql_transaction_cmd()
542 pdo_pgsql_db_handle *H; in PHP_METHOD() local
574 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
576 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
579 pgsql_result = PQexec(H->server, query); in PHP_METHOD()
587 status = (ExecStatusType) PQstatus(H->server); in PHP_METHOD()
612 if (PQputCopyData(H->server, query, query_len) != 1) { in PHP_METHOD()
623 if (PQputCopyEnd(H->server, NULL) != 1) { in PHP_METHOD()
628 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
650 pdo_pgsql_db_handle *H; in PHP_METHOD() local
681 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
683 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
686 pgsql_result = PQexec(H->server, query); in PHP_METHOD()
693 status = (ExecStatusType) PQstatus(H->server); in PHP_METHOD()
703 if (PQputCopyData(H->server, buf, line_len) != 1) { in PHP_METHOD()
713 if (PQputCopyEnd(H->server, NULL) != 1) { in PHP_METHOD()
718 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
742 pdo_pgsql_db_handle *H; in PHP_METHOD() local
762 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
770 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
779 pgsql_result = PQexec(H->server, query); in PHP_METHOD()
785 status = (ExecStatusType) PQstatus(H->server); in PHP_METHOD()
792 int ret = PQgetCopyData(H->server, &csv, 0); in PHP_METHOD()
813 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
831 pdo_pgsql_db_handle *H; in PHP_METHOD() local
849 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
851 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
860 pgsql_result = PQexec(H->server, query); in PHP_METHOD()
866 status = (ExecStatusType) PQstatus(H->server); in PHP_METHOD()
875 int ret = PQgetCopyData(H->server, &csv, 0); in PHP_METHOD()
887 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
904 pdo_pgsql_db_handle *H; in PHP_METHOD() local
910 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
911 lfd = lo_creat(H->server, INV_READ|INV_WRITE); in PHP_METHOD()
929 pdo_pgsql_db_handle *H; in PHP_METHOD() local
956 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
958 lfd = lo_open(H->server, oid, mode); in PHP_METHOD()
978 pdo_pgsql_db_handle *H; in PHP_METHOD() local
996 H = (pdo_pgsql_db_handle *)dbh->driver_data; in PHP_METHOD()
998 if (1 == lo_unlink(H->server, oid)) { in PHP_METHOD()
1030 pdo_pgsql_db_handle *H = (pdo_pgsql_db_handle *)dbh->driver_data; in pdo_pgsql_set_attr() local
1035 H->emulate_prepares = Z_LVAL_P(val); in pdo_pgsql_set_attr()
1038 H->disable_native_prepares = Z_LVAL_P(val); in pdo_pgsql_set_attr()
1067 pdo_pgsql_db_handle *H; in pdo_pgsql_handle_factory() local
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()
1076 H->einfo.errcode = 0; in pdo_pgsql_handle_factory()
1077 H->einfo.errmsg = NULL; in pdo_pgsql_handle_factory()
1107 H->server = PQconnectdb(conn_str); in pdo_pgsql_handle_factory()
1118 if (PQstatus(H->server) != CONNECTION_OK) { in pdo_pgsql_handle_factory()
1123 PQsetNoticeProcessor(H->server, (void(*)(void*,const char*))_pdo_pgsql_notice, (void *)&dbh); in pdo_pgsql_handle_factory()
1125 H->attached = 1; in pdo_pgsql_handle_factory()
1126 H->pgoid = -1; in pdo_pgsql_handle_factory()
