sturdy.sqlite.ops — com.sturdystats/sturdy-sqlite 0.0.10

close-batch-writer! clj

(close-batch-writer! {:keys [req-ch worker-ch]})

err-busy clj

err-code clj

(err-code e)

Returns the full (extended) SQLite error code by bypassing standard JDBC and accessing the native SQLite driver result code.

err-constraint clj

err-constraint-datatype clj

err-constraint-foreignkey clj

err-constraint-notnull clj

err-constraint-primarykey clj

err-constraint-trigger clj

err-constraint-unique clj

err-locked clj

execute-batched! clj

(execute-batched! batch-sys sql-vec & [opts])

Pushes a standard JDBC sql-vec to the batch writer and blocks for the result. Acts as a drop-in replacement for (jdbc/execute! ds ["..."] opts).

execute-batched-async! clj

(execute-batched-async! batch-sys sql-vec & [opts])

Enqueues a write without waiting for SQL execution or commit. Blocks to apply backpressure if the bounded writer queue is full.

ImmediateTransactable clj protocol

-transact-immediate clj

(-transact-immediate this opts f)

primary-err-code clj

(primary-err-code e)

Masks the extended bits to return only the primary SQLite error category. Safe to use on both standard SQLExceptions and extended SQLiteExceptions.

retry-sqlite clj

(retry-sqlite f
              &
              {:keys [retries base-delay-ms]
               :or {retries 3 base-delay-ms 1000}})

Retries (f) up to retries times on ANY flavor of SQLITE_BUSY (5) or SQLITE_LOCKED (6). Uses randomized jitter for the delay to prevent thundering herd collisions.

start-batch-writer! clj

(start-batch-writer! ds max-batch-size max-wait-ms global-builder-opts)

(start-batch-writer! ds
                     max-batch-size
                     max-wait-ms
                     global-builder-opts
                     async-error-fn)

Starts a background thread that pulls from req-ch and executes in time/size bounded batches. Returns a map with the input channel (:req-ch) and the thread completion channel (:worker-ch).

validate-batch-options! clj

(validate-batch-options! max-batch-size max-wait-ms)

Throws if the batch writer's size or wait options are invalid.

with-immediate-transaction clj macro

(with-immediate-transaction bindings & body)