सिद्धांत का उपयोग करके डेडलॉक के बाद लेनदेन का पुन: प्रयास कैसे करें?

Question

मैं एक PHP फ़ंक्शन लिख रहा हूं जो किसी तालिका में डेटा के बड़े सेट को स्टोर/अपडेट करता है और इससे डेडलॉक हो सकता है। मैंने जांच की कोशिश की कि सिद्धांत के साथ एक असफल लेनदेन कैसे पुनः प्रयास करें लेकिन दुख की बात है कि ऑनलाइन कोई जानकारी नहीं मिल सका। इस बात की संभावना इस दृष्टिकोण डेटाबेस में डुप्लिकेट सम्मिलित जाएगा: मैं अंत में निम्न कोड

$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" 
    ); 
} 

मेरा प्रश्न लिखा? यदि हां, तो मैं लेनदेन को वापस लाने के लिए सिद्धांत को कैसे मजबूर कर सकता हूं?

Answer 1

एक गतिरोध त्रुटि 1213 जो आप क्लाइंट की तरफ संसाधित करना चाहिए

ध्यान दें कि एक गतिरोध और लॉक प्रतीक्षा अलग बातें हैं देता है। डेडलॉक में, कोई "असफल" लेनदेन नहीं होता है: वे दोनों दोषी हैं। कोई गारंटी नहीं है कि एक वापस लुढ़का जाएगा।

आपको rollback का उपयोग करना होगा, आपका स्टाइल कोड डुप्लिकेट डालेगा। उदाहरण के लिए आपको:

$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++; 

    } 

} 

इस सहायता की आशा करें।

Answer 2

यदि आप ओआरएम का उपयोग नहीं कर रहे हैं तो इसका उपयोग करें कि यह स्वचालित रूप से डेडलॉक स्थिति प्रबंधित करेगा।

Answer 3

यह वह जगह है मैं कैसे Sf2.7 साथ पुन: प्रयास करने में विफल रहा है लेनदेन और सिद्धांत 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; 
    } 
}