lib/aws/record/model/finder_methods.rb



# Copyright 2011-2013 Amazon.com, Inc. or its affiliates. All Rights Reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License"). You
# may not use this file except in compliance with the License. A copy of
# the License is located at
#
#     http://aws.amazon.com/apache2.0/
#
# or in the "license" file accompanying this file. This file is
# distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
# ANY KIND, either express or implied. See the License for the specific
# language governing permissions and limitations under the License.

module AWS
  module Record
    class Model
      class << self

        # @param [String] id The id of the record to load.
        # @param [Hash] options
        # @option options [String] :shard Specifies what shard (i.e. domain)
        #   should be searched.
        # @raise [RecordNotFound] Raises a record not found exception if there
        #   was no data found for the given id.
        # @return [Record::HashModel] Returns the record with the given id.
        def find_by_id id, options = {}

          domain = sdb_domain(options[:shard] || options[:domain])

          data = domain.items[id].data.attributes

          raise RecordNotFound, "no data found for id: #{id}" if data.empty?

          obj = self.new(:shard => domain)
          obj.send(:hydrate, id, data)
          obj

        end
        alias_method :[], :find_by_id

        # Finds records in SimpleDB and returns them as objects of the
        # current class.
        #
        # Finding `:all` returns an enumerable scope object
        #
        #     People.find(:all, :order => [:age, :desc], :limit => 10).each do |person|
        #       puts person.name
        #     end
        #
        # Finding `:first` returns a single record (or nil)
        #
        #     boss = People.find(:first, :where => { :boss => true })
        #
        # Find accepts a hash of find modifiers (`:where`, `:order` and
        # `:limit`).  You can also choose to omit these modifiers and
        # chain them on the scope object returned.  In the following
        # example only one request is made to SimpleDB (when #each is
        # called)
        #
        #     people = People.find(:all)
        #
        #     johns = people.where(:name => 'John Doe')
        #
        #     johns.order(:age, :desc).limit(10).each do |suspects|
        #       # ...
        #     end
        #
        # See also {where}, {order} and {limit} for more
        # information and options.
        #
        # @overload find(id)
        #   @param id The record to find, raises an exception if the record is
        #     not found.
        #
        # @overload find(mode, options = {})
        #   @param [:all,:first] mode (:all) When finding `:all` matching records
        #     and array is returned of records.  When finding `:first` then
        #     `nil` or a single record will be returned.
        #   @param [Hash] options
        #   @option options [Mixed] :where Conditions that determine what
        #     records are returned.
        #   @option options [String,Array] :sort The order records should be
        #     returned in.
        #   @option options [Integer] :limit The max number of records to fetch.
        def find *args
          new_scope.find(*args)
        end

        # Returns a chainable scope object that restricts further scopes to a
        # particular domain.
        #
        #     Book.domain('books-2').each do |book|
        #       # ...
        #     end
        #
        # @param [String] shard_name
        # @return [Scope] Returns a scope for restricting the domain of subsequent
        def shard shard_name
          new_scope.shard(shard_name)
        end
        alias_method :domain, :shard

        # Returns an enumerable scope object represents all records.
        #
        #     Book.all.each do |book|
        #       # ...
        #     end
        #
        # This method is equivalent to `find(:all)`, and therefore you can also
        # pass aditional options.  See {.find} for more information on what
        # options you can pass.
        #
        #     Book.all(:where => { :author' => 'me' }).each do |my_book|
        #       # ...
        #     end
        #
        # @return [Scope] Returns an enumerable scope object.
        def all options = {}
          new_scope.find(:all, options)
        end

        # Yields once for each record.
        def each &block
          all.each(&block)
        end

        # Counts records in SimpleDB.
        #
        # With no arguments, counts all records:
        #
        #     People.count
        #
        # Accepts query options to count a subset of records:
        #
        #     People.count(:where => { :boss => true })
        #
        # You can also count records on a scope object:
        #
        #     People.find(:all).where(:boss => true).count
        #
        # See {find} and {Scope#count} for more details.
        #
        # @param [Hash] options (<code>{}</code>) Options for counting
        #   records.
        #
        # @option options [Mixed] :where Conditions that determine what
        #   records are counted.
        # @option options [Integer] :limit The max number of records to count.
        def count(options = {})
          new_scope.count(options)
        end
        alias_method :size, :count

        # @return [Object,nil] Returns the first record found.  If there were
        #   no records found, nil is returned.
        def first options = {}
          new_scope.first(options)
        end

        # Limits which records are retried from SimpleDB when performing a find.
        #
        # Simple string condition
        #
        #     Car.where('color = "red" or color = "blue"').each {|car| ... }
        #
        # String with placeholders for quoting params
        #
        #     Car.where('color = ?', 'red')
        #
        #     Car.where('color = ? OR style = ?', 'red', 'compact')
        #
        #     # produces a condition using in, like: WHERE color IN ('red', 'blue')
        #     Car.where('color IN ?', ['red','blue'])
        #
        # Hash arguments
        #
        #     # WHERE age = '40' AND gender = 'male'
        #     People.where(:age => 40, :gender => 'male').each {|person| ... }
        #
        #     # WHERE name IN ('John', 'Jane')
        #     People.where(:name => ['John', 'Jane']).each{|person| ... }
        #
        # Chaining where with other scope modifiers
        #
        #     # 10 most expensive red cars
        #     Car.where(:color => 'red').order(:price, :desc).limit(10)
        #
        # @overload where(conditions_hash)
        #   @param [Hash] conditions_hash A hash of attributes to values.  Each
        #     key/value pair from the hash becomes a find condition.  All
        #     conditions are joined by AND.
        #
        # @overload where(sql_fragment[, quote_params, ...])
        #
        def where *args
          new_scope.where(*args)
        end

        # Defines the order in which records are returned when performing a find.
        # SimpleDB only allows sorting by one attribute per request.
        #
        #     # oldest to youngest
        #     People.order(:age, :desc).each {|person| ... }
        #
        # You can chain order with the other scope modifiers:
        #
        #     Pepole.order(:age, :desc).limit(10).each {|person| ... }
        #
        # @overload order(attribute, direction = :asc)
        #   @param [String,Symbol] attribute The attribute to sort by.
        #   @param [:asc,:desc] direction (:asc) The direction to sort.
        def order *args
          new_scope.order(*args)
        end

        # The maximum number of records to return.  By default, all records
        # matching the where conditions will be returned from a find.
        #
        #     People.limit(10).each {|person| ... }
        #
        # Limit can be chained with other scope modifiers:
        #
        #     People.where(:age => 40).limit(10).each {|person| ... }
        #
        def limit limit
          new_scope.limit(limit)
        end

      end
    end
  end
end