Lines Matching refs:server
72 char *errmsg = PQerrorMessage(H->server); in _pdo_pgsql_error()
194 self->conn = H->server; in pdo_pgsql_create_lob_stream()
232 if (H->server) { in pgsql_handle_closer()
233 PQfinish(H->server); in pgsql_handle_closer()
234 H->server = NULL; in pgsql_handle_closer()
281 if (!emulate && PQprotocolVersion(H->server) <= 2) { in pgsql_handle_preparer()
323 if (!(res = PQexec(H->server, ZSTR_VAL(sql)))) { in pgsql_handle_doer()
360 …escaped = PQescapeByteaConn(H->server, (unsigned char *)ZSTR_VAL(unquoted), ZSTR_LEN(unquoted), &t… in pgsql_handle_quoter()
372 …quotedlen = PQescapeStringConn(H->server, quoted + 1, ZSTR_VAL(unquoted), ZSTR_LEN(unquoted), NULL… in pgsql_handle_quoter()
391 res = PQexec(H->server, "SELECT LASTVAL()"); in pdo_pgsql_last_insert_id()
396 res = PQexecParams(H->server, "SELECT CURRVAL($1)", 1, NULL, q, NULL, NULL, 0); in pdo_pgsql_last_insert_id()
448 if (PQprotocolVersion(H->server) >= 3) { /* PostgreSQL 7.4 or later */ in pdo_pgsql_get_attribute()
449 ZVAL_STRING(return_value, (char*)PQparameterStatus(H->server, "server_version")); in pdo_pgsql_get_attribute()
452 PGresult *res = PQexec(H->server, "SELECT VERSION()"); in pdo_pgsql_get_attribute()
464 switch (PQstatus(H->server)) { in pdo_pgsql_get_attribute()
498 int spid = PQbackendPID(H->server); in pdo_pgsql_get_attribute()
505 (char*)PQparameterStatus(H->server, "client_encoding"), in pdo_pgsql_get_attribute()
506 (char*)PQparameterStatus(H->server, "is_superuser"), in pdo_pgsql_get_attribute()
507 (char*)PQparameterStatus(H->server, "session_authorization"), in pdo_pgsql_get_attribute()
508 (char*)PQparameterStatus(H->server, "DateStyle")); in pdo_pgsql_get_attribute()
525 if (!PQconsumeInput(H->server) || PQstatus(H->server) == CONNECTION_BAD) { in pdo_pgsql_check_liveness()
526 PQreset(H->server); in pdo_pgsql_check_liveness()
528 return (PQstatus(H->server) == CONNECTION_OK) ? SUCCESS : FAILURE; in pdo_pgsql_check_liveness()
536 return PQtransactionStatus(H->server) > PQTRANS_IDLE; in pgsql_handle_in_transaction()
545 res = PQexec(H->server, cmd); in pdo_pgsql_transaction_cmd()
627 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
630 pgsql_result = PQexec(H->server, query); in PHP_METHOD()
638 status = (ExecStatusType) PQstatus(H->server); in PHP_METHOD()
664 if (PQputCopyData(H->server, query, query_len) != 1) { in PHP_METHOD()
675 if (PQputCopyEnd(H->server, NULL) != 1) { in PHP_METHOD()
681 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
740 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
743 pgsql_result = PQexec(H->server, query); in PHP_METHOD()
750 status = (ExecStatusType) PQstatus(H->server); in PHP_METHOD()
760 if (PQputCopyData(H->server, buf, line_len) != 1) { in PHP_METHOD()
771 if (PQputCopyEnd(H->server, NULL) != 1) { in PHP_METHOD()
777 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
832 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
842 pgsql_result = PQexec(H->server, query); in PHP_METHOD()
848 status = (ExecStatusType) PQstatus(H->server); in PHP_METHOD()
855 int ret = PQgetCopyData(H->server, &csv, 0); in PHP_METHOD()
878 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
917 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
927 pgsql_result = PQexec(H->server, query); in PHP_METHOD()
933 status = (ExecStatusType) PQstatus(H->server); in PHP_METHOD()
942 int ret = PQgetCopyData(H->server, &csv, 0); in PHP_METHOD()
955 while ((pgsql_result = PQgetResult(H->server))) { in PHP_METHOD()
982 lfd = lo_creat(H->server, INV_READ|INV_WRITE); in PHP_METHOD()
1030 lfd = lo_open(H->server, oid, mode); in PHP_METHOD()
1072 if (1 == lo_unlink(H->server, oid)) { in PHP_METHOD()
1120 if (!PQconsumeInput(H->server)) { in PHP_METHOD()
1125 pgsql_notify = PQnotifies(H->server); in PHP_METHOD()
1128 php_pollfd_for_ms(PQsocket(H->server), PHP_POLLREADABLE, (int)ms_timeout); in PHP_METHOD()
1130 if (!PQconsumeInput(H->server)) { in PHP_METHOD()
1135 pgsql_notify = PQnotifies(H->server); in PHP_METHOD()
1175 RETURN_LONG(PQbackendPID(H->server)); in PHP_METHOD()
1278 H->server = PQconnectdb(conn_str); in pdo_pgsql_handle_factory()
1291 if (PQstatus(H->server) != CONNECTION_OK) { in pdo_pgsql_handle_factory()
1296 PQsetNoticeProcessor(H->server, (void(*)(void*,const char*))_pdo_pgsql_notice, (void *)&dbh); in pdo_pgsql_handle_factory()
