Index: dbfile.scm
==================================================================
--- dbfile.scm
+++ dbfile.scm
@@ -795,22 +795,27 @@
 	     fields)
 
 	    ;; read the source table
             ;; store a list of all rows in the table in fromdat, up to batch-len.
             ;; Then add fromdat to the fromdats list, clear fromdat and repeat.
-	    (sqlite3:for-each-row
-	     (lambda (a . b)
-	       (set! fromdat (cons (apply vector a b) fromdat))
-	       (if (> (length fromdat) batch-len)
-		   (begin
-		     (set! fromdats (cons fromdat fromdats))
-		     (set! fromdat  '())
-		     (set! totrecords (+ totrecords 1)))
-               )
-             )
-	     (dbr:dbdat-dbh fromdb)
-	     full-sel)
+            (sqlite3:with-transaction 
+              (dbr:dbdat-dbh fromdb)
+              (lambda ()
+	        (sqlite3:for-each-row
+	          (lambda (a . b)
+	            (set! fromdat (cons (apply vector a b) fromdat))
+	            (if (> (length fromdat) batch-len)
+		      (begin
+		        (set! fromdats (cons fromdat fromdats))
+		        (set! fromdat  '())
+		        (set! totrecords (+ totrecords 1)))
+                    )
+                 )
+	         (dbr:dbdat-dbh fromdb)
+	         full-sel)
+              )
+            )
 
              ;; Count less than batch-len as a record
              (if (> (length fromdat) 0)
                  (set! totrecords (+ totrecords 1)))