121 lines
3.2 KiB
PHP
121 lines
3.2 KiB
PHP
<?php
|
|
|
|
namespace Database;
|
|
|
|
use Exception;
|
|
use PDO;
|
|
|
|
class DataBase
|
|
{
|
|
|
|
private $connection;
|
|
private $options = [PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8"];
|
|
|
|
private $dbHost = DB_HOST;
|
|
private $dbName = DB_NAME;
|
|
private $dbUsername = DB_USERNAME;
|
|
private $dbPassword = DB_PASSWORD;
|
|
|
|
public function __construct()
|
|
{
|
|
|
|
try {
|
|
$this->connection = new PDO('mysql:host=' . $this->dbHost . ";dbname=" . $this->dbName, $this->dbUsername, $this->dbPassword, $this->options);
|
|
|
|
} catch (Exception $e) {
|
|
echo 'error ' . $e->getMessage();
|
|
return false;
|
|
}
|
|
|
|
}
|
|
|
|
// select('select * from user');
|
|
// select('select * from user WHERE id = ?', [2]);
|
|
public function select($sql, $values = null)
|
|
{
|
|
try {
|
|
|
|
$statement = $this->connection->prepare($sql);
|
|
if ($values == null) {
|
|
$statement->execute();
|
|
} else {
|
|
$statement->execute($values);
|
|
}
|
|
$result = $statement;
|
|
return $result;
|
|
|
|
} catch (Exception $e) {
|
|
echo 'error ' . $e->getMessage();
|
|
return false;
|
|
}
|
|
|
|
}
|
|
|
|
// insert('users', ['email', 'age'], ['ali@yahoo.com', 20]);
|
|
public function insert($tableName, $fields, $values)
|
|
{
|
|
try {
|
|
$statement = $this->connection->prepare("INSERT INTO " . $tableName . "(" . implode(', ', $fields) . ", created_at) VALUES ( :" . implode(', :', $fields) . ", now() );");
|
|
$statement->execute(array_combine($fields, $values));
|
|
return true;
|
|
} catch (Exception $e) {
|
|
echo 'error ' . $e->getMessage();
|
|
return false;
|
|
}
|
|
|
|
}
|
|
|
|
// update('users', 2, ['email', 'age'], ['ali@yahoo.com', 20]);
|
|
// 0 => 'ali@yahoo.com',
|
|
public function update($tableName, $id, $fields, $values)
|
|
{
|
|
$sql = "UPDATE " . $tableName . " SET ";
|
|
foreach (array_combine($fields, $values) as $field => $value) {
|
|
if ($value) {
|
|
$sql .= $field . ' = ?, ';
|
|
} else {
|
|
$sql .= $field . ' = NULL, ';
|
|
}
|
|
}
|
|
$sql .= " updated_at = now()";
|
|
$sql .= " WHERE id = ?";
|
|
|
|
try {
|
|
|
|
$statement = $this->connection->prepare($sql);
|
|
$statement->execute(array_merge(array_filter(array_values($values)), [$id]));
|
|
return true;
|
|
} catch (Exception $e) {
|
|
echo 'error ' . $e->getMessage();
|
|
return false;
|
|
}
|
|
|
|
}
|
|
|
|
// delete('users', 2)
|
|
public function delete($tableName, $id)
|
|
{
|
|
$sql = "DELETE FROM " . $tableName . " WHERE id = ?";
|
|
try {
|
|
$statement = $this->connection->prepare($sql);
|
|
$statement->execute([$id]);
|
|
return true;
|
|
} catch (Exception $e) {
|
|
echo 'error ' . $e->getMessage();
|
|
return false;
|
|
}
|
|
|
|
}
|
|
|
|
public function createTable($query)
|
|
{
|
|
try {
|
|
$this->connection->exec($query);
|
|
return true;
|
|
} catch (Exception $e) {
|
|
echo 'error ' . $e->getMessage();
|
|
return false;
|
|
}
|
|
}
|
|
|
|
}
|