Function _execute_sql

blackbox/test_docs.py:134–149

Invoke a single SQL statement and automatically close the HTTP connection when done.

(stmt)

def _execute_sql(stmt):
    """
    Invoke a single SQL statement and automatically close the HTTP connection
    when done.
    """
    with connect(crate.http_url) as conn:
        c = conn.cursor()
        try:
            c.execute(stmt)
            return c
        except ConnectionError as e:
            logfile = os.path.join(crate.logs_path, crate.cluster_name + '.log')
            with open(logfile, 'r') as f:
                logs = f.read()
            msg = str(e) + '\n' + logs
            raise ConnectionError(msg, e.error_trace)


def wait_for_schema_update(schema, table, column):