miniflux-legacy/miniflux/vendor/PicoDb/Database.php

114 lines
2.2 KiB
PHP
Raw Normal View History

2013-02-18 03:48:21 +01:00
<?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;
/*
case 'mysql':
$this->pdo = new \PDO(
'mysql:host='.$settings['hostname'].';dbname='.$settings['dbname'],
$settings['username'],
$settings['password']
);
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);
}
}