Run postgres iterate within a transaction

Author: lovelydinosaur

databases/backends/postgres.py

@@ -169,9 +169,10 @@ async def iterate(
         self, query: ClauseElement
     ) -> typing.AsyncGenerator[typing.Any, None]:
         assert self._connection is not None, "Connection is not acquired"
-        query, args, result_columns = self._compile(query)
-        async for row in self._connection.cursor(query, *args):
-            yield Record(row, result_columns, self._dialect)
+        async with self.transaction():
+            query, args, result_columns = self._compile(query)
+            async for row in self._connection.cursor(query, *args):
+                yield Record(row, result_columns, self._dialect)
 
     def transaction(self) -> TransactionBackend:
         return PostgresTransaction(connection=self)