collet.actions.jdbc — io.velio/collet-actions 0.2.7

->batch-result clj

(->batch-result batch-size prefix-table?)

->rows-seq clj

(->rows-seq xs mapper cleanup)

Convert a sequence of JSON strings to a lazy sequence of maps. The cleanup function is called when the sequence is exhausted.

append-row-to-file clj

(append-row-to-file writer row)

Append a row to a file as a JSON string.

convert-values clj

(convert-values types row)

Convert the values in a row to the appropriate types.

execute-params-spec clj

execute-statement clj

(execute-statement {:keys [connection statement options prefix-table? timeout]
                    :or {options {} prefix-table? true}})

Execute a query and return the result set as a sequence of maps.

expand-datasets clj

(expand-datasets query-map)

get-columns-types clj

(get-columns-types row prefix-table?)

Returns a map of column names and their SQL types.

make-query clj

(make-query {:keys [connection query options prefix-table? preserve-types?
                    timeout concurrency result-type cursors fetch-size]
             :or {options {}
                  prefix-table? true
                  preserve-types? false
                  fetch-size 5000
                  concurrency :read-only
                  cursors :close
                  result-type :forward-only}})

Execute a query and write the results to a temporary file. Return a lazy sequence of maps representing the rows in the result set. The query can be a HoneySQL query or a plain SQL string (wrapped in the vector).

PRecordHandler clj protocol

append clj

(append this record)

flush-batch clj

(flush-batch this batch)

prep-connection clj

(prep-connection connection)

Prepare a connection for use in a query.

query-params-spec clj

record->map clj

(record->map record)