DAOUpdatesTrait::updateGroup() - Code Metrics - phpMv/ubiquity - Measure and Improve Code Quality continuously with Scrutinizer

DAOUpdatesTrait::updateGroup() B
last analyzed 2023-05-30 15:31 UTC

↳ Parent: DAOUpdatesTrait

Complexity

Conditions	7
Paths	30

Size

Total Lines	36
Code Lines	29

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	56

Importance

Changes	1
Bugs	0	Features	1

Metric	Value
eloc	29
dl	0
loc	36
ccs	0
cts	29
cp	0
rs	8.5226
c	1
b	0
f	1
cc	7
nc	30
nop	2
crap	56

<?php

namespace Ubiquity\orm\traits;

use Ubiquity\controllers\Startup;
use Ubiquity\db\SqlUtils;
use Ubiquity\events\DAOEvents;
use Ubiquity\events\EventsManager;
use Ubiquity\log\Logger;
use Ubiquity\orm\OrmUtils;
use Ubiquity\orm\parser\ManyToManyParser;
use Ubiquity\orm\parser\Reflexion;

/**
 * Trait for DAO Updates (Create, Update, Delete)
 * Ubiquity\orm\traits$DAOUpdatesTrait
 * This class is part of Ubiquity
 *
 * @author jcheron <[email protected]>
 * @version 1.1.8
 * @property \Ubiquity\db\Database $db
 *
 */
trait DAOUpdatesTrait {

	/**
	 * Deletes the object $instance from the database
	 *
	 * @param object $instance instance à supprimer
	 */
	public static function remove($instance): ?int {
		self::deleteAllChildren($instance);
		$className = \get_class($instance);
		$tableName = OrmUtils::getTableName($className);
		$keyAndValues = OrmUtils::getKeyFieldsAndValues($instance);
		return self::removeByKey_($className, $tableName, $keyAndValues);
	}

	/**
	 *
	 * @param string $className
	 * @param string $tableName
	 * @param array $keyAndValues
	 * @return int the number of rows that were modified or deleted by the SQL statement you issued
	 */
	private static function removeByKey_($className, $tableName, $keyAndValues): ?int {
		$db = self::getDb($className);
		$sql = 'DELETE FROM ' . $db->quote . $tableName . $db->quote . ' WHERE ' . SqlUtils::getWhere($keyAndValues);
		Logger::info('DAOUpdates', $sql, 'delete');
		$statement = $db->prepareStatement($sql);
		try {
			if ($statement->execute($keyAndValues)) {
				return $statement->rowCount();
			}
		} catch (\PDOException $e) {
			Logger::warn('DAOUpdates', $e->getMessage(), 'delete');
			return null;
		}
		return 0;
	}

	/**
	 *
	 * @param \Ubiquity\db\Database $db
	 * @param string $className
	 * @param string $tableName
	 * @param string $where
	 * @param array $params
	 * @return boolean|int the number of rows that were modified or deleted by the SQL statement you issued
	 */
	private static function remove_($db, $tableName, $where, $params) {
		$sql = 'DELETE FROM ' . $tableName . ' ' . SqlUtils::checkWhere($where);
		Logger::info('DAOUpdates', $sql, 'delete');
		$statement = $db->prepareStatement($sql);
		try {
			if ($statement->execute($params)) {
				return $statement->rowCount();
			}
		} catch (\PDOException $e) {
			Logger::warn('DAOUpdates', $e->getMessage(), 'delete');
			return false;
		}
	}

	/**
	 * Deletes all instances from $modelName matching the condition $where.
	 *
	 * @param string $modelName
	 * @param string $where
	 * @param array $params
	 * @return int|boolean
	 */
	public static function deleteAll($modelName, $where, $params = []) {
		$db = self::getDb($modelName);
		$quote = $db->quote;
		$tableName = OrmUtils::getTableName($modelName);
		return self::remove_($db, $quote . $tableName . $quote, $where, $params);
	}

	protected static function deleteManyToManyChildren(object $instance, string $memberName) {
		$modelName = \get_class($instance);
		$db = self::getDb($modelName);
		$manyParser = new ManyToManyParser($db, $instance, $memberName);
		$manyParser->init();
		$pkv = OrmUtils::getFirstKeyValue($instance);
		$quote = $db->quote;
		$tableName = $manyParser->getJoinTable();
		$fkManyField = $manyParser->getMyFkField();
		return self::remove_($db, $quote . $tableName . $quote, "$fkManyField= ?", [$pkv]);
	}

	protected static function deleteOneToManyChildren(object $instance, string $memberName) {
		$getter = 'get' . \ucfirst($memberName);
		$instances = $instance->{$getter}();
		foreach ($instances as $o) {
			self::remove($o);
		}
	}


	public static function deleteAllChildren(object $instance) {
		$classname = \get_class($instance);
		$oneToManyMembers = OrmUtils::getRemoveCascadeFields($classname);
		$i = 0;
		$count = \count($oneToManyMembers);
		while ($i < $count) {
			self::deleteOneToManyChildren($instance, $oneToManyMembers[$i]);
			$i++;
		}

		$manyToManyMembers = OrmUtils::getRemoveCascadeFields($classname, '#manyToMany');
		$j = 0;
		$count = \count($manyToManyMembers);
		while ($j < $count) {
			self::deleteManyToManyChildren($instance, $manyToManyMembers[$j]);
			$j++;
		}
		return $i + $j;
	}

	/**
	 * Mass update for $modelName matching the condition $where, with an associative array of $values.
	 *
	 * @param string $modelName
	 * @param array $values
	 * @param string $condition
	 * @param array $params
	 */
	public static function updateAll(string $modelName, array $values, string $condition, array $params) {
		$db = self::getDb($modelName);
		$quote = $db->quote;
		$tableName = OrmUtils::getTableName($modelName);

		$allParams = \array_merge($values, $params);

		$sql = "UPDATE {$quote}{$tableName}{$quote} SET " . SqlUtils::getUpdateFieldsKeyAndParams($values) . SqlUtils::checkWhereParams($condition, $params);
		if (Logger::isActive()) {
			Logger::info("DAOUpdates", $sql, "updateAll");
			Logger::info("DAOUpdates", \json_encode($allParams), "All params");
		}
		$statement = $db->getUpdateStatement($sql);
		try {
			return $statement->execute($allParams);
		} catch (\Exception $e) {
			Logger::warn("DAOUpdates", $e->getMessage(), "updateAll");
		}
		return false;
	}

	/**
	 * Deletes all instances from $modelName corresponding to $ids
	 *
	 * @param string $modelName
	 * @param array|int $ids
	 * @return int|boolean
	 */
	public static function delete($modelName, $ids) {
		$tableName = OrmUtils::getTableName($modelName);
		$db = self::getDb($modelName);
		$pk = OrmUtils::getFirstKey($modelName);
		if (!\is_array($ids)) {
			$ids = [$ids];
		}
		$quote = $db->quote;
		$count = \count($ids);
		$r = $quote . $pk . $quote . "= ?";
		return self::remove_($db, $quote . $tableName . $quote, \str_repeat("$r OR", $count - 1) . $r, $ids);
	}

	public static function deleteById($modelName, $id) {
		$tableName = OrmUtils::getTableName($modelName);
		if (!\is_array($id)) {
			$id = [OrmUtils::getFirstKey($modelName) => $id];
		}
		return self::removeByKey_($modelName, $tableName, $id);
	}

	/**
	 * Inserts a new instance $instance into the database
	 *
	 * @param object $instance the instance to insert
	 * @param boolean $insertMany if true, save instances related to $instance by a ManyToMany association
	 */
	public static function insert($instance, $insertMany = false) {
		EventsManager::trigger('dao.before.insert', $instance);
		$className = \get_class($instance);
		$db = self::getDb($className);
		$quote = $db->quote;
		$tableName = OrmUtils::getTableName($className);
		$keyAndValues = Reflexion::getPropertiesAndValues($instance);
		$keyAndValues = \array_merge($keyAndValues, OrmUtils::getManyToOneMembersAndValues($instance));
		$pk = OrmUtils::getFirstKey($className);
		$pkVal = $keyAndValues [$pk] ?? null;
		if (($pkVal) == null) {
			unset ($keyAndValues [$pk]);
		}
		$sql = "INSERT INTO {$quote}{$tableName}{$quote} (" . SqlUtils::getInsertFields($keyAndValues) . ') VALUES(' . SqlUtils::getInsertFieldsValues($keyAndValues) . ')';
		if (Logger::isActive()) {
			Logger::info('DAOUpdates', $sql, 'insert');
			Logger::info('DAOUpdates', \json_encode($keyAndValues), 'Key and values');
		}

		$statement = $db->getUpdateStatement($sql);
		try {
			$result = $statement->execute($keyAndValues);
			if ($result) {
				if ($pkVal == null) {
					$lastId = $db->lastInserId("{$tableName}_{$pk}_seq");
					if ($lastId != 0) {
						$propKey = OrmUtils::getFirstPropKey($className);
						$propKey->setValue($instance, $lastId);
						$pkVal = $lastId;
					}
				}
				$instance->_rest = $keyAndValues;
				$instance->_rest [$pk] = $pkVal;

				if ($insertMany) {
					self::insertOrUpdateAllManyToMany($instance);
				}
			}
			EventsManager::trigger(DAOEvents::AFTER_INSERT, $instance, $result);
			return $result;
		} catch (\Exception $e) {
			Logger::warn('DAOUpdates', $e->getMessage(), 'insert');
			if (Startup::$config ['debug']) {
				throw $e;
			}
		}
		return false;
	}

	/**
	 * Updates manyToMany members
	 *
	 * @param object $instance
	 */
	public static function insertOrUpdateAllManyToMany($instance) {
		$members = OrmUtils::getAnnotationInfo(get_class($instance), '#manyToMany');
		if ($members !== false) {
			$members = \array_keys($members);
			foreach ($members as $member) {
				self::insertOrUpdateManyToMany($instance, $member);
			}
		}
	}

	/**
	 * Updates the $member member of $instance annotated by a ManyToMany
	 *
	 * @param Object $instance
	 * @param String $member
	 */
	public static function insertOrUpdateManyToMany($instance, $member) {
		$db = self::getDb(\get_class($instance));
		$parser = new ManyToManyParser ($db, $instance, $member);
		if ($parser->init()) {
			$quote = $db->quote;
			$myField = $parser->getMyFkField();
			$field = $parser->getFkField();
			$sql = "INSERT INTO {$quote}" . $parser->getJoinTable() . "{$quote}({$quote}" . $myField . "{$quote},{$quote}" . $field . "{$quote}) VALUES (:" . $myField . ",:" . $field . ");";
			$memberAccessor = 'get' . \ucfirst($member);
			$memberValues = $instance->$memberAccessor ();
			$myKey = $parser->getMyPk();
			$myAccessorId = 'get' . \ucfirst($myKey);
			$accessorId = 'get' . \ucfirst($parser->getPk());
			$id = $instance->$myAccessorId ();
			if (!\is_null($memberValues)) {
				$db->execute("DELETE FROM {$quote}" . $parser->getJoinTable() . "{$quote} WHERE {$quote}{$myField}{$quote}='{$id}'");
				$statement = $db->prepareStatement($sql);
				foreach ($memberValues as $targetInstance) {
					$foreignId = $targetInstance->$accessorId ();
					$foreignInstances = self::getAll($parser->getTargetEntity(), $quote . $parser->getPk() . $quote . "='{$foreignId}'");
					if (!OrmUtils::exists($targetInstance, $parser->getPk(), $foreignInstances)) {
						self::insert($targetInstance, false);
						$foreignId = $targetInstance->$accessorId ();
						Logger::info('DAOUpdates', "Insertion d'une instance de " . get_class($instance), 'InsertMany');
					}
					$db->bindValueFromStatement($statement, $myField, $id);
					$db->bindValueFromStatement($statement, $field, $foreignId);
					$statement->execute();
					Logger::info('DAOUpdates', "Insertion des valeurs dans la table association '" . $parser->getJoinTable() . "'", 'InsertMany');
				}
			}
		}
	}

	/**
	 * Updates an existing $instance in the database.
	 * Be careful not to modify the primary key
	 *
	 * @param object $instance instance to modify
	 * @param boolean $updateMany Adds or updates ManyToMany members
	 */
	public static function update($instance, $updateMany = false) {
		EventsManager::trigger('dao.before.update', $instance);
		$className = \get_class($instance);
		$db = self::getDb($className);
		$quote = $db->quote;
		$tableName = OrmUtils::getTableName($className);
		$ColumnskeyAndValues = \array_merge(Reflexion::getPropertiesAndValues($instance), OrmUtils::getManyToOneMembersAndValues($instance));
		$keyFieldsAndValues = $instance->_pkv ?? OrmUtils::getKeyFieldsAndValues($instance, '___');
		$allParameterValues = $ColumnskeyAndValues + $keyFieldsAndValues;
		$sql = "UPDATE {$quote}{$tableName}{$quote} SET " . SqlUtils::getUpdateFieldsKeyAndParams($ColumnskeyAndValues) . ' WHERE ' . SqlUtils::getWherePK($keyFieldsAndValues);
		if (Logger::isActive()) {
			Logger::info("DAOUpdates", $sql, "update");
			Logger::info("DAOUpdates", \json_encode($allParameterValues), "Key and values");
		}
		$statement = $db->getUpdateStatement($sql);
		try {
			$result = $statement->execute($allParameterValues);
			if ($updateMany && $result) {
				self::insertOrUpdateAllManyToMany($instance);
			}
			EventsManager::trigger(DAOEvents::AFTER_UPDATE, $instance, $result);
			$instance->_rest = \array_merge($instance->_rest, $ColumnskeyAndValues);
			return $result;
		} catch (\Exception $e) {
			Logger::warn("DAOUpdates", $e->getMessage(), "update");
		}
		return false;
	}

	/**
	 * Updates an array of $instances in the database.
	 * Be careful not to modify the primary key
	 *
	 * @param array $instances instances to modify
	 * @param boolean $updateMany Adds or updates ManyToMany members
	 * @return boolean
	 */
	public static function updateGroup($instances, $updateMany = false) {
		if (\count($instances) > 0) {
			$instance = \current($instances);
			$className = \get_class($instance);
			$db = self::getDb($className);
			$quote = $db->quote;
			$tableName = OrmUtils::getTableName($className);
			$ColumnskeyAndValues = \array_merge(Reflexion::getPropertiesAndValues($instance), OrmUtils::getManyToOneMembersAndValues($instance));
			$keyFieldsAndValues = OrmUtils::getKeyFieldsAndValues($instance);
			$sql = "UPDATE {$quote}{$tableName}{$quote} SET " . SqlUtils::getUpdateFieldsKeyAndParams($ColumnskeyAndValues) . ' WHERE ' . SqlUtils::getWhere($keyFieldsAndValues);

			$statement = $db->getUpdateStatement($sql);
			try {
				$db->beginTransaction();
				foreach ($instances as $instance) {
					EventsManager::trigger('dao.before.update', $instance);
					$ColumnskeyAndValues = \array_merge(Reflexion::getPropertiesAndValues($instance), OrmUtils::getManyToOneMembersAndValues($instance));
					$result = $statement->execute($ColumnskeyAndValues);
					if ($updateMany && $result) {
						self::insertOrUpdateAllManyToMany($instance);
					}
					EventsManager::trigger(DAOEvents::AFTER_UPDATE, $instance, $result);
					$instance->_rest = \array_merge($instance->_rest, $ColumnskeyAndValues);
					if (Logger::isActive()) {
						Logger::info("DAOUpdates", $sql, "update");
						Logger::info("DAOUpdates", json_encode($ColumnskeyAndValues), "Key and values");
					}
				}
				$db->commit();
				return true;
			} catch (\Exception $e) {
				Logger::warn("DAOUpdates", $e->getMessage(), "update");
				$db->rollBack();
			}
		}
		return false;
	}

	/**
	 *
	 * @param object $instance
	 * @param boolean $updateMany
	 * @return boolean|int
	 */
	public static function save($instance, $updateMany = false) {
		if (isset ($instance->_rest)) {
			return self::update($instance, $updateMany);
		}
		return self::insert($instance, $updateMany);
	}
}


1		<?php
2
3		namespace Ubiquity\orm\traits;
4
5		use Ubiquity\controllers\Startup;
6		use Ubiquity\db\SqlUtils;
7		use Ubiquity\events\DAOEvents;
8		use Ubiquity\events\EventsManager;
9		use Ubiquity\log\Logger;
10		use Ubiquity\orm\OrmUtils;
11		use Ubiquity\orm\parser\ManyToManyParser;
12		use Ubiquity\orm\parser\Reflexion;
13
14		/**
15		* Trait for DAO Updates (Create, Update, Delete)
16		* Ubiquity\orm\traits$DAOUpdatesTrait
17		* This class is part of Ubiquity
18		*
19		* @author jcheron <[email protected]>
20		* @version 1.1.8
21		* @property \Ubiquity\db\Database $db
22		*
23		*/
24		trait DAOUpdatesTrait {
25
26		/**
27		* Deletes the object $instance from the database
28		*
29		* @param object $instance instance à supprimer
30		*/
31	13	public static function remove($instance): ?int {
32	13	self::deleteAllChildren($instance);
33	13	$className = \get_class($instance);
34	13	$tableName = OrmUtils::getTableName($className);
35	13	$keyAndValues = OrmUtils::getKeyFieldsAndValues($instance);
36	13	return self::removeByKey_($className, $tableName, $keyAndValues);
37		}
38
39		/**
40		*
41		* @param string $className
42		* @param string $tableName
43		* @param array $keyAndValues
44		* @return int the number of rows that were modified or deleted by the SQL statement you issued
45		*/
46	13	private static function removeByKey_($className, $tableName, $keyAndValues): ?int {
47	13	$db = self::getDb($className);
48	13	$sql = 'DELETE FROM ' . $db->quote . $tableName . $db->quote . ' WHERE ' . SqlUtils::getWhere($keyAndValues);
49	13	Logger::info('DAOUpdates', $sql, 'delete');
50	13	$statement = $db->prepareStatement($sql);
51		try {
52	13	if ($statement->execute($keyAndValues)) {
53	12	return $statement->rowCount();
54		}
55	1	} catch (\PDOException $e) {
56	1	Logger::warn('DAOUpdates', $e->getMessage(), 'delete');
57	1	return null;
58		}
59		return 0;
60		}
61
62		/**
63		*
64		* @param \Ubiquity\db\Database $db
65		* @param string $className
66		* @param string $tableName
67		* @param string $where
68		* @param array $params
69		* @return boolean\|int the number of rows that were modified or deleted by the SQL statement you issued
70		*/
71		private static function remove_($db, $tableName, $where, $params) {
72		$sql = 'DELETE FROM ' . $tableName . ' ' . SqlUtils::checkWhere($where);
73		Logger::info('DAOUpdates', $sql, 'delete');
74		$statement = $db->prepareStatement($sql);
75		try {
76		if ($statement->execute($params)) {
77		return $statement->rowCount();
78		}
79		} catch (\PDOException $e) {
80		Logger::warn('DAOUpdates', $e->getMessage(), 'delete');
81		return false;
82		}
83		}
84
85		/**
86		* Deletes all instances from $modelName matching the condition $where.
87		*
88		* @param string $modelName
89		* @param string $where
90		* @param array $params
91		* @return int\|boolean
92		*/
93		public static function deleteAll($modelName, $where, $params = []) {
94		$db = self::getDb($modelName);
95		$quote = $db->quote;
96		$tableName = OrmUtils::getTableName($modelName);
97		return self::remove_($db, $quote . $tableName . $quote, $where, $params);
98		}
99
100		protected static function deleteManyToManyChildren(object $instance, string $memberName) {
101		$modelName = \get_class($instance);
102		$db = self::getDb($modelName);
103		$manyParser = new ManyToManyParser($db, $instance, $memberName);
104		$manyParser->init();
105		$pkv = OrmUtils::getFirstKeyValue($instance);
106		$quote = $db->quote;
107		$tableName = $manyParser->getJoinTable();
108		$fkManyField = $manyParser->getMyFkField();
109		return self::remove_($db, $quote . $tableName . $quote, "$fkManyField= ?", [$pkv]);
110		}
111
112		protected static function deleteOneToManyChildren(object $instance, string $memberName) {
113		$getter = 'get' . \ucfirst($memberName);
114		$instances = $instance->{$getter}();
115		foreach ($instances as $o) {
116		self::remove($o);
117		}
118		}
119
120
121	13	public static function deleteAllChildren(object $instance) {
122	13	$classname = \get_class($instance);
123	13	$oneToManyMembers = OrmUtils::getRemoveCascadeFields($classname);
124	13	$i = 0;
125	13	$count = \count($oneToManyMembers);
126	13	while ($i < $count) {
127		self::deleteOneToManyChildren($instance, $oneToManyMembers[$i]);
128		$i++;
129		}
130
131	13	$manyToManyMembers = OrmUtils::getRemoveCascadeFields($classname, '#manyToMany');
132	13	$j = 0;
133	13	$count = \count($manyToManyMembers);
134	13	while ($j < $count) {
135		self::deleteManyToManyChildren($instance, $manyToManyMembers[$j]);
136		$j++;
137		}
138	13	return $i + $j;
139		}
140
141		/**
142		* Mass update for $modelName matching the condition $where, with an associative array of $values.
143		*
144		* @param string $modelName
145		* @param array $values
146		* @param string $condition
147		* @param array $params
148		*/
149		public static function updateAll(string $modelName, array $values, string $condition, array $params) {
150		$db = self::getDb($modelName);
151		$quote = $db->quote;
152		$tableName = OrmUtils::getTableName($modelName);
153
154		$allParams = \array_merge($values, $params);
155
156		$sql = "UPDATE {$quote}{$tableName}{$quote} SET " . SqlUtils::getUpdateFieldsKeyAndParams($values) . SqlUtils::checkWhereParams($condition, $params);
157		if (Logger::isActive()) {
158		Logger::info("DAOUpdates", $sql, "updateAll");
159		Logger::info("DAOUpdates", \json_encode($allParams), "All params");
160		}
161		$statement = $db->getUpdateStatement($sql);
162		try {
163		return $statement->execute($allParams);
164		} catch (\Exception $e) {
165		Logger::warn("DAOUpdates", $e->getMessage(), "updateAll");
166		}
167		return false;
168		}
169
170		/**
171		* Deletes all instances from $modelName corresponding to $ids
172		*
173		* @param string $modelName
174		* @param array\|int $ids
175		* @return int\|boolean
176		*/
177		public static function delete($modelName, $ids) {
178		$tableName = OrmUtils::getTableName($modelName);
179		$db = self::getDb($modelName);
180		$pk = OrmUtils::getFirstKey($modelName);
181		if (!\is_array($ids)) {
182		$ids = [$ids];
183		}
184		$quote = $db->quote;
185		$count = \count($ids);
186		$r = $quote . $pk . $quote . "= ?";
187		return self::remove_($db, $quote . $tableName . $quote, \str_repeat("$r OR", $count - 1) . $r, $ids);
188		}
189
190		public static function deleteById($modelName, $id) {
191		$tableName = OrmUtils::getTableName($modelName);
192		if (!\is_array($id)) {
193		$id = [OrmUtils::getFirstKey($modelName) => $id];
194		}
195		return self::removeByKey_($modelName, $tableName, $id);
196		}
197
198		/**
199		* Inserts a new instance $instance into the database
200		*
201		* @param object $instance the instance to insert
202		* @param boolean $insertMany if true, save instances related to $instance by a ManyToMany association
203		*/
204	20	public static function insert($instance, $insertMany = false) {
205	20	EventsManager::trigger('dao.before.insert', $instance);
206	20	$className = \get_class($instance);
207	20	$db = self::getDb($className);
208	20	$quote = $db->quote;
209	20	$tableName = OrmUtils::getTableName($className);
210	20	$keyAndValues = Reflexion::getPropertiesAndValues($instance);
211	20	$keyAndValues = \array_merge($keyAndValues, OrmUtils::getManyToOneMembersAndValues($instance));
212	20	$pk = OrmUtils::getFirstKey($className);
213	20	$pkVal = $keyAndValues [$pk] ?? null;
214	20	if (($pkVal) == null) {
215	20	unset ($keyAndValues [$pk]);
216		}
217	20	$sql = "INSERT INTO {$quote}{$tableName}{$quote} (" . SqlUtils::getInsertFields($keyAndValues) . ') VALUES(' . SqlUtils::getInsertFieldsValues($keyAndValues) . ')';
218	20	if (Logger::isActive()) {
219	20	Logger::info('DAOUpdates', $sql, 'insert');
220	20	Logger::info('DAOUpdates', \json_encode($keyAndValues), 'Key and values');
221		}
222
223	20	$statement = $db->getUpdateStatement($sql);
224		try {
225	20	$result = $statement->execute($keyAndValues);
226	20	if ($result) {
227	20	if ($pkVal == null) {
228	20	$lastId = $db->lastInserId("{$tableName}_{$pk}_seq");
229	20	if ($lastId != 0) {
230	20	$propKey = OrmUtils::getFirstPropKey($className);
231	20	$propKey->setValue($instance, $lastId);
232	20	$pkVal = $lastId;
233		}
234		}
235	20	$instance->_rest = $keyAndValues;
236	20	$instance->_rest [$pk] = $pkVal;
237
238	20	if ($insertMany) {
239	1	self::insertOrUpdateAllManyToMany($instance);
240		}
241		}
242	20	EventsManager::trigger(DAOEvents::AFTER_INSERT, $instance, $result);
243	20	return $result;
244	1	} catch (\Exception $e) {
245	1	Logger::warn('DAOUpdates', $e->getMessage(), 'insert');
246	1	if (Startup::$config ['debug']) {
247	1	throw $e;
248		}
249		}
250		return false;
251		}
252
253		/**
254		* Updates manyToMany members
255		*
256		* @param object $instance
257		*/
258	1	public static function insertOrUpdateAllManyToMany($instance) {
259	1	$members = OrmUtils::getAnnotationInfo(get_class($instance), '#manyToMany');
260	1	if ($members !== false) {
261		$members = \array_keys($members);
262		foreach ($members as $member) {
263		self::insertOrUpdateManyToMany($instance, $member);
264		}
265		}
266		}
267
268		/**
269		* Updates the $member member of $instance annotated by a ManyToMany
270		*
271		* @param Object $instance
272		* @param String $member
273		*/
274		public static function insertOrUpdateManyToMany($instance, $member) {
275		$db = self::getDb(\get_class($instance));
276		$parser = new ManyToManyParser ($db, $instance, $member);
277		if ($parser->init()) {
278		$quote = $db->quote;
279		$myField = $parser->getMyFkField();
280		$field = $parser->getFkField();
281		$sql = "INSERT INTO {$quote}" . $parser->getJoinTable() . "{$quote}({$quote}" . $myField . "{$quote},{$quote}" . $field . "{$quote}) VALUES (:" . $myField . ",:" . $field . ");";
282		$memberAccessor = 'get' . \ucfirst($member);
283		$memberValues = $instance->$memberAccessor ();
284		$myKey = $parser->getMyPk();
285		$myAccessorId = 'get' . \ucfirst($myKey);
286		$accessorId = 'get' . \ucfirst($parser->getPk());
287		$id = $instance->$myAccessorId ();
288		if (!\is_null($memberValues)) {
289		$db->execute("DELETE FROM {$quote}" . $parser->getJoinTable() . "{$quote} WHERE {$quote}{$myField}{$quote}='{$id}'");
290		$statement = $db->prepareStatement($sql);
291		foreach ($memberValues as $targetInstance) {
292		$foreignId = $targetInstance->$accessorId ();
293		$foreignInstances = self::getAll($parser->getTargetEntity(), $quote . $parser->getPk() . $quote . "='{$foreignId}'");
294		if (!OrmUtils::exists($targetInstance, $parser->getPk(), $foreignInstances)) {
295		self::insert($targetInstance, false);
296		$foreignId = $targetInstance->$accessorId ();
297		Logger::info('DAOUpdates', "Insertion d'une instance de " . get_class($instance), 'InsertMany');
298		}
299		$db->bindValueFromStatement($statement, $myField, $id);
300		$db->bindValueFromStatement($statement, $field, $foreignId);
301		$statement->execute();
302		Logger::info('DAOUpdates', "Insertion des valeurs dans la table association '" . $parser->getJoinTable() . "'", 'InsertMany');
303		}
304		}
305		}
306		}
307
308		/**
309		* Updates an existing $instance in the database.
310		* Be careful not to modify the primary key
311		*
312		* @param object $instance instance to modify
313		* @param boolean $updateMany Adds or updates ManyToMany members
314		*/
315	3	public static function update($instance, $updateMany = false) {
316	3	EventsManager::trigger('dao.before.update', $instance);
317	3	$className = \get_class($instance);
318	3	$db = self::getDb($className);
319	3	$quote = $db->quote;
320	3	$tableName = OrmUtils::getTableName($className);
321	3	$ColumnskeyAndValues = \array_merge(Reflexion::getPropertiesAndValues($instance), OrmUtils::getManyToOneMembersAndValues($instance));
322	3	$keyFieldsAndValues = $instance->_pkv ?? OrmUtils::getKeyFieldsAndValues($instance, '___');
323	3	$allParameterValues = $ColumnskeyAndValues + $keyFieldsAndValues;
324	3	$sql = "UPDATE {$quote}{$tableName}{$quote} SET " . SqlUtils::getUpdateFieldsKeyAndParams($ColumnskeyAndValues) . ' WHERE ' . SqlUtils::getWherePK($keyFieldsAndValues);
325	3	if (Logger::isActive()) {
326	3	Logger::info("DAOUpdates", $sql, "update");
327	3	Logger::info("DAOUpdates", \json_encode($allParameterValues), "Key and values");
328		}
329	3	$statement = $db->getUpdateStatement($sql);
330		try {
331	3	$result = $statement->execute($allParameterValues);
332	3	if ($updateMany && $result) {
333	1	self::insertOrUpdateAllManyToMany($instance);
334		}
335	3	EventsManager::trigger(DAOEvents::AFTER_UPDATE, $instance, $result);
336	3	$instance->_rest = \array_merge($instance->_rest, $ColumnskeyAndValues);
337	3	return $result;
338		} catch (\Exception $e) {
339		Logger::warn("DAOUpdates", $e->getMessage(), "update");
340		}
341		return false;
342		}
343
344		/**
345		* Updates an array of $instances in the database.
346		* Be careful not to modify the primary key
347		*
348		* @param array $instances instances to modify
349		* @param boolean $updateMany Adds or updates ManyToMany members
350		* @return boolean
351		*/
352		public static function updateGroup($instances, $updateMany = false) {
353		if (\count($instances) > 0) {
354		$instance = \current($instances);
355		$className = \get_class($instance);
356		$db = self::getDb($className);
357		$quote = $db->quote;
358		$tableName = OrmUtils::getTableName($className);
359		$ColumnskeyAndValues = \array_merge(Reflexion::getPropertiesAndValues($instance), OrmUtils::getManyToOneMembersAndValues($instance));
360		$keyFieldsAndValues = OrmUtils::getKeyFieldsAndValues($instance);
361		$sql = "UPDATE {$quote}{$tableName}{$quote} SET " . SqlUtils::getUpdateFieldsKeyAndParams($ColumnskeyAndValues) . ' WHERE ' . SqlUtils::getWhere($keyFieldsAndValues);
362
363		$statement = $db->getUpdateStatement($sql);
364		try {
365		$db->beginTransaction();
366		foreach ($instances as $instance) {
367		EventsManager::trigger('dao.before.update', $instance);
368		$ColumnskeyAndValues = \array_merge(Reflexion::getPropertiesAndValues($instance), OrmUtils::getManyToOneMembersAndValues($instance));
369		$result = $statement->execute($ColumnskeyAndValues);
370		if ($updateMany && $result) {
371		self::insertOrUpdateAllManyToMany($instance);
372		}
373		EventsManager::trigger(DAOEvents::AFTER_UPDATE, $instance, $result);
374		$instance->_rest = \array_merge($instance->_rest, $ColumnskeyAndValues);
375		if (Logger::isActive()) {
376		Logger::info("DAOUpdates", $sql, "update");
377		Logger::info("DAOUpdates", json_encode($ColumnskeyAndValues), "Key and values");
378		}
379		}
380		$db->commit();
381		return true;
382		} catch (\Exception $e) {
383		Logger::warn("DAOUpdates", $e->getMessage(), "update");
384		$db->rollBack();
385		}
386		}
387		return false;
388		}
389
390		/**
391		*
392		* @param object $instance
393		* @param boolean $updateMany
394		* @return boolean\|int
395		*/
396		public static function save($instance, $updateMany = false) {
397		if (isset ($instance->_rest)) {
398		return self::update($instance, $updateMany);
399		}
400		return self::insert($instance, $updateMany);
401		}
402		}
403

phpMv / ubiquity

DAOUpdatesTrait::updateGroup() B last analyzed 2023-05-30 15:31 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

DAOUpdatesTrait::updateGroup() B
last analyzed 2023-05-30 15:31 UTC