Doctrine2 ORM选择更新

Question

请问您能告诉我如何SELECT FOR UPDATE使用Doctrine 实现一些方法吗？

我需要读取一些计数器值,在PHP代码中使用它并在其他人(来自另一个进程)使用相同值之前立即递增该值.

Answer 1

显然,Doctrine 2使用LOCK IN SHARED MODE和MySQL的悲观读锁,这与SELECT FOR UPDATE不同.

看看当前稳定版本的来源,似乎在Doctrine中没有本地方式这样做(我不确定为什么Doctrine团队为MySQL选择了这种类型的锁).

我使用本机SQL作为解决方法,可以映射到传统实体,就像使用DQL一样:

<?php
$rsm = new ResultSetMappingBuilder($this->_em);
$rsm->addRootEntityFromClassMetadata('Model_Record_Delivery', 'u');
$query = $this->_em->createNativeQuery("SELECT * FROM delivery WHERE id = :id FOR UPDATE", $rsm);
$query->setParameter("id", $id);
$result = $query->getOneOrNullResult();

更新

正如本杰明指出的那样,PESSIMISTIC_WRITE正是您所寻找的.

用DQL

<?php
$query = $this->em->createQuery('SELECT e
    FROM Application\Model\Entity\MyEntity e
    WHERE e = :id');

$query->setParameter("id", $id);
$query->setLockMode(\Doctrine\DBAL\LockMode::PESSIMISTIC_WRITE);

没有DQL

<?php
$entity = $em->find('Application\Model\Entity\MyEntity', $id, \Doctrine\DBAL\LockMode::PESSIMISTIC_WRITE);

此外,您必须使用事务中的语句才能使其工作.

Answer 2

锁定支持

Doctrine 2实现了对实体的锁定支持:

<?php
use Doctrine\DBAL\LockMode;
use Doctrine\ORM\OptimisticLockException;

$theEntityId = 1;
$expectedVersion = 184;

try {
    $entity = $em->find('User', $theEntityId, LockMode::OPTIMISTIC, $expectedVersion);

    // do the work

    $em->flush();
} catch(OptimisticLockException $e) {
    echo "Someone else has already changed this entity. Apply the changes again!";
}

原生sql

此外,您可以执行它抛出执行原始SQL:

$em->getConnection()->exec('LOCK TABLES table_name WRITE;'); //lock for write access

然后

$em->getConnection()->exec('UNLOCK TABLES;');