Record - Code Metrics - Inspection of "Removed the now redundant Record::generate()." - darya/framework - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 94a512...56c648 )

by Chris

created 2015-12-10 22:57 UTC

Record C

↳ Parent: Project

Complexity

Total Complexity

Size/Duplication

Total Lines	575
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes	16
Bugs	3	Features	5

Metric	Value
dl	0
loc	575
wmc	77
lcom	1
cbo	5
rs	5.4717
c	16
b	3
f	5

30 Methods

Rating	Name	Size	Complexity
A	__construct()	7	3
A	has()	3	2
A	get()	7	2
A	set()	7	3
A	table()	9	2
A	storage()	5	3
A	getSharedStorage()	3	1
A	setSharedStorage()	3	1
D	prepareData()	32	9
A	prepareFilter()	12	3
A	prepareListing()	14	3
A	load()	7	1
A	find()	5	2
A	findOrNew()	5	2
A	all()	3	1
A	eager()	12	3
A	search()	14	3
A	listing()	8	1
A	distinct()	10	2
A	query()	17	2
C	save()	41	7
A	saveMany()	11	3
A	delete()	11	3
A	hasRelation()	5	1
A	relation()	19	3
A	hasRelated()	5	2
A	related()	11	2
B	setRelated()	13	5
A	defaultSearchAttributes()	3	1
A	__call()	3	1

How to fix Complexity

<?php
namespace Darya\ORM;

use Exception;
use Darya\ORM\Model;
use Darya\ORM\Relation;
use Darya\Storage\Query;
use Darya\Storage\Readable;
use Darya\Storage\Queryable;
use Darya\Storage\Modifiable;
use Darya\Storage\Searchable;
use Darya\Storage\Aggregational;
use Darya\Storage\Query\Builder;

/**
 * Darya's active record implementation.
 * 
 * @author Chris Andrew <[email protected]>
 */
class Record extends Model {
	
	/**
	 * Overrides the name of the database table that persists the model. The
	 * model's lowercased class name is used if this is not set.
	 * 
	 * @var string Database table name
	 */
	protected $table;
	
	/**
	 * @var \Darya\Storage\Readable Instance storage
	 */
	protected $storage;
	
	/**
	 * @var \Darya\Storage\Readable Shared storage
	 */
	protected static $sharedStorage;
	
	/**
	 * @var array Definitions of related models
	 */
	protected $relations = array();
	
	/**
	 * @var array Default searchable attributes
	 */
	protected $search = array();
	
	/**
	 * Instantiate a new record with the given data or load an instance from
	 * storage if the given data is a valid primary key.
	 * 
	 * @param mixed $data An array of key-value attributes to set or a primary key to load by
	 */
	public function __construct($data = null) {
		if (is_numeric($data) || is_string($data)) {
			$this->data = static::load($data);
		}
		
		parent::__construct($data);
	}
	
	/**
	 * Determine whether the given attribute or relation is set on the record.
	 * 
	 * @param string $attribute
	 */
	public function has($attribute) {
		return $this->hasRelated($attribute) || parent::has($attribute);
	}
	
	/**
	 * Retrieve the given attribute or relation from the record.
	 * 
	 * @param string $attribute
	 * @return mixed
	 */
	public function get($attribute) {
		if ($this->hasRelation($attribute)) {
			return $this->related($attribute);
		}
		
		return parent::get($attribute);
	}
	
	/**
	 * Set the value of an attribute or relation on the model.
	 * 
	 * @param string $attribute
	 * @param mixed  $value
	 */
	public function set($attribute, $value = null) {
		if (is_string($attribute) && $this->hasRelation($attribute)) {
			return $this->setRelated($attribute, $value);
		}
		
		parent::set($attribute, $value);
	}
	
	/**
	 * Retrieve the name of the table this model belongs to.
	 * 
	 * If none is set, it defaults to creating it from the class name.
	 * 
	 * For example:
	 *     Page        -> pages
	 *     PageSection -> page_sections
	 * 
	 * @return string
	 */
	public function table() {
		if ($this->table) {
			return $this->table;
		}
		
		return preg_replace_callback('/([A-Z])/', function($matches) {
			return '_' . strtolower($matches[1]);
		}, lcfirst(basename(get_class($this)))) . 's';
	}
	
	/**
	 * Get and optionally set the model's storage instance.
	 * 
	 * @return \Darya\Storage\Readable
	 */
	public function storage(Readable $storage = null) {
		$this->storage = $storage ?: $this->storage;
		
		return $this->storage ?: static::getSharedStorage();
	}
	
	/**
	 * Get the storage shared to all instances of this model.
	 * 
	 * @return \Darya\Storage\Readable
	 */
	public static function getSharedStorage() {
		return static::$sharedStorage;
	}
	
	/**
	 * Share the given database connection to all instances of this model.
	 * 
	 * @param \Darya\Storage\Readable $storage
	 */
	public static function setSharedStorage(Readable $storage) {
		static::$sharedStorage = $storage;
	}
	
	/**
	 * Prepare the record's data for storage. This is here until repositories
	 * are implemented.
	 * 
	 * @return array
	 */
	protected function prepareData() {
		$types = $this->attributes;
		
		$changed = array_intersect_key($this->data, array_flip($this->changed));
		
		$data = $this->id() && $changed ? $changed : $this->data;
		
		foreach ($data as $attribute => $value) {
			if (isset($types[$attribute])) {
				$type = $types[$attribute];
				
				switch ($type) {
					case 'int':
						$value = (int) $value;
						break;
					case 'date':
						$value = date('Y-m-d', $value);
						break;
					case 'datetime':
						$value = date('Y-m-d H:i:s', $value);
						break;
					case 'time':
						$value = date('H:i:s', $value);
						break;
				}
				
				$data[$attribute] = $value;
			}
		}
		
		return $data;
	}
	
	/**
	 * Prepare the given filter.
	 * 
	 * Creates a filter for the record's key attribute if the given value is not
	 * an array.
	 * 
	 * @param mixed $filter
	 * @return string
	 */
	protected static function prepareFilter($filter) {
		if ($filter === null) {
			return array();
		}
		
		if (!is_array($filter)) {
			$instance = new static;
			$filter = array($instance->key() => $filter);
		}
		
		return $filter;
	}
	
	/**
	 * Prepare the given list data.
	 * 
	 * @param array  $data
	 * @param string $attribute
	 * @return array
	 */
	protected static function prepareListing($data, $attribute) {
		$instance = new static;
		$key = $instance->key();
		
		$list = array();
		
		foreach ($data as $row) {
			if (isset($row[$attribute])) {
				$list[$row[$key]] = $row[$attribute];
			}
		}
		
		return $list;
	}
	
	/**
	 * Load record data from storage using the given criteria.
	 * 
	 * @param array|string|int $filter [optional]
	 * @param array|string     $order  [optional]
	 * @param int              $limit  [optional]
	 * @param int              $offset [optional]
	 * @return array
	 */
	public static function load($filter = array(), $order = array(), $limit = null, $offset = 0) {
		$instance = new static;
		$storage = $instance->storage();
		$filter = static::prepareFilter($filter);
		
		return $storage->read($instance->table(), $filter, $order, $limit, $offset);
	}
	
	/**
	 * Load a record instance from storage using the given criteria.
	 * 
	 * Returns false if the record cannot be found.
	 * 
	 * @param array|string|int $filter [optional]
	 * @param array|string     $order  [optional]
	 * @return Record|bool
	 */
	public static function find($filter = array(), $order = array()) {
		$data = static::load($filter, $order, 1);
		
		return !empty($data[0]) ? new static($data[0]) : false;
	}
	
	/**
	 * Load a record instance from storage using the given criteria or create a
	 * new instance if nothing is found.
	 * 
	 * @param array|string|int $filter [optional]
	 * @param array|string     $order  [optional]
	 * @return Record
	 */
	public static function findOrNew($filter = array(), $order = array()) {
		$instance = static::find($filter, $order);
		
		return $instance === false ? new static : $instance;
	}

	/**
	 * Load multiple record instances from storage using the given criteria.
	 * 
	 * @param array|string|int $filter [optional]
	 * @param array|string     $order  [optional]
	 * @param int              $limit  [optional]
	 * @param int              $offset [optional]
	 * @return array
	 */
	public static function all($filter = array(), $order = array(), $limit = null, $offset = 0) {
		return static::generate(static::load($filter, $order, $limit, $offset));
	}
	
	/**
	 * Eagerly load the given relations of multiple record instances.
	 * 
	 * @param array|string $relations
	 * @return array
	 */
	public static function eager($relations) {
		$instance = new static;
		$instances = static::all();
		
		foreach ((array) $relations as $relation) {
			if ($instance->relation($relation)) {
				$instances = $instance->relation($relation)->eager($instances, $relation);
			}
		}
		
		return $instances;
	}
	
	/**
	 * Search for record instances in storage using the given criteria.
	 * 
	 * @param string           $query
	 * @param array            $attributes [optional]
	 * @param array|string|int $filter     [optional]
	 * @param array|string     $order      [optional]
	 * @param int              $limit      [optional]
	 * @param int              $offset     [optional]
	 * @return array
	 */
	public static function search($query, $attributes = array(), $filter = array(), $order = array(), $limit = null, $offset = 0) {
		$instance = new static;
		$storage = $instance->storage();
		
		if (!$storage instanceof Searchable) {
			throw new Exception(get_class($instance) . ' storage is not searchable');
		}
		
		$attributes = $attributes ?: $instance->defaultSearchAttributes();
		
		$data = $storage->search($instance->table(), $query, $attributes, $filter, $order, $limit, $offset);
		
		return static::generate($data);
	}
	
	/**
	 * Retrieve key => value pairs using `id` for keys and the given attribute
	 * for values.
	 * 
	 * @param string $attribute
	 * @param array  $filter    [optional]
	 * @param array  $order     [optional]
	 * @param int    $limit     [optional]
	 * @param int    $offset    [optional]
	 * @return array
	 */
	public static function listing($attribute, $filter = array(), $order = array(), $limit = null, $offset = 0) {
		$instance = new static;
		$storage = $instance->storage();
		
		$data = $storage->listing($instance->table(), array($instance->key(), $attribute), $filter, $order, $limit, $offset);
		
		return static::prepareListing($data, $attribute);
	}
	
	/**
	 * Retrieve the distinct values of the given attribute.
	 * 
	 * @param string $attribute
	 * @param array  $filter    [optional]
	 * @param array  $order     [optional]
	 * @param int    $limit     [optional]
	 * @param int    $offset    [optional]
	 * @return array
	 */
	public static function distinct($attribute, $filter = array(), $order = array(), $limit = null, $offset = 0) {
		$instance = new static;
		$storage = $instance->storage();
		
		if (!$storage instanceof Aggregational) {
			return array_values(array_unique(static::listing($attribute, $filter, $order)));
		}
		
		return $storage->distinct($instance->table(), $attribute, $filter, $order, $limit, $offset);
	}
	
	/**
	 * Create a query builder for the model.
	 * 
	 * @return Builder
	 */
	public static function query() {
		$instance = new static;
		$storage = $instance->storage();
		
		if (!$storage instanceof Queryable) {
			throw new Exception(get_class($instance) . ' storage is not queryable');
		}
		
		$query = new Query($instance->table());
		$builder = new Builder($query, $instance->storage());
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
		
		$builder->callback(function($result) use ($instance) {
			return $instance::generate($result->data);
		});
		
		return $builder;
	}
	
	/**
	 * Save the record to storage.
	 * 
	 * @return bool
	 */
	public function save() {
		if ($this->validate()) {
			$storage = $this->storage();
			$class = get_class($this);
			
			if (!$storage instanceof Modifiable) {
				throw new Exception(basename($class) . ' storage is not modifiable');
			}
			
			$data = $this->prepareData();
			
			if (!$this->id()) {
				$id = $storage->create($this->table(), $data);
				
				if ($id) {
					$this->set($this->key(), $id);
					$this->reinstate();
					
					return true;
				}
			} else {
				$updated = $storage->update($this->table(), $data, array($this->key() => $this->id()), 1);
				
				if (!$updated) {
					$updated = $storage->create($this->table(), $data) > 0;
				}
				
				if ($updated) {
					$this->reinstate();
					
					return true;
				}
			}
			
			$entity = strtolower(basename($class));
			$this->errors['save'] = "Failed to save $entity";
			$this->errors['storage'] = $this->storage()->error();
		}
		
		return false;
	}
	
	/**
	 * Save multiple record instances to storage.
	 * 
	 * Returns the number of instances that saved successfully.
	 * 
	 * @param array $instances
	 * @return int
	 */
	public static function saveMany($instances) {
		$failed = 0;
		
		foreach ($instances as $instance) {
			if (!$instance->save()) {
				$failed++;
			}
		}
		
		return count($instances) - $failed;
	}
	
	/**
	 * Delete the record from storage.
	 * 
	 * @return bool
	 */
	public function delete() {
		if ($this->id()) {
			$storage = $this->storage();
			
			if ($storage instanceof Modifiable) {
				return (bool) $storage->delete($this->table(), array($this->key() => $this->id()), 1);
			}
		}
		
		return false;
	}
	
	/**
	 * Determine whether the given attribute is a relation.
	 * 
	 * @param string $attribute
	 * @return bool
	 */
	protected function hasRelation($attribute) {
		$attribute = $this->prepareAttribute($attribute);
		
		return isset($this->relations[$attribute]);
	}
	
	/**
	 * Retrieve the given relation.
	 * 
	 * @param string $attribute
	 * @return \Darya\ORM\Relation
	 */
	public function relation($attribute) {
		if (!$this->hasRelation($attribute)) {
			return null;
		}
		
		$attribute = $this->prepareAttribute($attribute);
		$relation = $this->relations[$attribute];
		
		if (!$relation instanceof Relation) {
			$type = array_shift($relation);
			$arguments = array_merge(array($this), $relation);
			
			$relation = Relation::factory($type, $arguments);
			
			$this->relations[$attribute] = $relation;
		}
		
		return $relation;
	}
	
	/**
	 * Determine whether the given relation has any set model(s).
	 * 
	 * @param string $attribute
	 * @return bool
	 */
	protected function hasRelated($attribute) {
		$attribute = $this->prepareAttribute($attribute);
		
		return $this->hasRelation($attribute) && $this->relation($attribute)->count();
	}
	
	/**
	 * Retrieve the model(s) of the given relation.
	 * 
	 * @param string $attribute
	 * @return array
	 */
	public function related($attribute) {
		if (!$this->hasRelation($attribute)) {
			return null;
		}
		
		$attribute = $this->prepareAttribute($attribute);
		
		$relation = $this->relation($attribute);
		
		return $relation->retrieve();
	}
	
	/**
	 * Set the given related model(s).
	 * 
	 * @param string $attribute
	 * @param mixed  $value
	 */
	protected function setRelated($attribute, $value) {
		if (!$this->hasRelation($attribute)) {
			return;
		}
		
		$relation = $this->relation($attribute);
		
		if ($value !== null && !$value instanceof $relation->target && !is_array($value)) {
			return;
		}
		
		$relation->associate($value);
	}

	/**
	 * Retrieve the default search attributes for the model.
	 * 
	 * @return array
	 */
	public function defaultSearchAttributes() {
		return $this->search;
	}
	
	/**
	 * Retrieve a relation. Shortcut for `relation()`.
	 * 
	 * @param string $method
	 * @param array  $arguments
	 * @return Relation
	 */
	public function __call($method, $arguments) {
		return $this->relation($method);
	}
	
}


1			<?php
2			namespace Darya\ORM;
3
4			use Exception;
5			use Darya\ORM\Model;
6			use Darya\ORM\Relation;
7			use Darya\Storage\Query;
8			use Darya\Storage\Readable;
9			use Darya\Storage\Queryable;
10			use Darya\Storage\Modifiable;
11			use Darya\Storage\Searchable;
12			use Darya\Storage\Aggregational;
13			use Darya\Storage\Query\Builder;
14
15			/**
16			* Darya's active record implementation.
17			*
18			* @author Chris Andrew <[email protected]>
19			*/
20			class Record extends Model {
21
22			/**
23			* Overrides the name of the database table that persists the model. The
24			* model's lowercased class name is used if this is not set.
25			*
26			* @var string Database table name
27			*/
28			protected $table;
29
30			/**
31			* @var \Darya\Storage\Readable Instance storage
32			*/
33			protected $storage;
34
35			/**
36			* @var \Darya\Storage\Readable Shared storage
37			*/
38			protected static $sharedStorage;
39
40			/**
41			* @var array Definitions of related models
42			*/
43			protected $relations = array();
44
45			/**
46			* @var array Default searchable attributes
47			*/
48			protected $search = array();
49
50			/**
51			* Instantiate a new record with the given data or load an instance from
52			* storage if the given data is a valid primary key.
53			*
54			* @param mixed $data An array of key-value attributes to set or a primary key to load by
55			*/
56			public function __construct($data = null) {
57			if (is_numeric($data) \|\| is_string($data)) {
58			$this->data = static::load($data);
59			}
60
61			parent::__construct($data);
62			}
63
64			/**
65			* Determine whether the given attribute or relation is set on the record.
66			*
67			* @param string $attribute
68			*/
69			public function has($attribute) {
70			return $this->hasRelated($attribute) \|\| parent::has($attribute);
71			}
72
73			/**
74			* Retrieve the given attribute or relation from the record.
75			*
76			* @param string $attribute
77			* @return mixed
78			*/
79			public function get($attribute) {
80			if ($this->hasRelation($attribute)) {
81			return $this->related($attribute);
82			}
83
84			return parent::get($attribute);
85			}
86
87			/**
88			* Set the value of an attribute or relation on the model.
89			*
90			* @param string $attribute
91			* @param mixed $value
92			*/
93			public function set($attribute, $value = null) {
94			if (is_string($attribute) && $this->hasRelation($attribute)) {
95			return $this->setRelated($attribute, $value);
96			}
97
98			parent::set($attribute, $value);
99			}
100
101			/**
102			* Retrieve the name of the table this model belongs to.
103			*
104			* If none is set, it defaults to creating it from the class name.
105			*
106			* For example:
107			* Page -> pages
108			* PageSection -> page_sections
109			*
110			* @return string
111			*/
112			public function table() {
113			if ($this->table) {
114			return $this->table;
115			}
116
117			return preg_replace_callback('/([A-Z])/', function($matches) {
118			return '_' . strtolower($matches[1]);
119			}, lcfirst(basename(get_class($this)))) . 's';
120			}
121
122			/**
123			* Get and optionally set the model's storage instance.
124			*
125			* @return \Darya\Storage\Readable
126			*/
127			public function storage(Readable $storage = null) {
128			$this->storage = $storage ?: $this->storage;
129
130			return $this->storage ?: static::getSharedStorage();
131			}
132
133			/**
134			* Get the storage shared to all instances of this model.
135			*
136			* @return \Darya\Storage\Readable
137			*/
138			public static function getSharedStorage() {
139			return static::$sharedStorage;
140			}
141
142			/**
143			* Share the given database connection to all instances of this model.
144			*
145			* @param \Darya\Storage\Readable $storage
146			*/
147			public static function setSharedStorage(Readable $storage) {
148			static::$sharedStorage = $storage;
149			}
150
151			/**
152			* Prepare the record's data for storage. This is here until repositories
153			* are implemented.
154			*
155			* @return array
156			*/
157			protected function prepareData() {
158			$types = $this->attributes;
159
160			$changed = array_intersect_key($this->data, array_flip($this->changed));
161
162			$data = $this->id() && $changed ? $changed : $this->data;
163
164			foreach ($data as $attribute => $value) {
165			if (isset($types[$attribute])) {
166			$type = $types[$attribute];
167
168			switch ($type) {
169			case 'int':
170			$value = (int) $value;
171			break;
172			case 'date':
173			$value = date('Y-m-d', $value);
174			break;
175			case 'datetime':
176			$value = date('Y-m-d H:i:s', $value);
177			break;
178			case 'time':
179			$value = date('H:i:s', $value);
180			break;
181			}
182
183			$data[$attribute] = $value;
184			}
185			}
186
187			return $data;
188			}
189
190			/**
191			* Prepare the given filter.
192			*
193			* Creates a filter for the record's key attribute if the given value is not
194			* an array.
195			*
196			* @param mixed $filter
197			* @return string
198			*/
199			protected static function prepareFilter($filter) {
200			if ($filter === null) {
201			return array();
202			}
203
204			if (!is_array($filter)) {
205			$instance = new static;
206			$filter = array($instance->key() => $filter);
207			}
208
209			return $filter;
210			}
211
212			/**
213			* Prepare the given list data.
214			*
215			* @param array $data
216			* @param string $attribute
217			* @return array
218			*/
219			protected static function prepareListing($data, $attribute) {
220			$instance = new static;
221			$key = $instance->key();
222
223			$list = array();
224
225			foreach ($data as $row) {
226			if (isset($row[$attribute])) {
227			$list[$row[$key]] = $row[$attribute];
228			}
229			}
230
231			return $list;
232			}
233
234			/**
235			* Load record data from storage using the given criteria.
236			*
237			* @param array\|string\|int $filter [optional]
238			* @param array\|string $order [optional]
239			* @param int $limit [optional]
240			* @param int $offset [optional]
241			* @return array
242			*/
243			public static function load($filter = array(), $order = array(), $limit = null, $offset = 0) {
244			$instance = new static;
245			$storage = $instance->storage();
246			$filter = static::prepareFilter($filter);
247
248			return $storage->read($instance->table(), $filter, $order, $limit, $offset);
249			}
250
251			/**
252			* Load a record instance from storage using the given criteria.
253			*
254			* Returns false if the record cannot be found.
255			*
256			* @param array\|string\|int $filter [optional]
257			* @param array\|string $order [optional]
258			* @return Record\|bool
259			*/
260			public static function find($filter = array(), $order = array()) {
261			$data = static::load($filter, $order, 1);
262
263			return !empty($data[0]) ? new static($data[0]) : false;
264			}
265
266			/**
267			* Load a record instance from storage using the given criteria or create a
268			* new instance if nothing is found.
269			*
270			* @param array\|string\|int $filter [optional]
271			* @param array\|string $order [optional]
272			* @return Record
273			*/
274			public static function findOrNew($filter = array(), $order = array()) {
275			$instance = static::find($filter, $order);
276
277			return $instance === false ? new static : $instance;
278			}
279
280			/**
281			* Load multiple record instances from storage using the given criteria.
282			*
283			* @param array\|string\|int $filter [optional]
284			* @param array\|string $order [optional]
285			* @param int $limit [optional]
286			* @param int $offset [optional]
287			* @return array
288			*/
289			public static function all($filter = array(), $order = array(), $limit = null, $offset = 0) {
290			return static::generate(static::load($filter, $order, $limit, $offset));
291			}
292
293			/**
294			* Eagerly load the given relations of multiple record instances.
295			*
296			* @param array\|string $relations
297			* @return array
298			*/
299			public static function eager($relations) {
300			$instance = new static;
301			$instances = static::all();
302
303			foreach ((array) $relations as $relation) {
304			if ($instance->relation($relation)) {
305			$instances = $instance->relation($relation)->eager($instances, $relation);
306			}
307			}
308
309			return $instances;
310			}
311
312			/**
313			* Search for record instances in storage using the given criteria.
314			*
315			* @param string $query
316			* @param array $attributes [optional]
317			* @param array\|string\|int $filter [optional]
318			* @param array\|string $order [optional]
319			* @param int $limit [optional]
320			* @param int $offset [optional]
321			* @return array
322			*/
323			public static function search($query, $attributes = array(), $filter = array(), $order = array(), $limit = null, $offset = 0) {
324			$instance = new static;
325			$storage = $instance->storage();
326
327			if (!$storage instanceof Searchable) {
328			throw new Exception(get_class($instance) . ' storage is not searchable');
329			}
330
331			$attributes = $attributes ?: $instance->defaultSearchAttributes();
332
333			$data = $storage->search($instance->table(), $query, $attributes, $filter, $order, $limit, $offset);
334
335			return static::generate($data);
336			}
337
338			/**
339			* Retrieve key => value pairs using `id` for keys and the given attribute
340			* for values.
341			*
342			* @param string $attribute
343			* @param array $filter [optional]
344			* @param array $order [optional]
345			* @param int $limit [optional]
346			* @param int $offset [optional]
347			* @return array
348			*/
349			public static function listing($attribute, $filter = array(), $order = array(), $limit = null, $offset = 0) {
350			$instance = new static;
351			$storage = $instance->storage();
352
353			$data = $storage->listing($instance->table(), array($instance->key(), $attribute), $filter, $order, $limit, $offset);
354
355			return static::prepareListing($data, $attribute);
356			}
357
358			/**
359			* Retrieve the distinct values of the given attribute.
360			*
361			* @param string $attribute
362			* @param array $filter [optional]
363			* @param array $order [optional]
364			* @param int $limit [optional]
365			* @param int $offset [optional]
366			* @return array
367			*/
368			public static function distinct($attribute, $filter = array(), $order = array(), $limit = null, $offset = 0) {
369			$instance = new static;
370			$storage = $instance->storage();
371
372			if (!$storage instanceof Aggregational) {
373			return array_values(array_unique(static::listing($attribute, $filter, $order)));
374			}
375
376			return $storage->distinct($instance->table(), $attribute, $filter, $order, $limit, $offset);
377			}
378
379			/**
380			* Create a query builder for the model.
381			*
382			* @return Builder
383			*/
384			public static function query() {
385			$instance = new static;
386			$storage = $instance->storage();
387
388			if (!$storage instanceof Queryable) {
389			throw new Exception(get_class($instance) . ' storage is not queryable');
390			}
391
392			$query = new Query($instance->table());
393			$builder = new Builder($query, $instance->storage());
			0 ignored issues – show Documentation introduced 2015-11-24 14:38 UTC by Report Bug Copy Issue Report `$instance->storage()` is of type `object<Darya\Storage\Readable>`, but the function expects a `object<Darya\Storage\Queryable>`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
394
395			$builder->callback(function($result) use ($instance) {
396			return $instance::generate($result->data);
397			});
398
399			return $builder;
400			}
401
402			/**
403			* Save the record to storage.
404			*
405			* @return bool
406			*/
407			public function save() {
408			if ($this->validate()) {
409			$storage = $this->storage();
410			$class = get_class($this);
411
412			if (!$storage instanceof Modifiable) {
413			throw new Exception(basename($class) . ' storage is not modifiable');
414			}
415
416			$data = $this->prepareData();
417
418			if (!$this->id()) {
419			$id = $storage->create($this->table(), $data);
420
421			if ($id) {
422			$this->set($this->key(), $id);
423			$this->reinstate();
424
425			return true;
426			}
427			} else {
428			$updated = $storage->update($this->table(), $data, array($this->key() => $this->id()), 1);
429
430			if (!$updated) {
431			$updated = $storage->create($this->table(), $data) > 0;
432			}
433
434			if ($updated) {
435			$this->reinstate();
436
437			return true;
438			}
439			}
440
441			$entity = strtolower(basename($class));
442			$this->errors['save'] = "Failed to save $entity";
443			$this->errors['storage'] = $this->storage()->error();
444			}
445
446			return false;
447			}
448
449			/**
450			* Save multiple record instances to storage.
451			*
452			* Returns the number of instances that saved successfully.
453			*
454			* @param array $instances
455			* @return int
456			*/
457			public static function saveMany($instances) {
458			$failed = 0;
459
460			foreach ($instances as $instance) {
461			if (!$instance->save()) {
462			$failed++;
463			}
464			}
465
466			return count($instances) - $failed;
467			}
468
469			/**
470			* Delete the record from storage.
471			*
472			* @return bool
473			*/
474			public function delete() {
475			if ($this->id()) {
476			$storage = $this->storage();
477
478			if ($storage instanceof Modifiable) {
479			return (bool) $storage->delete($this->table(), array($this->key() => $this->id()), 1);
480			}
481			}
482
483			return false;
484			}
485
486			/**
487			* Determine whether the given attribute is a relation.
488			*
489			* @param string $attribute
490			* @return bool
491			*/
492			protected function hasRelation($attribute) {
493			$attribute = $this->prepareAttribute($attribute);
494
495			return isset($this->relations[$attribute]);
496			}
497
498			/**
499			* Retrieve the given relation.
500			*
501			* @param string $attribute
502			* @return \Darya\ORM\Relation
503			*/
504			public function relation($attribute) {
505			if (!$this->hasRelation($attribute)) {
506			return null;
507			}
508
509			$attribute = $this->prepareAttribute($attribute);
510			$relation = $this->relations[$attribute];
511
512			if (!$relation instanceof Relation) {
513			$type = array_shift($relation);
514			$arguments = array_merge(array($this), $relation);
515
516			$relation = Relation::factory($type, $arguments);
517
518			$this->relations[$attribute] = $relation;
519			}
520
521			return $relation;
522			}
523
524			/**
525			* Determine whether the given relation has any set model(s).
526			*
527			* @param string $attribute
528			* @return bool
529			*/
530			protected function hasRelated($attribute) {
531			$attribute = $this->prepareAttribute($attribute);
532
533			return $this->hasRelation($attribute) && $this->relation($attribute)->count();
534			}
535
536			/**
537			* Retrieve the model(s) of the given relation.
538			*
539			* @param string $attribute
540			* @return array
541			*/
542			public function related($attribute) {
543			if (!$this->hasRelation($attribute)) {
544			return null;
545			}
546
547			$attribute = $this->prepareAttribute($attribute);
548
549			$relation = $this->relation($attribute);
550
551			return $relation->retrieve();
552			}
553
554			/**
555			* Set the given related model(s).
556			*
557			* @param string $attribute
558			* @param mixed $value
559			*/
560			protected function setRelated($attribute, $value) {
561			if (!$this->hasRelation($attribute)) {
562			return;
563			}
564
565			$relation = $this->relation($attribute);
566
567			if ($value !== null && !$value instanceof $relation->target && !is_array($value)) {
568			return;
569			}
570
571			$relation->associate($value);
572			}
573
574			/**
575			* Retrieve the default search attributes for the model.
576			*
577			* @return array
578			*/
579			public function defaultSearchAttributes() {
580			return $this->search;
581			}
582
583			/**
584			* Retrieve a relation. Shortcut for `relation()`.
585			*
586			* @param string $method
587			* @param array $arguments
588			* @return Relation
589			*/
590			public function __call($method, $arguments) {
591			return $this->relation($method);
592			}
593
594			}
595

darya / framework

Push — master ( 94a512...56c648 )

Record C

Complexity

Size/Duplication

Coupling/Cohesion

Importance

30 Methods

How to fix Complexity

Complex Class

Duplication Side-by-Side

Filter issues like