Lines Matching refs:pgsql
95 ZEND_DECLARE_MODULE_GLOBALS(pgsql)
96 static PHP_GINIT_FUNCTION(pgsql);
729 PHP_MINIT(pgsql),
730 PHP_MSHUTDOWN(pgsql),
731 PHP_RINIT(pgsql),
732 PHP_RSHUTDOWN(pgsql),
733 PHP_MINFO(pgsql),
735 PHP_MODULE_GLOBALS(pgsql),
736 PHP_GINIT(pgsql),
744 ZEND_GET_MODULE(pgsql) in ZEND_GET_MODULE() argument
868 static inline char * _php_pgsql_trim_result(PGconn * pgsql, char **buf) in _php_pgsql_trim_result() argument
870 return *buf = _php_pgsql_trim_message(PQerrorMessage(pgsql), NULL); in _php_pgsql_trim_result()
874 #define PQErrorMessageTrim(pgsql, buf) _php_pgsql_trim_result(pgsql, buf) argument
876 #define PHP_PQ_ERROR(text, pgsql) { \ argument
877 char *msgbuf = _php_pgsql_trim_message(PQerrorMessage(pgsql), NULL); \
1062 static PHP_GINIT_FUNCTION(pgsql) in PHP_INI_END()
1072 PHP_MINIT_FUNCTION(pgsql) in PHP_MINIT_FUNCTION() argument
1159 PHP_MSHUTDOWN_FUNCTION(pgsql) in PHP_MSHUTDOWN_FUNCTION() argument
1170 PHP_RINIT_FUNCTION(pgsql) in PHP_RINIT_FUNCTION() argument
1180 PHP_RSHUTDOWN_FUNCTION(pgsql) in PHP_RSHUTDOWN_FUNCTION() argument
1192 PHP_MINFO_FUNCTION(pgsql) in PHP_MINFO_FUNCTION() argument
1228 PGconn *pgsql; local
1300 pgsql=PQconnectdb(connstring);
1302 pgsql=PQsetdb(host,port,options,tty,dbname);
1304 if (pgsql==NULL || PQstatus(pgsql)==CONNECTION_BAD) {
1305 PHP_PQ_ERROR("Unable to connect to PostgreSQL server: %s", pgsql)
1306 if (pgsql) {
1307 PQfinish(pgsql);
1314 new_le.ptr = pgsql;
1349 pgsql = (PGconn *) le->ptr;
1351 if (PQprotocolVersion(pgsql) >= 3 && atof(PQparameterStatus(pgsql, "server_version")) >= 7.2) {
1355 pg_result = PQexec(pgsql, "RESET ALL;");
1359 ZEND_REGISTER_RESOURCE(return_value, pgsql, le_plink);
1394 pgsql = PQconnectdb(connstring);
1396 pgsql = PQsetdb(host,port,options,tty,dbname);
1398 if (pgsql==NULL || PQstatus(pgsql)==CONNECTION_BAD) {
1399 PHP_PQ_ERROR("Unable to connect to PostgreSQL server: %s", pgsql);
1400 if (pgsql) {
1401 PQfinish(pgsql);
1407 ZEND_REGISTER_RESOURCE(return_value, pgsql, le_link);
1419 PQsetNoticeProcessor(pgsql, _php_pgsql_notice_handler, (void*)Z_RESVAL_P(return_value));
1469 PGconn *pgsql; local
1484 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
1516 PGconn *pgsql; local
1532 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
1536 Z_STRVAL_P(return_value) = PQdb(pgsql);
1539 RETURN_STRING(PQErrorMessageTrim(pgsql, &msgbuf), 0);
1542 Z_STRVAL_P(return_value) = PQoptions(pgsql);
1545 Z_STRVAL_P(return_value) = PQport(pgsql);
1548 Z_STRVAL_P(return_value) = PQtty(pgsql);
1551 Z_STRVAL_P(return_value) = PQhost(pgsql);
1557 add_assoc_long(return_value, "protocol", PQprotocolVersion(pgsql));
1559 if (PQprotocolVersion(pgsql) >= 3) {
1560 add_assoc_string(return_value, "server", (char*)PQparameterStatus(pgsql, "server_version"), 1);
1642 PGconn *pgsql; local
1658 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
1660 param = (char*)PQparameterStatus(pgsql, param);
1676 PGconn *pgsql; local
1689 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
1692 res = PQexec(pgsql, "SELECT 1;");
1696 if (PQstatus(pgsql) == CONNECTION_OK)
1700 PQreset(pgsql);
1701 if (PQstatus(pgsql) == CONNECTION_OK) {
1716 PGconn *pgsql; local
1737 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
1739 if (PQ_SETNONBLOCKING(pgsql, 0)) {
1743 while ((pgsql_result = PQgetResult(pgsql))) {
1750 pgsql_result = PQexec(pgsql, query);
1751 if ((PGG(auto_reset_persistent) & 2) && PQstatus(pgsql) != CONNECTION_OK) {
1753 PQreset(pgsql);
1754 pgsql_result = PQexec(pgsql, query);
1760 status = (ExecStatusType) PQstatus(pgsql);
1768 PHP_PQ_ERROR("Query failed: %s", pgsql);
1776 pg_result->conn = pgsql;
1818 PGconn *pgsql; local
1839 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
1841 if (PQ_SETNONBLOCKING(pgsql, 0)) {
1845 while ((pgsql_result = PQgetResult(pgsql))) {
1886 pgsql_result = PQexecParams(pgsql, query, num_params,
1888 if ((PGG(auto_reset_persistent) & 2) && PQstatus(pgsql) != CONNECTION_OK) {
1890 PQreset(pgsql);
1891 pgsql_result = PQexecParams(pgsql, query, num_params,
1898 status = (ExecStatusType) PQstatus(pgsql);
1908 PHP_PQ_ERROR("Query failed: %s", pgsql);
1916 pg_result->conn = pgsql;
1939 PGconn *pgsql; local
1960 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
1962 if (PQ_SETNONBLOCKING(pgsql, 0)) {
1966 while ((pgsql_result = PQgetResult(pgsql))) {
1973 pgsql_result = PQprepare(pgsql, stmtname, query, 0, NULL);
1974 if ((PGG(auto_reset_persistent) & 2) && PQstatus(pgsql) != CONNECTION_OK) {
1976 PQreset(pgsql);
1977 pgsql_result = PQprepare(pgsql, stmtname, query, 0, NULL);
1983 status = (ExecStatusType) PQstatus(pgsql);
1991 PHP_PQ_ERROR("Query failed: %s", pgsql);
1999 pg_result->conn = pgsql;
2025 PGconn *pgsql; local
2046 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
2048 if (PQ_SETNONBLOCKING(pgsql, 0)) {
2052 while ((pgsql_result = PQgetResult(pgsql))) {
2093 pgsql_result = PQexecPrepared(pgsql, stmtname, num_params,
2095 if ((PGG(auto_reset_persistent) & 2) && PQstatus(pgsql) != CONNECTION_OK) {
2097 PQreset(pgsql);
2098 pgsql_result = PQexecPrepared(pgsql, stmtname, num_params,
2105 status = (ExecStatusType) PQstatus(pgsql);
2115 PHP_PQ_ERROR("Query failed: %s", pgsql);
2123 pg_result->conn = pgsql;
2229 static char *get_field_name(PGconn *pgsql, Oid oid, HashTable *list TSRMLS_DC) argument
2249 …if ((result = PQexec(pgsql,"select oid,typname from pg_type")) == NULL || PQresultStatus(result) !…
3012 PGconn *pgsql; local
3029 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
3042 PQtrace(pgsql, fp);
3053 PGconn *pgsql; local
3068 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
3069 PQuntrace(pgsql);
3079 PGconn *pgsql; local
3100 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
3129 if ((pgsql_oid = lo_create(pgsql, wanted_oid)) == InvalidOid) {
3138 if ((pgsql_oid = lo_creat(pgsql, INV_READ|INV_WRITE)) == InvalidOid) {
3155 PGconn *pgsql; local
3207 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
3209 if (lo_unlink(pgsql, oid) == -1) {
3225 PGconn *pgsql; local
3279 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
3302 if ((pgsql_lofd = lo_open(pgsql, oid, pgsql_mode)) == -1) {
3304 if ((oid = lo_creat(pgsql, INV_READ|INV_WRITE)) == 0) {
3309 if ((pgsql_lofd = lo_open(pgsql, oid, pgsql_mode)) == -1) {
3310 if (lo_unlink(pgsql, oid) == -1) {
3319 pgsql_lofp->conn = pgsql;
3331 pgsql_lofp->conn = pgsql;
3343 pgLofp *pgsql; local
3349 ZEND_FETCH_RESOURCE(pgsql, pgLofp *, &pgsql_lofp, -1, "PostgreSQL large object", le_lofp);
3351 if (lo_close((PGconn *)pgsql->conn, pgsql->lofd) < 0) {
3352 …f(NULL TSRMLS_CC, E_WARNING, "Unable to close PostgreSQL large object descriptor %d", pgsql->lofd);
3373 pgLofp *pgsql; local
3379 ZEND_FETCH_RESOURCE(pgsql, pgLofp *, &pgsql_id, -1, "PostgreSQL large object", le_lofp);
3386 if ((nbytes = lo_read((PGconn *)pgsql->conn, pgsql->lofd, buf, buf_len))<0) {
3405 pgLofp *pgsql; local
3427 ZEND_FETCH_RESOURCE(pgsql, pgLofp *, &pgsql_id, -1, "PostgreSQL large object", le_lofp);
3429 if ((nbytes = lo_write((PGconn *)pgsql->conn, pgsql->lofd, str, len)) == -1) {
3445 pgLofp *pgsql; local
3451 ZEND_FETCH_RESOURCE(pgsql, pgLofp *, &pgsql_id, -1, "PostgreSQL large object", le_lofp);
3454 while ((nbytes = lo_read((PGconn *)pgsql->conn, pgsql->lofd, buf, PGSQL_LO_READ_BUF_SIZE))>0) {
3470 PGconn *pgsql; local
3499 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
3530 returned_oid = lo_import_with_oid(pgsql, file_in, wanted_oid);
3540 returned_oid = lo_import(pgsql, file_in);
3559 PGconn *pgsql; local
3632 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
3634 if (lo_export(pgsql, oid, file_out) == -1) {
3647 pgLofp *pgsql; local
3658 ZEND_FETCH_RESOURCE(pgsql, pgLofp *, &pgsql_id, -1, "PostgreSQL large object", le_lofp);
3660 if (lo_lseek((PGconn *)pgsql->conn, pgsql->lofd, offset, whence) > -1) {
3674 pgLofp *pgsql; local
3681 ZEND_FETCH_RESOURCE(pgsql, pgLofp *, &pgsql_id, -1, "PostgreSQL large object", le_lofp);
3683 offset = lo_tell((PGconn *)pgsql->conn, pgsql->lofd);
3696 PGconn *pgsql; local
3714 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
3717 Z_LVAL_P(return_value) = PQsetErrorVerbosity(pgsql, verbosity);
3735 PGconn *pgsql; local
3753 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
3755 Z_LVAL_P(return_value) = PQsetClientEncoding(pgsql, encoding);
3766 PGconn *pgsql; local
3781 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
3785 Z_STRVAL_P(return_value) = (char *) pg_encoding_to_char(PQclientEncoding(pgsql));
3803 PGconn *pgsql; local
3819 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
3821 result = PQendcopy(pgsql);
3824 PHP_PQ_ERROR("Query failed: %s", pgsql);
3839 PGconn *pgsql; local
3858 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
3860 result = PQputline(pgsql, query);
3862 PHP_PQ_ERROR("Query failed: %s", pgsql);
3878 PGconn *pgsql; local
3898 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
3907 while ((pgsql_result = PQgetResult(pgsql))) {
3910 pgsql_result = PQexec(pgsql, query);
3919 status = (ExecStatusType) PQstatus(pgsql);
3930 ret = PQgetCopyData(pgsql, &csv, 0);
3937 PHP_PQ_ERROR("getline failed: %s", pgsql);
3949 if ((ret = PQgetline(pgsql, copybuf, COPYBUFSIZ))) {
3950 PHP_PQ_ERROR("getline failed: %s", pgsql);
3983 if (PQendcopy(pgsql)) {
3984 PHP_PQ_ERROR("endcopy failed: %s", pgsql);
3988 while ((pgsql_result = PQgetResult(pgsql))) {
3998 PHP_PQ_ERROR("Copy command failed: %s", pgsql);
4017 PGconn *pgsql; local
4035 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
4038 while ((pgsql_result = PQgetResult(pgsql))) {
4041 pgsql_result = PQexec(pgsql, query);
4051 status = (ExecStatusType) PQstatus(pgsql);
4072 if (PQputCopyData(pgsql, query, strlen(query)) != 1) {
4076 PHP_PQ_ERROR("copy failed: %s", pgsql);
4084 if (PQputCopyEnd(pgsql, NULL) != 1) {
4085 PHP_PQ_ERROR("putcopyend failed: %s", pgsql);
4100 if (PQputline(pgsql, query)==EOF) {
4104 PHP_PQ_ERROR("copy failed: %s", pgsql);
4112 if (PQputline(pgsql, "\\.\n") == EOF) {
4113 PHP_PQ_ERROR("putline failed: %s", pgsql);
4116 if (PQendcopy(pgsql)) {
4117 PHP_PQ_ERROR("endcopy failed: %s", pgsql);
4121 while ((pgsql_result = PQgetResult(pgsql))) {
4123 PHP_PQ_ERROR("Copy command failed: %s", pgsql);
4139 PHP_PQ_ERROR("Copy command failed: %s", pgsql);
4154 PGconn *pgsql; local
4179 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
4180 to_len = (int) PQescapeStringConn(pgsql, to, from, (size_t)from_len, NULL);
4197 PGconn *pgsql; local
4219 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
4220 to = (char *)PQescapeByteaConn(pgsql, (unsigned char *)from, (size_t)from_len, &to_len);
4368 PGconn *pgsql; local
4394 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
4395 if (pgsql == NULL) {
4401 tmp = PGSQLescapeLiteral(pgsql, from, (size_t)from_len);
4403 tmp = PGSQLescapeIdentifier(pgsql, from, (size_t)from_len);
4511 PGconn *pgsql; local
4518 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
4520 RETURN_LONG(PQstatus(pgsql));
4533 PGconn *pgsql; local
4540 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
4542 RETURN_LONG(PQtransactionStatus(pgsql));
4555 PGconn *pgsql; local
4562 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
4564 PQreset(pgsql);
4565 if (PQstatus(pgsql) == CONNECTION_BAD) {
4579 static int php_pgsql_flush_query(PGconn *pgsql TSRMLS_DC)
4584 if (PQ_SETNONBLOCKING(pgsql, 1)) {
4588 while ((res = PQgetResult(pgsql))) {
4592 PQ_SETNONBLOCKING(pgsql, 0);
4604 PGconn *pgsql; local
4612 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
4614 if (PQ_SETNONBLOCKING(pgsql, 1)) {
4620 PQconsumeInput(pgsql);
4621 Z_LVAL_P(return_value) = PQisBusy(pgsql);
4625 Z_LVAL_P(return_value) = PQrequestCancel(pgsql);
4627 while ((pgsql_result = PQgetResult(pgsql))) {
4635 if (PQ_SETNONBLOCKING(pgsql, 0)) {
4666 PGconn *pgsql; local
4676 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
4678 if (PQ_SETNONBLOCKING(pgsql, 1)) {
4682 while ((res = PQgetResult(pgsql))) {
4689 if (!PQsendQuery(pgsql, query)) {
4690 if ((PGG(auto_reset_persistent) & 2) && PQstatus(pgsql) != CONNECTION_OK) {
4691 PQreset(pgsql);
4693 if (!PQsendQuery(pgsql, query)) {
4698 while ((ret = PQflush(pgsql))) {
4705 if (PQ_SETNONBLOCKING(pgsql, 0)) {
4722 PGconn *pgsql; local
4735 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
4737 if (PQ_SETNONBLOCKING(pgsql, 1)) {
4741 while ((res = PQgetResult(pgsql))) {
4782 …if (!PQsendQueryParams(pgsql, query, num_params, NULL, (const char * const *)params, NULL, NULL, 0…
4783 if ((PGG(auto_reset_persistent) & 2) && PQstatus(pgsql) != CONNECTION_OK) {
4784 PQreset(pgsql);
4786 …if (!PQsendQueryParams(pgsql, query, num_params, NULL, (const char * const *)params, NULL, NULL, 0…
4793 while ((ret = PQflush(pgsql))) {
4800 if (PQ_SETNONBLOCKING(pgsql, 0)) {
4816 PGconn *pgsql; local
4829 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
4831 if (PQ_SETNONBLOCKING(pgsql, 1)) {
4835 while ((res = PQgetResult(pgsql))) {
4842 if (!PQsendPrepare(pgsql, stmtname, query, 0, NULL)) {
4843 if ((PGG(auto_reset_persistent) & 2) && PQstatus(pgsql) != CONNECTION_OK) {
4844 PQreset(pgsql);
4846 if (!PQsendPrepare(pgsql, stmtname, query, 0, NULL)) {
4851 while ((ret = PQflush(pgsql))) {
4858 if (PQ_SETNONBLOCKING(pgsql, 0)) {
4877 PGconn *pgsql; local
4890 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
4892 if (PQ_SETNONBLOCKING(pgsql, 1)) {
4896 while ((res = PQgetResult(pgsql))) {
4937 …if (!PQsendQueryPrepared(pgsql, stmtname, num_params, (const char * const *)params, NULL, NULL, 0)…
4938 if ((PGG(auto_reset_persistent) & 2) && PQstatus(pgsql) != CONNECTION_OK) {
4939 PQreset(pgsql);
4941 …if (!PQsendQueryPrepared(pgsql, stmtname, num_params, (const char * const *)params, NULL, NULL, 0)…
4948 while ((ret = PQflush(pgsql))) {
4955 if (PQ_SETNONBLOCKING(pgsql, 0)) {
4969 PGconn *pgsql; local
4977 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
4979 pgsql_result = PQgetResult(pgsql);
4985 pg_result->conn = pgsql;
5032 PGconn *pgsql; local
5040 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
5047 PQconsumeInput(pgsql);
5048 pgsql_notify = PQnotifies(pgsql);
5058 if (PQprotocolVersion(pgsql) >= 3 && atof(PQparameterStatus(pgsql, "server_version")) >= 9.0) {
5071 if (PQprotocolVersion(pgsql) >= 3 && atof(PQparameterStatus(pgsql, "server_version")) >= 9.0) {
5090 PGconn *pgsql; local
5097 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
5099 RETURN_LONG(PQbackendPID(pgsql));
5210 PGconn *pgsql; local
5218 ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
5221 if (php_pgsql_meta_data(pgsql, table_name, return_value TSRMLS_CC) == FAILURE) {
