From b55ded11e00dfed40fc9ecfeeec83766eb2667c7 Mon Sep 17 00:00:00 2001 From: Dimitri Fontaine Date: Tue, 16 Jun 2015 23:14:10 +0200 Subject: [PATCH] Fix read counters when reading data from SQLite. --- src/sources/sqlite/sqlite.lisp | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/sources/sqlite/sqlite.lisp b/src/sources/sqlite/sqlite.lisp index 5b42a4a..999746d 100644 --- a/src/sources/sqlite/sqlite.lisp +++ b/src/sources/sqlite/sqlite.lisp @@ -101,7 +101,9 @@ :do (setf (aref v x) val)) v) counting t into rows - do (funcall process-row-fn row) + do (progn + (pgstate-incf *state* (target sqlite) :read 1) + (funcall process-row-fn row)) finally (sqlite:finalize-statement statement) (return rows)) @@ -112,8 +114,7 @@ (defmethod copy-to-queue ((sqlite copy-sqlite) queue) "Copy data from SQLite table TABLE-NAME within connection DB into queue DATAQ" - (let ((read (pgloader.queue:map-push-queue sqlite queue))) - (pgstate-incf *state* (target sqlite) :read read))) + (map-push-queue sqlite queue)) (defmethod copy-from ((sqlite copy-sqlite) &key (kernel nil k-s-p) truncate disable-triggers)