miniflux-legacy/vendor/PicoDb/Database.php

<?php

namespace PicoDb;

class Database
{
    private $logs = array();
    private $pdo;


    public function __construct(array $settings)
    {
        if (! isset($settings['driver'])) {

            throw new \LogicException('You must define a database driver.');
        }

        switch ($settings['driver']) {

            case 'sqlite':
                require_once __DIR__.'/Drivers/Sqlite.php';
                $this->pdo = new Sqlite($settings['filename']);
                break;

            default:
                throw new \LogicException('This database driver is not supported.');
        }

        $this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
    }


    public function setLogMessage($message)
    {
        $this->logs[] = $message;
    }


    public function getLogMessages()
    {
        return implode(', ', $this->logs);
    }


    public function getConnection()
    {
        return $this->pdo;
    }


    public function escapeIdentifier($value)
    {
        return $this->pdo->escapeIdentifier($value);
    }


    public function execute($sql, array $values = array())
    {
        try {

            $this->setLogMessage($sql);
            $this->setLogMessage(implode(', ', $values));

            $rq = $this->pdo->prepare($sql);
            $rq->execute($values);

            return $rq;
        }
        catch (\PDOException $e) {

            $this->setLogMessage($e->getMessage());
            return false;
        }
    }


    public function startTransaction()
    {
        $this->pdo->beginTransaction();
    }


    public function closeTransaction()
    {
        $this->pdo->commit();
    }


    public function cancelTransaction()
    {
        $this->pdo->rollback();
    }


    public function table($table_name)
    {
        return new Table($this, $table_name);
    }


    public function schema()
    {
        require_once __DIR__.'/Schema.php';
        return new Schema($this);
    }
}