Fix copy_to overwrite flag

NEWS.md

@@ -1,5 +1,6 @@
 # dbplyr (development version)
 
+* Fixed overwrite flag in `copy_to()` to work when source is in the same DB as destination (@liudvikasakelis, #1535)
 * Snowflake correctly translates `$` to `:` (@jsowder, #1608)
 * `dbplyr_uncount()` now works with Redshift (@owenjonesuob, #1601).
 

R/verb-compute.R

@@ -35,6 +35,7 @@ compute.tbl_sql <- function(
   x,
   name = NULL,
   temporary = TRUE,
+  overwrite = FALSE,
   unique_indexes = list(),
   indexes = list(),
   analyze = TRUE,
@@ -67,6 +68,7 @@ compute.tbl_sql <- function(
     name,
     sql,
     temporary = temporary,
+    overwrite = overwrite,
     unique_indexes = unique_indexes,
     indexes = indexes,
     analyze = analyze,

R/verb-copy-to.R

@@ -74,6 +74,7 @@ copy_to.src_sql <- function(
       df,
       name = name,
       temporary = temporary,
+      overwrite = overwrite,
       unique_indexes = unique_indexes,
       indexes = indexes,
       analyze = analyze,

tests/testthat/test-verb-copy-to.R

@@ -35,6 +35,16 @@ test_that("only overwrite existing table if explicitly requested", {
   expect_silent(copy_to(con, data.frame(x = 1), name = "df", overwrite = TRUE))
 })
 
+test_that("overwrite flag works when copying *within* db sources", {
+  con <- local_sqlite_connection()
+  df <- copy_to(con, tibble(x = 1), "df", temporary = FALSE)
+  copy_to(con, df, "df2", temporary = FALSE)
+
+  df2 <- tibble(x = 2)
+  out <- copy_to(con, df2, name = "df2", temporary = FALSE, overwrite = TRUE)
+  expect_equal(collect(out), df2)
+})
+
 test_that("can create a new table in non-default schema", {
   con <- local_sqlite_con_with_aux()