(Micro PR) Created DatabaseInterface and simple implementations

src/Meta/AdapterFactory.php

@@ -0,0 +1,43 @@
+<?php
+
+namespace Reliese\Meta;
+
+use Illuminate\Database\MySqlConnection;
+use Illuminate\Database\PostgresConnection;
+use Illuminate\Database\SQLiteConnection;
+use Reliese\Meta\MySql\Database as MySqlDatabase;
+use Reliese\Meta\Postgres\Database as PostgresDatabase;
+use Reliese\Meta\Sqlite\Database as SqliteDatabase;
+use Reliese\Meta\MySql\Schema as MySqlSchema;
+use Reliese\Meta\Postgres\Schema as PostgresSchema;
+use Reliese\Meta\Sqlite\Schema as SqliteSchema;
+
+use function get_class;
+
+/**
+ * Class AdapterFactory
+ */
+class AdapterFactory
+{
+    /**
+     * @param \Illuminate\Database\Connection $connection
+     * @return DatabaseInterface
+     */
+    public function database($connection)
+    {
+        switch (get_class($connection)) {
+            case \Larapack\DoctrineSupport\Connections\MySqlConnection::class:
+            case MySqlConnection::class:
+                /** @noinspection PhpParamsInspection */
+                return new MySqlDatabase($connection);
+            case SQLiteConnection::class:
+                /** @noinspection PhpParamsInspection */
+                return new SqliteDatabase($connection);
+            case PostgresConnection::class:
+                /** @noinspection PhpParamsInspection */
+                return new PostgresDatabase($connection);
+        }
+
+        throw new \RuntimeException(__METHOD__." does not define an implementation for ".DatabaseInterface::class);
+    }
+}

src/Meta/DatabaseInterface.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace Reliese\Meta;
+
+use Reliese\Meta\MySql\Schema;
+
+/**
+ * Interface DatabaseInterface
+ */
+interface DatabaseInterface
+{
+    /**
+     * Returns an array of accessible schema names
+     *
+     * @return string[]
+     */
+    public function getSchemaNames();
+
+    /**
+     * @param string $schemaName
+     * @return Schema
+     */
+    public function getSchema($schemaName);
+}

src/Meta/MySql/Database.php

@@ -0,0 +1,59 @@
+<?php
+
+namespace Reliese\Meta\MySql;
+
+use Reliese\Meta\DatabaseInterface;
+
+use function array_diff;
+
+/**
+ * Class Database
+ */
+class Database implements DatabaseInterface
+{
+    /**
+     * @var Schema[]
+     */
+    private $schemaAdapters = [];
+
+    /**
+     * @var \Illuminate\Database\MySqlConnection
+     */
+    private $connection;
+
+    /**
+     * Database constructor.
+     * @param \Illuminate\Database\MySqlConnection $connection
+     */
+    public function __construct(\Illuminate\Database\MySqlConnection $connection)
+    {
+        $this->connection = $connection;
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function getSchemaNames()
+    {
+        $schemas = $this->connection->getDoctrineSchemaManager()->listDatabases();
+
+        return array_diff($schemas, [
+            'information_schema',
+            'sys',
+            'mysql',
+            'performance_schema',
+        ]);
+    }
+
+    /**
+     * @param string $schemaName
+     * @return Schema
+     */
+    public function getSchema($schemaName)
+    {
+        if (!empty($this->schemaAdapters[$schemaName])) {
+            return $this->schemaAdapters[$schemaName];
+        }
+        return $this->schemaAdapters[$schemaName] = new Schema($schemaName, $this->connection);
+    }
+}

src/Meta/MySql/Schema.php

@@ -265,19 +265,12 @@ protected function resolveForeignTable($table, Blueprint $blueprint)
 
     /**
      * @param \Illuminate\Database\Connection $connection
-     *
+     * @deprecated use \Reliese\Meta\MySql\Database::getSchemaNames instead
      * @return array
      */
     public static function schemas(Connection $connection)
     {
-        $schemas = $connection->getDoctrineSchemaManager()->listDatabases();
-
-        return array_diff($schemas, [
-            'information_schema',
-            'sys',
-            'mysql',
-            'performance_schema',
-        ]);
+        return (new Database($connection))->getSchemaNames();
     }
 
     /**

src/Meta/Postgres/Database.php

@@ -0,0 +1,58 @@
+<?php
+
+namespace Reliese\Meta\Postgres;
+
+use Reliese\Meta\DatabaseInterface;
+
+use function array_diff;
+
+/**
+ * Class Database
+ */
+class Database implements DatabaseInterface
+{
+    /**
+     * @var Schema[]
+     */
+    private $schemaAdapters = [];
+
+    /**
+     * @var \Illuminate\Database\PostgresConnection
+     */
+    private $connection;
+
+    /**
+     * Database constructor.
+     * @param \Illuminate\Database\PostgresConnection $connection
+     */
+    public function __construct(\Illuminate\Database\PostgresConnection $connection)
+    {
+        $this->connection = $connection;
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function getSchemaNames()
+    {
+        $schemas = $this->connection->getDoctrineSchemaManager()->listDatabases();
+
+        return array_diff($schemas, [
+            'postgres',
+            'template0',
+            'template1',
+        ]);
+    }
+
+    /**
+     * @param string $schemaName
+     * @return Schema
+     */
+    public function getSchema($schemaName)
+    {
+        if (!empty($this->schemaAdapters[$schemaName])) {
+            return $this->schemaAdapters[$schemaName];
+        }
+        return $this->schemaAdapters[$schemaName] = new Schema($schemaName, $this->connection);
+    }
+}

src/Meta/Postgres/Schema.php

@@ -268,18 +268,12 @@ protected function wrap($table)
 
     /**
      * @param \Illuminate\Database\Connection $connection
-     *
+     * @deprecated use \Reliese\Meta\Postgres\Database::getSchemaNames
      * @return array
      */
     public static function schemas(Connection $connection)
     {
-        $schemas = $connection->getDoctrineSchemaManager()->listDatabases();
-
-        return array_diff($schemas, [
-            'postgres',
-            'template0',
-            'template1',
-        ]);
+        return (new Database($connection))->getSchemaNames();
     }
 
     /**

src/Meta/Sqlite/Database.php

@@ -0,0 +1,50 @@
+<?php
+
+namespace Reliese\Meta\Sqlite;
+
+use Reliese\Meta\DatabaseInterface;
+
+/**
+ * Class Database
+ */
+class Database implements DatabaseInterface
+{
+    /**
+     * @var Schema[]
+     */
+    private $schemaAdapters = [];
+
+    /**
+     * @var \Illuminate\Database\SQLiteConnection
+     */
+    private $connection;
+
+    /**
+     * Database constructor.
+     * @param \Illuminate\Database\SQLiteConnection $connection
+     */
+    public function __construct(\Illuminate\Database\SQLiteConnection $connection)
+    {
+        $this->connection = $connection;
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function getSchemaNames()
+    {
+        return ['database'];
+    }
+
+    /**
+     * @param string $schemaName
+     * @return Schema
+     */
+    public function getSchema($schemaName)
+    {
+        if (!empty($this->schemaAdapters[$schemaName])) {
+            return $this->schemaAdapters[$schemaName];
+        }
+        return $this->schemaAdapters[$schemaName] = new Schema($schemaName, $this->connection);
+    }
+}

src/Meta/Sqlite/Schema.php

@@ -36,7 +36,7 @@ class Schema implements \Reliese\Meta\Schema
      * Mapper constructor.
      *
      * @param string $schema
-     * @param \Illuminate\Database\MySqlConnection $connection
+     * @param \Illuminate\Database\SQLiteConnection $connection
      */
     public function __construct($schema, $connection)
     {
@@ -194,12 +194,12 @@ protected function fillRelations(Blueprint $blueprint)
 
     /**
      * @param \Illuminate\Database\Connection $connection
-     *
+     * @deprecated use \Reliese\Meta\Sqlite\Database::getSchemaNames
      * @return array
      */
     public static function schemas(Connection $connection)
     {
-        return ['database'];
+        return (new Database($connection))->getSchemaNames();
     }
 
     /**