qbits.alia.result-set — cc.qbits/alia 5.0.0-alpha4

->iterable-async-result-set clj

(->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

->result-set clj

(->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

AliaAsyncResultSetPage clj

async-result-set-page clj

(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

create-row-gen->map-like clj

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

create a row-generator for map-like things

decode-row clj

(decode-row row rg decode)

handle-async-result-set-completion-stage clj

(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

PAsyncResultSet clj protocol

execution-info clj

(execution-info this)

PAsyncResultSetPage clj protocol

fetch-next-page clj

(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>

has-more-pages? clj

(has-more-pages? this)

returns true when there are more pages to fetch

PResultSet clj protocol

execution-infos clj

(execution-infos this)

result-set clj

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

row-decoder-xform clj

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

row-gen->map clj

Row Generator that returns map instances

row-gen->ns-map clj

row-generator creating maps with table-namespaced keys

row-gen->ns-record clj

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

Row Generator that builds record instances with table-namspaced keys

row-gen->record clj

(row-gen->record record-ctor)

Row Generator that builds record instances

row-gen->vector clj

Row Generator that builds vector instances

RowGenerator clj protocol

conj-row clj

(conj-row this r k v)

Adds a entry/col to a row

finalize-row clj

(finalize-row this r)

"completes" the row

init-row clj

(init-row this)

Constructs a row base