Method query_all

misc/python/materialize/mzexplore/sql.py:69–74

(self, query: str)

            return cast(dict[Any, Any], row)

    def query_all(self, query: str) -> DictGenerator:
        with self.conn.cursor() as cursor:
            cursor.execute(query)
            cols = [d[0].lower() for d in cursor.description]
            for row in cursor.fetchall():
                yield {key: val for key, val in zip(cols, row)}

    def execute(self, statement: str) -> None:
        with self.conn.cursor() as cursor: