deblan/FOSElasticaBundle
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Bulk upsert

Browse source
This commit is contained in:
Evan Owens 2014-04-04 15:51:55 -04:00 committed by nurikabe
parent 49284a4963
commit 6f444f1ce8
1 changed files with 2 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
Persister/ObjectPersister.php
View file

@ -99,7 +99,7 @@ class ObjectPersister implements ObjectPersisterInterface
}
/**
* Bulk updates an array of objects in the type
* Bulk update an array of objects in the type. Create document if it does not already exist.
*
* @param array $objects array of domain model objects
*/
@ -108,13 +108,7 @@ class ObjectPersister implements ObjectPersisterInterface
$documents = array();
foreach ($objects as $object) {
$document = $this->transformToElasticaDocument($object);
try {
$this->type->getDocument($document->getId());
} catch (NotFoundException $e) {
$this->type->addDocument($document);
}
$document->setDocAsUpsert(true);
$documents[] = $document;
}
$this->type->updateDocuments($documents);