GeekLab\GLPDO2\GLPDO2

Complexity

Total Complexity

14

Size/Duplication

Total Lines	188
Duplicated Lines	0 %

Importance

Changes	6
Bugs	1	Features	0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	queryUpdate()	0	3	1
A	inTransaction()	0	3	1
A	rollback()	0	3	1
A	__construct()	0	3	1
A	queryInsert()	0	12	2
A	commit()	0	3	1
A	beginTransaction()	0	3	1
A	selectRow()	0	7	1
A	queryAffectedRows()	0	7	1
A	queryDelete()	0	3	1
A	selectRows()	0	6	1
A	selectValueCaseSensitive()	0	8	1
A	selectValue()	0	10	1

<?php

namespace GeekLab\GLPDO2;

// Make EA inspection stop complaining.
use \PDO;
use \Exception;

class GLPDO2
{
    /** @var PDO $PDO */
    private $PDO;

    public function __construct(PDO $pdo)
    {
        $this->PDO = $pdo;
    }

    /**
     * Begin transaction.
     *
     * @return bool
     */
    public function beginTransaction(): bool
    {
        return $this->PDO->beginTransaction();
    }

    /**
     * Is the operation in the middle of the transaction?
     *
     * @return bool
     */
    public function inTransaction(): bool
    {
        return $this->PDO->inTransaction();
    }

    /**
     * Commit transaction.
     *
     * @return bool
     */
    public function commit(): bool
    {
        return $this->PDO->commit();
    }

    /**
     * Rollback transaction.
     *
     * @return bool
     */
    public function rollback(): bool
    {
        return $this->PDO->rollBack();
    }

    /**
     * Perform UPDATE or DELETE query and return the number of affected rows.
     *
     * @param Statement $Statement
     *
     * @return int
     * @throws Exception
     */
    private function queryAffectedRows(Statement $Statement): int
    {
        // Execute statement
        $sth = $Statement->execute($this->PDO);

        // Return number of rows affected
        return $sth->rowCount();
    }

    /**
     * Perform DELETE query.
     *
     * @param Statement $Statement
     *
     * @return int
     * @throws Exception
     */
    public function queryDelete(Statement $Statement): int
    {
        return $this->queryAffectedRows($Statement);
    }

    /**
     * Perform UPDATE query
     *
     * @param Statement $Statement
     *
     * @return int
     * @throws Exception
     */
    public function queryUpdate(Statement $Statement): int
    {
        return $this->queryAffectedRows($Statement);
    }

    /**
     * Perform INSERT query
     *
     * @param Statement $Statement
     *
     * @return bool|string
     * @throws Exception
     */
    public function queryInsert(Statement $Statement)
    {
        // Execute the statement
        $sth = $Statement->execute($this->PDO);

        if (!$sth->rowCount()) {
            // Insert failed
            return false;
        }

        // Return the ID
        return $this->PDO->lastInsertId();
    }

    /**
     * Return multiple rows result as an array
     *
     * @param Statement $Statement
     *
     * @return array|false
     * @throws Exception
     */
    public function selectRows(Statement $Statement)
    {
        // Execute the statement
        $sth = $Statement->execute($this->PDO);

        return $sth->fetchAll(PDO::FETCH_ASSOC);
    }

    /**
     * Execute statement and returns first row of results as an associative array.
     *
     * @param Statement $Statement
     *
     * @return mixed
     * @throws Exception
     */
    public function selectRow(Statement $Statement)
    {
        // Execute the statement
        $sth = $Statement->execute($this->PDO);

        // Return the first row fetched
        return $sth->fetch(PDO::FETCH_ASSOC);
    }

    /**
     * Executes statement and return a specific column from the first row of results.
     *
     * @param Statement $Statement
     * @param string $column
     * @param mixed $default
     *
     * @return string|null
     * @throws Exception
     */
    public function selectValue(
        Statement $Statement,
        string $column,
        $default = null
    ): ?string {
        $row = $this->selectRow($Statement);
        $row = array_change_key_case($row);
        $column = strtolower($column);

        return $row[$column] ?? $default;
    }

    /**
     * Executes statement and return a specific column from the first row of results.
     *
     * @param Statement $Statement
     * @param string $column
     * @param mixed $default
     *
     * @return string|null
     * @throws Exception
     */
    public function selectValueCaseSensitive(
        Statement $Statement,
        string $column,
        $default = null
    ): ?string {
        $row = $this->selectRow($Statement);

        return $row[$column] ?? $default;
    }
}