'`execute` calls are non-blocking: just queue up the request and
return a future.'

@verify_started
def execute(self, query, parameters=(), commit=False):

    fr = self.sql_executor.query(query, parameters)
    if (self.autocommit or commit):
        self.sql_executor.commit()
    return fr
