

def _execute_sql(self, sql):
    conn = connect(host=self.DB_HOST, user=self.DB_USER, password=self.DB_PASSWORD)
    conn.set_isolation_level(ISOLATION_LEVEL_AUTOCOMMIT)
    cur = conn.cursor()
    cur.execute(sql)
    cur.close()
    conn.close()

dataset/ETHPy150Open scrapinghub/frontera/frontera/contrib/backends/sqlalchemy/test_backend.py Postgres._execute_sql/original