Convert from java.jdbc to next.jdbc

Author: tobias

db-importer/src/clojars/db_import.clj

@@ -1,8 +1,9 @@
 (ns clojars.db-import
   (:require
-   [clojure.java.jdbc :as jdbc]
+   [clojars.db :as db]
    [clojure.set :as set]
-   [clojure.walk :as walk]))
+   [clojure.walk :as walk]
+   [next.jdbc.sql :as sql]))
 
 (def tables
   [:users
@@ -12,13 +13,13 @@
 
 (defn select-all
   [db table]
-  (jdbc/query
+  (sql/query
    db
    [(format "select * from %s" (name table))]))
 
 (defn clear-psql-db
   [psql-db]
-  (jdbc/db-do-commands
+  (db/do-commands
    psql-db
    (mapv
     #(format "delete from %s" (name %))
@@ -79,15 +80,15 @@
   [db table data]
   (doseq [chunk (partition-all 10000 data)]
     (printf "==> inserting batch of %s\n" (count chunk))
-    (jdbc/insert-multi! db table
-                        (map translate-row chunk))))
+    (sql/insert-multi! db table
+                       (map translate-row chunk))))
 
 (defn existing-ids
   [db table]
-  (set
-   (jdbc/query db
-               [(format "select id from %s" (name table))]
-               {:row-fn :id})))
+  (into #{}
+        (map :id)
+        (sql/query db
+                   [(format "select id from %s" (name table))])))
 
 (defn -main
   [& [sqlite-db-path pg-host pg-port pg-user pg-password :as args]]

deps.edn

@@ -28,6 +28,7 @@
   com.cognitect.aws/ssm {:mvn/version "847.2.1365.0"}
   com.github.scribejava/scribejava-apis {:mvn/version "8.3.1"}
   com.github.seancorfield/honeysql {:mvn/version "2.4.1078"}
+  com.github.seancorfield/next.jdbc {:mvn/version "1.3.894"}
   com.stuartsierra/component {:mvn/version "0.3.1"}
 
   digest/digest {:mvn/version "1.4.10"}
@@ -50,7 +51,6 @@
   org.apache.maven/maven-model {:mvn/version "3.8.4"}
   org.apache.maven/maven-repository-metadata {:mvn/version "3.8.4"}
   org.clojure/clojure {:mvn/version "1.11.1"}
-  org.clojure/java.jdbc {:mvn/version "0.7.12"}
   org.clojure/tools.logging {:mvn/version "1.2.4"}
   org.clojure/tools.nrepl {:mvn/version "0.2.11"}
   org.postgresql/postgresql {:mvn/version "42.6.0"}