wcfsetup/install/files/lib/data/DatabaseObjectEditor.class.php

   1 <?php
   2 namespace wcf\data;
   3 use wcf\system\WCF;
   4
   5 /**
   6  * Basic implementation for object editors following the decorator pattern.
   7  *
   8  * @author      Marcel Werk
   9  * @copyright   2001-2012 WoltLab GmbH
  10  * @license     GNU Lesser General Public License <http://opensource.org/licenses/lgpl-license.php>
  11  * @package     com.woltlab.wcf
  12  * @subpackage  data
  13  * @category    Community Framework
  14  */
  15 abstract class DatabaseObjectEditor extends DatabaseObjectDecorator implements IEditableObject {
  16         /**
  17          * @see wcf\data\IEditableObject::create()
  18          */
  19         public static function create(array $parameters = array()) {
  20                 $keys = $values = '';
  21                 $statementParameters = array();
  22                 foreach ($parameters as $key => $value) {
  23                         if (!empty($keys)) {
  24                                 $keys .= ',';
  25                                 $values .= ',';
  26                         }
  27
  28                         $keys .= $key;
  29                         $values .= '?';
  30                         $statementParameters[] = $value;
  31                 }
  32
  33                 // save object
  34                 $sql = "INSERT INTO     ".static::getDatabaseTableName()."
  35                                         (".$keys.")
  36                         VALUES          (".$values.")";
  37                 $statement = WCF::getDB()->prepareStatement($sql);
  38                 $statement->execute($statementParameters);
  39
  40                 // return new object
  41                 if (static::getDatabaseTableIndexIsIdentity()) {
  42                         $id = WCF::getDB()->getInsertID(static::getDatabaseTableName(), static::getDatabaseTableIndexName());
  43                 }
  44                 else {
  45                         $id = $parameters[static::getDatabaseTableIndexName()];
  46                 }
  47                 return new static::$baseClass($id);
  48         }
  49
  50         /**
  51          * @see wcf\data\IEditableObject::update()
  52          */
  53         public function update(array $parameters = array()) {
  54                 if (empty($parameters)) return;
  55
  56                 $updateSQL = '';
  57                 $statementParameters = array();
  58                 foreach ($parameters as $key => $value) {
  59                         if (!empty($updateSQL)) $updateSQL .= ', ';
  60                         $updateSQL .= $key . ' = ?';
  61                         $statementParameters[] = $value;
  62                 }
  63                 $statementParameters[] = $this->getObjectID();
  64
  65                 $sql = "UPDATE  ".static::getDatabaseTableName()."
  66                         SET     ".$updateSQL."
  67                         WHERE   ".static::getDatabaseTableIndexName()." = ?";
  68                 $statement = WCF::getDB()->prepareStatement($sql);
  69                 $statement->execute($statementParameters);
  70         }
  71
  72         /**
  73          * @see wcf\data\IEditableObject::updateCounters()
  74          */
  75         public function updateCounters(array $counters = array()) {
  76                 if (empty($counters)) return;
  77
  78                 $updateSQL = '';
  79                 $statementParameters = array();
  80                 foreach ($counters as $key => $value) {
  81                         if (!empty($updateSQL)) $updateSQL .= ', ';
  82                         $updateSQL .= $key . ' = ' . $key . ' + ?';
  83                         $statementParameters[] = $value;
  84                 }
  85                 $statementParameters[] = $this->getObjectID();
  86
  87                 $sql = "UPDATE  ".static::getDatabaseTableName()."
  88                         SET     ".$updateSQL."
  89                         WHERE   ".static::getDatabaseTableIndexName()." = ?";
  90                 $statement = WCF::getDB()->prepareStatement($sql);
  91                 $statement->execute($statementParameters);
  92         }
  93
  94         /**
  95          * @see wcf\data\IEditableObject::delete()
  96          */
  97         public function delete() {
  98                 static::deleteAll(array($this->getObjectID()));
  99         }
 100
 101         /**
 102          * @see wcf\data\IEditableObject::deleteAll()
 103          */
 104         public static function deleteAll(array $objectIDs = array()) {
 105                 $sql = "DELETE FROM     ".static::getDatabaseTableName()."
 106                         WHERE           ".static::getDatabaseTableIndexName()." = ?";
 107                 $statement = WCF::getDB()->prepareStatement($sql);
 108
 109                 $affectedCount = 0;
 110                 WCF::getDB()->beginTransaction();
 111                 foreach ($objectIDs as $objectID) {
 112                         $statement->executeUnbuffered(array($objectID));
 113                         $affectedCount += $statement->getAffectedRows();
 114                 }
 115                 WCF::getDB()->commitTransaction();
 116
 117                 return $affectedCount;
 118         }
 119 }