Quantum\Libraries\Database\Adapters\Idiorm\Statements\Query

Complexity

Total Complexity

12

Size/Duplication

Total Lines	86
Duplicated Lines	0 %

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	lastQuery()	0	7	2
A	execute()	0	7	2
A	queryLog()	0	7	2
A	lastStatement()	0	7	2
A	fetchColumns()	0	12	2
A	query()	0	7	2

<?php

/**
 * Quantum PHP Framework
 *
 * An open source software development framework for PHP
 *
 * @package Quantum
 * @author Arman Ag. <arman.ag@softberg.org>
 * @copyright Copyright (c) 2018 Softberg LLC (https://softberg.org)
 * @link http://quantum.softberg.org/
 * @since 2.9.5
 */

namespace Quantum\Libraries\Database\Adapters\Idiorm\Statements;

use Quantum\Libraries\Database\Exceptions\DatabaseException;

/**
 * Trait Query
 * @package Quantum\Libraries\Database
 */
trait Query
{

    /**
     * @inheritDoc
     * @throws DatabaseException
     */
    public static function execute(string $query, array $parameters = []): bool
    {
        if (!self::getConnection()) {
            throw DatabaseException::missingConfig();
        }

        return (self::$ormClass)::raw_execute($query, $parameters);
    }

    /**
     * @inheritDoc
     * @throws DatabaseException
     */
    public static function query(string $query, array $parameters = []): array
    {
        if (!self::getConnection()) {
            throw DatabaseException::missingConfig();
        }

        return (self::$ormClass)::for_table('dummy')->raw_query($query, $parameters)->find_array();
    }

    /**
     * @inheritDoc
     * @throws DatabaseException
     */
    public static function lastQuery(): ?string
    {
        if (!self::getConnection()) {
            throw DatabaseException::missingConfig();
        }

        return (self::$ormClass)::get_last_query();
    }

    /**
     * @inheritDoc
     * @throws DatabaseException
     */
    public static function lastStatement(): object
    {
        if (!self::getConnection()) {
            throw DatabaseException::missingConfig();
        }

        return (self::$ormClass)::get_last_statement();
    }

    /**
     * @inheritDoc
     * @throws DatabaseException
     */
    public static function queryLog(): array
    {
        if (!self::getConnection()) {
            throw DatabaseException::missingConfig();
        }

        return (self::$ormClass)::get_query_log();
    }

    /**
     * Fetches columns of the table
     * @param string $table
     * @return array
     * @throws DatabaseException
     */
    public static function fetchColumns(string $table): array
    {
        $columns = [];

        self::query('SELECT * FROM ' . $table);
        $statement = self::lastStatement();

        for ($i = 0; $i < $statement->columnCount(); $i++) {
            $columns[] = $statement->getColumnMeta($i)['name'];
        }

        return $columns;
    }
}