Move database functions to model modules

1 files changed, 43 insertions, 0 deletions

diff --git a/src/model/books.phel b/src/model/books.phel
new file mode 100644
index 0000000..26dbe6f
--- /dev/null
+++ b/src/model/books.phel
@@ -0,0 +1,43 @@
+(ns lezer.model.books
+  (:require lezer.db :refer [conn])
+  (:require phel.pdo)
+  (:require phel.sql)
+  (:require lezer.model.authors))
+
+(defn all []
+  (let [[query _] (sql/format {:select [:*]
+                               :from [:books]})]
+    (pdo/select conn query)))
+
+(defn create [fields]
+  (pdo/insert conn :books fields))
+
+(defn pages [book-id]
+  (let [[query params] (sql/format {:select [:pages]
+                                    :from [:books]
+                                    :where [:= :id book-id]})]
+    (-> (pdo/prepare conn query)
+        (pdo/execute params)
+        (pdo/fetch-column))))
+
+(defn find [id]
+  (let [[query params] (sql/format {:select [:*]
+                                    :from [:books]
+                                    :where [:= :id id]})]
+    (-> (pdo/prepare conn query)
+        (pdo/execute params)
+        (pdo/fetch))))
+
+(defn for-author [author-id]
+  (let [[query params] (sql/format {:select [:*]
+                                    :from [:books]
+                                    :where [:in :id {:select [:book_id]
+                                                     :from [:authors_books]
+                                                     :where [:= :author_id author-id]}]})]
+    (-> (pdo/prepare conn query)
+        (pdo/execute params)
+        (pdo/fetch-all))))
+
+(defn add-author [id fields]
+  (pdo/insert conn :authors_books {:book_id id
+                                   :author_id (authors/find-or-create (:name fields) fields)}))