diff --git a/memsql/common/database.py b/memsql/common/database.py
index <HASH>..<HASH> 100644
--- a/memsql/common/database.py
+++ b/memsql/common/database.py
@@ -100,6 +100,10 @@ class Connection(object):
         """ Ping the server """
         return self._db.ping()
 
+    def thread_id(self):
+        """ Retrieve the thread id for the current connection """
+        return self._db.thread_id()
+
     def debug_query(self, query, *parameters, **kwparameters):
         return self._query(query, parameters, kwparameters, debug=True)
 
diff --git a/memsql/common/test/test_database_adapters.py b/memsql/common/test/test_database_adapters.py
index <HASH>..<HASH> 100644
--- a/memsql/common/test/test_database_adapters.py
+++ b/memsql/common/test/test_database_adapters.py
@@ -28,6 +28,9 @@ def test_query(test_db_conn):
 def test_ping(test_db_conn):
     test_db_conn.ping()
 
+def test_thread_id(test_db_conn):
+    assert isinstance(test_db_conn.thread_id(), int)
+
 class TestQueries(object):
     @pytest.fixture(scope="class")
     def x_conn(self, request, test_db_args, test_db_database):
expose thread_id method on database connections