...
:dependencies [[org.clojure/clojure "1.11.1"]
...
[ai.z7/leveldb-clj "0.0.4"]]
...Liking cljdoc? Tell your friends :D
leveldb-clj
A Clojure tiny and low-level library to handle key-value store at LevelDB for blockchain projects.
Usage
leiningen project.clj
and then
(ns my.application.ns
(:require [leveldb-clj.core :as leveldb]
[leveldb-clj.kv :as kv]
[leveldb-clj.tx :as tx]))
;; regular interface designed for generic kv/* methods
(defonce ^:private store
(leveldb/map->LevelDBStore {:path "mystore.level.db"}))
;; atomic interface designed for transactional tx/* methods
(defonce ^:private atomic-store
(tx/->LevelDB-TX store (atom {})))That is - the store is ready!
Generic interface
test=> (def store (leveldb/map->LevelDBStore {:path "mystore.level.db"}))
test=> (kv/insert store (.getBytes "eee") (.getBytes "fff"))
; #leveldb_clj.core.LevelDBStore{:db #object[org.iq80.leveldb.impl.DbImpl 0x69957a8 "org.iq80.leveldb.impl.DbImpl@69957a8"], :codec nil}
test=> (kv/list-keys store)
; (#object["[B" 0x72b795cf "[B@72b795cf"])
test=> (map #(String. %) (kv/list-keys store))
; ("eee")
test=> (kv/retrieve store (.getBytes "eee"))
; #object["[B" 0x453ad576 "[B@453ad576"]
test=> (String. (kv/retrieve store (.getBytes "eee")))
; "fff"
test=> (kv/delete store (.getBytes "eee"))
; #leveldb_clj.core.LevelDBStore{:db #object[org.iq80.leveldb.impl.DbImpl 0x69957a8 "org.iq80.leveldb.impl.DbImpl@69957a8"], :codec nil}
test=> (map #(String. %) (kv/list-keys store))
; ()
test=> (String. (kv/retrieve store (.getBytes "eee")))
; Execution error (NullPointerException) at java.lang.String/<init> (String.java:1460).
; Cannot invoke "java.lang.StringBuffer.toString()" because "buffer" is nullTransactional interface
test=> (def atomic-store (tx/->LevelDB-TX store (atom {})))
test=> (map #(String. %) (kv/list-keys store))
; ()
test=> (tx/add atomic-store (.getBytes "eee") (.getBytes "fff"))
; #leveldb_clj.tx.LevelDB-TX{:store #leveldb_clj.core.LevelDBStore{:db #object[org.iq80.leveldb.impl.DbImpl 0x69957a8 "org.iq80.leveldb.impl.DbImpl@69957a8"], :codec nil}, :state #object[clojure.lang.Atom 0x3e85d3ce {:status :ready, :val {#object["[B" 0x38381caf "[B@38381caf"] #object["[B" 0x4b1aeb91 "[B@4b1aeb91"]}}]}
test=> (map #(String. %) (kv/list-keys store))
; ()
test=> (tx/commit atomic-store)
; #leveldb_clj.tx.LevelDB-TX{:store #leveldb_clj.core.LevelDBStore{:db #object[org.iq80.leveldb.impl.DbImpl 0x69957a8 "org.iq80.leveldb.impl.DbImpl@69957a8"], :codec nil}, :state #object[clojure.lang.Atom 0x3e85d3ce {:status :ready, :val {}}]}
test=> (map #(String. %) (kv/list-keys store))
; ("eee")
(tx/add atomic-store (.getBytes "eee") (.getBytes "HHH"))
; #leveldb_clj.tx.LevelDB-TX{:store #leveldb_clj.core.LevelDBStore{:db #object[org.iq80.leveldb.impl.DbImpl 0xb2e2921 "org.iq80.leveldb.impl.DbImpl@b2e2921"], :codec nil}, :state #object[clojure.lang.Atom 0x7d995254 {:status :ready, :val {#object["[B" 0x266702a9 "[B@266702a9"] #object["[B" 0x77cfe94e "[B@77cfe94e"]}}]}
test=> (map #(String. %) (kv/list-keys store))
; ("eee")
test=> (String. (kv/retrieve store (.getBytes "eee")))
; "fff"
test=> (tx/rollback atomic-store)
; #leveldb_clj.tx.LevelDB-TX{:store #leveldb_clj.core.LevelDBStore{:db #object[org.iq80.leveldb.impl.DbImpl 0xb2e2921 "org.iq80.leveldb.impl.DbImpl@b2e2921"], :codec nil}, :state #object[clojure.lang.Atom 0x7d995254 {:status :ready, :val {}}]}
test=> (String. (kv/retrieve store (.getBytes "eee")))
; "fff"
test=> (tx/add atomic-store (.getBytes "eee") (.getBytes "HHH"))
; #leveldb_clj.tx.LevelDB-TX{:store #leveldb_clj.core.LevelDBStore{:db #object[org.iq80.leveldb.impl.DbImpl 0xb2e2921 "org.iq80.leveldb.impl.DbImpl@b2e2921"], :codec nil}, :state #object[clojure.lang.Atom 0x7d995254 {:status :ready, :val {#object["[B" 0xe0570d "[B@e0570d"] #object["[B" 0x159a9133 "[B@159a9133"]}}]}
test=> (String. (kv/retrieve store (.getBytes "eee")))
"fff"
test=> (tx/commit atomic-store)
; #leveldb_clj.tx.LevelDB-TX{:store #leveldb_clj.core.LevelDBStore{:db #object[org.iq80.leveldb.impl.DbImpl 0xb2e2921 "org.iq80.leveldb.impl.DbImpl@b2e2921"], :codec nil}, :state #object[clojure.lang.Atom 0x7d995254 {:status :ready, :val {}}]}
test=> (String. (kv/retrieve store (.getBytes "eee")))
; "HHH"License
Distributed under the MIT license.
Can you improve this documentation?Edit on GitHub
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close