mme/ddbmodel


ActiveRecord-like Model for DynamoDB

Language: Elixir


DDBModel

ActiveRecord-like Model for DynamoDB

Environment Variables

  • AWS_DYNAMO_DB_PREFIX - All DynamoDB tablenames will be prefixed with the value of this variable (optional)
  • AWS_ACCESS_KEY_ID - AWS access key
  • AWS_SECRET_ACCESS_KEY - AWS secret key

Usage

defmodule YourModel do

  # specify the DynamoDB key column (default is :hash). 
  use DDBModel :id

  # if you have a table with hash key and range, pass a tuple
  use DDBModel {:id, :timestamp}

  # optionally set a custom table name. default is the model name
  use DDBModel table_name: "your_dynamo_table"

end

Defining Models

defmodule Account do

  use DDBModel 
  # uuid type automatically creates a uuid before saving if needed
  defcolumn :uuid, type: :uuid

  # set default value
  defcolumn :status, default: :A

  # validate in_list
  defcolumn :membership, default: :free, in_list: [:free, :paid]

  # validate not null
  defcolumn :first_name, null: false

  # validate by function
  defcolumn :last_name, validate: &1 != "Doe"
  # or defcolumn :last_name, validate: fn(v) v != "Doe" end

end

Using Models

  # Create an instance with new
  account = Account.new

  # Pass in parameters by keyword
  account = Account.new first_name: "Dale", last_name: "Cooper"

  # Update a single parameter (don't forget to assign to a variable, the update does not happen in place..)
  account = account.membership(:paid)

  # Mass Assignment
  account = account.set membership: :paid, status: :A

  # Whitelisted mass assignment
  # change only membership and status
  fields = [:membership, :status]
  account = account.set [membership: :paid, password: "owned", first_name: "John"], fields

Updating

  # create or update with put!
  {:ok, account} = account.put!

  # pass an array for batch put
  {:ok, accounts} = Account.put! [Account.new, Account.new]

  # ensure that the record is new, i.e. nothing gets overwritten in the DB
  {:ok, account} = Account.new.insert!

  # ensure the record exist
  {:ok, account} = account.membership(:paid).update!

  # delete an existing record
  {:ok, id} = account.delete!

  # delete works with IDs, too
  {:ok, id} = Account.delete! {22,4}

  # batch delete records
  {:ok, ids} = Account.delete [acc1, acc2, acc3]

Querying

  # find by id
  {:ok, account} = account.find("1234")

  # find returns :not_found when the account does not exist
  :not_found = account.find("non-existent")

  # pass a list for batch find
  {:ok, [acc1, acc2]} = account.find ["1234", "1235"]

License

Copyright (c) 2013, Markus Ecker

All rights reserved.

Redistribution and use in source and binary forms, with or without modification, are permitted provided that the following conditions are met:

  • Redistributions of source code must retain the above copyright notice, this list of conditions and the following disclaimer.
  • Redistributions in binary form must reproduce the above copyright notice, this list of conditions and the following disclaimer in the documentation and/or other materials provided with the distribution.

THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

Project Statistics

Sourcerank 2
Repository Size 232 KB
Stars 3
Forks 5
Watchers 2
Open issues 0
Dependencies 0
Contributors 1
Tags 0
Created
Last updated
Last pushed

Top Contributors See all

Markus Ecker

Something wrong with this page? Make a suggestion

Last synced: 2016-06-16 15:54:40 UTC

Login to resync this repository