<?php
class Db
{
public static function getConnection()
{
$paramsPath = ROOT . '/cfg/db_connect.php';
$params = require $paramsPath;
try{
$dbConnect = "mysql:host={$params['host']};dbname={$params['name']}";
$db = new PDO($dbConnect, $params['user'], $params['password']);
$db->setAttribute( PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION );
}
catch (PDOException $e) {
print "Error!: " . $e->getMessage() . "<br/>";
exit();
}
return $db;
}
//Выбор из базы
static function sqlSelectAll($table, $par)
{
$db = self::getConnection();
$result = $db->query('SELECT '.$par.' FROM `'.$table.'`');
$result->execute();
$result = $result->fetch(PDO::FETCH_ASSOC);
return $result;
}
//Выбор из базы по параметрам
static function sqlSelect($table, $par, $sql, $params){
$db = self::getConnection();
$result = $db->prepare('SELECT '.$par.' FROM `'.$table.'` WHERE '.$sql.'');
$result->execute($params);
$result = $result->fetch(PDO::FETCH_ASSOC);
return $result;
}
//Запись в базу
static function sqlInsert($table, $par, $values, $params)
{
$db = self::getConnection();
$result = $db->prepare('INSERT INTO `'.$table.'` '.$par.' VALUES '.$values.'')->execute($params);
return $result;
}
//Обновление базы
static function sqlUpdate($table, $sql, $par, $params)
{
$db = self::getConnection();
$result = $db->prepare('UPDATE `'.$table.'` SET '.$sql.' WHERE '.$par.'');
$result->execute($params);
return $result;
}
//Удаление из базы
static function sqlDel($table, $sql, $params)
{
$db = self::getConnection();
$result = $db->prepare('DELETE FROM `'.$table.'` WHERE '.$sql.'')->execute($params);
return $result;
}
//Запрос для циклов
static function sqlWhile($table, $par, $sql, $params)
{
$db = self::getConnection();
$result = $db->prepare('SELECT '.$par.' FROM `'.$table.'` WHERE '.$sql.'');
$result->execute($params);
return $result;
}
}