SQL Storage implementation for DataScript
Add this to deps.edn:
io.github.tonsky/datascript-storage-sql{:mvn/version"2.0.0"}Create storage by passing in javax.sql.DataSource and :dbtype option:
(defdatasource (doto (org.sqlite.SQLiteDataSource.) (.setUrl"jdbc:sqlite:target/db.sqlite"))) (defstorage (storage-sql/make datasource{:dbtype:sqlite}))You can also pass optional options:
(storage-sql/make datasource{:dbtype:sqlite:batch-size1000:table"datascript":ddl"create table if not exists datascript (addr INTEGER primary key, content TEXT)":freeze-str pr-str :thaw-str clojure.edn/read-string})Or use binary serialization:
(storage-sql/make datasource{:dbtype:sqlite:freeze-bytes (fn ^bytes [obj] (with-open [out (ByteArrayOutputStream.)] (t/write (t/writer out :msgpack) obj) (.toByteArray out))) :thaw-bytes (fn [^bytes b] (t/read (t/reader (ByteArrayInputStream. b) :msgpack)))})After that, use it as any other storage:
(d/create-conn schema{:storage storage}) or
(d/store db storage) Currently supported :dbtype-s:
:h2:mysql:postgresql:sqlite
If your JDBC driver only provides you with DataSource and you want to add some basic pooling on top, use storage-sql/pool:
(def datasource (doto (SQLiteDataSource.) (.setUrl "jdbc:sqlite:target/db.sqlite"))) (def pooled-datasource (storage-sql/pool datasource{:max-conn 10 :max-idle-conn 4})) (def storage (storage-sql/make pooled-datasource{:dbtype :sqlite})) pool takes non-pooled DataSource and returns new DataSource that pools connections for you.
If you used pool to create storage, you can close it this way:
(storage-sql/close storage) Copyright © 2023 Nikita Prokopov
Licensed under MIT License.