Skip to content

Commit

Permalink
read configuration from config.edn file in root directory
Browse files Browse the repository at this point in the history
  • Loading branch information
AlexWheeler committed Nov 17, 2016
1 parent e0bcf22 commit 4453489
Show file tree
Hide file tree
Showing 3 changed files with 25 additions and 26 deletions.
34 changes: 19 additions & 15 deletions config.edn
Original file line number Diff line number Diff line change
@@ -1,16 +1,20 @@
{:sftp
{
:username ""
:password ""
:host ""
}
:db
{
:user ""
:password ""
:address ""
:port "1433"
:name ""
:tables []
}
{
:sftp {
:username ""
:password ""
:host ""
}
:db {
:username ""
:password ""
:address "localhost"
:port "1433"
:name ""
:tables [
""
""
""
""
]
}
}
13 changes: 4 additions & 9 deletions src/airlift/core.clj
Original file line number Diff line number Diff line change
Expand Up @@ -4,17 +4,12 @@
[airlift.channel :as ch]
[airlift.csv :as csv]))

(defn export-tables
[]
(let [config (read-string (slurp "config.edn"))]
(println config)))

(def creds {:host "" :username "" :password ""})
(def config (clojure.edn/read-string (slurp "config.edn")))

(defn -main [& args]
(let [conn (db/init "" "" "")
chan (ch/channel creds)]
(doseq [table []]
(let [conn (db/init (select-keys (:db config) [:name :username :password]))
chan (ch/channel (:sftp config))]
(doseq [table (get-in config [:db :tables])]
(let [data [] res (db/query conn (str "SELECT * FROM " table))]
(let [headers (->> (first res)
(keys)
Expand Down
4 changes: 2 additions & 2 deletions src/airlift/db.clj
Original file line number Diff line number Diff line change
Expand Up @@ -19,9 +19,9 @@
(defn- connect [db dbname config]
(.connect db (str "jdbc:sqlserver://127.0.0.1:1433;databaseName=" dbname) config))

(defn init [dbname username password]
(defn init [{:keys [name username password]}]
"Returns new database connection"
(connect driver dbname (config username password)))
(connect driver name (config username password)))

(defn query [conn query]
"Executes query on db connection and returns ResultSet"
Expand Down

0 comments on commit 4453489

Please sign in to comment.