fruithostPanel/classes/Storage/DatabaseFactory.class.php

<?php
	/**
	 * fruithost | OpenSource Hosting
	 *
	 * @author Adrian Preuß
	 * @version 1.0.0
	 * @license MIT
	 */

	namespace fruithost\Storage;

	class DatabaseFactory extends \PDO {
		private static ?DatabaseFactory $instance = null;
		
		public function __construct(string $dsn, ?string $username = null, #[\SensitiveParameter] ?string $password = null, ?array $options = null) {
			parent::__construct($dsn, $username, $password, $options);
		}
		
		public static function getInstance($host = 'mysql:host=%s;port=%d;dbname=%s') : DatabaseFactory {
			if(self::$instance === null) {
				self::$instance = new self(sprintf($host, DATABASE_HOSTNAME, DATABASE_PORT, DATABASE_NAME), DATABASE_USERNAME, DATABASE_PASSWORD, [
					\PDO::MYSQL_ATTR_INIT_COMMAND	=> 'SET NAMES utf8',
					#\PDO::ATTR_ERRMODE				=> \PDO::ERRMODE_EXCEPTION,
					#\PDO::ATTR_EMULATE_PREPARES	=> false
				]);
			}
			
			return self::$instance;
		}
		
		public function getError(?object $object = null) : array | false {
			if(empty($object)) {
				return $this->errorInfo();
			}
			
			return $object->errorInfo();
		}
		
		public function tableExists(string $table) : bool {
			$result = $this->single('SELECT count(*) AS `result` FROM information_schema.TABLES WHERE (TABLE_SCHEMA=\'' . DATABASE_NAME . '\') AND (TABLE_NAME=\'' . $table . '\')');
			
			if(isset($result) && $result !== null) {
				return $result->result == 1;
			}
			
			return false;
		}
		
		public function file(string $file, callable $callback) :void {
			try {
				if(!file_exists($file)) {
					throw new \Exception(sprintf('Can\'t found file: %s', $file));
					return;
				}
				
				$sql = file_get_contents($file);
				
				if(empty(trim($sql))) {
					throw new \Exception(sprintf('File is empty: %s', $file));
					return;
				}
				
				$sql = str_replace([
					'[DATABASE_PREFIX]'
				], [
					DATABASE_PREFIX
				], $sql);
				
				$stmt = $this->query($sql);
				
				//var_dump($stmt);
				
				if(!$stmt) {
					throw new \Exception(sprintf('SQL Error: ', $this->errorInfo()));
					return;
				}
				
				call_user_func_array($callback, [ null ]);
			} catch(\Exception $e) {
				call_user_func_array($callback, [ $e ]);
			}
		}
		
		public function query(string $query, ?int $fetchMode = null, mixed ...$parameters) : \PDOStatement | false {
			$parameters	= (isset($parameters[0]) ? $parameters[0] : $parameters);
			$stmt		= $this->prepare($query);
			
			if($stmt) {
				$stmt->execute($parameters);
			}
			
			return $stmt;
		}
		
		public function single(string $query, array $parameters = []) : mixed {
			return $this->query($query, null, $parameters)->fetch(\PDO::FETCH_OBJ);
		}
		
		public function count(string $query, array $parameters = []) : int {
			return $this->query($query, null, $parameters)->rowCount();
		}
		
		public function fetch(string $query, array $parameters = []) : array | false {
			return $this->query($query, null, $parameters)->fetchAll(\PDO::FETCH_OBJ);
		}
		
		public function update(string $table, string | array $where, array $parameters = []) : array | false {
			$fields = '';
			
			foreach($parameters AS $name => $value) {
				$fields .= sprintf('`%1$s`=:%1$s, ', $name);
			}
			
			if(is_array($where)) {
				$query	= sprintf('UPDATE `%1$s` SET %2$s WHERE', $table, rtrim($fields, ', '));
				$checks	= [];
				
				foreach($where AS $entry) {
					$checks[] = sprintf('`%1$s`=:%1$s', $entry);
				}
				
				$query .= implode(' AND ', $checks);
			} else {
				$query = sprintf('UPDATE `%1$s` SET %2$s WHERE `%3$s`=:%3$s', $table, rtrim($fields, ', '), $where);
			}
			
			return $this->query($query, null, $parameters)->fetchAll(\PDO::FETCH_OBJ);
		}
		
		public function reset(string $table, string $where, string $old, string $new) : \PDOStatement | false {
			return $this->query(sprintf('UPDATE `%1$s` SET %2$s=%4$d WHERE `%2$s`=:%3$d', $table, $where, $old, $new));
		}
		
		public function delete(string $table, array $parameters = []) : \PDOStatement | false {
			$where = [];
			
			foreach($parameters AS $name => $value) {
				$where[] = sprintf('`%s`=:%s', $name, $name);
			}
			
			return $this->query(sprintf('DELETE FROM `%s` WHERE %s', $table, implode(' AND ', $where)), null, $parameters);
		}
		
		public function deleteWhereNot(string $table, array $delete_not = [], array $parameters = []) : \PDOStatement | false {
			$where				= [];
			$default_parameters	= [];
			
			foreach($parameters AS $name => $value) {
				$default_parameters[] = sprintf('`%s`=:%s', $name, $name);
			}
			
			foreach($delete_not AS $name => $values) {
				if(is_array($values)) {
					foreach($values AS $index => $value) {
						$parameters[$name . '_' . $index]	= $value;
						$where[]							= sprintf('(`%s`!=:%s_%d AND %s)', $name, $name, $index, implode(' AND ', $default_parameters));
					}
				} else {
					$parameters[$name]	= $values;
					$where[]			= sprintf('(`%s`!=:%s AND ?)', $name, $name);
				}
			}
			
			return $this->query(sprintf('DELETE FROM `%s` WHERE %s', $table, implode(' AND ', $where)), null, $parameters);
		}
		
		public function insert(string $table, array $parameters = []) : int {
			$names		= [];
			$values		= [];
			
			foreach($parameters AS $name => $value) {
				$names[]	= '`' . $name . '`';
				$values[]	= ':' . $name;
			}
			
			$this->query(sprintf('INSERT INTO `%s` (%s) VALUES (%s)', $table, implode(', ', $names), implode(', ', $values)), null, $parameters);
			
			return $this->lastInsertId();
		}
	}
?>