add email validity function and introduce ::validity-checks

README.org

@@ -166,11 +166,11 @@ Run =docker compose up= to have postgress running
   bb test:watch
 #+end_src
 
-#+begin_src
+#+begin_src shell
   $ bin/koacha
 #+end_src
 
-#+begin_src
+#+begin_src shell
   $ bin/koacha --watch
 #+end_src
 

src/dqt/query_runner.clj

@@ -4,12 +4,16 @@
    [next.jdbc :as jdbc]
    [next.jdbc.result-set :as rs]))
 
+(defn ->sql
+  [q]
+  (honey/format q))
+
 (defn execute!
   "Execute query and builds result set with keys in kebab case"
   ([db query]
    (execute! db query {}))
   ([db query opts]
-   (let [formatted-query (honey/format query)]
+   (let [formatted-query (->sql query)]
      (println formatted-query)
      (jdbc/execute! db formatted-query
                     (assoc opts
@@ -20,7 +24,7 @@
   ([db query]
    (execute-one! db query {}))
   ([db query opts]
-   (let [formatted-query (honey/format query)]
+   (let [formatted-query (->sql query)]
      (println formatted-query)
      (jdbc/execute-one! db formatted-query
                         (assoc opts

src/dqt/system.clj

@@ -18,8 +18,10 @@
                                       :columns-metadata (ig/ref ::columns-metadata-enriched))
    ::calculated-metrics        {:columns     (ig/ref ::columns-metadata-enriched)
                                 :sql-metrics (ig/ref ::sql-metrics)}
+   ::validity-checks           {:columns (ig/ref ::columns-metadata-enriched)}
    ::test-results              {:sql-metrics        (ig/ref ::sql-metrics)
                                 :calculated-metrics (ig/ref ::calculated-metrics)
+                                :validity-checks    (ig/ref ::validity-checks)
                                 :tests              (:tests options)}
    ::report                    (ig/ref ::test-results)})
 
@@ -39,6 +41,11 @@
   [_ {:keys [db table-name columns-metadata]}]
   (m/get-metrics db table-name columns-metadata))
 
+(defmethod ig/init-key ::validity-checks
+  [_ {:keys [columns]}]
+  (println "validity checks")
+  (println columns))
+
 (defmethod ig/init-key ::calculated-metrics
   [_ {:keys [columns sql-metrics]}]
   (into {} (map #(m/calculated-metrics % sql-metrics) columns)))

src/dqt/validity_checks.clj

@@ -0,0 +1,14 @@
+(ns dqt.validity-checks
+  (:require [dqt.query-runner :as q]))
+
+;; select EmailAddress from FindInvalidEmailAddressDemo
+;; -> where EmailAddress NOT LIKE '%_@_%._%';
+
+(def email-regex #"%_@_%._%")
+
+(defn email
+  "Returns list of invalid emails from the column"
+  [column table]
+  {:select [column]
+   :from table
+   :where [column :not :like email-regex]})