oc.lib.db.common — open-company/lib 0.16.22

CRUD functions on resources stored in RethinkDB.

add-to-set clj

(add-to-set conn table-name primary-key-value field element)

For the resource specified by the primary key, add the element to the set of elements with the specified field name. Return the updated resource if a change is made, and an exception on DB error.

build-filter-fn clj

(build-filter-fn filter-map)

conn? clj

(conn? conn)

Check if a var is a valid RethinkDB connection map/atom.

create-resource clj

(create-resource conn table-name resource timestamp)

Create a resource in the DB, returning the property map for the resource.

current-timestamp clj

default-timeout clj

delete-all-resources! clj

(delete-all-resources! conn table-name)

Use with caution! Failure can result in partial deletes of just some resources. Returns true if successful.

delete-resource clj

(delete-resource conn table-name primary-key-value)

(delete-resource conn table-name key-name key-value)

Delete the specified resource and return true.

grouped-resources-by-most-common clj

(grouped-resources-by-most-common conn
                                  table-name
                                  index-name
                                  index-value
                                  group-field)

(grouped-resources-by-most-common conn
                                  table-name
                                  index-name
                                  index-value
                                  group-field
                                  limit)

Given a table name, an index name and value, a grouping field, return an sequence of the grouping field, and a count of how many were in the group. Sequence is ordered, most common to least. Optionally specify a limit on how many to return.

Response:

[['😜' 3] ['👌' 2] ['💥' 1]]

iterate-filters clj

(iterate-filters filter-map row)

Given a list of filters, map the list into rethinkdb functions.

months-with-resource clj

(months-with-resource conn table-name index-name index-value date-field)

Given a table name, an index name and value, and an ISO8601 date field, return an ordered sequence of all the months that have at least one resource.

Response:

[['2017' '06'] ['2017' '01'] [2016 '05']]

Sequence is ordered, newest to oldest.

read-resource clj

(read-resource conn table-name primary-key-value)

Given a table name and a primary key value, retrieve the resource from the database, or return nil if it doesn't exist.

read-resources clj

(read-resources conn table-name)

(read-resources conn table-name fields)

(read-resources conn table-name index-name index-value)

(read-resources conn table-name index-name index-value fields)

(read-resources conn table-name index-name index-value fields limit)

Given a table name, and an optional index name and value, an optional set of fields, and an optional limit, retrieve the resources from the database.

read-resources-and-relations clj

(read-resources-and-relations conn
                              table-name
                              index-name
                              index-value
                              relation-name
                              relation-table-name
                              relation-field-name
                              relation-index-name
                              relation-fields
                              {:keys [count] :or {count false}})

(read-resources-and-relations conn
                              table-name
                              index-name
                              index-value
                              order-by
                              order
                              start
                              direction
                              limit
                              relation-name
                              relation-table-name
                              relation-field-name
                              relation-index-name
                              relation-fields
                              {:keys [count] :or {count false}})

(read-resources-and-relations conn
                              table-name
                              index-name
                              index-value
                              order-by
                              order
                              start
                              direction
                              limit
                              filter-map
                              relation-name
                              relation-table-name
                              relation-field-name
                              relation-index-name
                              relation-fields
                              {:keys [count] :or {count false}})

In the first arity (9): Given a table name, an index name and value, and what amounts to a document key, foreign table, foreign key, foreign key index and the fields of the foreign table that are interesting, return all the resources that match the index, and any related resources in the other table in an array in each resource.

E.g.

Table A: foo, bar Table B: blat, a-bar, blu

Here bar and a-bar have the same value, with a-bar acting as a foreign key pointing each B at an A.

(read-resources-and-relations conn 'A' :foo-index '1234' :my-bees 'B' :bar :a-bar-index ['blat', 'blu'])

will return something like:

[ { :foo '1234' :bar 'abcd' :my-bees [{:blat 'ferret' :blu 42} {:blat 'monkey' :blu 7}] } { :foo '1234' :bar 'efgh' :my-bees [{:blat 'mouse' :blu 77} {:blat 'mudskipper' :blu 17}] } ]

The second arity (14) is largely the same functionality as the first, but with more control over the selection and order of the returned resources in the form of:

• an order-by field for the order of the returned resources
• an order, one of either :desc or :asc
• an initial value of the order-by field to start the limited set from
• a direction, one of either :before or :after the start value
• limit, a numeric limit to the number returned

The third arity (15) is largely the same functionality as the second, but with an additonal filter map in the form of:

• a filter-map A sequence of filters used to filter results. example: [{:fn :contains :value ['blah'] :filed :blah} {:fn :eq :value true :field-name}]

TODO: Switch to a query map for index, relationship, filtering, and ordering.

read-resources-by-primary-keys clj

(read-resources-by-primary-keys conn table-name primary-keys)

(read-resources-by-primary-keys conn table-name primary-keys fields)

Given a table name, a sequence of primary keys, and an optional set of fields, retrieve the resources from the database.

read-resources-in-order clj

(read-resources-in-order conn table-name index-name index-value)

(read-resources-in-order conn table-name index-name index-value fields)

Given a table name, an index name and value, and an optional set of fields, retrieve the resources from the database in updated-at property order.

remove-from-set clj

(remove-from-set conn table-name primary-key-value field element)

For the resource specified by the primary key, remove the element to the set of elements with the specified field name. Return the updated resource if a change is made, nil if not, and an exception on DB error.

remove-property clj

(remove-property conn table-name primary-key-value property-name)

(remove-property conn table-name primary-key-value property-name timestamp)

Given a table name, the name of the primary key, and a property to remove, update a resource in the DB, removing the specified property of the resource.

s-or-k? clj

(s-or-k? value)

Truthy if the provided value is a string or a keyword.

timestamp-format clj

unique-id clj

(unique-id)

Return a 12 character fragment from a UUID e.g. 51ab-4c86-a474

update-resource clj

Given a table name, the name of the primary key, an optional original resource (for efficiency if it's already been retrieved) and the updated resource, update the resource in the DB, returning the property map for the updated resource.

updated-at-order clj

(updated-at-order coll)

Return items in a sequence sorted by their :updated-at key. Newest first.

with-timeout clj macro

(with-timeout ms & body)

A basic macro to wrap things in a timeout. Will throw an exception if the operation times out. Note: This is a simplistic approach and piggybacks on core.asyncs executor-pool. Read this discussion for more info: https://gist.github.com/martinklepsch/0caf92b5e42eefa3a894