test07r_jsonb.py 文件源码

def execute_sql(sql):
    # je hebt hier een andere config nodig dan die in de global_test_suite staat!:
    engine = create_engine(test_config['conn_dwh'])
    conn = engine.raw_connection()
    cursor = conn.cursor(cursor_factory=DictCursor)
    cursor.execute(sql)
    result = cursor.fetchall()
    conn.commit()
    cursor.close()

    return result