 (def enable-testing true)   ; #todo  FOR TESTING ONLY *******************************************
 (def test-rs-limit-fn       ; #todo  FOR TESTING ONLY *******************************************
   (if enable-testing 
-    #(take 1234 %)
+    #(take 12345 %)
     identity ))
 
 (defn result-set->pg-insert [table-name result-set]

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

    (when false
      (newline)

  ))

(defn proc-table [table-name]
  (let [completed (atom false)]
    (while (not @completed)
      (Thread/sleep (rand-int (* 30 1000)))
      (println "Trying tx for:" table-name)
      (try
        (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 %) ))
        (reset! completed true)
        (catch Exception ex 
          (println (format "    %s failed... will retry" table-name)))))))

(defn transfer-data []
  (newline)
