base_mapper::ensure_multi_array() - Code Metrics - Inspection of "Fix issue #24" - blitze/phpBB-ext-sitemaker - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 349ca4...22d2e9 )

by Daniel

created 2016-03-28 12:30 UTC

base_mapper::ensure_multi_array() A

↳ Parent: base_mapper

Complexity

Conditions	2
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	2

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	4
ccs	2
cts	2
cp	1
rs	10
cc	2
eloc	2
nc	1
nop	1
crap	2

<?php
/**
 *
 * @package sitemaker
 * @copyright (c) 2015 Daniel A. (blitze)
 * @license http://opensource.org/licenses/gpl-2.0.php GNU General Public License v2
 *
 */

namespace blitze\sitemaker\model;

abstract class base_mapper implements mapper_interface
{
	/** @var \phpbb\db\driver\driver_interface */
	protected $db;

	/** @var \blitze\sitemaker\model\base_collection */
	protected $collection;

	/** @var \blitze\sitemaker\model\mapper_factory */
	protected $mapper_factory;

	/** @var string */
	protected $entity_table;

	/** @var string */
	protected $entity_class;

	/** @var string */
	protected $entity_pkey;

	/**
	 * Constructor
	 *
	 * @param \phpbb\db\driver\driver_interface				$db					Database object
	 * @param \blitze\sitemaker\model\base_collection		$collection			Entity collection
	 * @param \blitze\sitemaker\model\mapper_factory		$mapper_factory		Mapper factory object
	 * @param string										$entity_table
	 */
	public function  __construct(\phpbb\db\driver\driver_interface $db, \blitze\sitemaker\model\base_collection $collection, \blitze\sitemaker\model\mapper_factory $mapper_factory, $entity_table)
	{
		$this->db = $db;
		$this->collection = $collection;
		$this->mapper_factory = $mapper_factory;
		$this->entity_table = $entity_table;
	}

	/**
	 * Get the collection
	 */
	public function get_collection()
	{
		return $this->collection;
	}

	/**
	 * {@inheritdoc}
	 */
	public function load(array $condition = array())
	{
		$sql_where = $this->get_sql_condition($condition);
		$results = $this->db->sql_query($this->find_sql($sql_where));
		$row = $this->db->sql_fetchrow($results);
		$this->db->sql_freeresult($results);

		if ($row)
		{
			return $this->create_entity($row);
		}
		return null;
	}

	/**
	 * {@inheritdoc}
	 */
	public function find(array $condition = array())
	{
		$sql_where = $this->get_sql_condition($condition);
		$results = $this->db->sql_query($this->find_sql($sql_where));
		$this->collection->clear();

		while ($row = $this->db->sql_fetchrow($results))
		{
			$this->collection[$row[$this->entity_pkey]] = $this->create_entity($row);
		}
		$this->db->sql_freeresult($results);

		return $this->collection;
	}

	/**
	 * {@inheritdoc}
	 */
	public function save(\blitze\sitemaker\model\entity_interface $entity)
	{
		$accessor = 'get_' . $this->entity_pkey;
		if (is_null($entity->$accessor()))
		{
			$entity = $this->insert($entity);
		}
		else
		{
			$this->update($entity);
		}

		return $entity;
	}

	/**
	 * {@inheritdoc}
	 */
	public function delete($condition)
	{
		if (!is_array($condition))
		{
			if ($condition instanceof $this->entity_class)
			{
				$accessor = 'get_' . $this->entity_pkey;
				$condition = array($this->entity_pkey, '=', $condition->$accessor());
			}
			else
			{
				throw new \blitze\sitemaker\exception\unexpected_value('INVALID_ENTITY');
			}
		}

		$sql_where = $this->get_sql_condition($condition);
		$this->db->sql_query('DELETE FROM ' . $this->entity_table . (sizeof($sql_where) ? ' WHERE ' . join(' AND ', $sql_where) : ''));
	}

	/**
	 * {@inheritdoc}
	 */
	public function create_entity(array $row)
	{
		return new $this->entity_class($row);
	}

	/**
	 * Insert a new row in the table corresponding to the specified entity
	 * @param \blitze\sitemaker\model\entity_interface $entity
	 * @return \blitze\sitemaker\model\entity_interface
	 * @throws \blitze\sitemaker\exception\unexpected_value
	 */
	protected function insert(\blitze\sitemaker\model\entity_interface $entity)
	{
		if ($entity instanceof $this->entity_class)
		{
			$this->db->sql_query('INSERT INTO ' . $this->entity_table . ' ' . $this->db->sql_build_array('INSERT', $entity->to_db()));

			$mutator = 'set_' . $this->entity_pkey;
			$entity->$mutator((int) $this->db->sql_nextid());

			return $entity;
		}

		throw new \blitze\sitemaker\exception\unexpected_value('INVALID_ENTITY');
	}

	/**
	 * Update the row in the table corresponding to the specified entity
	 * @param \blitze\sitemaker\model\entity_interface $entity
	 * @return mixed
	 * @throws \blitze\sitemaker\exception\unexpected_value
	 */
	protected function update(\blitze\sitemaker\model\entity_interface $entity)
	{
		if ($entity instanceof $this->entity_class)
		{
			$accessor = 'get_' . $this->entity_pkey;

			return $this->db->sql_query('UPDATE ' . $this->entity_table . '
				SET ' . $this->db->sql_build_array('UPDATE', $entity->to_db()) . '
				WHERE ' . $this->entity_pkey . ' = ' . (int) $entity->$accessor());
		}

		throw new \blitze\sitemaker\exception\unexpected_value('INVALID_ENTITY');
	}

	/**
	 * @param array $sql_where
	 * @return string
	 */
	protected function find_sql(array $sql_where)
	{
		return 'SELECT * FROM ' . $this->entity_table .
			(sizeof($sql_where) ? ' WHERE ' . join(' AND ', $sql_where) : '');
	}

	/**
	 * @param array $condition
	 * @return array
	 */
	protected function get_sql_condition(array $condition)
	{
		$sql_where = array();
		$condition = $this->ensure_multi_array($condition);

		foreach ($condition as $info)
		{
			list($field, $operator, $value) = $info;

			switch (gettype($value))
			{
				case 'array':
					$sql_where[] = $this->db->sql_in_set($field, $value, ($operator == '=') ? false : true);
				break;
				case 'string':
					$sql_where[] = $field . " $operator '" . $this->db->sql_escape($value) . "'";
				break;
				case 'boolean':
				case 'integer':
					$sql_where[] = $field . " $operator " . (int) $value;
				break;
			}
		}

		return $sql_where;
	}

	/**
	 * @param array $condition
	 * @return mixed
	 */
	protected function ensure_multi_array(array $condition)
	{
		return array_filter((is_array(current($condition))) ? $condition : array($condition));
	}
}


1		<?php
2		/**
3		*
4		* @package sitemaker
5		* @copyright (c) 2015 Daniel A. (blitze)
6		* @license http://opensource.org/licenses/gpl-2.0.php GNU General Public License v2
7		*
8		*/
9
10		namespace blitze\sitemaker\model;
11
12		abstract class base_mapper implements mapper_interface
13		{
14		/** @var \phpbb\db\driver\driver_interface */
15		protected $db;
16
17		/** @var \blitze\sitemaker\model\base_collection */
18		protected $collection;
19
20		/** @var \blitze\sitemaker\model\mapper_factory */
21		protected $mapper_factory;
22
23		/** @var string */
24		protected $entity_table;
25
26		/** @var string */
27		protected $entity_class;
28
29		/** @var string */
30		protected $entity_pkey;
31
32		/**
33		* Constructor
34		*
35		* @param \phpbb\db\driver\driver_interface $db Database object
36		* @param \blitze\sitemaker\model\base_collection $collection Entity collection
37		* @param \blitze\sitemaker\model\mapper_factory $mapper_factory Mapper factory object
38		* @param string $entity_table
39		*/
40	117	public function __construct(\phpbb\db\driver\driver_interface $db, \blitze\sitemaker\model\base_collection $collection, \blitze\sitemaker\model\mapper_factory $mapper_factory, $entity_table)
41		{
42	117	$this->db = $db;
43	117	$this->collection = $collection;
44	117	$this->mapper_factory = $mapper_factory;
45	117	$this->entity_table = $entity_table;
46	117	}
47
48		/**
49		* Get the collection
50		*/
51		public function get_collection()
52		{
53		return $this->collection;
54		}
55
56		/**
57		* {@inheritdoc}
58		*/
59	55	public function load(array $condition = array())
60		{
61	55	$sql_where = $this->get_sql_condition($condition);
62	55	$results = $this->db->sql_query($this->find_sql($sql_where));
63	55	$row = $this->db->sql_fetchrow($results);
64	55	$this->db->sql_freeresult($results);
65
66		if ($row)
67	55	{
68	44	return $this->create_entity($row);
69		}
70	19	return null;
71		}
72
73		/**
74		* {@inheritdoc}
75		*/
76	42	public function find(array $condition = array())
77		{
78	42	$sql_where = $this->get_sql_condition($condition);
79	42	$results = $this->db->sql_query($this->find_sql($sql_where));
80	42	$this->collection->clear();
81
82	42	while ($row = $this->db->sql_fetchrow($results))
83		{
84	39	$this->collection[$row[$this->entity_pkey]] = $this->create_entity($row);
85	39	}
86	42	$this->db->sql_freeresult($results);
87
88	42	return $this->collection;
89		}
90
91		/**
92		* {@inheritdoc}
93		*/
94	26	public function save(\blitze\sitemaker\model\entity_interface $entity)
95		{
96	26	$accessor = 'get_' . $this->entity_pkey;
97	26	if (is_null($entity->$accessor()))
98	26	{
99	11	$entity = $this->insert($entity);
100	11	}
101		else
102		{
103	16	$this->update($entity);
104		}
105
106	25	return $entity;
107		}
108
109		/**
110		* {@inheritdoc}
111		*/
112	15	public function delete($condition)
113		{
114	15	if (!is_array($condition))
115	15	{
116	10	if ($condition instanceof $this->entity_class)
117	10	{
118	10	$accessor = 'get_' . $this->entity_pkey;
119	10	$condition = array($this->entity_pkey, '=', $condition->$accessor());
120	10	}
121		else
122		{
123		throw new \blitze\sitemaker\exception\unexpected_value('INVALID_ENTITY');
124		}
125	10	}
126
127	15	$sql_where = $this->get_sql_condition($condition);
128	15	$this->db->sql_query('DELETE FROM ' . $this->entity_table . (sizeof($sql_where) ? ' WHERE ' . join(' AND ', $sql_where) : ''));
129	15	}
130
131		/**
132		* {@inheritdoc}
133		*/
134	71	public function create_entity(array $row)
135		{
136	71	return new $this->entity_class($row);
137		}
138
139		/**
140		* Insert a new row in the table corresponding to the specified entity
141		* @param \blitze\sitemaker\model\entity_interface $entity
142		* @return \blitze\sitemaker\model\entity_interface
143		* @throws \blitze\sitemaker\exception\unexpected_value
144		*/
145	11	protected function insert(\blitze\sitemaker\model\entity_interface $entity)
146		{
147	11	if ($entity instanceof $this->entity_class)
148	11	{
149	11	$this->db->sql_query('INSERT INTO ' . $this->entity_table . ' ' . $this->db->sql_build_array('INSERT', $entity->to_db()));
150
151	11	$mutator = 'set_' . $this->entity_pkey;
152	11	$entity->$mutator((int) $this->db->sql_nextid());
153
154	11	return $entity;
155		}
156
157		throw new \blitze\sitemaker\exception\unexpected_value('INVALID_ENTITY');
158		}
159
160		/**
161		* Update the row in the table corresponding to the specified entity
162		* @param \blitze\sitemaker\model\entity_interface $entity
163		* @return mixed
164		* @throws \blitze\sitemaker\exception\unexpected_value
165		*/
166	16	protected function update(\blitze\sitemaker\model\entity_interface $entity)
167		{
168	16	if ($entity instanceof $this->entity_class)
169	16	{
170	16	$accessor = 'get_' . $this->entity_pkey;
171
172	16	return $this->db->sql_query('UPDATE ' . $this->entity_table . '
173	16	SET ' . $this->db->sql_build_array('UPDATE', $entity->to_db()) . '
174	15	WHERE ' . $this->entity_pkey . ' = ' . (int) $entity->$accessor());
175		}
176
177		throw new \blitze\sitemaker\exception\unexpected_value('INVALID_ENTITY');
178		}
179
180		/**
181		* @param array $sql_where
182		* @return string
183		*/
184	28	protected function find_sql(array $sql_where)
185		{
186	28	return 'SELECT * FROM ' . $this->entity_table .
187	28	(sizeof($sql_where) ? ' WHERE ' . join(' AND ', $sql_where) : '');
188		}
189
190		/**
191		* @param array $condition
192		* @return array
193		*/
194	107	protected function get_sql_condition(array $condition)
195		{
196	107	$sql_where = array();
197	107	$condition = $this->ensure_multi_array($condition);
198
199	107	foreach ($condition as $info)
200		{
201	78	list($field, $operator, $value) = $info;
202
203	78	switch (gettype($value))
204		{
205	78	case 'array':
206	9	$sql_where[] = $this->db->sql_in_set($field, $value, ($operator == '=') ? false : true);
207	9	break;
208	78	case 'string':
209	23	$sql_where[] = $field . " $operator '" . $this->db->sql_escape($value) . "'";
210	23	break;
211	77	case 'boolean':
212	77	case 'integer':
213	77	$sql_where[] = $field . " $operator " . (int) $value;
214	77	break;
215	78	}
216	107	}
217
218	107	return $sql_where;
219		}
220
221		/**
222		* @param array $condition
223		* @return mixed
224		*/
225	107	protected function ensure_multi_array(array $condition)
226		{
227	107	return array_filter((is_array(current($condition))) ? $condition : array($condition));
228		}
229		}
230

blitze / phpBB-ext-sitemaker

Push — master ( 349ca4...22d2e9 )

base_mapper::ensure_multi_array() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like