diff --git a/R/Result.R b/R/Result.R index 8df1562..0f5f237 100644 --- a/R/Result.R +++ b/R/Result.R @@ -58,7 +58,7 @@ init_result <- function(connection, statement, class, immediate = NULL, } res <- new_result(stmt, immediate, prepared, match.arg(type), statement, - class) + class) register_result(connection, res) diff --git a/R/ResultArrow.R b/R/ResultArrow.R index 06e1446..67a4f3a 100644 --- a/R/ResultArrow.R +++ b/R/ResultArrow.R @@ -2,7 +2,7 @@ NULL AdbiResultArrow <- function(connection, statement, immediate = NULL, - type = c("query", "statement")) { + type = c("query", "statement")) { init_result(connection, statement, "AdbiResultArrow", immediate, type) } diff --git a/R/dbSendQueryArrow_Connection.R b/R/dbSendQueryArrow_Connection.R index d72e2f9..0727de4 100644 --- a/R/dbSendQueryArrow_Connection.R +++ b/R/dbSendQueryArrow_Connection.R @@ -6,7 +6,7 @@ #' @inheritParams DBI::dbSendQuery #' @usage NULL dbSendQueryArrow_AdbiConnection <- function(conn, statement, ..., - params = NULL, immediate = NULL) { + params = NULL, immediate = NULL) { if (!is.null(params)) { immediate <- FALSE diff --git a/README.Rmd b/README.Rmd index 3575f59..99aa125 100644 --- a/README.Rmd +++ b/README.Rmd @@ -77,7 +77,7 @@ while (!dbHasCompleted(res)) { dbBind(res, 20) -while(!dbHasCompleted(res)) { +while (!dbHasCompleted(res)) { print(dbFetchArrow(res)) }