App\Ship\Utils\Database\LoggerAdapter

Complexity

Total Complexity

8

Size/Duplication

Total Lines	52
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	4
A	up()	0	11	1
A	isTable()	0	3	1
A	checkLog()	0	13	1
A	writeLog()	0	3	1

<?php

namespace App\Ship\Utils\Database;

use Rudra\Model\QBFacade;
use Rudra\Container\Facades\Rudra;
use App\Ship\Utils\Database\Driver\MySQL;
use App\Ship\Utils\Database\Driver\PgSQL;
use App\Ship\Utils\Database\Driver\SQLite;

class LoggerAdapter
{
    protected $driver;
    protected string $table;

    public function __construct()
    {
        if (Rudra::get("DSN")->getAttribute(\PDO::ATTR_DRIVER_NAME) === "mysql") {
            $this->driver = new MySQL($this->table);
        } elseif (Rudra::get("DSN")->getAttribute(\PDO::ATTR_DRIVER_NAME) === "pgsql") {
            $this->driver = new PgSQL($this->table);
        } elseif (Rudra::get("DSN")->getAttribute(\PDO::ATTR_DRIVER_NAME) === "sqlite") {
            $this->driver = new SQLite($this->table);
        }
    }

    public function up(): void
    {
        $query = QBFacade::create($this->table)
            ->integer('id', '', true)
            ->string('name')
            ->created_at()
            ->pk('id')
            ->close()
            ->get();

        Rudra::get("DSN")->prepare("$query")->execute();
    }

    public function isTable()
    {
        return $this->driver->isTable();
    }

    public function writeLog(string $name): void
    {
        $this->driver->writeLog($name);
    }

    public function checkLog(string $name)
    {
        $stmt = Rudra::get("DSN")->prepare(QBFacade::select()
            ->from($this->table)
            ->where('name = :name')
            ->get()
        );

        $stmt->execute([
            ':name' => $name,
        ]);

        return $stmt->fetch(\PDO::FETCH_ASSOC);
    }
}