From 3e13ac26e938a9133d24c3249dd92121f5583a5e Mon Sep 17 00:00:00 2001 From: Yasuo Ohgaki Date: Sat, 30 Mar 2002 23:23:58 +0000 Subject: [PATCH] MFH. 6.5.3 libpq build fix. --- ext/pgsql/pgsql.c | 45 +++++++++++++++++++++++++++++---------------- 1 file changed, 29 insertions(+), 16 deletions(-) diff --git a/ext/pgsql/pgsql.c b/ext/pgsql/pgsql.c index 46798f19ea..225e3e4b37 100644 --- a/ext/pgsql/pgsql.c +++ b/ext/pgsql/pgsql.c @@ -48,6 +48,12 @@ #define PGSQL_ESCAPE_STRING 1 #define PGSQL_ESCAPE_BYTEA 2 +#if HAVE_PQSETNONBLOCKING +#define PQ_SETNONBLOCKING(pg_link, flag) PQsetnonblocking(pg_link, flag) +#else +#define PQ_SETNONBLOCKING(pg_link, flag) 0 +#endif + #define CHECK_DEFAULT_LINK(x) if (x == -1) { php_error(E_WARNING, "%s() no PostgreSQL link opened yet", get_active_function_name(TSRMLS_C)); } /* {{{ pgsql_functions[] @@ -253,13 +259,18 @@ static int _rollback_transactions(zend_rsrc_list_entry *rsrc TSRMLS_DC) return 0; link = (PGconn *) rsrc->ptr; + + if (PQ_SETNONBLOCKING(link, 0)) { + php_error(E_NOTICE,"PostgreSQL cannot set connection to blocking mode"); + return -1; + } - PQsetnonblocking(link, 0); while ((res = PQgetResult(link))) { PQclear(res); } PGG(ignore_notices) = 1; - PQexec(link,"BEGIN;ROLLBACK;"); + res = PQexec(link,"BEGIN;ROLLBACK;"); + PQclear(res); PGG(ignore_notices) = 0; return 0; @@ -336,9 +347,6 @@ PHP_MINIT_FUNCTION(pgsql) REGISTER_LONG_CONSTANT("PGSQL_SEEK_CUR", SEEK_CUR, CONST_CS | CONST_PERSISTENT); REGISTER_LONG_CONSTANT("PGSQL_SEEK_END", SEEK_END, CONST_CS | CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("PGSQL_ESCAPE_STRING", PGSQL_ESCAPE_STRING, CONST_CS | CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("PGSQL_ESCAPE_BYTEA", PGSQL_ESCAPE_BYTEA, CONST_CS | CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("PGSQL_EMPTY_QUERY", PGRES_EMPTY_QUERY, CONST_CS | CONST_PERSISTENT); REGISTER_LONG_CONSTANT("PGSQL_COMMAND_OK", PGRES_COMMAND_OK, CONST_CS | CONST_PERSISTENT); REGISTER_LONG_CONSTANT("PGSQL_TUPLES_OK", PGRES_TUPLES_OK, CONST_CS | CONST_PERSISTENT); @@ -849,7 +857,11 @@ PHP_FUNCTION(pg_query) ZEND_FETCH_RESOURCE2(pgsql, PGconn *, pgsql_link, id, "PostgreSQL link", le_link, le_plink); convert_to_string_ex(query); - PQsetnonblocking(pgsql, 0); + if (PQ_SETNONBLOCKING(pgsql, 0)) { + php_error(E_NOTICE,"%s() cannot set connection to blocking mode", + get_active_function_name(TSRMLS_C)); + RETURN_FALSE; + } while ((pgsql_result = PQgetResult(pgsql))) { PQclear(pgsql_result); leftover = 1; @@ -1422,7 +1434,7 @@ PHP_FUNCTION(pg_last_oid) ZEND_FETCH_RESOURCE(pg_result, pgsql_result_handle *, result, -1, "PostgreSQL result", le_result); pgsql_result = pg_result->result; -#if HAVE_PQOIDVALUE +#ifdef HAVE_PQOIDVALUE Z_LVAL_P(return_value) = (int) PQoidValue(pgsql_result); if (Z_LVAL_P(return_value) == InvalidOid) { RETURN_FALSE; @@ -2054,8 +2066,7 @@ PHP_FUNCTION(pg_client_encoding) #define pg_encoding_to_char(x) "SQL_ASCII" #endif - Z_STRVAL_P(return_value) - = (char *) pg_encoding_to_char(PQclientEncoding(pgsql)); + Z_STRVAL_P(return_value) = (char *) pg_encoding_to_char(PQclientEncoding(pgsql)); Z_STRLEN_P(return_value) = strlen(Z_STRVAL_P(return_value)); Z_STRVAL_P(return_value) = (char *) estrdup(Z_STRVAL_P(return_value)); Z_TYPE_P(return_value) = IS_STRING; @@ -2359,7 +2370,7 @@ PHP_FUNCTION(pg_copy_from) } /* }}} */ -#if HAVE_PQESCAPE +#ifdef HAVE_PQESCAPE /* {{{ proto string pg_escape_string(string data) Escape string for text/char type */ PHP_FUNCTION(pg_escape_string) @@ -2406,6 +2417,7 @@ PHP_FUNCTION(pg_result_error) zval *result; PGresult *pgsql_result; pgsql_result_handle *pg_result; + char *err = NULL; if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &result) == FAILURE) { @@ -2416,9 +2428,10 @@ PHP_FUNCTION(pg_result_error) pgsql_result = pg_result->result; if (!pgsql_result) { - RETURN_FALSE; + RETURN_FALSE; } - RETURN_STRING(PQresultErrorMessage(pgsql_result),1); + err = (char *)PQresultErrorMessage(pgsql_result); + RETURN_STRING(err,1); } /* }}} */ @@ -2485,7 +2498,7 @@ static void php_pgsql_do_async(INTERNAL_FUNCTION_PARAMETERS, int entry_type) ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink); - if (PQsetnonblocking(pgsql, 1)) { + if (PQ_SETNONBLOCKING(pgsql, 1)) { php_error(E_NOTICE,"%s() cannot set connection to nonblocking mode", get_active_function_name(TSRMLS_C)); RETURN_FALSE; @@ -2508,7 +2521,7 @@ static void php_pgsql_do_async(INTERNAL_FUNCTION_PARAMETERS, int entry_type) get_active_function_name(TSRMLS_C)); break; } - if (PQsetnonblocking(pgsql, 0)) { + if (PQ_SETNONBLOCKING(pgsql, 0)) { php_error(E_NOTICE,"%s() cannot set connection to blocking mode", get_active_function_name(TSRMLS_C)); } @@ -2551,7 +2564,7 @@ PHP_FUNCTION(pg_send_query) ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink); - if (PQsetnonblocking(pgsql, 1)) { + if (PQ_SETNONBLOCKING(pgsql, 1)) { php_error(E_NOTICE,"%s() cannot set connection to nonblocking mode", get_active_function_name(TSRMLS_C)); RETURN_FALSE; @@ -2567,7 +2580,7 @@ PHP_FUNCTION(pg_send_query) if (!PQsendQuery(pgsql, query)) { RETURN_FALSE; } - if (PQsetnonblocking(pgsql, 0)) { + if (PQ_SETNONBLOCKING(pgsql, 0)) { php_error(E_NOTICE,"%s() cannot set connection to blocking mode", get_active_function_name(TSRMLS_C)); } -- 2.40.0