From 9a13cac9d234af3a34df9e176c47ae9bcc3b4f38 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Samuel=20=C5=A0tancl?= <samuel.stancl@gmail.com>
Date: Thu, 5 Mar 2020 18:08:16 +0100
Subject: [PATCH] Store string instead of Connection instance

---
 .../PostgreSQLSchemaManager.php               | 38 +++++++++----------
 1 file changed, 19 insertions(+), 19 deletions(-)

diff --git a/src/TenantDatabaseManagers/PostgreSQLSchemaManager.php b/src/TenantDatabaseManagers/PostgreSQLSchemaManager.php
index fa6054b2..592a6dde 100644
--- a/src/TenantDatabaseManagers/PostgreSQLSchemaManager.php
+++ b/src/TenantDatabaseManagers/PostgreSQLSchemaManager.php
@@ -12,36 +12,36 @@ use Stancl\Tenancy\Contracts\TenantDatabaseManager;
 
 class PostgreSQLSchemaManager implements TenantDatabaseManager, CanSetConnection
 {
-    /** @var Connection */
-    protected $database;
-
     /** @var string */
     protected $connection;
 
-    public function __construct(Repository $config, DatabaseManager $databaseManager)
+    public function __construct(Repository $config)
     {
-        $this->connection = $config['tenancy.database_manager_connections.pgsql'];
-
-        $this->database = $databaseManager->connection($this->connection);
+        $this->connection = $config->get('tenancy.database_manager_connections.mysql');
     }
 
-    public function createDatabase(string $name): bool
+    protected function database(): Connection
     {
-        return $this->database->statement("CREATE SCHEMA \"$name\"");
-    }
-
-    public function deleteDatabase(string $name): bool
-    {
-        return $this->database->statement("DROP SCHEMA \"$name\"");
-    }
-
-    public function databaseExists(string $name): bool
-    {
-        return (bool) $this->database->select("SELECT schema_name FROM information_schema.schemata WHERE schema_name = '$name'");
+        return DB::connection($this->connection);
     }
 
     public function setConnection(string $connection): void
     {
         $this->connection = $connection;
     }
+
+    public function createDatabase(string $name): bool
+    {
+        return $this->database()->statement("CREATE SCHEMA \"$name\"");
+    }
+
+    public function deleteDatabase(string $name): bool
+    {
+        return $this->database()->statement("DROP SCHEMA \"$name\"");
+    }
+
+    public function databaseExists(string $name): bool
+    {
+        return (bool) $this->database()->select("SELECT schema_name FROM information_schema.schemata WHERE schema_name = '$name'");
+    }
 }