Liking cljdoc? Tell your friends :D

qbits.alia.result-set


->iterable-async-result-setclj

(->iterable-async-result-set async-result-set decoder-xform)

ISeqable and IReduceInit support for an AsyncResultSet, to be given to the :result-set-fn to create the :current-page object

cf: clojure.lang.Eduction - the returned object is similar, but also permits the retrieval of execution-info

ISeqable and IReduceInit support for an AsyncResultSet, to
be given to the :result-set-fn to create the :current-page object

cf: clojure.lang.Eduction - the returned object is similar, but
also permits the retrieval of execution-info
sourceraw docstring

->result-setclj

(->result-set rs decoder-xform)

ISeqable and IReduceInit support for a ResultSet, to be given to the :result-set-fn for sync query results

cf: clojure.lang.Eduction - the returned object is similar, but also permits the retrieval of execution-infos

ISeqable and IReduceInit support for a ResultSet, to
be given to the :result-set-fn for sync query results

cf: clojure.lang.Eduction - the returned object is similar, but
also permits the retrieval of execution-infos
sourceraw docstring

AliaAsyncResultSetPageclj

source

async-result-set-pageclj

(async-result-set-page ars
                       {result-set-fn :result-set-fn
                        row-generator :row-generator
                        codec :codec
                        :as opts})

make a single AliaAsyncResultSetPage of an execute-async result

if the current-page is the last page and is empty then nil is returned

the records from the current page are in the :current-page field which is constructed from an Iterable/IReduceInit AsyncResultSet wrapper by the :result-set-fn (which defaults to clojure.core/seq)

subsequent pages can be fetched with PAsyncResultSetPage/fetch-next-page, which is defined as a record rather than an opaque type to aid with debugging

make a single `AliaAsyncResultSetPage` of an `execute-async` result

if the current-page is the last page and is empty then `nil` is returned

the records from the current page are in the `:current-page` field
which is constructed from an `Iterable`/`IReduceInit` `AsyncResultSet`
wrapper by the `:result-set-fn` (which defaults to `clojure.core/seq`)

subsequent pages can be fetched with `PAsyncResultSetPage/fetch-next-page`,
which is defined as a record rather than an opaque type to aid with debugging
sourceraw docstring

create-row-gen->map-likeclj

(create-row-gen->map-like {constructor :constructor table-ns? :table-ns?})

create a row-generator for map-like things

create a row-generator for map-like things
sourceraw docstring

decode-rowclj

(decode-row row rg decode)
source

handle-async-result-set-completion-stageclj

(handle-async-result-set-completion-stage
  completion-stage
  {:keys [codec result-set-fn row-generator executor statement values]
   :as opts})

handle a CompletionStage resulting from an .executeAsync of a query

when successful, applies the :row-generator and :result-set-fn to the current page when failed, decorates the exception with query and value details

handle a `CompletionStage` resulting from an `.executeAsync` of a query

when successful, applies the `:row-generator` and `:result-set-fn`
to the current page
when failed, decorates the exception with query and value details
sourceraw docstring

PAsyncResultSetcljprotocol

execution-infoclj

(execution-info this)
source

PAsyncResultSetPagecljprotocol

fetch-next-pageclj

(fetch-next-page this)

returns a CompletedFuture<PAsyncResultSetPage> of the next page, or, if this was the final page, or the next page is empty, returns CompletedFuture<nil>

returns a `CompletedFuture<PAsyncResultSetPage>` of the next
page, or, if `this` was the final page, or the next page
is empty, returns `CompletedFuture<nil>`

has-more-pages?clj

(has-more-pages? this)

returns true when there are more pages to fetch

returns true when there are more pages to fetch
source

PResultSetcljprotocol

execution-infosclj

(execution-infos this)
source

result-setclj

(result-set rs result-set-fn row-generator codec)
source

row-decoder-xformclj

(row-decoder-xform row-generator {decoder :decoder :as codec})
source

row-gen->mapclj

Row Generator that returns map instances

Row Generator that returns map instances
sourceraw docstring

row-gen->ns-mapclj

row-generator creating maps with table-namespaced keys

row-generator creating maps with table-namespaced keys
sourceraw docstring

row-gen->ns-recordclj

(row-gen->ns-record record-ctor)

Row Generator that builds record instances with table-namspaced keys

Row Generator that builds record instances with table-namspaced keys
sourceraw docstring

row-gen->recordclj

(row-gen->record record-ctor)

Row Generator that builds record instances

Row Generator that builds record instances
sourceraw docstring

row-gen->vectorclj

Row Generator that builds vector instances

Row Generator that builds vector instances
sourceraw docstring

RowGeneratorcljprotocol

conj-rowclj

(conj-row this r k v)

Adds a entry/col to a row

Adds a entry/col to a row

finalize-rowclj

(finalize-row this r)

"completes" the row

"completes" the row

init-rowclj

(init-row this)

Constructs a row base

Constructs a row base
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close