diff --git a/R/CtasHack.R b/R/CtasHack.R index 195cd7b9..f6bebb61 100644 --- a/R/CtasHack.R +++ b/R/CtasHack.R @@ -179,7 +179,7 @@ ctasHack <- function(connection, sqlTableName, tempTable, sqlFieldNames, sqlData inform(paste("Inserting data took", signif(delta, 3), attr(delta, "units"))) } -multiValuesInsert <- function(connection, sqlTableName, tempTable, sqlFieldNames, sqlDataTypes, data, progressBar, tempEmulationSchema) { +multiValuesInsert <- function(connection, sqlTableName, sqlFieldNames, sqlDataTypes, data, progressBar, tempEmulationSchema) { logTrace(sprintf("Inserting %d rows into table '%s' using multi-values inserts", nrow(data), sqlTableName)) assign("noLogging", TRUE, envir = globalVars) @@ -216,4 +216,3 @@ multiValuesInsert <- function(connection, sqlTableName, tempTable, sqlFieldNames delta <- Sys.time() - startTime inform(paste("Inserting data took", signif(delta, 3), attr(delta, "units"))) } - diff --git a/R/InsertTable.R b/R/InsertTable.R index b4aee506..e95226fd 100644 --- a/R/InsertTable.R +++ b/R/InsertTable.R @@ -313,7 +313,7 @@ insertTable.default <- function(connection, # Inserting using CTAS hack ---------------------------------------------------------------- ctasHack(connection, sqlTableName, tempTable, sqlFieldNames, sqlDataTypes, data, progressBar, tempEmulationSchema) } else if (dbms == "spark") { - multiValuesInsert(connection, sqlTableName, tempTable, sqlFieldNames, sqlDataTypes, data, progressBar, tempEmulationSchema) + multiValuesInsert(connection, sqlTableName, sqlFieldNames, sqlDataTypes, data, progressBar, tempEmulationSchema) } else { # Inserting using SQL inserts -------------------------------------------------------------- logTrace(sprintf("Inserting %d rows into table '%s'", nrow(data), sqlTableName))