Doctrine

Timestamp:

08/08/08 20:33:17 (11 months ago)

Author:

jwage

Message:

Fixing mistakes.

Files:

• branches/1.0/docs/cookbook/en/creating-a-unit-of-work-using-doctrine.txt (modified) (2 diffs)

branches/1.0/docs/cookbook/en/creating-a-unit-of-work-using-doctrine.txt

@@ -84 +84 @@
 {
     // code to check to see if the model exists already
-    if ($this->existsInCollections($model)) {
+    if ($this->_existsInCollections($model)) {
           throw new Exception('model already in another collection for this transaction');
     }
@@ -174 +174 @@
 class UnitOfWork
 {
-  /**
-   * Collection of models to be persisted
-   *
-   * @var array Doctrine_Record
-   */
-  protected $_createOrUpdateCollection = array();
-
-  /**
-   * Collection of models to be persisted
-   *
-   * @var array Doctrine_Record
-   */
-  protected $_deleteCollection = array();
-
-  /**
-   * Add a model object to the create collection
-   *
-   * @param Doctrine_Record $model
-   */
-  public function registerModelForCreateOrUpdate($model)
-  {
-      // code to check to see if the model exists already
-      if ($this->_existsInCollections($model)) {
-          throw new Exception('model already in another collection for this transaction');
-      }
-
-      // no? add it
-      $this->_createOrUpdateCollection[] = $model;
-  }
-
-  /**
-   * Add a model object to the delete collection
-   *
-   * @param Doctrine_Record $model
-   */
-  public function registerModelForDelete($model)
-  {
+    /**
+     * Collection of models to be persisted
+     *
+     * @var array Doctrine_Record
+     */
+    protected $_createOrUpdateCollection = array();
+
+    /**
+     * Collection of models to be persisted
+     *
+     * @var array Doctrine_Record
+     */
+    protected $_deleteCollection = array();
+
+    /**
+     * Add a model object to the create collection
+     *
+     * @param Doctrine_Record $model
+     */
+    public function registerModelForCreateOrUpdate($model)
+    {
         // code to check to see if the model exists already
-        if ($this->existsInCollections($model)) {
+        if ($this->_existsInCollections($model)) {
             throw new Exception('model already in another collection for this transaction');
         }
 
         // no? add it
-        $this->_deleteCollection[] = $model;
-  }
-
-  /**
-   * Clear the Unit of Work
-   */
-  public function ClearAll()
-  {
-      $this->_deleteCollection = array();
-      $this->_createOrUpdateCollection = array();
-  }
-
-  /**
-   * Perform a Commit and clear the Unit Of Work. Throw an Exception if it fails and roll back.
-   */
-  public function commitAll()
-  {
-      $manager = Doctrine_Manager::getInstance();
-      $conn = array_pop($manager->getConnections());
-
-      try {
-          $conn->beginTransaction();
-
-          $this->performCreatesOrUpdates($conn);
-          $this->performDeletes($conn);
-
-          $conn->commit();
-      } catch(Doctrine_Exception $e) {
-          $conn->rollback();
-      }
-
-      $this->ClearAll();
-  }
-
-  private function performCreatesOrUpdates($conn)
-  {
-      foreach ($this->_createOrUpdateCollection as $model) {
-          $model->save($conn);
-      }
-  }
-
-  private function performDeletes($conn)
-  {
-      foreach ($this->_deleteCollection as $model) {
-          $model->delete($conn);
-      }
-  }
-
-  private function existsInCollections($model)
-  {
-     foreach ($this->_createOrUpdateCollection as $m) {
-          if ($model->getOid() == $m->getOid()) {
-              return true;
+        $this->_createOrUpdateCollection[] = $model;
+    }
+
+    /**
+     * Add a model object to the delete collection
+     *
+     * @param Doctrine_Record $model
+     */
+    public function registerModelForDelete($model)
+    {
+          // code to check to see if the model exists already
+          if ($this->_existsInCollections($model)) {
+              throw new Exception('model already in another collection for this transaction');
           }
-     }
-
-     foreach ($this->_deleteCollection as $m) {
-          if ($model->getOid() == $m->getOid()) {
-              return true;
-          }
-     }
-
-     return false;
-  }
+
+          // no? add it
+          $this->_deleteCollection[] = $model;
+    }
+
+    /**
+     * Clear the Unit of Work
+     */
+    public function ClearAll()
+    {
+        $this->_deleteCollection = array();
+        $this->_createOrUpdateCollection = array();
+    }
+
+    /**
+     * Perform a Commit and clear the Unit Of Work. Throw an Exception if it fails and roll back.
+     */
+    public function commitAll()
+    {
+        $manager = Doctrine_Manager::getInstance();
+        $conn = array_pop($manager->getConnections());
+
+        try {
+            $conn->beginTransaction();
+
+            $this->performCreatesOrUpdates($conn);
+            $this->performDeletes($conn);
+
+            $conn->commit();
+        } catch(Doctrine_Exception $e) {
+            $conn->rollback();
+        }
+
+        $this->ClearAll();
+    }
+
+    protected function _performCreatesOrUpdates($conn)
+    {
+        foreach ($this->_createOrUpdateCollection as $model) {
+            $model->save($conn);
+        }
+    }
+
+    protected function _performDeletes($conn)
+    {
+        foreach ($this->_deleteCollection as $model) {
+            $model->delete($conn);
+        }
+    }
+
+    protected function _existsInCollections($model)
+    {
+       foreach ($this->_createOrUpdateCollection as $m) {
+            if ($model->getOid() == $m->getOid()) {
+                return true;
+            }
+       }
+
+       foreach ($this->_deleteCollection as $m) {
+            if ($model->getOid() == $m->getOid()) {
+                return true;
+            }
+       }
+
+       return false;
+    }
 }
 </code>