doctrine / mongodb-odm

     * @param array $documents Array of documents to insert

     * @param array $options Array of options to be used with batchInsert()

     */

    private function executeInserts(ClassMetadata $class, array $documents, array $options = array())

    {

        $persister = $this->getDocumentPersister($class->name);

        foreach ($documents as $oid => $document) {

            $persister->addInsert($document);

            unset($this->documentInsertions[$oid]);

        }

        $persister->executeInserts($options);

        $hasPostPersistLifecycleCallbacks = ! empty($class->lifecycleCallbacks[Events::postPersist]);

        $hasPostPersistListeners = $this->evm->hasListeners(Events::postPersist);

        foreach ($documents as $document) {

            if ($hasPostPersistLifecycleCallbacks) {

                $class->invokeLifecycleCallbacks(Events::postPersist, $document);

            }

            if ($hasPostPersistListeners) {

                $this->evm->dispatchEvent(Events::postPersist, new LifecycleEventArgs($document, $this->dm));

            }

            $this->cascadePostPersist($class, $document);

        }

    }

    /**

     * Executes all document upserts for documents of the specified type.

     * @param array $documents Array of documents to upsert

     * @param array $options Array of options to be used with batchInsert()

     */

    private function executeUpserts(ClassMetadata $class, array $documents, array $options = array())

    {

        $persister = $this->getDocumentPersister($class->name);

        foreach ($documents as $oid => $document) {

            $persister->addUpsert($document);

            unset($this->documentUpserts[$oid]);

        }

        $persister->executeUpserts($options);

        $hasLifecycleCallbacks = isset($class->lifecycleCallbacks[Events::postPersist]);

        $hasListeners = $this->evm->hasListeners(Events::postPersist);

        foreach ($documents as $document) {

            if ($hasLifecycleCallbacks) {

                $class->invokeLifecycleCallbacks(Events::postPersist, $document);

            }

            if ($hasListeners) {

                $this->evm->dispatchEvent(Events::postPersist, new LifecycleEventArgs($document, $this->dm));

            }

            $this->cascadePostPersist($class, $document);

        }

    }

    /**

     * Executes all document updates for documents of the specified type.