add db postgre

engine/app/model/MusicModel.php

@@ -1,10 +1,16 @@
 <?php
+
 namespace App\Model;
 
+use Shalex\Engine\DataBase;
+
 class MusicModel
 {
     static function getData()
     {
+        $db = new DataBase();
+        $result = $db->getDataBase('SELECT * FROM top_chart');
+        var_dump($result);
         $box = [];
         if ($handle = opendir('./uploads')) {
             while (false !== ($entry = readdir($handle))) {

engine/core/DataBase.php

@@ -0,0 +1,101 @@
+<?php
+
+namespace Shalex\Engine;
+
+define('DB_PERSISTENCY', 'true');
+define('DB_SERVER', '127.127.126.49');
+define('DB_USERNAME', 'music');
+define('DB_PASSWORD', '123');
+define('DB_DATABASE', 'music');
+define('PDO_DSN', 'pgsql:host=' . DB_SERVER . ';dbname=' . DB_DATABASE);
+
+
+class DataBase
+{
+
+    private static $db;
+
+    // Clear the PDO class instance
+    public static function Close()
+    {
+        self::$db = null;
+    }
+
+    protected function createTable(\PDO $db)
+    {
+
+
+
+        $db->exec("
+        CREATE TABLE IF NOT EXISTS top_chart (
+            id INT(4) serial PRIMARY KEY,
+            name varchar(100),
+            url varchar(100),
+        )");
+    }
+
+
+    public function openDataBase()
+    {
+        if (!isset(self::$db)) {
+            // Execute code catching potential exceptions
+            try {
+                // $options = array(\PDO::ATTR_PERSISTENT => DB_PERSISTENCY, \PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES UTF8');
+                self::$db = new \PDO(PDO_DSN, DB_USERNAME, DB_PASSWORD);
+                // self::$db->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
+                // $this->createTable(self::$db);
+            } catch (\PDOException $e) {
+                // Close the database handler and trigger an error
+                self::Close();
+                trigger_error($e->getMessage(), E_USER_ERROR);
+            }
+        }
+        return self::$db;
+    }
+
+    public function lastInsertId()
+    {
+        $db = $this->openDataBase();
+        return $db->lastInsertId();
+    }
+
+    public function setDataBase($string)
+    {
+        $db = $this->openDataBase();
+        $db->exec($string);
+    }
+
+    public function setBasePrepare($query, $data)
+    {
+        $db = $this->openDataBase();
+        $stmt = $db->prepare($query);
+        $stmt->execute($data);
+    }
+
+    public function getDataBase($string)
+    {
+        $db = $this->openDataBase();
+        $query = $db->query($string);
+        if ($query) {
+            return $query->fetchAll(\PDO::FETCH_ASSOC);
+        } else {
+            return false;
+        }
+    }
+
+    public function rowCount($query, $data)
+    {
+        $db = $this->openDataBase();
+        $stmt = $db->prepare($query);
+        $stmt->execute($data);
+        return $stmt->rowCount();
+    }
+
+    public function getBasePrepare($query, $data)
+    {
+        $db = $this->openDataBase();
+        $stmt = $db->prepare($query);
+        $stmt->execute($data);
+        return $stmt->fetchAll(\PDO::FETCH_ASSOC);
+    }
+}