use dbFetch() instead of fetch()

kvpradap · Sep 29, 2016 · d8407fa · d8407fa
1 parent 1313baa
commit d8407fa
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/DESCRIPTION b/DESCRIPTION
@@ -21,7 +21,7 @@ Imports:
     tibble,
     magrittr,
     lazyeval (>= 0.1.10),
-    DBI (>= 0.4.1)
+    DBI (>= 0.5)
 Suggests: 
     RSQLite (>= 1.0.0),
     RMySQL,

diff --git a/R/query.r b/R/query.r
@@ -41,7 +41,7 @@ Query <- R6::R6Class("Query",
       res <- dbSendQuery(self$con, self$sql)
       on.exit(dbClearResult(res))
 
-      out <- fetch(res, n)
+      out <- dbFetch(res, n)
       res_warn_incomplete(res)
       out
     },
@@ -51,7 +51,7 @@ Query <- R6::R6Class("Query",
       on.exit(dbClearResult(qry))
 
       while (!dbHasCompleted(qry)) {
-        chunk <- fetch(qry, chunk_size)
+        chunk <- dbFetch(qry, chunk_size)
         callback(chunk)
       }