Sha256: 2e4c27300f246fc80b2e6eb64aa4f6df9077e55df3f3b7dd656da82100110246

Contents?: true

Size: 1.93 KB

Versions: 1

Compression:

Stored size: 1.93 KB

Contents

# encoding: utf-8
module Mongoid #:nodoc:
  module Persistence #:nodoc:
    # Insert is a persistence command responsible for taking a document that
    # has not been saved to the database and saving it.
    #
    # The underlying query resembles the following MongoDB query:
    #
    #   collection.insert(
    #     { "_id" : 1, "field" : "value" },
    #     false
    #   );
    class Insert
      include Persistence::Command

      # Create the new insert persister.
      #
      # Options:
      #
      # document: The +Document+ to persist.
      # validate: +Boolean+ to validate or not.
      #
      # Example:
      #
      # <tt>Insert.new(document)</tt>
      def initialize(document, validate = true)
        init(document, validate)
        @options = { :safe => Mongoid.persist_in_safe_mode }
      end

      # Insert the new document in the database. This delegates to the standard
      # MongoDB collection's insert command.
      #
      # Example:
      #
      # <tt>Insert.persist</tt>
      #
      # Returns:
      #
      # The +Document+, whether the insert succeeded or not.
      def persist
        return @document if validate && !@document.valid?
        @document.run_callbacks(:create, :save) do
          @document.new_record = false if insert
          @document
        end
      end

      protected
      # Insert the document into the database.
      def insert
        if @document.embedded
          insert_embedded
        else
          collection.insert(@document.raw_attributes, options)
        end
      end

      # Logic for determining how to insert the embedded doc.
      def insert_embedded
        parent = @document._parent
        if parent.new_record?
          @document.notify_observers(document, true); parent.insert
        else
          update = { @document.path => { "$push" => @document.raw_attributes } }
          collection.update(parent.selector, update, @options)
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
mongoid-pre-2.0.0.beta1 lib/mongoid/persistence/insert.rb