Fix the processlist_raw view for 5.7 to also show memory use per thread

Author: MarkLeith

views/p_s/processlist_57.sql

@@ -7,28 +7,29 @@
  * mysql> select * from processlist_full where conn_id is not null\G
  * ...
  * *************************** 8. row ***************************
- *                 thd_id: 12400
- *                conn_id: 12379
+ *                 thd_id: 31
+ *                conn_id: 12
  *                   user: root@localhost
  *                     db: ps_helper
  *                command: Query
- *                  state: Copying to tmp table
+ *                  state: Sending data
  *                   time: 0
- *      current_statement: select * from processlist_full where conn_id is not null
- *         last_statement: NULL
- * last_statement_latency: NULL
- *           lock_latency: 1.00 ms
+ *      current_statement: select * from processlist limit 5
+ *           lock_latency: 684.00 us
  *          rows_examined: 0
  *              rows_sent: 0
  *          rows_affected: 0
- *             tmp_tables: 1
+ *             tmp_tables: 2
  *        tmp_disk_tables: 0
  *              full_scan: YES
- *              last_wait: wait/synch/mutex/sql/THD::LOCK_thd_data
- *      last_wait_latency: 62.53 ns
- *                 source: sql_class.h:3843
+ *         current_memory: 1.29 MiB
+ *         last_statement: NULL
+ * last_statement_latency: NULL
+ *              last_wait: wait/synch/mutex/sql/THD::LOCK_query_plan
+ *      last_wait_latency: 260.13 ns
+ *                 source: sql_optimizer.cc:1075
  *
- * Versions: 5.6.2+
+ * Versions: 5.7.2+
  *
  */
 
@@ -80,29 +81,29 @@ ORDER BY pps.processlist_time DESC, last_wait_latency DESC;
  * 
  * mysql> select * from processlist_full where conn_id is not null\G
  * *************************** 1. row ***************************
- *                 thd_id: 25
- *                conn_id: 6
+ *                 thd_id: 31
+ *                conn_id: 12
  *                   user: root@localhost
  *                     db: ps_helper
  *                command: Query
  *                  state: Sending data
  *                   time: 0
- *      current_statement: select * from processlist_full where conn_id is not null
- *         last_statement: NULL
- * last_statement_latency: NULL
- *           lock_latency: 741.00 us
+ *      current_statement: select * from processlist_raw limit 5
+ *           lock_latency: 1066000000
  *          rows_examined: 0
  *              rows_sent: 0
  *          rows_affected: 0
- *             tmp_tables: 1
- *        tmp_disk_tables: 0
+ *             tmp_tables: 2
+ *        tmp_disk_tables: 1
  *              full_scan: YES
- *              last_wait: wait/synch/mutex/sql/THD::LOCK_query_plan
- *      last_wait_latency: 196.04 ns
- *                 source: sql_optimizer.cc:1075
- * 1 row in set (0.00 sec)
+ *         current_memory: 1464694
+ *         last_statement: NULL
+ * last_statement_latency: NULL
+ *              last_wait: wait/io/file/myisam/dfile
+ *      last_wait_latency: 1602250
+ *                 source: mf_iocache.c:163
  *
- * Versions: 5.6.2+
+ * Versions: 5.7.2+
  *
  */
 
@@ -119,20 +120,21 @@ SELECT pps.thread_id AS thd_id,
        pps.processlist_state AS state,
        pps.processlist_time AS time,
        pps.processlist_info AS current_statement,
-       IF(esc.timer_wait IS NOT NULL,
-          esc.sql_text,
-          NULL) AS last_statement,
-       IF(esc.timer_wait IS NOT NULL,
-          esc.timer_wait,
-          NULL) as last_statement_latency,
        esc.lock_time AS lock_latency,
        esc.rows_examined,
        esc.rows_sent,
        esc.rows_affected,
        esc.created_tmp_tables AS tmp_tables,
-       esc.created_tmp_disk_tables as tmp_disk_tables,
+       esc.created_tmp_disk_tables AS tmp_disk_tables,
        IF(esc.no_good_index_used > 0 OR esc.no_index_used > 0, 
           'YES', 'NO') AS full_scan,
+       SUM(mem.current_number_of_bytes_used) AS current_memory,
+       IF(esc.timer_wait IS NOT NULL,
+          esc.sql_text,
+          NULL) AS last_statement,
+       IF(esc.timer_wait IS NOT NULL,
+          esc.timer_wait,
+          NULL) as last_statement_latency,
        ewc.event_name AS last_wait,
        IF(ewc.timer_wait IS NULL AND ewc.event_name IS NOT NULL, 
           'Still Waiting', 
@@ -141,4 +143,6 @@ SELECT pps.thread_id AS thd_id,
   FROM performance_schema.threads AS pps
   LEFT JOIN performance_schema.events_waits_current AS ewc USING (thread_id)
   LEFT JOIN performance_schema.events_statements_current as esc USING (thread_id)
+  LEFT JOIN performance_schema.memory_summary_by_thread_by_event_name as mem USING (thread_id)
+GROUP BY thread_id
 ORDER BY pps.processlist_time DESC, last_wait_latency DESC;