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:
(def datasource
(doto (org.sqlite.SQLiteDataSource.)
(.setUrl "jdbc:sqlite:target/db.sqlite")))
(def storage
(storage-sql/make datasource
{:dbtype :sqlite}))
You can also pass optional options:
(storage-sql/make datasource
{:dbtype :sqlite
:batch-size 1000
: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.