Merge pull request #19 from JesperWisborgKrogh/dev/ps_thread_id

ps_thread_id()

Author: MarkLeith

README.md

@@ -1424,6 +1424,39 @@ mysql> SELECT sys.ps_is_account_enabled('localhost', 'root');
 1 row in set (0.01 sec)
 ```
 
+#### ps_thread_id
+
+##### Description
+
+Return the Performance Schema THREAD_ID for the specified connection ID.
+
+##### Parameters
+
+* in_connection_id (BIGINT UNSIGNED): The id of the connection to return the thread id for.
+
+##### Returns
+
+BIGINT UNSIGNED
+
+##### Example
+```SQL
+mysql> SELECT sys.ps_thread_id(79);
++----------------------+
+| sys.ps_thread_id(79) |
++----------------------+
+|                   98 |
++----------------------+
+1 row in set (0.00 sec)
+
+mysql> SELECT sys.ps_thread_id(CONNECTION_ID());
++-----------------------------------+
+| sys.ps_thread_id(CONNECTION_ID()) |
++-----------------------------------+
+|                                98 |
++-----------------------------------+
+1 row in set (0.00 sec)
+```
+
 #### ps_thread_stack
 
 ##### Description

functions/ps_thread_id.sql

@@ -0,0 +1,60 @@
+/* Copyright (c) 2014, Oracle and/or its affiliates. All rights reserved.
+
+   This program is free software; you can redistribute it and/or modify
+   it under the terms of the GNU General Public License as published by
+   the Free Software Foundation; version 2 of the License.
+
+   This program is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+   GNU General Public License for more details.
+
+   You should have received a copy of the GNU General Public License
+   along with this program; if not, write to the Free Software
+   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */
+
+DROP FUNCTION IF EXISTS ps_thread_id;
+
+CREATE DEFINER='root'@'localhost' FUNCTION ps_thread_id(
+        in_connection_id BIGINT UNSIGNED
+    ) RETURNS BIGINT UNSIGNED
+    COMMENT '
+             Description
+             -----------
+
+             Return the Performance Schema THREAD_ID for the specified connection ID.
+
+             Parameters
+             -----------
+
+             in_connection_id (BIGINT UNSIGNED):
+               The id of the connection to return the thread id for.
+
+             Example
+             -----------
+
+             mysql> SELECT sys.ps_thread_id(79);
+             +----------------------+
+             | sys.ps_thread_id(79) |
+             +----------------------+
+             |                   98 |
+             +----------------------+
+             1 row in set (0.00 sec)
+
+             mysql> SELECT sys.ps_thread_id(CONNECTION_ID());
+             +-----------------------------------+
+             | sys.ps_thread_id(CONNECTION_ID()) |
+             +-----------------------------------+
+             |                                98 |
+             +-----------------------------------+
+             1 row in set (0.00 sec)
+            '
+
+SQL SECURITY INVOKER
+NOT DETERMINISTIC
+READS SQL DATA
+    RETURN (SELECT THREAD_ID
+              FROM `performance_schema`.`threads`
+             WHERE PROCESSLIST_ID = in_connection_id
+           )
+;

sys_56.sql

@@ -22,6 +22,7 @@ SOURCE ./functions/format_path.sql
 SOURCE ./functions/format_statement.sql
 SOURCE ./functions/format_time.sql
 SOURCE ./functions/ps_is_account_enabled.sql
+SOURCE ./functions/ps_thread_id.sql
 SOURCE ./functions/ps_thread_stack.sql
 
 SOURCE ./procedures/create_synonym_db.sql

sys_57.sql

@@ -22,6 +22,7 @@ SOURCE ./functions/format_path.sql
 SOURCE ./functions/format_statement.sql
 SOURCE ./functions/format_time.sql
 SOURCE ./functions/ps_is_account_enabled.sql
+SOURCE ./functions/ps_thread_id.sql
 SOURCE ./functions/ps_thread_stack.sql
 
 SOURCE ./procedures/create_synonym_db.sql