fixup!

doctrine · Sep 14, 2023 · e4a7610 · e4a7610
1 parent 89f1572
commit e4a7610
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 11 deletions.
diff --git a/src/Id/TableGenerator.php b/src/Id/TableGenerator.php
@@ -6,8 +6,6 @@
 use Doctrine\DBAL\Driver;
 use Doctrine\DBAL\DriverManager;
 use Doctrine\DBAL\Exception;
-use Doctrine\DBAL\LockMode;
-use Doctrine\DBAL\Platforms\SQLServerPlatform;
 use Doctrine\Deprecations\Deprecation;
 use Throwable;
 
@@ -116,12 +114,13 @@ public function nextValue($sequence)
         $this->conn->beginTransaction();
 
         try {
-            $platform = $this->conn->getDatabasePlatform();
-            $sql      = 'SELECT sequence_value, sequence_increment_by'
-                . ' FROM ' . $platform->appendLockHint($this->generatorTableName, LockMode::PESSIMISTIC_WRITE)
-                . ' WHERE sequence_name = ? '
-                . ($platform instanceof SQLServerPlatform ? '' : $platform->getWriteLockSQL());
-            $row      = $this->conn->fetchAssociative($sql, [$sequence]);
+            $qb  = $this->conn->createQueryBuilder();
+            $sql = $qb->select('t.sequence_value', 't.sequence_increment_by')
+                ->from($this->generatorTableName, 't')
+                ->where('t.sequence_name = ?')
+                ->lockForUpdate()
+                ->getSQL();
+            $row = $this->conn->fetchAssociative($sql, [$sequence]);
 
             if ($row !== false) {
                 $row = array_change_key_case($row, CASE_LOWER);

diff --git a/src/Query/QueryLockBuilder.php b/src/Query/QueryLockBuilder.php
@@ -13,9 +13,7 @@
 use function rtrim;
 use function trim;
 
-/**
- * @internal
- */
+/** @internal */
 final class QueryLockBuilder
 {
     public const FOR_UPDATE = 'FOR_UPDATE';