20180720

Author: dbacvetkov

build.gradle

@@ -10,7 +10,7 @@
 apply plugin: 'application'
 apply plugin: 'java'
 
-version = '0.4.0'
+version = '0.4.1'
 sourceCompatibility = 1.7
 targetCompatibility = 1.7
 

src/org/ash/database/ASHDatabasePG10ASH.java

@@ -88,7 +88,7 @@ public class ASHDatabasePG10ASH extends ASHDatabase {
             + "application_name, backend_type, "
             + "coalesce(client_hostname, client_addr::text, 'localhost') as client_hostname, "
             + "wait_event_type, wait_event, query, queryid, "
-            + "coalesce(query_start, xact_start, backend_start) as query_start, 1000 * EXTRACT(EPOCH FROM (clock_timestamp()-coalesce(query_start, xact_start, backend_start))) as duration "
+            + "coalesce(query_start, xact_start, backend_start) as query_start, 1000 * EXTRACT(EPOCH FROM (ash_time - coalesce(query_start, xact_start, backend_start))) as duration "
             + "from pg_active_session_history "
             + "where state='active' and pid != pg_backend_pid()";
 
@@ -246,6 +246,8 @@ private void loadAshDataToLocal() {
                                 query_text = "wal";
                         } else if(backendType != null && (backendType.equals("walreceiver") || backendType.equals("walsender"))) {
                                 query_text = "wal";
+                        } else if(backendType != null && (backendType.equals("autovacuum worker"))) {
+                                query_text = "autovacuum";
                         } else {
                                 query_text = "empty";
 			}

src/org/ash/database/DBUtils.java

@@ -73,7 +73,7 @@ else if (s == 0) {
                 return "BEGIN";
             } else if (array[i].equals("vacuum")) {
                 return "VACUUM";
-            } else if (array[i].equals("autovacuum:")) {
+            } else if (array[i].equals("autovacuum:")||array[i].equals("autovacuum")) {
                 return "AUTOVACUUM";
             } else if (array[i].equals("analyze")) {
                 return "ANALYZE";

src/org/ash/gui/MainFrame.java

@@ -341,7 +341,6 @@ private void initializeBerkeleyDatabaseAndLoading() {
 		} else if (versionOracleDB.startsWith("10.")) {
 			if(ASHsupport) {
 				this.database = new ASHDatabasePG10ASH(this.model);
-				// this.database = new ASHDatabasePG10(this.model);
 			} else {
 				this.database = new ASHDatabasePG10(this.model);
 			}