From 54113fffc086a6571e661a508070245f6c8191a2 Mon Sep 17 00:00:00 2001
From: Dariusz <u1024@fufle.net>
Date: Sun, 7 Mar 2021 01:15:16 +0100
Subject: [PATCH] connectors

---
 app/Model/Job.php                             |  2 +-
 app/Query/JobQuery.php                        |  2 +-
 src/Fufle/Database/ConnectionManager.php      | 32 ------------
 src/Fufle/Database/Connector/IConnector.php   |  0
 .../Database/Connector/PostgresConnector.php  |  0
 src/Fufle/ORM/Database/ConnectionManager.php  | 52 +++++++++++++++++++
 .../ORM/Database/Connector/IConnector.php     |  9 ++++
 .../Database/Connector/PostgresConnector.php  | 11 ++++
 src/Fufle/ORM/Database/Credentials.php        | 15 ++++++
 src/Fufle/{ => ORM}/Database/QueryData.php    |  2 +-
 src/Fufle/ORM/Model.php                       |  4 +-
 src/Fufle/ORM/Query.php                       |  2 +-
 tests/ModelTests.php                          | 13 ++++-
 13 files changed, 105 insertions(+), 39 deletions(-)
 delete mode 100644 src/Fufle/Database/ConnectionManager.php
 delete mode 100644 src/Fufle/Database/Connector/IConnector.php
 delete mode 100644 src/Fufle/Database/Connector/PostgresConnector.php
 create mode 100644 src/Fufle/ORM/Database/ConnectionManager.php
 create mode 100644 src/Fufle/ORM/Database/Connector/IConnector.php
 create mode 100644 src/Fufle/ORM/Database/Connector/PostgresConnector.php
 create mode 100644 src/Fufle/ORM/Database/Credentials.php
 rename src/Fufle/{ => ORM}/Database/QueryData.php (95%)

diff --git a/app/Model/Job.php b/app/Model/Job.php
index b1bf6e6..27e0a4e 100644
--- a/app/Model/Job.php
+++ b/app/Model/Job.php
@@ -9,7 +9,7 @@ use Fufle\ORM\Model as BaseModel;
 class Job extends BaseModel {
     public int $id;
     public float $budget;
-    public static function QueryModel() {
+    public static function SetQueryModel() {
         return new JobQuery( static::class );
     }
 
diff --git a/app/Query/JobQuery.php b/app/Query/JobQuery.php
index 8f064e9..9f9df4c 100644
--- a/app/Query/JobQuery.php
+++ b/app/Query/JobQuery.php
@@ -7,6 +7,6 @@ use Fufle\ORM\Query as BaseQuery;
 
 class JobQuery extends BaseQuery implements IJobQuery {
     public function GetLast10(): string {
-        return "select * from jobs order by id desc limit 10";
+        return "SELECT * from jobs order by id desc limit 10";
     }
 }
diff --git a/src/Fufle/Database/ConnectionManager.php b/src/Fufle/Database/ConnectionManager.php
deleted file mode 100644
index d1e4ecb..0000000
--- a/src/Fufle/Database/ConnectionManager.php
+++ /dev/null
@@ -1,32 +0,0 @@
-<?php
-
-namespace Fufle\Database;
-
-use PDO;
-use Fufle\Database\QueryData;
-
-class ConnectionManager {
-    private static $connection;
-
-    public static function connect(string $connectionString) {
-        self::$connection = new PDO($connectionString);
-    }
-
-    public static function Query(string $query, array|object $params = [], string $output = 'stdObject') {
-        $data = new QueryData($query, $params);
-        $data->normalize();
-        $stmt = self::$connection->prepare($data->query);
-        $stmt->execute($data->params);
-        $stmt->setFetchMode(PDO::FETCH_CLASS, $output);
-        return $stmt->fetch();
-    }
-
-    public static function QueryAll(string $query, array|object $params = [], string $output = 'stdObject') {
-        $data = new QueryData($query, $params);
-        $data->normalize();
-        $stmt = self::$connection->prepare($data->query);
-        $stmt->execute($data->params);
-        $stmt->setFetchMode(PDO::FETCH_CLASS, $output);
-        return $stmt->fetchAll();
-    }
-}
\ No newline at end of file
diff --git a/src/Fufle/Database/Connector/IConnector.php b/src/Fufle/Database/Connector/IConnector.php
deleted file mode 100644
index e69de29..0000000
diff --git a/src/Fufle/Database/Connector/PostgresConnector.php b/src/Fufle/Database/Connector/PostgresConnector.php
deleted file mode 100644
index e69de29..0000000
diff --git a/src/Fufle/ORM/Database/ConnectionManager.php b/src/Fufle/ORM/Database/ConnectionManager.php
new file mode 100644
index 0000000..54935ef
--- /dev/null
+++ b/src/Fufle/ORM/Database/ConnectionManager.php
@@ -0,0 +1,52 @@
+<?php
+
+namespace Fufle\ORM\Database;
+
+use PDO;
+use Fufle\ORM\Database\QueryData;
+use Fufle\ORM\Database\Connectors\IConnector;
+
+class ConnectionManager {
+    private static $connection;
+    private static $connectors = [];
+    private static string $connectionString;
+    private static Credentials $credentials;
+
+    public static function RegisterConnector(IConnector $connector) {
+        self::$connectors[] = $connector;
+    }
+
+    public static function Connect(string $driver, $host, $port = null, $database = null, $user = null, $password = null) {
+        foreach (self::$connectors as $c) {
+            if ($c->driverEquals($driver)) {
+                $credentials = new Credentials($host, $port, $database, $user, $password);
+                self::$connectionString = $c->getConnectionString($credentials);
+                self::ConnectWithString(self::$connectionString);
+                return;
+            }
+        }
+        throw new Exception('Driver not found');
+    }
+
+    public static function ConnectWithString(string $connectionString) {
+        self::$connection = new PDO($connectionString);
+    }
+
+    public static function Query(string $query, array|object $params = [], string $output = 'stdObject') {
+        $data = new QueryData($query, $params);
+        $data->normalize();
+        $stmt = self::$connection->prepare($data->query);
+        $stmt->execute($data->params);
+        $stmt->setFetchMode(PDO::FETCH_CLASS, $output);
+        return $stmt->fetch();
+    }
+
+    public static function QueryAll(string $query, array|object $params = [], string $output = 'stdObject') {
+        $data = new QueryData($query, $params);
+        $data->normalize();
+        $stmt = self::$connection->prepare($data->query);
+        $stmt->execute($data->params);
+        $stmt->setFetchMode(PDO::FETCH_CLASS, $output);
+        return $stmt->fetchAll();
+    }
+}
\ No newline at end of file
diff --git a/src/Fufle/ORM/Database/Connector/IConnector.php b/src/Fufle/ORM/Database/Connector/IConnector.php
new file mode 100644
index 0000000..0fac25d
--- /dev/null
+++ b/src/Fufle/ORM/Database/Connector/IConnector.php
@@ -0,0 +1,9 @@
+<?php
+
+namespace Fufle\ORM\Database\Connectors;
+
+use Fufle\ORM\Database\Credentials;
+
+class IConnector {
+    public function getConnectionString(Credentials $credentials);
+}
\ No newline at end of file
diff --git a/src/Fufle/ORM/Database/Connector/PostgresConnector.php b/src/Fufle/ORM/Database/Connector/PostgresConnector.php
new file mode 100644
index 0000000..a42dec9
--- /dev/null
+++ b/src/Fufle/ORM/Database/Connector/PostgresConnector.php
@@ -0,0 +1,11 @@
+<?php
+
+namespace Fufle\ORM\Database\Connectors;
+
+use Fufle\ORM\Database\Credentials;
+
+class PostgresConnector implements IConnector {
+    public function getConnectionString(Credentials $credentials) {
+        return "";
+    }
+}
\ No newline at end of file
diff --git a/src/Fufle/ORM/Database/Credentials.php b/src/Fufle/ORM/Database/Credentials.php
new file mode 100644
index 0000000..fbdb52b
--- /dev/null
+++ b/src/Fufle/ORM/Database/Credentials.php
@@ -0,0 +1,15 @@
+<?php
+
+namespace Fufle\ORM\Database;
+
+class Credentials {
+    
+    public function __construct(
+        public string $host,
+        public int $port = null,
+        public string $database = null,
+        public string $user = null,
+        public string $password = null) {
+    }
+    
+}
\ No newline at end of file
diff --git a/src/Fufle/Database/QueryData.php b/src/Fufle/ORM/Database/QueryData.php
similarity index 95%
rename from src/Fufle/Database/QueryData.php
rename to src/Fufle/ORM/Database/QueryData.php
index 3c96740..30e4408 100644
--- a/src/Fufle/Database/QueryData.php
+++ b/src/Fufle/ORM/Database/QueryData.php
@@ -1,6 +1,6 @@
 <?php
 
-namespace Fufle\Database;
+namespace Fufle\ORM\Database;
 
 class QueryData {
     public function __construct(
diff --git a/src/Fufle/ORM/Model.php b/src/Fufle/ORM/Model.php
index 12200d3..f99500c 100644
--- a/src/Fufle/ORM/Model.php
+++ b/src/Fufle/ORM/Model.php
@@ -24,7 +24,7 @@ abstract class Model {
 
     protected static function QueryModel() {
         if (self::$query === null && self::class !== static::class) {
-            self::$query = static::QueryModel();
+            self::$query = static::SetQueryModel();
         }
         return self::$query;
     }
@@ -59,4 +59,6 @@ abstract class Model {
             $params,
             get_called_class());
     }
+    
+    abstract public static function SetQueryModel(): IQuery;
 }
\ No newline at end of file
diff --git a/src/Fufle/ORM/Query.php b/src/Fufle/ORM/Query.php
index a499557..b0e0950 100644
--- a/src/Fufle/ORM/Query.php
+++ b/src/Fufle/ORM/Query.php
@@ -1,7 +1,7 @@
 <?php
 namespace Fufle\ORM;
 
-class Query {
+class Query implements IQuery {
     protected string $table;
     protected string $primaryKey;
 
diff --git a/tests/ModelTests.php b/tests/ModelTests.php
index 962e72a..5feebdf 100644
--- a/tests/ModelTests.php
+++ b/tests/ModelTests.php
@@ -4,8 +4,17 @@ require_once __DIR__ . '/../vendor/autoload.php';
 use Fufle\Demo\Model\Job;
 use Fufle\Database\ConnectionManager;
 
-$dns = 'pgsql:host=localhost;port=5432;dbname=dynamic;user=dynamic;password=password123';
-ConnectionManager::Connect($dns);
+//$dns = 'pgsql:host=localhost;port=5432;dbname=dynamic;user=dynamic;password=password123';
+$params = [
+    'pgsql',
+    'localhost',
+    5432,
+    'dynamic_dev',
+    'dynamic',
+    'password123',
+];
+ConnectionManager::RegisterConnector(new PostgresConnector());
+ConnectionManager::Connect(...$params);
 echo "
 
 ";