Simples Persistence package

Author: wilcorrea

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2016 Grupo de PHP da Zona da Mata
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

composer.json

@@ -0,0 +1,40 @@
+{
+  "name": "phpzm/persistence",
+  "description": "Simples Persistence package",
+  "minimum-stability": "dev",
+  "keywords": [
+    "php",
+    "framework",
+    "api",
+    "simples"
+  ],
+  "homepage": "https://github.com/phpzm/persistence",
+  "license": "MIT",
+  "version": "1.0.0",
+  "type": "package",
+  "authors": [
+    {
+      "name": "William",
+      "email": "[email protected]"
+    },
+    {
+      "name": "Ezio",
+      "email": "[email protected]"
+    }
+  ],
+  "require": {
+    "php": ">=7.0",
+    "phpzm/kernel": "dev-master"
+  },
+  "autoload": {
+    "psr-4": {
+      "Simples\\Core\\": "src/"
+    },
+    "files": [
+      "bootstrap/index.php"
+    ]
+  },
+  "scripts": {
+    "sami": "php sami.phar update config/sami.php"
+  }
+}

src/Persistence/Connection.php

@@ -0,0 +1,76 @@
+<?php
+
+namespace Simples\Persistence;
+
+use Simples\Kernel\App;
+use Simples\Kernel\Wrapper;
+
+/**
+ * Class Connection
+ * @package Simples\Persistence
+ */
+abstract class Connection
+{
+    /**
+     * @var mixed
+     */
+    protected $resource = null;
+
+    /**
+     * @var array
+     */
+    protected $settings = [];
+
+    /**
+     * @var array
+     */
+    protected $logs = [];
+
+    /**
+     * Connection constructor.
+     * @param array $settings
+     */
+    public function __construct(array $settings)
+    {
+        $this->settings = $settings;
+    }
+
+    /**
+     * @return mixed
+     */
+    abstract protected function connection();
+
+    /**
+     * @return array
+     */
+    public function getSettings(): array
+    {
+        return $this->settings;
+    }
+
+    /**
+     * @return array
+     */
+    public function getLogs(): array
+    {
+        return $this->logs;
+    }
+
+    /**
+     * @SuppressWarnings("BooleanArgumentFlag")
+     *
+     * @param string $command
+     * @param array $parameters
+     * @param bool $logging (false)
+     * @return Connection
+     */
+    public function addLog(string $command, array $parameters, bool $logging = false): Connection
+    {
+        $log = ['command' => $command, 'parameters' => $parameters];
+        $this->logs[] = $log;
+        if ($logging || App::log()) {
+            Wrapper::log($log);
+        }
+        return $this;
+    }
+}

src/Persistence/Driver.php

@@ -0,0 +1,54 @@
+<?php
+
+namespace Simples\Persistence;
+
+/**
+ * Interface Driver
+ * @package Simples\Persistence
+ */
+interface Driver
+{
+    /**
+     * @return bool
+     */
+    public function start();
+
+    /**
+     * @return bool
+     */
+    public function commit();
+
+    /**
+     * @return bool
+     */
+    public function rollback();
+
+    /**
+     * @param array $clausules
+     * @param array $values
+     * @return string
+     */
+    public function create(array $clausules, array $values);
+
+    /**
+     * @param array $clausules
+     * @param array $values
+     * @return array
+     */
+    public function read(array $clausules, array $values = []);
+
+    /**
+     * @param array $clausules
+     * @param array $values
+     * @param array $filters
+     * @return int
+     */
+    public function update(array $clausules, array $values, array $filters);
+
+    /**
+     * @param array $clausules
+     * @param array $values
+     * @return int
+     */
+    public function destroy(array $clausules, array $values);
+}

src/Persistence/Drivers/MySQL.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace Simples\Persistence\Drivers;
+
+use Simples\Persistence\SQL\SQLDriver;
+
+/**
+ * Class MySQL
+ * @package Simples\Persistence
+ */
+class MySQL extends SQLDriver
+{
+    /**
+     * @return string
+     */
+    protected function dsn()
+    {
+        $host = "host={$this->settings['host']}";
+        $port = "port={$this->settings['port']}";
+        $dbname = "dbname={$this->settings['database']}";
+
+        return "mysql:{$host};{$port};{$dbname}";
+    }
+}

src/Persistence/Engine.php

@@ -0,0 +1,153 @@
+<?php
+
+namespace Simples\Persistence;
+
+use Simples\Error\SimplesRunTimeError;
+use Simples\Kernel\App;
+
+/**
+ * Class Engine
+ * @package Simples\Persistence
+ *
+ * @method $this source (string $source)
+ * @method $this relation (array $relations)
+ * @method $this fields (array $fields)
+ * @method $this filter (array $filter)
+ * @method $this order (array $order)
+ * @method $this group (array $group)
+ * @method $this having (array $having)
+ * @method $this limit (array $limit)
+ *
+ * @method $this log (bool $active)
+ */
+class Engine
+{
+    /**
+     * @var Driver
+     */
+    private $driver;
+
+    /**
+     * @var array
+     */
+    private $clausules = [];
+
+    /**
+     * @var array|mixed
+     */
+    private $settings = [];
+
+    /**
+     * Engine constructor.
+     * @param $id
+     */
+    public function __construct($id)
+    {
+        $this->settings = off(App::config('database'), $id);
+        if ($this->settings) {
+            $this->driver = Factory::create($this->settings);
+        }
+    }
+
+    /**
+     * @param $name
+     * @param $arguments
+     * @return $this
+     */
+    public function __call($name, $arguments)
+    {
+        $clausule = $arguments[0];
+        if (count($arguments) > 1) {
+            $clausule = $arguments;
+        }
+        $name = strtolower($name);
+
+        $this->clausules[$name] = $clausule;
+        if (is_null($clausule)) {
+            unset($this->clausules[$name]);
+        }
+
+        return $this;
+    }
+
+    /**
+     * @return Driver
+     * @throws SimplesRunTimeError
+     */
+    protected function driver(): Driver
+    {
+        if ($this->driver) {
+            return $this->driver;
+        }
+        throw new SimplesRunTimeError("Cant use the driver", $this->settings);
+    }
+
+    /**
+     * @param array $values
+     * @return string
+     */
+    final public function register($values): string
+    {
+        return $this->driver()->create($this->clausules, $values);
+    }
+
+    /**
+     * @param $values
+     * @return array
+     */
+    final public function recover($values = []): array
+    {
+        return $this->driver()->read($this->clausules, $values);
+    }
+
+    /**
+     * @param $values
+     * @param $filters
+     * @return int
+     */
+    final public function change($values, $filters = []): int
+    {
+        return $this->driver()->update($this->clausules, $values, $filters);
+    }
+
+    /**
+     * @param $filters
+     * @return int
+     */
+    final public function remove($filters): int
+    {
+        return $this->driver()->destroy($this->clausules, $filters);
+    }
+
+    /**
+     * @return Driver
+     */
+    public function getDriver(): Driver
+    {
+        return $this->driver;
+    }
+
+    /**
+     * @return array
+     */
+    public function getClausules(): array
+    {
+        return $this->clausules;
+    }
+
+    /**
+     * @return array|mixed
+     */
+    public function getSettings()
+    {
+        return $this->settings;
+    }
+
+    /**
+     * Clear the clausules changes
+     */
+    public function reset()
+    {
+        $this->clausules = [];
+    }
+}