Changeset 197 for trunk/trax/vendor/trax/active_record.php

Timestamp:

04/18/06 11:43:51 (6 years ago)

Author:

john

Message:

added to AR

Files:

• trunk/trax/vendor/trax/active_record.php (modified) (6 diffs)

trunk/trax/vendor/trax/active_record.php

@@ -167 +167 @@
      */
     protected $save_associations = array();
+    
     /**
      *  @todo Document this property
@@ -303 +304 @@
      */
     public $auto_save_habtm = true; # auto insert / update $has_and_belongs_to_many tables
+
+    /**
+     *  @todo Document this API
+     */    
+    public $auto_delete_habtm = true; # auto delete $has_and_belongs_to_many associations
 
     /**
@@ -527 +533 @@
         $other_foreign_key = Inflector::singularize($other_table_name)."_id";
         # Set up the SQL segments
-        $conditions = "{$join_table}.{$this_foreign_key}={$this->id}";
+        $conditions = "{$join_table}.{$this_foreign_key}=".intval($this->id);
         $orderings = null;
         $limit = null;
@@ -1425 +1431 @@
                     $foreign_key = Inflector::singularize($this->table_name)."_id";
                     $object->$foreign_key = $this->id; 
-                    //echo "fk:$foreign_key = $this->id<br>";
+                    echo "fk:$foreign_key = $this->id<br>";
                     break;
             }
@@ -1452 +1458 @@
         $this->before_delete();
         $result = $this->delete_all("id IN ($id)");
+        if($this->auto_delete_habtm) {
+            if(is_string($this->has_and_belongs_to_many)) {
+                $habtms = explode(",", $this->has_and_belongs_to_many);
+                foreach($habtms as $other_table_name) {
+                    $this->delete_all_habtm_records(trim($other_table_name), $id);                             
+                }
+            } elseif(is_array($this->has_and_belongs_to_many)) {
+                foreach($this->has_and_belongs_to_many as $other_table_name => $values) {
+                    $this->delete_all_habtm_records($other_table_name, $id);                             
+                }
+            } 
+        }
         $this->after_delete();
 
@@ -1570 +1588 @@
             reset($this->habtm_attributes);
             foreach($this->habtm_attributes as $other_table_name => $values) {
-                $table_name = $this->get_join_table_name($this->table_name,$other_table_name);
-                $this_foreign_key = Inflector::singularize($this->table_name)."_id";
-                $sql = "DELETE FROM $table_name WHERE $this_foreign_key = $this_foreign_value";
-                //echo "delete_habtm_records: SQL: $sql<br>";
-                $result = $this->query($sql);
-                if($this->is_error($result)) {
-                    $this->raise($result->getMessage());
-                }
+                $this->delete_all_habtm_records($other_table_name, $this_foreign_value);
             }
         }
         return true;
+    }
+    
+    private function delete_all_habtm_records($other_table_name, $this_foreign_value) {
+        if($other_table_name && $this_foreign_value > 0) {
+            $habtm_table_name = $this->get_join_table_name($this->table_name,$other_table_name);
+            $this_foreign_key = Inflector::singularize($this->table_name)."_id";
+            $sql = "DELETE FROM $habtm_table_name WHERE $this_foreign_key = $this_foreign_value";
+            //echo "delete_all_habtm_records: SQL: $sql<br>";
+            $result = $this->query($sql);
+            if($this->is_error($result)) {
+                $this->raise($result->getMessage());
+            }            
+        }
     }