datascript-persistent

gistfile1.txt

(defn crete-persistent-conn
  [schema]
  (letfn [(read-file [source]
            (with-open [r (PushbackReader. (jio/reader source))]
              (edn/read
                {:readers {'datascript/DB (fn [{:keys [datoms schema]}]
                                            (db/init-db (mapv #(apply db/datom %) datoms) schema))}}
                r)))
          (write-file [filepath data]
            (with-open [w (jio/writer filepath)]
              (.write ^BufferedWriter w (pr-str data))))]
    (with-meta (duratom/duratom
                 :local-file
                 :file-path "./db"
                 :rw {:read read-file
                      :write write-file}
                 :init @(d/create-conn schema)) {:listeners (atom {})})))