class Database {

// Экземпляр класса
    private static $instance;
// Дескрипторы
    private $pdo = array();
// Prepared Statement обьект 
    private $stmt;
// Текущее соединение
    private $nowConnection;

// Нельзя создать экземпляр класса через конструктор
    private function __construct() {
        
    }

// Получение экземпляра только через метод instance()
    public static function instance() {
        if (empty(self::$instance)) {
            self::$instance = new self;
        }
        return self::$instance;
    }

// Добавление нового соединения
    public function addConnection($host, $db, $user, $pass, $id, $port = false, $charset = "utf8") {
        try {
// Определяем порт
            if (!$port)
                $port = ini_get("mysql.default_port");
// Драйвер
            $dsn = "mysql:";
// Хост
            $dsn .= "host={$host};";
// Порт
            $dsn .= "port={$port};";
// База данных
            $dsn .= "dbname={$db};";
// Кодировка
            $options = array(
                PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES {$charset}",
            );
            if (!isset($this->pdo[$id])) {
// Если ещё не подключены к базе - подключаемся
                $this->pdo[$id] = new PDO($dsn, $user, $pass, $options);
                $this->pdo[$id]->setAttribute( PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION );
            }
// И устанавливаем как текущее соединение
            $this->switchConnection($id);
        } catch (PDOException $e) {
// В случае ошибки - бросам исключение
            throw new DatabaseExeption("[Database.php]Error in switchConnection(): " . $e->getMessage());
        }
    }

// Переключает активное соединение
    public function switchConnection($id) {
        if (isset($this->pdo[$id])) {
// Устанавливаем соединение $id как текущее
            $this->nowConnection = &$this->pdo[$id];
        } else {
// В случае, если нет соединение $id - бросаем исключение
            throw new DatabaseExeption("[Database.php]Error in switchConnection(): There is no connections called {$id}");
        }
    }

// Запрос к базе данных
    public function query() {
// Получаем аргументы
        $args = func_get_args();
// Первый аргумент - шаблон
        $query = array_shift($args);
        try {
// Если запрос не требует prepared statement - вызов simplyQuery
            if (empty($args))
                $this->simplyQuery($query);
// Если аргументы для placeholders переданны как массив - вызываем stmtQuery() с передачей массива
            elseif (is_array($args[0]))
                $this->stmtQuery($query, $args[0]);
// Иначе собираем аргументы в массив самостоятельно и вызываем stmtQuery()
            else
                $this->stmtQuery($query, $args);
        } catch (PDOException $e) {
// В случае ошибки - бросам исключение
            throw new DatabaseExeption("[Database.php]Error in query: " . $e->getMessage());
        }
    }

// Запрос, не требующий prepared statement
    private function simplyQuery($query) {
// Просто выполняем запрос
        $this->stmt = $this->nowConnection->query($query);
    }

// Запрос, требующий prepared statement
    private function stmtQuery($query, $args) {
// Подготавливаем запрос
        $this->stmt = $this->nowConnection->prepare($query);
// Выполняем
        $this->stmt->execute($args);
    }

// Получение строк, затронутых запросом
    public function affectedRows() {
        $this->rowCount();
    }

// Получение строк в результирующем наборе
    public function numRows() {
        $this->rowCount();
    }

// Подсчёт строк после запроса
    private function rowCount() {
        try {
            // Возвращаем rowCount()
            return $this->stmt->rowCount();
        } catch (PDOException $e) {
            // В случе ошибки бросаем исключение
            throw new DatabaseExeption("[Database.php]Error in rowCount() " . $e->getMessage());
        }
    }
}