rows2dict

cursor = conn.cursor(cursor_factory=DictCursor)
cursor.execute(sql)
rows = cursor.fetchall()
rows_dict = [dict(row) for row in rows]

            rows = session.execute(sql)
            keys = rows.keys()
            return [dict(zip(keys, row)) for row in rows]

import polars as pl
import pyarrow as pa


def rows2df(rows_dict):
    if rows_dict:
        return pl.from_dicts(rows_dict, infer_schema_length=len(rows_dict))
    return pl.DataFrame()


def rows2table(rows_dict):
    return pa.Table.from_pylist(rows_dict)