Innitial commit

Author: riverside

src/Configuration.php

@@ -0,0 +1,80 @@
+<?php
+namespace PhpOrm;
+
+class Configuration
+{
+    private $charset;
+
+    private $collation;
+
+    private $database;
+
+    private $driver;
+
+    private $host;
+
+    private $password;
+
+    private $port;
+
+    private $username;
+
+    public function __construct(string $username,
+                                string $password,
+                                string $database,
+                                string $host=null,
+                                int $port=null,
+                                string $driver=null,
+                                string $charset=null,
+                                string $collation=null)
+    {
+        $this->host     = $host ?: 'localhost';
+        $this->port     = $port ?: 3306;
+        $this->username = $username;
+        $this->password = $password;
+        $this->database = $database;
+        $this->driver   = $driver ?: 'mysql';
+        $this->charset   = $charset ?: 'utf8mb4';
+        $this->collation = $collation ?: 'utf8mb4_general_ci';
+    }
+
+    public function getCharset(): string
+    {
+        return $this->charset;
+    }
+
+    public function getCollation(): string
+    {
+        return $this->collation;
+    }
+
+    public function getDatabase(): string
+    {
+        return $this->database;
+    }
+
+    public function getDriver(): string
+    {
+        return $this->driver;
+    }
+
+    public function getHost(): string
+    {
+        return $this->host;
+    }
+
+    public function getPassword(): string
+    {
+        return $this->password;
+    }
+
+    public function getPort(): int
+    {
+        return $this->port;
+    }
+
+    public function getUsername(): string
+    {
+        return $this->username;
+    }
+}

src/Connection.php

@@ -0,0 +1,113 @@
+<?php
+namespace PhpOrm;
+
+class Connection
+{
+    private $configuration;
+
+    private $dbh;
+
+    public function __construct(Configuration $configuration)
+    {
+        $this->configuration = $configuration;
+    }
+
+    public function getDbh(): \PDO
+    {
+        $this->connect();
+
+        return $this->dbh;
+    }
+
+    public function getDsn(): string
+    {
+        $dsn = "";
+        switch ($this->configuration->getDriver())
+        {
+            case 'mysql':
+                $dsn = sprintf('mysql:host=%s;port=%u;dbname=%s;charset=%s',
+                    $this->configuration->getHost(),
+                    $this->configuration->getPort(),
+                    $this->configuration->getDatabase(),
+                    $this->configuration->getCharset());
+                break;
+            case 'oci':
+                $dsn = sprintf('oci:dbname=%s;charset=%s',
+                    $this->configuration->getDatabase(),
+                    $this->configuration->getCharset());
+                break;
+            case 'firebird':
+                $dsn = sprintf('firebird:dbname=%s;charset=%s',
+                    $this->configuration->getDatabase(),
+                    $this->configuration->getCharset());
+                break;
+            case 'pgsql':
+                $dsn = sprintf('pgsql:host=%s;port=%u;dbname=%s;user=%s;password=%s',
+                    $this->configuration->getHost(),
+                    $this->configuration->getPort(),
+                    $this->configuration->getDatabase(),
+                    $this->configuration->getUsername(),
+                    $this->configuration->getPassword());
+                break;
+            case 'sqlite':
+                $dsn = sprintf('sqlite:%s',
+                    $this->configuration->getDatabase());
+                break;
+            case 'sybase':
+            case 'mssql':
+            case 'dblib':
+                $dsn = sprintf("%s:host=%s;dbname=%s;charset=%s",
+                    $this->configuration->getDriver(),
+                    $this->configuration->getHost(),
+                    $this->configuration->getDatabase(),
+                    $this->configuration->getCharset());
+                break;
+            case 'cubrid':
+                $dsn = sprintf("cubrid:host=%s;port=%u;dbname=%s",
+                    $this->configuration->getHost(),
+                    $this->configuration->getPort(),
+                    $this->configuration->getDatabase());
+                break;
+            case '4D':
+                $dsn = sprintf('4D:host=%s;port=%u;user=%s;password=%s;dbname=%s;charset=%s',
+                    $this->configuration->getHost(),
+                    $this->configuration->getPort(),
+                    $this->configuration->getUsername(),
+                    $this->configuration->getPassword(),
+                    $this->configuration->getDatabase(),
+                    $this->configuration->getCharset());
+                break;
+        }
+
+        return $dsn;
+    }
+
+    public function connect(): Connection
+    {
+        try {
+            $this->dbh = new \PDO($this->getDsn(), $this->configuration->getUsername(), $this->configuration->getPassword());
+            $this->dbh->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
+            $this->dbh->setAttribute(\PDO::ATTR_EMULATE_PREPARES,true);
+
+        } catch (\PDOException $e) {
+            echo 'Connection failed: ' . $e->getMessage();
+        }
+
+        return $this;
+    }
+
+    public function disconnect(): Connection
+    {
+        $this->dbh = null;
+
+        return $this;
+    }
+
+    public function reconnect(): Connection
+    {
+        $this->disconnect();
+        $this->connect();
+
+        return $this;
+    }
+}