code: async def fetchall(self):
          
          try:
              rows = await self._cursor.fetchall()
          except AttributeError:
              self._non_result()
          else:
              ret = self._process_rows(rows)
              await self.close()
              return ret
docs: Fetch all rows, just like DB-API cursor.fetchall().