FileMaster

Edit File: TableGenerator.php

<?php
declare (strict_types=1);
namespace MailPoetVendor\Doctrine\ORM\Id;
if (!defined('ABSPATH')) exit;
use MailPoetVendor\Doctrine\ORM\EntityManagerInterface;
class TableGenerator extends AbstractIdGenerator
{
 private $tableName;
 private $sequenceName;
 private $allocationSize;
 private $nextValue;
 private $maxValue;
 public function __construct($tableName, $sequenceName = 'default', $allocationSize = 10)
 {
 $this->tableName = $tableName;
 $this->sequenceName = $sequenceName;
 $this->allocationSize = $allocationSize;
 }
 public function generateId(EntityManagerInterface $em, $entity)
 {
 if ($this->maxValue === null || $this->nextValue === $this->maxValue) {
 // Allocate new values
 $conn = $em->getConnection();
 if ($conn->getTransactionNestingLevel() === 0) {
 // use select for update
 $sql = $conn->getDatabasePlatform()->getTableHiLoCurrentValSql($this->tableName, $this->sequenceName);
 $currentLevel = $conn->fetchOne($sql);
 if ($currentLevel !== null) {
 $this->nextValue = $currentLevel;
 $this->maxValue = $this->nextValue + $this->allocationSize;
 $updateSql = $conn->getDatabasePlatform()->getTableHiLoUpdateNextValSql($this->tableName, $this->sequenceName, $this->allocationSize);
 if ($conn->executeStatement($updateSql, [1 => $currentLevel, 2 => $currentLevel + 1]) !== 1) {
 // no affected rows, concurrency issue, throw exception
 }
 } else {
 // no current level returned, TableGenerator seems to be broken, throw exception
 }
 } else {
 // only table locks help here, implement this or throw exception?
 // or do we want to work with table locks exclusively?
 }
 }
 return $this->nextValue++;
 }
}

Back