DB::_disconnect() - Code Metrics - Inspection of "Hasta aquí, crea y verifica las tablas definidas s..." - rsanjoseo/alxarafe - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed
Push — main ( a17396...e328ab )

by Rafael
created 2023-01-28 09:59 UTC
DB::_disconnect() A

↳ Parent: DB
Complexity

Conditions	1
Paths	1
Size

Total Lines	3
Code Lines	1
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
cc	1
eloc	1
nc	1
nop	0
dl	0
loc	3
rs	10
c	0
b	0
f	0
<?php
/**
 * Copyright (C) 2022-2023  Rafael San José Tovar   <[email protected]>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program. If not, see <https://www.gnu.org/licenses/>.
 */

namespace Alxarafe\Database;

use Alxarafe\Core\Singletons\Config;
use Alxarafe\Core\Singletons\Debug;
use Alxarafe\Core\Singletons\Translator;
use DebugBar\DebugBarException;
use Exception;

/**
 * Class DB
 *
 * Esta clase proporciona acceso directo a la base de datos.
 *
 * @author  Rafael San José Tovar <[email protected]>
 * @version 2022.0721
 *
 */
abstract class DB
{
    /**
     * Motor utilizado, puede ser MySql, MariaDB, PostgreSql o cualquier otro PDO
     *
     * @var Engine
     */
    public static Engine $engine;

    /**
     * Instancia de la clase con el código SQL específico del motor.
     *
     * @var SqlHelper
     */
    public static SqlHelper $helper;

    /**
     * Prefijo de la base de datos en uso
     *
     * @var string
     */
    public static string $dbPrefix;

    /**
     * Nombre de la base de datos en uso
     *
     * @var string
     */
    public static string $dbName;

    public static $user;
    public static $username;

    /**
     * Establece conexión con una base de datos.
     *
     * TODO: La idea en un futuro, es que se pueda establecer conexión con múltiples
     *       bases de datos pasándole el nombre de la conexión.
     *       El problema es, cómo invocar de forma fácil qué conexión queremos.
     *       Si se mantiene como clase abstracta es complicado, lo más fácil sería
     *       creando una instancia para cada conexión, pero no se podría utilizar como
     *       clase abstracta (o ahora mismo, no caigo en cómo hacerlo).
     *
     * @param string $db
     *
     * @return bool
     * @throws DebugBarException
     */
    public static function connectToDatabase(string $db = 'main'): bool
    {
        // TODO: Revisar ésto, porque debe de haber una conexión para cada base de datos según $db
        if (isset(self::$engine)) {
            return true;
        }

        $dbInfo = Config::getModuleVar('database');
        if (!isset($dbInfo[$db])) {
            Debug::sqlMessage(Translator::trans('empty-database-config', ['%name%' => $db]));
            return false;
        }

        self::$dbPrefix = strtolower($dbInfo[$db]['dbPrefix'] ?? '');
        self::$dbName = strtolower($dbInfo[$db]['dbName']);

        $engineName = $dbInfo[$db]['dbEngineName'] ?? 'PdoMySql';
        $helperName = 'Sql' . substr($engineName, 3);

        Debug::sqlMessage("Using '$engineName' engine.");
        Debug::sqlMessage("Using '$helperName' SQL helper engine.");

        $sqlEngine = '\\Alxarafe\\Database\\SqlHelpers\\' . $helperName;
        $engine = '\\Alxarafe\\Database\\Engines\\' . $engineName;
        try {
            self::$helper = new $sqlEngine();
            self::$engine = new $engine([
                'dbUser' => $dbInfo[$db]['dbUser'],
                'dbPass' => $dbInfo[$db]['dbPass'],
                'dbName' => self::$dbName,
                'dbHost' => $dbInfo[$db]['dbHost'],
                'dbPort' => $dbInfo[$db]['dbPort'],
            ]);
            return isset(self::$engine) && self::$engine->connect() && self::$engine->checkConnection();
        } catch (Exception $e) {
            Debug::addException($e);
        }
        return false;
    }

    public static function _connect()
    {
        return self::$engine[$db]->connect();

    }

    public static function _disconnect()
    {
        return self::$engine[$db]->disconnect();

    }

    public static function _connected()
    {
        return self::$engine[$db]->connected();

    }

    public static function _getDataTypes()
    {
        return self::$helper[$db]->getDataTypes();

    }

    /**
     * Ejecuta una sentencia SQL retornando TRUE si ha tenido éxito
     *
     * @author  Rafael San José Tovar <[email protected]>
     * @version 2022.0721
     *
     * @param string $query
     * @param array  $vars
     *
     * @return bool
     */
    public static function exec(string $query, array $vars = []): bool
    {
        return self::$engine->exec($query, $vars);
        return self::$engine->/** @scrutinizer ignore-call */ exec($query, $vars);
    }

    /**
     * Ejecuta una sentencia SELECT, retornando false si hay error, o un array
     * con el resultado de la consulta.
     *
     * @author  Rafael San José Tovar <[email protected]>
     * @version 2022.0721
     *
     * @param string $query
     * @param array  $vars
     *
     * @return array|false
     */
    public static function select(string $query, array $vars = [])
    {
        return self::$engine->select($query, $vars);
        return self::$engine->/** @scrutinizer ignore-call */ select($query, $vars);
    }

    /**
     * Retorna el tipo de datos que se utiliza para los índices
     *
     * @author Rafael San José Tovar <[email protected]>
     *
     * @return string
     */
    public static function getIndexType(): string
    {
        return self::$helper->getIndexType();
    }

    public static function _getErrors()
    {
        return self::$engine[$db]->getErrors();

    }

    public static function _beginTransaction()
    {
        return self::$engine[$db]->beginTransaction();

    }

    public static function _commit()
    {
        return self::$engine[$db]->commit();

    }

    public static function _close()
    {
        return self::$engine[$db]->close();

    }

    public static function _rollback()
    {
        return self::$engine[$db]->rollback();

    }

    public static function _version()
    {
        return self::$engine[$db]->server_info();

    }

    public static function tableExists(string $tableName)
    {
        return self::$helper->tableExists(self::$dbPrefix . $tableName);
    }

    public static function getColumns(string $tableName)
    {
        return self::$helper->getColumns(self::$dbPrefix . $tableName);
    }

    public static function _yamlFieldToDb(array $data): array
    {
        return self::$helper[$db]::yamlFieldToDb($data);

    }

    public static function _dbFieldToSchema(array $data): array
    {
        return self::$helper[$db]::dbFieldToSchema($data);

    }

    public static function _dbFieldToYaml(array $data): array
    {
        return self::$helper[$db]::dbFieldToYaml($data);

    }

    public static function _normalizeFromDb(array $data)
    {
        $result = self::$helper[$db]::normalizeDbField($data);

        dump([
            'normalizeFromDb',
            'data' => $data,
            'result' => $result,
        ]);
        return $result;
    }

    public static function _normalizeFromYaml(array $yamlFields)
    {
        $result = [];
        foreach ($yamlFields as $field => $yamlField) {
            $result[$field] = self::$helper[$db]::normalizeYamlField($yamlField);

        }
        dump([
            'normalizeFromYaml',
            'data' => $yamlFields,
            'result' => $result,
        ]);
        return $result;
    }

    public static function _normalize(array $data)
    {
        return self::$helper[$db]->normalizeField($data);

    }

    public static function modify(string $tableName, array $oldField, array $newField): string
    {
        return self::$helper->modify(self::$dbPrefix . $tableName, $oldField, $newField);
    }

    public static function _getUsername()
    {
        return self::$username;
    }

    public static function _connectToDatabaseAndAuth(): bool
    {
        if (!self::connectToDataBase()) {
            FlashMessages::setError('Database Connection error...');
filter:
    dependency_paths: ["lib/*"]
            return false;
        }
        if (!isset(self::$user)) {
            self::$user = new Auth();
filter:
    dependency_paths: ["lib/*"]
            self::$username = self::$user->getUser();
            if (self::$username === null) {
                self::$user->login();
            }
        }
        return true;
    }

}

rsanjoseo / alxarafe

Push — main ( a17396...e328ab )

DB::_disconnect() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
