Merge pull request #47 from Gravatronics/fixedUserGroupAction
[GitHub/WoltLab/WCF.git] / 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-2011 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 (!count($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->__get(static::getDatabaseTableIndexName());
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::delete()
74 */
75 public function delete() {
76 static::deleteAll(array($this->__get(static::getDatabaseTableIndexName())));
77 }
78
79 /**
80 * @see wcf\data\IEditableObject::deleteAll()
81 */
82 public static function deleteAll(array $objectIDs = array()) {
83 $sql = "DELETE FROM ".static::getDatabaseTableName()."
84 WHERE ".static::getDatabaseTableIndexName()." = ?";
85 $statement = WCF::getDB()->prepareStatement($sql);
86 foreach ($objectIDs as $objectID) {
87 $statement->execute(array($objectID));
88 }
89
90 return count($objectIDs);
91 }
92 }