| 17 | class TestPrepare(tb.ConnectedTestCase): |
| 18 | |
| 19 | async def test_prepare_01(self): |
| 20 | self.assertEqual(self.con._protocol.queries_count, 0) |
| 21 | st = await self.con.prepare('SELECT 1 = $1 AS test') |
| 22 | self.assertEqual(self.con._protocol.queries_count, 0) |
| 23 | self.assertEqual(st.get_query(), 'SELECT 1 = $1 AS test') |
| 24 | |
| 25 | rec = await st.fetchrow(1) |
| 26 | self.assertEqual(self.con._protocol.queries_count, 1) |
| 27 | self.assertTrue(rec['test']) |
| 28 | self.assertEqual(len(rec), 1) |
| 29 | |
| 30 | self.assertEqual(False, await st.fetchval(10)) |
| 31 | self.assertEqual(self.con._protocol.queries_count, 2) |
| 32 | |
| 33 | async def test_prepare_02(self): |
| 34 | with self.assertRaisesRegex(Exception, 'column "a" does not exist'): |