Operations on tables: CREATE / ALTER TABLE or queries different to CRUD (#30)

src/AdvancedStatement.php

@@ -117,9 +117,9 @@ protected function renderOrderBy(): string
     /**
      * @param LimitInterface $limit
      *
-     * @return self
+     * @return static
      */
-    public function limit(LimitInterface $limit): self
+    public function limit(LimitInterface $limit)
     {
         $this->limit = $limit;
 

src/AdvancedStatementInterface.php

@@ -38,7 +38,7 @@ public function orderBy(string $column, string $direction = '');
     /**
      * @param LimitInterface $limit
      *
-     * @return self
+     * @return static
      */
     public function limit(LimitInterface $limit);
 }

src/Definition/DropUser.php

@@ -0,0 +1,53 @@
+<?php
+
+namespace FaaPz\PDO\Definition;
+
+use FaaPz\PDO\AbstractStatement;
+use PDO;
+
+class DropUser extends AbstractStatement
+{
+
+    /**
+     * User information
+     */
+    protected string $user;
+    protected string $host;
+
+    /**
+     * Clauses
+     */
+    protected bool $ifExists = false; 
+
+    public function __construct(PDO $pdo, string $host, string $user)
+    {
+        parent::__construct($pdo);
+        $this->user = $user;
+        $this->host = $host;
+    }
+
+    public function ifExists()
+    {
+        $this->ifExists = true;
+        return $this;
+    }
+
+    public function getValues(): array
+    {
+        return [];
+    }
+
+    public function __toString(): string
+    {
+        $sql = 'DROP USER';
+
+        if ($this->ifExists) {
+            $sql = "{$sql} IF EXISTS {$this->user}@{$this->host}";
+        } else {
+            $sql = "{$sql} {$this->user}@{$this->host}";
+        }
+
+        return $sql;
+    }
+}
+

src/Definition/IndexInterface.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace FaaPz\PDO\Definition;
+
+interface IndexInterface
+{
+
+}

src/Definition/SchemaInterface.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace FaaPz\PDO\Definition;
+
+interface SchemaInterface
+{
+
+}

src/Definition/TableInterface.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace FaaPz\PDO\Definition;
+
+interface TableInterface
+{
+
+}

src/Definition/User.php

@@ -0,0 +1,90 @@
+<?php
+
+namespace FaaPz\PDO\Definition;
+
+use FaaPz\PDO\AbstractStatement;
+use PDO;
+
+class User extends AbstractStatement
+{
+    /** @var string $host */
+    protected string $host;
+
+    /** @var string $username */
+    protected string $username;
+
+    /** @var ?string $password */
+    protected ?string $password;
+
+    /**
+     * Clauses
+     */
+    protected bool $orReplace = false;
+    protected bool $ifNotExists = false;   
+
+    /**
+     * 
+     */
+    public function __construct(PDO $dbh, string $host, string $user, ?string $password = '')
+    {
+        parent::__construct($dbh);
+        $this->host = $host;
+        $this->user = $user;        
+        $this->password = $password;
+    }
+
+    public function getValues(): array
+    {
+        return [];
+    }
+
+    /**
+     * 
+     */
+    public function orReplace()
+    {
+        $this->orReplace = true;
+        return $this;
+    }
+
+    /**
+     * 
+     */
+    public function ifNotExists()
+    {
+        $this->ifNotExists = true;
+        return $this;
+    }
+
+    public function __toString(): string
+    {
+
+        /**
+         * Exception: CREATE 'OR REPLACE' USER 'IF NOT EXISTS' ...
+         */
+        if ($this->orReplace && $this->ifNotExists)
+        {
+            throw new \Exception('The clause "OR REPLACE" and "IF NOT EXISTS" cannot be used together');
+        }
+
+
+        $sql = 'CREATE';
+        if ($this->orReplace) {
+            $sql = "{$sql} OR REPLACE USER {$this->user}@{$this->host}";
+        }
+
+        if ($this->ifNotExists) {
+            $sql = "{$sql} USER IF NOT EXISTS {$this->user}@{$this->host}";
+        } 
+
+        if (!$this->ifNotExists && !$this->orReplace) {
+            $sql = "{$sql} USER {$this->user}@{$this->host}";
+        }
+
+        if ($this->password) {
+            $sql = "{$sql} IDENTIFIED BY '{$this->password}'";
+        }
+
+        return $sql;
+    }
+}

src/Definition/UserInterface.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace FaaPz\PDO\Definition;
+
+interface UserInterface
+{
+
+}

src/Definition/ViewInterface.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace FaaPz\PDO\Definition;
+
+interface ViewInterface
+{
+
+}

src/Statement/AlterInterface.php

@@ -0,0 +1,49 @@
+<?php
+
+/**
+ * @license MIT
+ * @license http://opensource.org/licenses/MIT
+ */
+
+namespace FaaPz\PDO\Statement;
+
+use FaaPz\PDO\Clause\MethodInterface;
+use FaaPz\PDO\StatementInterface;
+
+interface AlterInterface extends StatementInterface
+{
+    /**
+     * @param string $name
+     *
+     * @return SchemaInterface
+     */
+    public function schema(string $name);
+
+    /**
+     * @param string $name
+     *
+     * @return IndexInterface
+     */
+    public function index(string $name);
+
+    /**
+     * @param string $name
+     *
+     * @return TableInterface
+     */
+    public function table(string $name);
+
+    /**
+     * @param string $name
+     *
+     * @return UserInterface
+     */
+    public function user(string $name);
+
+    /**
+     * @param string $name
+     *
+     * @return ViewInterface
+     */
+    public function view(string $name);
+}

src/Statement/Call.php

@@ -33,9 +33,9 @@ public function __construct(Database $dbh, ?MethodInterface $procedure = null)
     /**
      * @param MethodInterface $procedure
      *
-     * @return self
+     * @return static
      */
-    public function method(MethodInterface $procedure): self
+    public function method(MethodInterface $procedure)
     {
         $this->method = $procedure;
 

src/Statement/CallInterface.php

@@ -15,7 +15,7 @@ interface CallInterface extends StatementInterface
     /**
      * @param MethodInterface $procedure
      *
-     * @return self
+     * @return static
      */
     public function method(MethodInterface $procedure);
 }

src/Statement/CreateInterface.php

@@ -0,0 +1,54 @@
+<?php
+
+/**
+ * @license MIT
+ * @license http://opensource.org/licenses/MIT
+ */
+
+namespace FaaPz\PDO\Statement;
+
+use FaaPz\PDO\Clause\MethodInterface;
+use FaaPz\PDO\Definition\IndexInterface;
+use FaaPz\PDO\Definition\SchemaInterface;
+use FaaPz\PDO\Definition\TableInterface;
+use FaaPz\PDO\Definition\UserInterface;
+use FaaPz\PDO\Definition\ViewInterface;
+use FaaPz\PDO\StatementInterface;
+
+interface CreateInterface extends StatementInterface
+{
+    /**
+     * @param string $name
+     *
+     * @return SchemaInterface
+     */
+    public function schema(string $name);
+
+    /**
+     * @param string $name
+     *
+     * @return IndexInterface
+     */
+    public function index(string $name);
+
+    /**
+     * @param string $name
+     *
+     * @return TableInterface
+     */
+    public function table(string $name);
+
+    /**
+     * @param string $name
+     *
+     * @return UserInterface
+     */
+    public function user(string $name);
+
+    /**
+     * @param string $name
+     *
+     * @return ViewInterface
+     */
+    public function view(string $name);
+}

src/Statement/Delete.php

@@ -32,9 +32,9 @@ public function __construct(Database $dbh, $table = null)
     /**
      * @param string|array<string, string> $table
      *
-     * @return self
+     * @return static
      */
-    public function from($table): self
+    public function from($table)
     {
         $this->table = $table;
 

src/Statement/DeleteInterface.php

@@ -14,7 +14,7 @@ interface DeleteInterface extends StatementInterface
     /**
      * @param string|array<string, string> $table
      *
-     * @return self
+     * @return static
      */
     public function from($table);
 }