postgres.py 文件源码

def connect_and_execute(query, database='postgres'):
    """Connect to database, execute given query and return fetched results"""

    conn = connect(database=database)

    try:
        conn.set_isolation_level(ISOLATION_LEVEL_AUTOCOMMIT)
        cursor = conn.cursor(cursor_factory=RealDictCursor)
        cursor.execute(query)

        return cursor.fetchall()
    finally:
        conn.close()