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()
评论列表
文章目录