Zend_Db_Adapter :: beginTransaction() 스택이 있습니까?

Question

다음을 고려하십시오.

/** (Cas_Template_Tree::DeleteNode) 
* Deletes the given node from the tree, and all of it's children. 
* 
* @static 
* @throws Exception 
* @param Cas_Template_Node $node 
* @return void 
*/ 
public static function DeleteNode(Cas_Template_Node $node) 
{ 
    $table = new Cas_Table_Templates(); 
    $adapter = $table->getAdapter(); 
    $leftStr = $adapter->quoteIdentifier('Left'); 
    $rightStr = $adapter->quoteIdentifier('Right'); 
    try 
    { 
     $adapter->beginTransaction(); 
     $row = $table->find($node->GetId())->current(); 
     $dependantRowSelector = array(
      "$leftStr >= ?" => $row->Left, 
      "$rightStr <= ?" => $row->Right 
     ); 
     //Get the rows removed so that we can nuke the ACLs later. 
     $rowsToDelete = $table->fetchAll($dependantRowSelector)->toArray(); 
     //Delete the rows. 
     $table->delete($dependantRowSelector); 
     //Delete access control lists on those rows. 
     foreach ($rowsToDelete as $rowToDelete) 
     { 
      Cas_Acl::CreateExisting($rowToDelete['Acl'])->Delete(); 
     } 
     $left = (int)$row->Left; 
     $right = (int)$row->Right; 
     $difference = $right - $left + 1; 
     $table->update(array('Left' => new Zend_Db_Expr("$leftStr - $difference")), 
         array("$leftStr > ?" => $right)); 
     $table->update(array('Right' => new Zend_Db_Expr("$rightStr - $difference")), 
         array("$rightStr > ?" => $right)); 
     $adapter->commit(); 
    } 
    catch (Exception $ex) 
    { 
     $adapter->rollBack(); 
     throw $ex; 
    } 
} 

/** (Cas_Acl::Delete) 
* Removes this ACL (and all of its dependent access control entries) from the database. 
* @return void 
*/ 
public function Delete() 
{ 
    $aclTable = new Cas_Table_AccessControlLists(); 
    $aceTable = new Cas_Table_AccessControlEntries(); 
    $adapter = Zend_Db_Table_Abstract::getDefaultAdapter(); 
    $identifierName = $adapter->quoteIdentifier('Identifier'); 
    $aclName = $adapter->quoteIdentifier('Acl'); 
    try 
    { 
     $adapter->beginTransaction(); 
     $aceTable->delete(array("$aclName = ?" => $this->GetId())); 
     $aclTable->delete(array("$identifierName = ?" => $this->GetId())); 
    } 
    catch (Exception $ex) 
    { 
     $adapter->rollBack(); 
     throw $ex; 
    } 
} 

그렇지 않으면 조작이 어둡지 않을 수 있기 때.에 둘 다 트랜잭션 작동이 필요합니다. 원래 DeleteNode 메소드는 Cas_Acl::Delete()를 호출합니다. Cas_Acl::Delete() 역시 트랜잭션 블록 내부에서 자체 실행을 시도합니다. 이상적으로, Zend_Db는이 경우를 인식 할만큼 똑똑 할 것이며,이 특정 호출에 대해 Cas_Acl::Delete 내부에서 begin transaction 및 commit/rollback 호출을 무시하십시오.

위의 코드가 안전할까요? 어떤 방식 으로든 크게 개선 될 수 있습니까?

Answer 1

을 : 할 당신이 수도

것은 트랜잭션을 사용 여부 및 DeleteNode()에 false PARAM으로 호출할지 여부를 결정합니다 Delete() 방법으로 두 번째 PARAM를 추가입니다 이 로직을 추가하십시오 (아직 시작되지 않은 경우 트랜잭션 시작).

이 유형의 객체 (위임?)가 매우 유용합니다. 나는 또한 올바른 액세스와 특정 DB 연결을 사용하는 데 사용합니다. 트랜잭션 내의 모든 쓰기 및 읽기 쿼리는이 TransactionManager 객체를 사용합니다.

roolback에 대한 호출은 컨트롤러에서 수행되지만 TransactionManager를 통해서도 수행됩니다. 실제로 수행해야하는지 여부를 감지합니다. 롤백을 두 번 호출하면 기존 데이터베이스의 대부분이 울려지기 때문에 매우 유용합니다.

마지막으로 일반 규칙 을 사용하여 트랜잭션 제어 코드를 코드에서 (컨트롤러에만 있음)에서 매우 "상위 수준"으로 설정하고 더 추상적 인 하위 수준 개체에서는 사용하지 않도록 설정합니다. 따라서 일반적으로 대부분의 객체에 대해 Delete -() 액션을 호출 할 수 있습니다.이 객체가 트랜잭션을 처리하지 않고 WE를 수행해야한다는 것을 알고 있습니다. 그러나 효과적으로, 이것은 일반적인 규칙 일 뿐이며 때로는 트랜잭션을 포함하고 TransactionManagers는 문제를 숨기고 (그리고 stacktrace를 사용하여 트랜잭션을 기록 할 수 있습니다) 도움이됩니다.

Answer 2

AFAIK Zend_Db은 중첩 트랜잭션을 인식 할 수 없습니다. 코드를보세요.

public function beginTransaction() 
{ 
    $this->_connect(); 
    $q = $this->_profiler->queryStart('begin', Zend_Db_Profiler::TRANSACTION); 
    $this->_beginTransaction(); 
    $this->_profiler->queryEnd($q); 
    return $this; 
} 

어떤 코드가 다른 트랜잭션을 인식 여기에 없다 (하지만 어쩌면 프로파일 러는 같은 일을하는 데 사용될 수)와 _beginTransaction는 PDO의 beginTransaction에 의존한다. 내가 정의 의 transactionManager 객체를 사용

//RB called as Cas_Acl::CreateExisting($rowToDelete['Acl'])->Delete(false); 
public function Delete($useTransaction = true) 
{ 
    $aclTable = new Cas_Table_AccessControlLists(); 
    $aceTable = new Cas_Table_AccessControlEntries(); 
    $adapter = Zend_Db_Table_Abstract::getDefaultAdapter(); 
    $identifierName = $adapter->quoteIdentifier('Identifier'); 
    $aclName = $adapter->quoteIdentifier('Acl'); 
    try 
    { 
     if ($useTransaction === true) { 
      $adapter->beginTransaction(); 
     } 
     $aceTable->delete(array("$aclName = ?" => $this->GetId())); 
     $aclTable->delete(array("$identifierName = ?" => $this->GetId())); 
     //BTW isn't commit() should be called here? 
    } 
    catch (Exception $ex) 
    { 
     if ($useTransaction === true) { 
      $adapter->rollBack(); 
     } 
     throw $ex; 
    } 
}