Qpdb\QueryBuilder\Abstracts\AbstractTableDao

Complexity

Total Complexity

15

Size/Duplication

Total Lines	147
Duplicated Lines	0 %

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getRowById()	0	8	2
A	deleteRowById()	0	8	2
A	updateRowById()	0	9	2
A	saveOrder()	0	14	3
A	getPrimaryKeyConditions()	0	14	4
A	insertRow()	0	3	1
A	__construct()	0	5	1

<?php
/**
 * Created by PhpStorm.
 * User: Adi
 * Date: 2/24/2019
 * Time: 6:54 PM
 */

namespace Qpdb\QueryBuilder\Abstracts;


use Qpdb\PdoWrapper\PdoWrapperService;
use Qpdb\QueryBuilder\Dependencies\QueryException;
use Qpdb\QueryBuilder\QueryBuild;

abstract class AbstractTableDao
{

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

	/**
	 * @var string|array
	 */
	protected $primary;

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


	/**
	 * AbstractTableCrud constructor.
	 */
	public function __construct()
	{
		$this->table = $this->getTableName();
		$this->primary = (array)$this->getPrimaryKey();
		$this->orderField = $this->getOrderField();
	}


	/**
	 * @return string
	 */
	abstract protected function getTableName();

	/**
	 * @return string|array
	 */
	abstract protected function getPrimaryKey();

	/**
	 * @return string
	 */
	abstract protected function getOrderField();


	/**
	 * @param $id
	 * @param array $fields
	 * @return array|bool
	 * @throws QueryException
	 */
	public function getRowById( $id, array $fields = [] )
	{
		$conditions = $this->getPrimaryKeyConditions( $id );
		$result = QueryBuild::select( $this->table )->fields( $fields );
		foreach ( $conditions as $field => $value )
			$result->whereEqual( $field, $value );

		return $result->first()->execute();
	}


	/**
	 * @param $id
	 * @return array|int|null
	 * @throws QueryException
	 */
	public function deleteRowById( $id )
	{
		$conditions = $this->getPrimaryKeyConditions( $id );
		$result = QueryBuild::delete( $this->table );
		foreach ( $conditions as $field => $value )
			$result->whereEqual( $field, $value );

		return $result->execute();
	}

	/**
	 * @param $id
	 * @param array $arrayUpdater
	 * @return array|int|null
	 * @throws \Qpdb\QueryBuilder\Dependencies\QueryException
	 */
	public function updateRowById( $id, array $arrayUpdater )
	{
		$conditions = $this->getPrimaryKeyConditions( $id );
		$result = QueryBuild::update( $this->table );
		foreach ( $conditions as $field => $value )
			$result->whereEqual( $field, $value );
		$result->setFieldsByArray( $arrayUpdater );

		return $result->execute();
	}


	/**
	 * @param array $arrayValues
	 * @return bool|mixed|\PDOStatement
	 * @throws QueryException
	 */
	public function insertRow( array $arrayValues )
	{
		return QueryBuild::insert( $this->table )->setFieldsByArray( $arrayValues )->execute();
	}

	/**
	 * @param array $updates_ord
	 * @return bool|\PDOStatement
	 * @throws QueryException
	 */
	public function saveOrder( $updates_ord = array() )
	{
		if ( empty( $this->orderField ) )
			throw new QueryException( 'Order field is not defined' );

		$query = /** @lang text */
			"UPDATE `{$this->table}` SET `{$this->orderField}` = CASE `{$this->primary[0]}` \r\n";
		foreach ( $updates_ord as $position => $id ) {
			$pos = $position + 1;
			$query .= " WHEN '$id' THEN '$pos' \r\n";
		}
		$query .= "ELSE `{$this->orderField}` END";

		return PdoWrapperService::getInstance()->query($query, []);
	}


	/**
	 * @param mixed
	 * @return array
	 * @throws QueryException
	 */
	protected function getPrimaryKeyConditions( $id )
	{
		if ( !is_array( $id ) )
			$id = [ $id ];

		if ( count( $this->primary ) !== count( $id ) )

It seems like $this->primary can also be of type string; however, parameter $var of count() does only seem to accept Countable|array, maybe add an additional type check?

			throw new QueryException( 'Invalid primary key', QueryException::QUERY_CRUD_INVALID_PRIMARY );

		$conditions = [];

		foreach ( $this->primary as $index => $key )
			$conditions[ $key ] = $id[ $index ];

		return $conditions;
	}


}