(self, sql_stmt, user=None)
| 723 | return r |
| 724 | |
| 725 | def execute_async(self, sql_stmt, user=None): |
| 726 | async_cursor = None |
| 727 | if user is None: |
| 728 | user = self.__user |
| 729 | try: |
| 730 | async_cursor = self.__open_single_cursor(user=user) |
| 731 | handle = OperationHandle(async_cursor, sql_stmt) |
| 732 | self.__log_execute(async_cursor, user, sql_stmt) |
| 733 | async_cursor.execute_async(sql_stmt, configuration=self.__query_options) |
| 734 | self.__async_cursors.append(async_cursor) |
| 735 | return handle |
| 736 | except Exception as e: |
| 737 | if async_cursor: |
| 738 | async_cursor.close_operation() |
| 739 | self.__close_single_cursor(async_cursor) |
| 740 | raise e |
| 741 | |
| 742 | def cancel(self, operation_handle): |
| 743 | self.log_handle(operation_handle, 'canceling operation') |
nothing calls this directly
no test coverage detected