Initial commit

Author: gjhuerte

composer.json

@@ -0,0 +1,21 @@
+{
+    "name": "gjhuerte/php-dbwrapper",
+    "description": "Database wrapper for PHP",
+    "type": "library",
+    "license": "GPLv2",
+    "authors": [
+        {
+            "name": "Gabriel Jay Huerte",
+            "email": "gjhuerte@gmail.com"
+        }
+    ],
+    "minimum-stability": "dev",
+    "require": {
+        "php": ">=5.3.0"
+    },
+    "autoload": {
+        "psr-4": {
+            "App\\": "src/"
+        }
+    }
+}

composer.lock

@@ -0,0 +1,87 @@
+<?php
+
+namespace App\Database;
+
+use App\Database\Traits\Orderable;
+use App\Database\Traits\Selectable;
+use App\Database\Traits\Filterable;
+use App\Database\Traits\Executable;
+use App\Database\Interfaces\DatabaseInterface;
+
+class DatabaseWrapper implements DatabaseInterface
+{
+
+    use Selectable, Filterable, Orderable, Executable;
+
+	protected static $db;
+    protected static $table;
+    
+	private static $instance;
+    private static $query;
+
+    private static $selectArguments;
+    private static $whereArguments = [];
+    private static $orderByArguments = [];
+    
+    /**
+     * Initialize database connection
+     *
+     * @param string $host
+     * @param string $db
+     * @param string $charset
+     * @return instance
+     */
+	public static function init($host, $db_name, $charset)
+	{
+		$dsn = 'mysql:host=' . $db_host . ';dbname=' . $db_name . ';charset=' . $charset . ';';
+		$options = [
+			PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
+			PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
+			PDO::ATTR_EMULATE_PREPARES => false,
+        ];
+        
+		try {
+			self::$db = new PDO($dsn, DB_USERNAME, DB_PASSWORD, $options);
+        }
+        
+		catch(\PDOException $e) {
+			throw new \PDOException($e->getMessage(), (int) $e->getCode());
+        }
+        
+		if(is_null(self::$instance)) {
+			self::$instance = new self();
+        }
+        
+		return self::$instance;
+    }
+    
+    /**
+     * Sets the value for the table
+     *
+     * @param string $name
+     * @return void
+     */
+	public static function table($name)
+	{
+		self::init();
+        self::$table = $name;
+        
+		if(is_null(self::$instance)) {
+			self::$instance = new self();
+        }
+        
+		return self::$instance;
+    }
+
+    /**
+     * Limits the number of rows the query returns
+     *
+     * @param integer $columnNumber
+     * @param integer $offset
+     * @return void
+     */
+    public function limit(int $columnNumber, int $offset)
+    {
+        $this->limitArgument = 'LIMIT ' . $coumnNumber . ( $offset ?? '');
+    }
+}

src/Database/DatabaseWrapper.php

@@ -0,0 +1,77 @@
+<?php
+
+namespace App\Database;
+
+interface DatabaseInterface
+{
+    
+    /**
+     * Initialize database connection
+     *
+     * @param string $host
+     * @param string $db
+     * @param string $charset
+     * @return instance
+     */
+	static function init($host, $db_name, $charset);
+    
+    /**
+     * Sets the value for the table
+     *
+     * @param string $name
+     * @return void
+     */
+	static function table($name);
+    
+    /**
+     * Select query
+     *
+     * @param array ...$args
+     * @return instance
+     */
+	function select(...$args);
+    
+    /**
+     * Returns the number of rows the query has
+     *
+     * @return instance
+     */
+    public function selectCount();
+
+    /**
+     * Returns all the columns
+     *
+     * @return instance
+     */
+    public function selectAll();
+
+    /**
+     * Where clause for sql query
+     *
+     * @return void
+     */
+    function where($column, $operator, $value);
+
+    /**
+     * order by clause for sql query
+     *
+     * @return void
+     */
+    function orderBy($column, $type);
+    
+    /**
+     * Execute the statement
+     *
+     * @return instance
+     */
+    function get();
+    
+    /**
+     * Limits the number of rows the query returns
+     *
+     * @param integer $columnNumber
+     * @param integer $offset
+     * @return void
+     */
+    public function limit(int $columnNumber, int $offset);
+}

src/Database/Interfaces/DatabaseInterface.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace App\Database\Traits;
+
+trait Executable
+{
+    
+    /**
+     * Execute the statement
+     *
+     * @return instance
+     */
+	public function get()
+	{
+        $query = $this->selectQuery . ' ' . implode(' ', $this->whereArguments) . ' '. implode(' ', $this->orderByArguments);
+		return self::$db->query($query);
+    }
+}

src/Database/Traits/Executable.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace App\Database\Traits;
+
+trait Filterable
+{
+    
+    /**
+     * Where clause for sql query
+     *
+     * @return void
+     */
+    public function where($column, $operator, $value)
+    {
+        $this->whereArguments[] = 'where ' . $column . ' ' . $operator . ' ' . $value;
+        return $this;
+    }
+}

src/Database/Traits/Filterable.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace App\Database\Traits;
+
+trait Orderable
+{
+
+    /**
+     * order by clause for sql query
+     *
+     * @return void
+     */
+    public function orderBy($column, $type)
+    {
+        $this->orderByArguments[] = 'order by ' . $column . ' ' . $type;
+        return $this;
+    }
+}

src/Database/Traits/Orderable.php

@@ -0,0 +1,41 @@
+<?php
+
+namespace App\Database\Traits;
+
+trait Selectable
+{
+    
+    /**
+     * Select query
+     *
+     * @param array ...$args
+     * @return instance
+     */
+	  public function select(...$args)
+    {
+        $this->selectQuery = 'SELECT ' . implode(',', $args) . ' FROM ' . self::$table;
+        return $this;
+    }
+    
+    /**
+     * Returns the number of rows the query has
+     *
+     * @return instance
+     */
+    public function selectCount()
+    {
+        $this->selectQuery = 'SELECT COUNT(*)' . ' FROM ' . self::$table;
+        return $this;
+    }
+    
+    /**
+     * Returns all the columns
+     *
+     * @return instance
+     */
+    public function selectAll()
+    {
+        $this->selectQuery = 'SELECT *' . ' FROM ' . self::$table;
+        return $this;
+    }
+}

src/Database/Traits/Selectable.php

@@ -0,0 +1,7 @@
+<?php
+
+// autoload.php @generated by Composer
+
+require_once __DIR__ . '/composer/autoload_real.php';
+
+return ComposerAutoloaderInitd8f8425448e5be7bb5fde1b283a3b2f2::getLoader();