greg/PdoWrapper
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 5 Wiki Activity

renommage de l'objet DB en Connection, suppression de la variable privée db dans le model

Browse Source
This commit is contained in:
Gregory Letellier
2023-11-03 08:58:42 +01:00
parent d67916e2ff
commit a6c51f5f17
4 changed files with 13 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

197
src/Connection.php Normal file
View File

@@ -0,0 +1,197 @@
<?php
namespace Kletellier\PdoWrapper;
use Dotenv\Dotenv;
use PDO;
use PDOStatement;
class Connection
{
protected PDO $pdo;
protected string $name;
protected string $connstring;
private static array $instances = [];
private string $type;
private ?string $user;
private ?string $password;
private string $database;
private ?string $port;
private ?string $host;
private string $error;
private function __construct($name, $config)
{
$this->error = "";
$this->name = $name;
if (is_array($config)) {
$this->parseArray($config);
} else {
if (is_dir($config)) {
$this->loadEnv($config);
}
}
$this->initPdo();
}
private function parseArray($config)
{
try {
$key = (strtolower(trim($this->name)));
$this->type = isset($config[$key]["TYPE"]) ? $config[$key]["TYPE"] : null;
$this->user = isset($config[$key]["USER"]) ? $config[$key]["USER"] : null;
$this->host = isset($config[$key]["HOST"]) ? $config[$config[$key]["HOST"]] : null;
$this->password = isset($config[$key]["PASSWORD"]) ? $config[$key]["PASSWORD"] : null;
$this->database = isset($config[$key]["DATABASE"]) ? $config[$key]["DATABASE"] : null;
$this->port = isset($config[$key]["PORT"]) ? $config[$key]["PORT"] : null;
} catch (\Throwable $th) {
$this->error = $th->getMessage();
}
}
private function loadEnv($dir)
{
try {
$dotenv = Dotenv::createImmutable($dir);
$dotenv->load();
} catch (\Throwable $th) {
$this->error = $th->getMessage();
}
$this->parseEnv();
}
private function parseEnv()
{
try {
$key = (strtoupper(trim($this->name)));
$this->type = isset($_ENV[$this->getKey("TYPE", $key)]) ? $_ENV[$this->getKey("TYPE", $key)] : null;
$this->user = isset($_ENV[$this->getKey("USER", $key)]) ? $_ENV[$this->getKey("USER", $key)] : null;
$this->host = isset($_ENV[$this->getKey("HOST", $key)]) ? $_ENV[$this->getKey("HOST", $key)] : null;
$this->password = isset($_ENV[$this->getKey("PASSWORD", $key)]) ? $_ENV[$this->getKey("PASSWORD", $key)] : null;
$this->database = isset($_ENV[$this->getKey("DATABASE", $key)]) ? $_ENV[$this->getKey("DATABASE", $key)] : null;
$this->port = isset($_ENV[$this->getKey("PORT", $key)]) ? $_ENV[$this->getKey("PORT", $key)] : null;
} catch (\Throwable $th) {
$this->error = $th->getMessage();
}
}
private function getKey(string $type, string $name): string
{
return "DB_" . $name . "_" . $type;
}
private function initPdo()
{
$this->getConnString();
$this->pdo = new PDO($this->connstring, $this->user, $this->password);
$this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
}
private function bindParams(PDOStatement $stmt, array $data): PDOStatement
{
$iParams = 1;
foreach ($data as $value) {
if ($value instanceof \DateTime) {
$stmt->bindValue($iParams, $value->format('Y-m-d H:i:s'), PDO::PARAM_STR);
} else {
switch (gettype($value)) {
case 'integer':
$stmt->bindValue($iParams, $value, PDO::PARAM_INT);
break;
case 'datetime':
$stmt->bindValue($iParams, $value, PDO::PARAM_STR);
break;
case 'boolean':
$stmt->bindValue($iParams, $value, PDO::PARAM_BOOL);
break;
case 'NULL':
$stmt->bindValue($iParams, $value, PDO::PARAM_NULL);
break;
default:
$stmt->bindValue($iParams, $value, PDO::PARAM_STR);
}
}
$iParams++;
}
return $stmt;
}
private function getConnString()
{
$this->connstring = match ($this->type) {
"mysql" => "mysql:host=" . $this->host . ":" . $this->port . ";dbname=" . $this->database,
"sqlite" => "sqlite:" . $this->database,
};
}
public function executeRawQuery(string $rawquery): bool
{
$stmt = $this->pdo->prepare($rawquery);
return $stmt->execute();
}
public function getSelectQuery(Query $query): mixed
{
$stmt = $this->pdo->prepare($query->getQuery());
$stmt = $this->bindParams($stmt, $query->getData());
EventDispatcher::emit("on.query", $query);
$stmt->execute();
return $stmt->fetchAll(PDO::FETCH_ASSOC);
}
public function updateQuery(Query $query): bool
{
$stmt = $this->pdo->prepare($query->getQuery());
$stmt = $this->bindParams($stmt, $query->getData());
EventDispatcher::emit("on.query", $query);
return $stmt->execute();
}
public function insertQuery(Query $query): mixed
{
$stmt = $this->pdo->prepare($query->getQuery());
$stmt = $this->bindParams($stmt, $query->getData());
EventDispatcher::emit("on.query", $query);
$ok = $stmt->execute();
if ($ok) {
return $this->pdo->lastInsertId();
} else {
return false;
}
}
public static function init($config, array $connections = ["default"])
{
self::fillInstances($config, $connections);
return self::getInstance();
}
private static function fillInstances($config, array $connections)
{
foreach ($connections as $connection) {
if (!isset(self::$instances[$connection])) {
self::$instances[$connection] = new Connection($connection, $config);
}
}
}
public static function getInstance($connection="")
{
if($connection=="" && count(self::$instances)>0)
{
$connection = array_keys(self::$instances)[0];
}
if (isset(self::$instances[$connection])) {
$instance = self::$instances[$connection];
if ($instance instanceof Connection) {
return self::$instances[$connection];
}
}
throw new \Exception("Unknown connection");
}
public function getError()
{
return $this->error;
}
}