Kumbia\ActiveRecord\BaseRecord

Complexity

Total Complexity

28

Size/Duplication

Total Lines	281
Duplicated Lines	2.49 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	7
Bugs	1	Features	1

21 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	alias()	0	4	1
A	getPK()	0	8	2
A	getTable()	0	4	1
A	getSource()	0	9	2
A	getDatabase()	0	4	1
A	dump()	0	6	2
A	hasPK()	0	7	2
A	getSchema()	0	4	1
A	metadata()	0	9	1
A	dbh()	0	4	1
A	prepare()	0	7	1
A	lastInsertId()	0	4	1
A	sql()	0	7	1
A	query()	0	13	4
A	exists()	7	7	1
A	paginateQuery()	0	4	1
A	getDriver()	0	4	1
A	begin()	0	4	1
A	rollback()	0	4	1
A	commit()	0	4	1

<?php
/**
 * KumbiaPHP web & app Framework.
 *
 * LICENSE
 *
 * This source file is subject to the new BSD license that is bundled
 * with this package in the file LICENSE.txt.
 * It is also available through the world-wide-web at this URL:
 * http://wiki.kumbiaphp.com/Licencia
 * If you did not receive a copy of the license and are unable to
 * obtain it through the world-wide-web, please send an email
 * to license@kumbiaphp.com so we can send you a copy immediately.
 *
 * @category   Kumbia
 *
 * @copyright  2005 - 2016 Kumbia Team (http://www.kumbiaphp.com)
 * @license    http://wiki.kumbiaphp.com/Licencia     New BSD License
 */
namespace Kumbia\ActiveRecord;

/**
 * Base del ORM ActiveRecord.
 */
class BaseRecord
{
    /**
     * Database por defecto usa default.
     *
     * @var string
     */
    protected static $database = 'default';

    /**
     * PK por defecto, si no existe mira en metadata.
     *
     * @var string
     */
    protected static $pk = 'id';

    /**
     * Constructor.
     *
     * @param array $data
     */
    public function __construct(array $data = [])
    {
        $this->dump($data);
    }

    /**
     * Cargar datos al objeto.
     *
     * @param array $data
     */
    public function dump(array $data = [])
    {
        foreach ($data as $k => $v) {
            $this->$k = $v;
        }
    }

    /**
     * Alias de los campos.
     *
     * @return array
     */
    public static function alias()
    {
        return [];
    }

    /**
     * Verifica que PK este seteado.
     *
     * @throw \KumbiaException
     */
    protected function hasPK()
    {
        $pk = static::getPK();
        if (empty($this->$pk)) {
            throw new \KumbiaException(__('No se ha especificado valor para la clave primaria'));
        }
    }

    /**
     * Obtiene la llave primaria.
     *
     * @return string
     */
    public static function getPK()
    {
        if (static::$pk) {
            return static::$pk;
        }

        return self::metadata()->getPK();
    }

    /**
     * Obtiene nombre de tabla en la bd.
     *
     * @return string smallcase del nombre de la clase
     */
    public static function getTable()
    {
        return strtolower(preg_replace('/([A-Z])/', '_\\1', lcfirst(\get_called_class())));
    }

    /**
     * Obtiene el schema al que pertenece.
     *
     * @return string
     */
    public static function getSchema()
    {
        return '';
    }

    /**
     * Obtiene la combinación de esquema y tabla.
     *
     * @return string
     */
    public static function getSource()
    {
        $source = static::getTable();
        if ($schema = static::getSchema()) {
            $source = "$schema.$source";
        }

        return $source;
    }

    /**
     * Obtiene la conexión que se utilizará (contenidas en databases.php).
     *
     * @return string
     */
    public static function getDatabase()
    {
        return static::$database;
    }

    /**
     * Obtiene metadatos.
     *
     * @return Metadata\Metadata
     */
    public static function metadata()
    {
        return Metadata\Metadata::get(
            static::getDriver(),
            static::getDatabase(),
            static::getTable(),
            static::getSchema()
        );
    }

    /**
     * Obtiene manejador de conexion a la base de datos.
     *
     * @param bool $force forzar nueva conexion PDO
     *
     * @return \PDO
     */
    protected static function dbh($force = false)
    {
        return Db::get(static::getDatabase(), $force);
    }

    /**
     * Consulta sql preparada.
     *
     * @param string $sql
     *
     * @return \PDOStatement
     * @throw \PDOException
     */
    public static function prepare($sql)
    {
        $sth = self::dbh()->prepare($sql);
        $sth->setFetchMode(\PDO::FETCH_CLASS, \get_called_class());

        return $sth;
    }

    /**
     * Retorna el último ID insertado.
     *
     * @return ID
     */
    public static function lastInsertId()
    {
        return self::dbh()->lastInsertId();
    }

    /**
     * Consulta sql.
     *
     * @param string $sql
     *
     * @return \PDOStatement
     * @throw PDOException
     */
    public static function sql($sql)
    {
        $sth = self::dbh()->query($sql);
        $sth->setFetchMode(\PDO::FETCH_CLASS, \get_called_class());

        return $sth;
    }

    /**
     * Ejecuta consulta sql.
     *
     * @param string         $sql
     * @param array | string $values valores
     *
     * @return PDOStatement
     */
    public static function query($sql, $values = null)
    {
        if (func_num_args() === 1) {
            return self::sql($sql);
        }

        $sth = self::prepare($sql);
        if (!is_array($values)) {
            $values = \array_slice(\func_get_args(), 1);
        }

        return $sth->execute($values) ? $sth : false;
    }

    /**
     * Verifica si existe el registro.
     *
     * @param string $pk valor para clave primaria
     *
     * @return bool
     */
    public static function exists($pk)

This method seems to be duplicated in your project.

    {
        $source = static::getSource();
        $pkField = static::getPK();

        return self::query("SELECT COUNT(*) AS count FROM $source WHERE $pkField = ?", $pk)->fetch()->count > 0;
    }

    /**
     * Paginar consulta sql.
     *
     * @param string $sql     consulta select sql
     * @param int    $page    numero de pagina
     * @param int    $perPage cantidad de items por pagina
     * @param array  $values  valores
     *
     * @return Paginator
     */
    public static function paginateQuery($sql, $page, $perPage, $values = [])
    {
        return new Paginator(\get_called_class(), $sql, (int) $page, (int) $perPage, $values);
    }

    /**
     * Devuelve el nombre del drive PDO utilizado.
     *
     * @return string
     */
    public static function getDriver()
    {
        return self::dbh()->getAttribute(\PDO::ATTR_DRIVER_NAME);
    }

    /**
     * Comienza una trasacción.
     *
     * @return bool
     */
    public static function begin()
    {
        return self::dbh()->beginTransaction();
    }

    /**
     * Da marcha atrás a una trasacción.
     *
     * @return bool
     */
    public static function rollback()
    {
        return self::dbh()->rollBack();
    }

    /**
     * Realiza el commit de  una trasacción.
     *
     * @return bool
     */
    public static function commit()
    {
        return self::dbh()->commit();
    }
}