From 2b4980933619c4e87934fd77c57ddb3ea9bcd684 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kirill=20M=C3=BCller?= Date: Mon, 4 Jul 2022 04:06:32 +0200 Subject: [PATCH] Add dbSendQuery() shim --- R/trace.R | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/R/trace.R b/R/trace.R index 57529f2fa..bf6da6216 100644 --- a/R/trace.R +++ b/R/trace.R @@ -39,6 +39,24 @@ dbGetQuery <- function(conn, statement, ...) { DBI::dbGetQuery(conn, statement, ...) } +dbSendQuery <- function(conn, statement, ...) { + level <- tracing_level() + id <- tracing_id() + + if (level >= 1) { + message_base <- paste0("[", id, "]: dbSendQuery()") + message_pre <- paste0(message_base, "\n", statement) + message_post <- paste0(message_base, " done") + class <- c("dplyr_message_trace_send_query", "dplyr_message_trace", "dplyr_message") + inform(message_pre, class = class) + on.exit({ + inform(message_post, class = class) + }) + } + + DBI::dbSendQuery(conn, statement, ...) +} + dbExecute <- function(conn, statement, ...) { level <- tracing_level() id <- tracing_id()