def execute_ok(self, statement):
    self.get_connection().query_with_session(statement)
    return None
def execute_ok(self, statement):
    self.get_connection().query_with_session(statement)
    return None