Make process screen report information in a way that makes sense in postgres 9.2

Also add in the waiting option, making it work back to at least 8.1

2 files changed, 28 insertions, 2 deletions

diff --git a/classes/database/Postgres.php b/classes/database/Postgres.php
index cba4cd6e..73ea2af8 100755
--- a/classes/database/Postgres.php
+++ b/classes/database/Postgres.php
@@ -7198,12 +7198,14 @@ class Postgres extends ADODB_base {
 	 */
 	function getProcesses($database = null) {
 		if ($database === null)
-			$sql = "SELECT datname, usename, pid, query, query_start
+			$sql = "SELECT datname, usename, pid, waiting, state_change as query_start,
+                  case when state='idle in transaction' then '<IDLE> in transaction' when state = 'idle' then '<IDLE>' else query end as query 
 				FROM pg_catalog.pg_stat_activity
 				ORDER BY datname, usename, pid";
 		else {
 			$this->clean($database);
-			$sql = "SELECT datname, usename, pid, query, query_start
+			$sql = "SELECT datname, usename, pid, waiting, state_change as query_start,
+                  case when state='idle in transaction' then '<IDLE> in transaction' when state = 'idle' then '<IDLE>' else query end as query 
 				FROM pg_catalog.pg_stat_activity
 				WHERE datname='{$database}'
 				ORDER BY usename, pid";
diff --git a/classes/database/Postgres81.php b/classes/database/Postgres81.php
index f3ec6d18..70d40b82 100644
--- a/classes/database/Postgres81.php
+++ b/classes/database/Postgres81.php
@@ -226,6 +226,30 @@ class Postgres81 extends Postgres82 {
 		return $status;
 	}
 
+	/**
+	 * Returns all available process information.
+	 * @param $database (optional) Find only connections to specified database
+	 * @return A recordset
+	 */
+	function getProcesses($database = null) {
+		if ($database === null)
+			$sql = "SELECT datname, usename, procpid AS pid, current_query AS query, query_start, 
+                  case when (select count(*) from pg_locks where pid=pg_stat_activity.procpid and granted is false) > 0 then 't' else 'f' end as waiting  
+				FROM pg_catalog.pg_stat_activity
+				ORDER BY datname, usename, procpid";
+		else {
+			$this->clean($database);
+			$sql = "SELECT datname, usename, procpid AS pid, current_query AS query, query_start
+                    case when (select count(*) from pg_locks where pid=pg_stat_activity.procpid and granted is false) > 0 then 't' else 'f' end as waiting 
+				FROM pg_catalog.pg_stat_activity
+				WHERE datname='{$database}'
+				ORDER BY usename, procpid";
+		}
+
+		$rc = $this->selectSet($sql);
+
+		return $rc;
+	}
 
 	// Tablespace functions