Làm cách nào để thử lại giao dịch sau khi bế tắc bằng Doctrine?

Question

Tôi đang viết một hàm PHP lưu trữ/cập nhật bộ dữ liệu lớn vào một bảng và có thể gây ra bế tắc. Tôi đã thử điều tra làm thế nào để thử lại một giao dịch thất bại với Doctrine nhưng thật đáng buồn không thể tìm thấy bất kỳ thông tin trực tuyến. Tôi cuối cùng đã viết đoạn mã sau

$retry = 0; 
$done = false; 
while (!$done and $retry < 3) { 
    try { 

     $this->entityManager->flush(); 
     $done = true; 

    } catch (\Exception $e) { 
     sleep(1); 

     $retry++; 
    } 
} 

if ($retry == 3) { 
    throw new Exception(
     "[Exception: MySQL Deadlock] Too many people accessing the server at the same time. Try again in few minutes" 
    ); 
} 

Câu hỏi của tôi: là có một cơ hội tiếp cận này sẽ chèn bản sao trong cơ sở dữ liệu? nếu có, làm cách nào tôi có thể buộc Doctrine quay lại giao dịch?

Answer 1

Một bế tắc trả về lỗi 1213 mà bạn nên xử lý trên các mặt hàng

Lưu ý rằng một bế tắc và chờ đợi khóa là những thứ khác nhau. Trong bế tắc, không có giao dịch "thất bại": cả hai đều có tội. Không có sự đảm bảo nào sẽ được khôi phục.

Bạn phải sử dụng rollback, mã kiểu của bạn sẽ chèn trùng lặp. ví dụ: bạn nên:

$retry = 0; 

$done = false; 


$this->entityManager->getConnection()->beginTransaction(); // suspend auto-commit 

while (!$done and $retry < 3) { 

    try { 

     $this->entityManager->flush(); 

     $this->entityManager->getConnection()->commit(); // commit if succesfull 

     $done = true; 

    } catch (\Exception $e) { 

     $this->entityManager->getConnection()->rollback(); // transaction marked for rollback only 

     $retry++; 

    } 

} 

Hy vọng trợ giúp này.

Answer 2

Nếu bạn không sử dụng ORM thì sử dụng nó sẽ tự động quản lý tình trạng bế tắc.

Answer 3

Đây là cách tôi đối phó với thử lại giao dịch thất bại với Sf2.7 và học thuyết 2.4.7:

use Doctrine\Bundle\DoctrineBundle\Registry; 
use Doctrine\ORM\EntityManager; 

class Foo 
{ 
    /** 
    * @var Registry 
    */ 
    protected $doctrine; 

    public function __construct(Registry $registry) 
    { 
     $this->doctrine = $registry; 
    } 

    protected function doSomething($entity, $attempt) 
    { 
     $em = $this->getEntityManager(); 
     $conn = $em->getConnection(); 
     try{ 
      $conn->beginTransaction(); 
      $entity->setBar("baz"); 
      $em->flush(); 
      $conn->commit(); 
     } catch(\PDOException $e){ 
      $conn->rollBack(); 
      $attempt++; 
      if($attempt <= 3){ 
       $this->doSomething($repayment, $attempt); 
      } 
     } 
    } 

    /** 
    * @return EntityManager 
    */ 
    protected function getEntityManager() 
    { 
     /** @var EntityManager $em */ 
     $em = $this->doctrine->getManager(); 
     if(!$em->isOpen()){ 
      $this->doctrine->resetManager(); 
      $em = $this->doctrine->getManager(); 
     } 

     return $em; 
    } 
}