Implement postgresIsTransacting()

NAMESPACE

@@ -6,6 +6,7 @@ export(Postgres)
 export(Redshift)
 export(postgresDefault)
 export(postgresHasDefault)
+export(postgresIsTransacting)
 export(postgresWaitForNotify)
 exportClasses(PqConnection)
 exportClasses(PqDriver)

R/PqConnection.R

@@ -308,6 +308,19 @@ postgresWaitForNotify <- function (conn, timeout = 1) {
   if ('pid' %in% names(out)) out else NULL
 }
 
+#' Return whether a transaction is ongoing
+#'
+#' Detect whether the transaction is active for the given connection. A
+#' transaction might be started with [dbBegin()] or wrapped within
+#' [DBI::dbWithTransaction()].
+#' @export
+#' @param conn a [PqConnection-class] object, produced by
+#'   [DBI::dbConnect()]
+#' @return A boolean, indicating if a transaction is ongoing.
+postgresIsTransacting <- function(conn) {
+  connection_is_transacting(conn@ptr)
+}
+
 #' Determine database type for R vector.
 #'
 #' @export

tests/testthat/test-isTransacting.R

@@ -0,0 +1,11 @@
+context("isTransacting")
+
+test_that("isTransacting detects transactions correctly", {
+  skip_on_cran()
+  db <- postgresDefault()
+  expect_false(postgresIsTransacting(con))
+  dbBegin(con)
+  expect_true(postgresIsTransacting(con))
+  dbCommit(con)
+  expect_false(postgresIsTransacting(con))
+})