Set a busy handler for dbUpdate() and dbSelect()

pharmaR · Mar 22, 2024 · fc51619 · fc51619
1 parent b834371
commit fc51619
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/R/utils_get_db.R b/R/utils_get_db.R
@@ -18,6 +18,7 @@ dbSelect <- function(query, db_name = golem::get_golem_options('assessment_db_na
   errFlag <- FALSE
   con <- DBI::dbConnect(RSQLite::SQLite(), db_name)
 
+  RSQLite::sqliteSetBusyHandler(con, 3000)
   tryCatch(
     expr = {
       rs <- DBI::dbSendQuery(con, glue::glue_sql(query, .envir = .envir, .con = con))

diff --git a/R/utils_insert_db.R b/R/utils_insert_db.R
@@ -21,6 +21,7 @@ dbUpdate <- function(command, db_name = golem::get_golem_options('assessment_db_
   errFlag <- FALSE
   con <- DBI::dbConnect(RSQLite::SQLite(), db_name)
 
+  RSQLite::sqliteSetBusyHandler(con, 3000)
   tryCatch({
     rs <- DBI::dbSendStatement(con, glue::glue_sql(command, .envir = .envir, .con = con))
     if (!is.null(params))