51 lines
1.2 KiB
PHP
51 lines
1.2 KiB
PHP
<?php
|
|
namespace Core;
|
|
|
|
use App\Config;
|
|
|
|
abstract class Model
|
|
{
|
|
protected static $conn = null;
|
|
|
|
protected static function connectDB()
|
|
{
|
|
try {
|
|
if (!self::$conn) {
|
|
$dsn = 'mysql:host='.Config::DB_HOST.';dbname='.Config::DB_DB;
|
|
self::$conn = new \PDO($dsn, Config::DB_UNAME, Config::DB_PWD);
|
|
|
|
self::$conn->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
|
|
}
|
|
return self::$conn;
|
|
} catch (PDOException $e) {
|
|
echo $e->getMessage();
|
|
}
|
|
}
|
|
|
|
public function createTable($table, $fields = [])
|
|
{
|
|
$sql = "CREATE TABLE IF NOT EXISTS {$table} (".implode(',', $fields).") ENGINE=InnoDB DEFAULT CHARSET=utf8;";
|
|
|
|
$db = static::connectDB();
|
|
$query = $db->prepare($sql);
|
|
|
|
if ($query->execute()) {
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
public function dropTable($table)
|
|
{
|
|
$sql = "DROP TABLE IF EXISTS {$table}";
|
|
|
|
$db = static::connectDB();
|
|
$query = $db->prepare($sql);
|
|
|
|
if ($query->execute()) {
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
}
|