Function execute_query

compat/src/test/python/runner_psycopg2.py:35–48

(cursor, query, parameters)

def execute_query(cursor, query, parameters):
    if parameters:
        cursor.execute(query, parameters)
    else:
        cursor.execute(query)
    try:
        if cursor.description:
            return cursor.fetchall()
        else:
            if cursor.rowcount == -1:
                return None
            return [(cursor.rowcount,)]
    except psycopg2.ProgrammingError:
        return cursor.statusmessage


def execute_steps(steps, variables, cursor, connection):