| 2408 | } |
| 2409 | |
| 2410 | void ClientBase::cancelQuery() |
| 2411 | { |
| 2412 | sendCancel(); |
| 2413 | |
| 2414 | stopKeystrokeInterceptorIfExists(); |
| 2415 | |
| 2416 | if (need_render_progress && tty_buf) |
| 2417 | { |
| 2418 | std::unique_lock lock(tty_mutex); |
| 2419 | progress_indication.clearProgressOutput(*tty_buf, lock); |
| 2420 | } |
| 2421 | if (need_render_progress_table && tty_buf) |
| 2422 | { |
| 2423 | std::unique_lock lock(tty_mutex); |
| 2424 | progress_table.clearTableOutput(*tty_buf, lock); |
| 2425 | } |
| 2426 | |
| 2427 | if (is_interactive) |
| 2428 | output_stream << "Cancelling query." << std::endl; |
| 2429 | |
| 2430 | cancelled = true; |
| 2431 | } |
| 2432 | |
| 2433 | void ClientBase::processParsedSingleQuery( |
| 2434 | std::string_view query_, |