1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
<?php
class MySQL extends DB {
protected function _open() {
@$this->_connection = mysql_connect($this->_conf['server'], $this->_conf['user'], $this->_conf['password']);
if (!$this->_connection) {
throw new Exception('Can\'t connect to MySQL server.');
}
if (!mysql_select_db($this->_conf['database'], $this->_connection)) {
throw new Exception('Database does not exist.');
}
}
protected function _close() {
return mysql_close($this->_connection);
}
protected function _query($sql) {
return mysql_query($sql, $this->_connection);
}
public function affectedRows() {
return mysql_affected_rows($this->_connection);
}
public function numRows() {
return $this->affectedRows();
}
public function error() {
return mysql_error($this->_connection);
}
public function errno() {
return mysql_errno($this->_connection);
}
public function insertId() {
return mysql_insert_id($this->_connection);
}
public function escape($string) {
return mysql_real_escape_string($string, $this->_connection);
}
public function fetch() {
return mysql_fetch_assoc($this->_result);
}
public function freeResult() {
return mysql_free_result($this->_result);
}
public function seek($row = 0) {
return mysql_data_seek($this->_result, $row);
}
}
?>
<?php
/**
* Абстрактный слой для работы с базой данных.
*
* Возможности:
* Поддержка плейсхолдеров.
* Типы плейсхолдеров.
* :tablename -> добавляем префикс к имени таблицы.
* {arg_num}?{flag} -> заменяет на значение.
* Подробнее см справку к методу prepare.
*
* Синтаксис.
* $dbo->{$method}($formatted_sql[, $arg1[, $arg2[, $_args]]]);
*
* Методы с полной поддержкой плейсхолдеров:
* prepare, pquery, one, row, rows
*
* Автоматизация рутинных операций, таких как: несложная выборка, INSERT, UPDATE, DELETE.
* Безопасное добавление и обновление данных(insert, update).
* Если нужно передать в методы insert, update строку как есть, то нужно для использовать метод raw:
* $entry['published'] = $db->raw('DATETIME');
* $db->insert('news', $entry);
*
*/
abstract class DB {
protected $_conf = array('prefix' => ''),
$_connection,
$_sql,
$_result,
$_args,
$_statistics = array('Queries' => 0, 'Execution Time' => 0, 'Total Execution Time' => 0);
abstract protected function _open();
abstract protected function _close();
abstract protected function _query($sql);
abstract public function fetch();
abstract public function numRows();
abstract public function affectedRows();
abstract public function error();
abstract public function errno();
abstract public function insertId();
abstract public function escape($string);
abstract public function freeResult();
abstract public function seek($row);
public function __construct($conf) {
$conf = array_change_key_case($conf);
$defaults = array('prefix' => '');
$conf = array_merge($defaults, $conf);
$this->_conf = $conf;
$this->_open();
}
public function getConf() {
return $this->_conf;
}
public function getSql() {
return $this->_sql;
}
public function getStatistics() {
return $this->_statistics;
}
public function table($name) {
return $this->_conf['prefix'] . $name;
}
/**
* Отправляет 'сырой' запрос, либо подготовленный.
*/
public function query($sql = null) {
if ($sql) {
$this->_sql = $sql;
}
if (is_resource($this->_result)) { // освобождаем предыдущий результат
$this->freeResult();
}
$this->_statistics['Queries'] += 1;
$this->_statistics['Execution Time'] = -microtime(1);
$this->_result = $this->_query($this->_sql);
$this->_statistics['Execution Time'] += microtime(1);
$this->_statistics['Total Execution Time'] += $this->_statistics['Execution Time'];
if (is_bool($this->_result) && !$this->_result) {
throw new Exception('SQL Error Code: ' . $this->errno() . ' - ' . $this->error() . '. Query: "' . $sql .'".');
}
return $this;
}
public function setCharset($charset) {
$this->query("SET NAMES $charset;");
}
public function fetchAll() {
$rows = array();
while ($row = $this->fetch()) {
$rows[] = $row;
}
return $rows;
}
