           (print (format "%s: %7d/%7d  "    table-name 
                                             (swap! rows-inserted + (count rows-chunk-new))
                                             table-rows ))
-          (time (apply jdbc/insert! pg-conn table-name rows-chunk-new  )))))
+          (time (apply jdbc/insert! pg-conn table-name rows-chunk-new  ))
+          (flush))))
 
     (when false
       (newline)

  ))

(defn proc-table [table-name]
  (jdbc/with-db-connection [ora-conn ora-spec]
    (oracle-set-context ora-conn)
    (jdbc/query ora-conn [ (format "select * from %s" table-name) ]
      :result-set-fn  #(result-set->pg-insert table-name %) )))

(defn transfer-data []
  (newline)

(def enable-testing true)   ; #todo  FOR TESTING ONLY *******************************************
(def test-rs-limit-fn       ; #todo  FOR TESTING ONLY *******************************************
  (if enable-testing 
    #(take 12345 %)
    identity ))

(defn result-set->pg-insert [table-name result-set]
