MySQL Doctrine2 ORM select for update语句

在使用MySQL数据库时，一些特定的场景需要使用select for update语法，用来锁定查询语句返回的行，以便进行操作。在Doctrine2 ORM中，也提供了相应的实现方式。

阅读更多：MySQL 教程

select for update是什么？

在MySQL中，select for update语法是用来锁定查询语句返回的行，以便进行操作。它通常与事务一起使用，以确保多个并发事务不会同时修改同一行数据。

因为在查询语句返回结果之后，对结果进行操作时会开启新事务，所以在操作之前，必须确保查询结果能够被锁定。由于行级锁是针对行级别进行锁定，所以只有在查询时使用了for update语法之后，才能对查询结果进行操作。

Doctrine2 ORM如何实现select for update？

在Doctrine2 ORM中，可以使用以下方式实现select for update：

$em = $this->getEntityManager();
$em->beginTransaction();
try {
    $qb = $em->createQueryBuilder();
    $query = $qb->update('YourBundle:YourEntity', 'e')
        ->set('e.someField', ':someValue')
        ->where('e.id = :id')
        ->setParameter('id', $id)
        ->setParameter('someValue', $newValue)
        ->getQuery();
    $query->setLockMode(\Doctrine\DBAL\LockMode::PESSIMISTIC_WRITE); // 此处指定锁的方式
    $query->execute();
    $em->commit();
} catch (\Exception $e) {
    $em->rollback();
    var_dump($e->getMessage());
}

在QueryBuilder中，可以调用setLockMode()方法，指定使用什么方式进行锁定。Doctrine2 ORM支持乐观锁和悲观锁两种锁定策略。

对于一些一些简单的sql查询,可以使用以下方式实现select for update：

$em = $this->getEntityManager();
$em->getConnection()->beginTransaction();
try {
    $sql = "SELECT * FROM your_table WHERE id = ? FOR UPDATE";
    $stmt = $em->getConnection()->prepare($sql);
    $stmt->bindValue(1, $id);
    $stmt->execute();
    $result = $stmt->fetchAll(\PDO::FETCH_ASSOC);
    // some operations
    $em->getConnection()->commit();
} catch (\Exception $e) {
    $em->getConnection()->rollBack();
}

使用$em->getConnection()获取到原生的PDO实例后，再调用beginTransaction()、prepare()、execute()等PDO原生的操作，即可完成查询锁定操作。

select for update的优缺点

优点

避免并发冲突。在高并发情况下，select for update能够在锁定行的同时，尽可能的保证事务的一致性和完整性，避免出现数据覆盖和重复提交等问题。
数据库事务处理及时。因为使用select for update会加锁，这样来保证数据库操作的一致性，在处理SQL语句的同时，可以及时的控制事务的提交和回滚。
减少系统资源的占用。当有大量并发访问一个表时，受限于硬件资源或软件性能，这样就容易出现堆积的问题。而使用select for update保证一定程度的分散并发的请求及其相应的处理，减少了系统资源的占用和处理负担数。

缺点

select for update是一种基于数据库锁的实现方案，在使用中，需要开发者考虑到可能出现死锁的情况。
select for update的执行时间较长，可能会影响系统的吞吐量以及性能表现。
开发者需要精确控制锁的粒度，如果锁的粒度过大或过小，可能会影响并发性能。

如何避免select for update的缺点？

避免select for update的缺点，需要开发者在实际使用中精细掌控。

避免死锁的发生。在一个事务中，最好避免对相同的资源使用不同的加锁顺序，避免出现死锁的情况。如果出现了死锁，需要释放占用的锁资源，才能继续执行。
避免过度使用select for update。如果在应用程序中过度增加select for update的使用，就会导致链路性能的下降。在实际应用中，尽可能减少select for update的调用次数，避免过度占用数据库资源，并使用索引优化查询性能。
使用优化方案及锁定技术。尽可能使用合理的方案和优化技术来减少select for update产生的影响。例如，对热点数据使用缓存，增强MySQL的IO等待能力，减少请求锁冲突的几率等。