still wip

src/Venom/Database/DatabaseHandler.php

@@ -5,6 +5,7 @@ namespace Venom\Database;
 
 
 use PDO;
+use PDOException;
 
 /**
  * Singleton DatabaseHandler... make sure we only have one connection to the database..
@@ -12,6 +13,14 @@ use PDO;
  */
 class DatabaseHandler
 {
+    // constants
+    public const DB_TYPE = 'type';
+    public const DB_HOST = 'host';
+    public const DB_PORT = 'port';
+    public const DB_USER = 'user';
+    public const DB_PASSWORD = 'pw';
+    public const DB_DB = 'db';
+    public const DB_EXTRA = 'extra';
     private static ?self $instance = null;
     private ?PDO $db = null;
 
@@ -30,7 +39,35 @@ class DatabaseHandler
             return;
         }
         $dsn = '%s:host=%s;dbname=%s;port=%s';
-
+        $connectString = sprintf($dsn, $data[self::DB_TYPE], $data[self::DB_HOST], $data[self::DB_DB], $data[self::DB_PORT] . $data[self::DB_EXTRA]);
+        try {
+            $this->db = new PDO($connectString, $data[self::DB_USER], $data[self::DB_PASSWORD]);
+        } catch (PDOException $e) {
+            trigger_error($e->getMessage());
+            die($e->getCode());
+        }
     }
 
+    public function getOne(string $query, array $args): ?array
+    {
+        $data = $this->getAll($query, $args);
+        if (count($data) > 0) {
+            return $data[0];
+        }
+        return null;
+    }
+
+    public function getAll(string $query, array $args): array
+    {
+        $stmt = $this->db->prepare($query);
+        $stmt->setFetchMode(PDO::FETCH_CLASS, DatabaseObject::class);
+        $stmt->execute($args);
+        return $stmt->fetchAll();
+    }
+
+    public function execute(string $query, array $args): void
+    {
+        $stmt = $this->db->prepare($query);
+        $stmt->execute($args);
+    }
 }