Ticket #118: 118.diff

comments.php

@@ -554 +554 @@
     }
 
 
+    /**
+     * static delete_by_status
+     * delete all the comments and associated commentinfo records for comments of the given status
+     * @param mixed a comment status ID or name
+    **/
     public static function delete_by_status( $status )
     {
-        $comments= DB::table( 'comments' );
-        $commentinfo= DB::table( 'commentinfo' );
-        $sql= "
-            DELETE {$comments}.*, {$commentinfo}.* 
-            FROM {$comments} 
-            LEFT JOIN {$commentinfo} ON {$comments}.id = {$commentinfo}.comment_id 
-            WHERE {$comments}.status = ?;
-        ";
-        
-        DB::query( $sql, array( Comment::status( $status ) ) );
+        if ( ! is_int( $status ) ) {
+            $status= Comment::status( $status );
+        }
+
+        $comment_ids= implode( ',', DB::get_column( 'SELECT id FROM {comments} WHERE status=?', array ( $status ) ) );
+        $results= DB::query( 'DELETE FROM {comments} WHERE id IN (?)', array( $comment_ids ) );
+        $results= DB::query( 'DELETE FROM {commentinfo} WHERE comment_id IN (?)', array( $comment_ids ) );
+
     }
 }
 ?>