execute.py 文件源码

def execute_to_json(conn, query, params=None):
    with conn.cursor(cursor_factory=RealDictCursor) as cursor:
        cursor.execute(query, params)

        results = []
        for row in cursor.fetchall():
            row = StringConverter().snake_case_to_camel_case(row)
            results.append(dict(zip(row.keys(), row.values())))

        return results