lib/wyrm/pump.rb in wyrm-0.3.1 vs lib/wyrm/pump.rb in wyrm-0.3.2

@@ -267,10 +267,12 @@
           page_size.times do
             # This skips all the checks in the Sequel code. Basically we want
             # to generate the
             #   insert into (field1,field2) values (value1,value2)
             # statement as quickly as possible.
-            sql = table_dataset.clone( columns: columns, values: row_enum.next ).send( :clause_sql, :insert )
+            #
+            # Uses a private method so it will need to be updated repeatedly.
+            sql = table_dataset.clone( columns: columns, values: row_enum.next ).send(:_insert_sql)
             db.execute sql unless dry_run?
             rows_restored += 1
           end
         rescue StopIteration
           # reached the end of the inout stream.