Рефакторинг, очистка, работа над ошибками, связанными с базой, отказ от глобальной переменной $user во многих файлах.
Singleton в некоторых местах вместо решения #42. Новые шаги для решения #16 и #52. Closes #42. Closes #32. Closes #31.
This commit is contained in:
Igor Barkov (iwork)
@@ -1,154 +0,0 @@
|
||||
<?php
|
||||
|
||||
|
||||
namespace Battles\Database;
|
||||
use Battles\GameConfigs;
|
||||
use PDO, PDOException;
|
||||
class DBPDO
|
||||
{
|
||||
|
||||
public $pdo;
|
||||
private static $_instance = null;
|
||||
public static DBPDO $db;
|
||||
|
||||
function __construct()
|
||||
{
|
||||
$this->connect();
|
||||
}
|
||||
|
||||
public static function INIT(): DBPDO
|
||||
{
|
||||
if (!self::$_instance) {
|
||||
self::$_instance = new DBPDO();
|
||||
}
|
||||
return self::$_instance;
|
||||
}
|
||||
|
||||
function prep_query($query)
|
||||
{
|
||||
return $this->pdo->prepare($query);
|
||||
}
|
||||
|
||||
|
||||
function connect():bool
|
||||
{
|
||||
if (!$this->pdo) {
|
||||
|
||||
$dsn = 'mysql:dbname=' . GameConfigs::DATABASE_NAME . ';host=' . GameConfigs::DATABASE_HOST . ';port=' . GameConfigs::DATABASE_PORT . ';charset=utf8;';
|
||||
$user = GameConfigs::DATABASE_USER;
|
||||
$password = GameConfigs::DATABASE_PASS;
|
||||
|
||||
try {
|
||||
$this->pdo = new PDO($dsn, $user, $password, array(PDO::ATTR_PERSISTENT => true));
|
||||
return true;
|
||||
} catch (PDOException $e) {
|
||||
die($e->getMessage());
|
||||
}
|
||||
} else {
|
||||
$this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
function table_exists($table_name)
|
||||
{
|
||||
$stmt = $this->prep_query('SHOW TABLES LIKE ?');
|
||||
$stmt->execute(array($table_name));
|
||||
return $stmt->rowCount() > 0;
|
||||
}
|
||||
|
||||
|
||||
function execute($query, $values = null)
|
||||
{
|
||||
if ($values == null) {
|
||||
$values = array();
|
||||
} else if (!is_array($values)) {
|
||||
$values = array($values);
|
||||
}
|
||||
$stmt = $this->prep_query($query);
|
||||
$stmt->execute($values);
|
||||
return $stmt;
|
||||
}
|
||||
|
||||
function fetch($query, $values = null)
|
||||
{
|
||||
if ($values == null) {
|
||||
$values = array();
|
||||
} else if (!is_array($values)) {
|
||||
$values = array($values);
|
||||
}
|
||||
$stmt = $this->execute($query, $values);
|
||||
return $stmt->fetch(PDO::FETCH_ASSOC);
|
||||
}
|
||||
|
||||
function fetchAll($query, $values = null, $key = null)
|
||||
{
|
||||
if ($values == null) {
|
||||
$values = array();
|
||||
} else if (!is_array($values)) {
|
||||
$values = array($values);
|
||||
}
|
||||
$stmt = $this->execute($query, $values);
|
||||
$results = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
||||
|
||||
// Allows the user to retrieve results using a
|
||||
// column from the results as a key for the array
|
||||
if ($key != null && $results[0][$key]) {
|
||||
$keyed_results = array();
|
||||
foreach ($results as $result) {
|
||||
$keyed_results[$result[$key]] = $result;
|
||||
}
|
||||
$results = $keyed_results;
|
||||
}
|
||||
return $results;
|
||||
}
|
||||
|
||||
function ofetch($query, $values = null)
|
||||
{
|
||||
if ($values == null) {
|
||||
$values = array();
|
||||
} else if (!is_array($values)) {
|
||||
$values = array($values);
|
||||
}
|
||||
$stmt = $this->execute($query, $values);
|
||||
return $stmt->fetch(PDO::FETCH_OBJ);
|
||||
}
|
||||
|
||||
function ofetchAll($query, $values = null, $key = null)
|
||||
{
|
||||
if ($values == null) {
|
||||
$values = array();
|
||||
} else if (!is_array($values)) {
|
||||
$values = array($values);
|
||||
}
|
||||
$stmt = $this->execute($query, $values);
|
||||
$results = $stmt->fetchAll(PDO::FETCH_OBJ);
|
||||
|
||||
// Allows the user to retrieve results using a
|
||||
// column from the results as a key for the array
|
||||
if ($key != null && $results[0][$key]) {
|
||||
$keyed_results = (object) array();
|
||||
foreach ($results as $result) {
|
||||
$keyed_results->$result[$key] = $result;
|
||||
}
|
||||
$results = $keyed_results;
|
||||
}
|
||||
return $results;
|
||||
}
|
||||
|
||||
function lastInsertId()
|
||||
{
|
||||
return $this->pdo->lastInsertId();
|
||||
}
|
||||
|
||||
function fetchColumn($query, $values = null) {
|
||||
if (is_null($values)) {
|
||||
$values = [];
|
||||
} elseif (!is_array($values)) {
|
||||
$values = [$values];
|
||||
}
|
||||
$stmt = $this->execute($query, $values);
|
||||
return $stmt->fetchColumn();
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,134 @@
|
||||
<?php
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace Battles\Database;
|
||||
|
||||
use Battles\GameConfigs;
|
||||
use PDO, PDOException;
|
||||
|
||||
class Db
|
||||
{
|
||||
|
||||
private PDO $pdo;
|
||||
private static ?self $_instance = null;
|
||||
|
||||
private function __construct()
|
||||
{
|
||||
$this->connect();
|
||||
}
|
||||
|
||||
private function connect(): void
|
||||
{
|
||||
$dsn = 'mysql:dbname=' . GameConfigs::DATABASE_NAME . ';host=' . GameConfigs::DATABASE_HOST . ';port=' . GameConfigs::DATABASE_PORT . ';charset=utf8;';
|
||||
$user = GameConfigs::DATABASE_USER;
|
||||
$password = GameConfigs::DATABASE_PASS;
|
||||
try {
|
||||
$this->pdo = new PDO($dsn, $user, $password, array(PDO::ATTR_PERSISTENT => true));
|
||||
$this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
|
||||
} catch (PDOException $e) {
|
||||
die($e->getMessage());
|
||||
}
|
||||
}
|
||||
|
||||
public static function getInstance(): self
|
||||
{
|
||||
if (is_null(self::$_instance)) {
|
||||
self::$_instance = new self();
|
||||
}
|
||||
return self::$_instance;
|
||||
}
|
||||
|
||||
public function execute($query, $values = null)
|
||||
{
|
||||
if (is_null($values)) {
|
||||
$values = [];
|
||||
} elseif (!is_array($values)) {
|
||||
$values = [$values];
|
||||
}
|
||||
$stmt = $this->pdo->prepare($query);
|
||||
$stmt->execute($values);
|
||||
return $stmt;
|
||||
}
|
||||
|
||||
public function fetch($query, $values = null)
|
||||
{
|
||||
if (is_null($values)) {
|
||||
$values = [];
|
||||
} elseif (!is_array($values)) {
|
||||
$values = [$values];
|
||||
}
|
||||
$stmt = $this->execute($query, $values);
|
||||
return $stmt->fetch(PDO::FETCH_ASSOC);
|
||||
}
|
||||
|
||||
public function fetchAll($query, $values = null, $key = null): array
|
||||
{
|
||||
if (is_null($values)) {
|
||||
$values = [];
|
||||
} elseif (!is_array($values)) {
|
||||
$values = [$values];
|
||||
}
|
||||
$stmt = $this->execute($query, $values);
|
||||
$results = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
||||
|
||||
// Allows the user to retrieve results using a
|
||||
// column from the results as a key for the array
|
||||
if (!is_null($key) && $results[0][$key]) {
|
||||
$keyed_results = array();
|
||||
foreach ($results as $result) {
|
||||
$keyed_results[$result[$key]] = $result;
|
||||
}
|
||||
$results = $keyed_results;
|
||||
}
|
||||
return $results;
|
||||
}
|
||||
|
||||
public function ofetch($query, $values = null)
|
||||
{
|
||||
if (is_null($values)) {
|
||||
$values = [];
|
||||
} elseif (!is_array($values)) {
|
||||
$values = [$values];
|
||||
}
|
||||
$stmt = $this->execute($query, $values);
|
||||
return $stmt->fetch(PDO::FETCH_OBJ);
|
||||
}
|
||||
|
||||
public function ofetchAll($query, $values = null, $key = null): object
|
||||
{
|
||||
if (is_null($values)) {
|
||||
$values = [];
|
||||
} elseif (!is_array($values)) {
|
||||
$values = [$values];
|
||||
}
|
||||
$stmt = $this->execute($query, $values);
|
||||
$results = $stmt->fetchAll(PDO::FETCH_OBJ);
|
||||
|
||||
// Allows the user to retrieve results using a
|
||||
// column from the results as a key for the array
|
||||
if (!is_null($key) && $results[0][$key]) {
|
||||
$keyed_results = (object)[];
|
||||
foreach ($results as $result) {
|
||||
$keyed_results->$result[$key] = $result;
|
||||
}
|
||||
$results = $keyed_results;
|
||||
}
|
||||
return $results;
|
||||
}
|
||||
|
||||
public function lastInsertId()
|
||||
{
|
||||
return $this->pdo->lastInsertId();
|
||||
}
|
||||
|
||||
public function fetchColumn($query, $values = null)
|
||||
{
|
||||
if (is_null($values)) {
|
||||
$values = [];
|
||||
} elseif (!is_array($values)) {
|
||||
$values = [$values];
|
||||
}
|
||||
$stmt = $this->execute($query, $values);
|
||||
return $stmt->fetchColumn();
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user