Fix read counters when reading data from SQLite.

This commit is contained in:
Dimitri Fontaine 2015-06-16 23:14:10 +02:00
parent 7e508374c4
commit b55ded11e0

View File

@ -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)