Added pg_ping()

NEWS

@@ -7,7 +7,7 @@ PHP 4                                                                      NEWS
 - Fixed bug #17825 (ob_start() chunk size option didn't work well). (Yasuo)
 - Fixed output buffering implicit flush. (Yasuo) 
 - Added getopt() for parsing command line options and arguments. (Jon)
-- Added pg_fetch_assoc(), pg_fetch_all(), pg_meta_data(), pg_convert(), 
+- Added pg_fetch_assoc(), pg_fetch_all(), pg_ping(), pg_meta_data(), pg_convert(), 
   pg_insert(), pg_select(), pg_update() and pg_delete(). (Yasuo)
 - Fixed bug #17281 (Sanity checks for encoding sessions). (Ilia)
 - Fixed bug #16995 and #19392 (Prevent crash if $HTTP_SESSION_VARS != ARRAY).

ext/pgsql/pgsql.c

@@ -88,6 +88,7 @@ function_entry pgsql_functions[] = {
 	PHP_FE(pg_port,			NULL)
 	PHP_FE(pg_tty,			NULL)
 	PHP_FE(pg_options,		NULL)
+	PHP_FE(pg_ping,			NULL)
 	/* query functions */
 	PHP_FE(pg_query,		NULL)
 	PHP_FE(pg_send_query,	NULL)
@@ -840,6 +841,37 @@ PHP_FUNCTION(pg_host)
 }
 /* }}} */
 
+/* {{{ proto bool pg_ping([resource connection])
+   Ping database. If connection is bad, try to reconnect. */
+PHP_FUNCTION(pg_ping)
+{
+	zval *pgsql_link = NULL;
+	int id = -1;
+	PGconn *pgsql;
+
+	if (zend_parse_parameters_ex(ZEND_PARSE_PARAMS_QUIET, ZEND_NUM_ARGS() TSRMLS_CC, "r",
+								 &pgsql_link) == FAILURE) {
+		RETURN_FALSE;
+	}
+
+	ZEND_FETCH_RESOURCE2(pgsql, PGconn *, &pgsql_link, id, "PostgreSQL link", le_link, le_plink);
+
+	/* ping connection */
+	PQexec(pgsql, "SELECT 1;");
+
+	/* check status. */
+	if (PQstatus(pgsql) == CONNECTION_OK)
+		RETURN_TRUE;
+
+	/* reset connection if it's broken */
+	PQreset(pgsql);
+	if (PQstatus(pgsql) == CONNECTION_OK) {
+		RETURN_TRUE;
+	}
+	RETURN_FALSE;
+}
+/* }}} */
+
 /* {{{ proto resource pg_query([resource connection,] string query)
    Execute a query */
 PHP_FUNCTION(pg_query)

ext/pgsql/php_pgsql.h

@@ -71,6 +71,7 @@ PHP_FUNCTION(pg_dbname);
 PHP_FUNCTION(pg_port);
 PHP_FUNCTION(pg_tty);
 PHP_FUNCTION(pg_options);
+PHP_FUNCTION(pg_ping);
 /* query functions */
 PHP_FUNCTION(pg_query);
 PHP_FUNCTION(pg_send_query);