for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace Dtc\QueueBundle\ODM;
use Doctrine\Common\Persistence\ObjectManager;
use Doctrine\ODM\MongoDB\DocumentManager;
use Dtc\QueueBundle\Document\Job;
use Dtc\QueueBundle\Document\JobTiming;
use Dtc\QueueBundle\Document\Run;
trait CommonTrait
{
/**
* @param string $objectName
* @param string $field
* @param \DateTime $olderThan
*
* @return int
*/
protected function removeOlderThan($objectName, $field, \DateTime $olderThan)
/** @var DocumentManager $objectManager */
$objectManager = $this->getObjectManager();
$qb = $objectManager->createQueryBuilder($objectName);
$qb
->remove()
->field($field)->lt($olderThan);
$query = $qb->getQuery();
$result = $query->execute();
if (isset($result['n'])) {
return $result['n'];
}
return 0;
* @param Run|Job|JobTiming $object
* @param string $action
protected function persist($object, $action = 'persist')
$objectManager->$action($object);
$objectManager->flush();
* @return ObjectManager
abstract public function getObjectManager();
public function stopIdGenerator($objectName)
// Not needed for ODM
public function restoreIdGenerator($objectName)
mmucklo /
DtcQueueBundle
