Add Statement.get_query()

Author: 1st1

asyncpg/prepared_stmt.py

@@ -13,6 +13,9 @@ def __init__(self, connection, query, state):
         self._query = query
         state.attach()
 
+    def get_query(self):
+        return self._query
+
     def get_parameters(self):
         self.__check_open()
         return self._state._get_parameters()

tests/test_prepare.py

@@ -9,6 +9,7 @@ class TestPrepare(tb.ConnectedTestCase):
 
     async def test_prepare_1(self):
         st = await self.con.prepare('SELECT 1 = $1 AS test')
+        self.assertEqual(st.get_query(), 'SELECT 1 = $1 AS test')
 
         rec = await st.fetch_row(1)
         self.assertTrue(rec['test'])