mirror of
https://github.com/archtechx/tenancy.git
synced 2026-02-05 05:14:03 +00:00
Add PostgreSQL DB driver
This commit is contained in:
parent
3abde1a791
commit
7a98f0874b
4 changed files with 62 additions and 0 deletions
|
|
@ -8,6 +8,7 @@ php:
|
||||||
|
|
||||||
services:
|
services:
|
||||||
- mysql
|
- mysql
|
||||||
|
- postgresql
|
||||||
- redis-server
|
- redis-server
|
||||||
|
|
||||||
before_install:
|
before_install:
|
||||||
|
|
|
||||||
19
src/TenantDatabaseManagers/PostgreSQLDatabaseManager.php
Normal file
19
src/TenantDatabaseManagers/PostgreSQLDatabaseManager.php
Normal file
|
|
@ -0,0 +1,19 @@
|
||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Stancl\Tenancy\TenantDatabaseManagers;
|
||||||
|
|
||||||
|
use Illuminate\Support\Facades\DB;
|
||||||
|
use Stancl\Tenancy\Interfaces\TenantDatabaseManager;
|
||||||
|
|
||||||
|
class PostgreSQLDatabaseManager implements TenantDatabaseManager
|
||||||
|
{
|
||||||
|
public function createDatabase(string $name): bool
|
||||||
|
{
|
||||||
|
return DB::statement("CREATE DATABASE `$name` WITH ENCODING 'UTF8' LC_COLLATE = 'en_US.UTF-8' LC_CTYPE = 'en_US.UTF-8'");
|
||||||
|
}
|
||||||
|
|
||||||
|
public function deleteDatabase(string $name): bool
|
||||||
|
{
|
||||||
|
return DB::statement("DROP DATABASE `$name`");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -38,6 +38,7 @@ return [
|
||||||
'database_managers' => [
|
'database_managers' => [
|
||||||
'sqlite' => 'Stancl\Tenancy\TenantDatabaseManagers\SQLiteDatabaseManager',
|
'sqlite' => 'Stancl\Tenancy\TenantDatabaseManagers\SQLiteDatabaseManager',
|
||||||
'mysql' => 'Stancl\Tenancy\TenantDatabaseManagers\MySQLDatabaseManager',
|
'mysql' => 'Stancl\Tenancy\TenantDatabaseManagers\MySQLDatabaseManager',
|
||||||
|
'pgsql' => 'Stancl\Tenancy\TenantDatabaseManagers\PostgreSQLDatabaseManager',
|
||||||
],
|
],
|
||||||
'queue_database_creation' => false,
|
'queue_database_creation' => false,
|
||||||
'queue_database_deletion' => false,
|
'queue_database_deletion' => false,
|
||||||
|
|
|
||||||
|
|
@ -78,6 +78,47 @@ class TenantDatabaseManagerTest extends TestCase
|
||||||
$this->assertEmpty(DB::select("SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE SCHEMA_NAME = '$db_name'"));
|
$this->assertEmpty(DB::select("SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE SCHEMA_NAME = '$db_name'"));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/** @test */
|
||||||
|
public function pgsql_database_can_be_created_and_deleted()
|
||||||
|
{
|
||||||
|
if (! $this->isTravis()) {
|
||||||
|
$this->markTestSkipped('As to not bloat your PostgreSQL instance with test databases, this test is not run by default.');
|
||||||
|
}
|
||||||
|
|
||||||
|
config()->set('database.default', 'pgsql');
|
||||||
|
|
||||||
|
$db_name = 'testdatabase' . $this->randomString(10);
|
||||||
|
app(DatabaseManager::class)->create($db_name, 'pgsql');
|
||||||
|
$this->assertNotEmpty(DB::select("SELECT datname FROM pg_catalog.pg_database WHERE datname = '$db_name'"));
|
||||||
|
|
||||||
|
app(DatabaseManager::class)->delete($db_name, 'pgsql');
|
||||||
|
$this->assertEmpty(DB::select("SELECT datname FROM pg_catalog.pg_database WHERE datname = '$db_name'"));
|
||||||
|
}
|
||||||
|
|
||||||
|
/** @test */
|
||||||
|
public function pgsql_database_can_be_created_and_deleted_using_queued_commands()
|
||||||
|
{
|
||||||
|
if (! $this->isTravis()) {
|
||||||
|
$this->markTestSkipped('As to not bloat your PostgreSQL instance with test databases, this test is not run by default.');
|
||||||
|
}
|
||||||
|
|
||||||
|
config()->set('database.default', 'pgsql');
|
||||||
|
|
||||||
|
$db_name = 'testdatabase' . $this->randomString(10);
|
||||||
|
|
||||||
|
$databaseManagers = config('tenancy.database_managers');
|
||||||
|
$job = new QueuedTenantDatabaseCreator(app($databaseManagers['pgsql']), $db_name);
|
||||||
|
$job->handle();
|
||||||
|
|
||||||
|
$this->assertNotEmpty(DB::select("SELECT datname FROM pg_catalog.pg_database WHERE datname = '$db_name'"));
|
||||||
|
|
||||||
|
$databaseManagers = config('tenancy.database_managers');
|
||||||
|
$job = new QueuedTenantDatabaseDeleter(app($databaseManagers['pgsql']), $db_name);
|
||||||
|
$job->handle();
|
||||||
|
|
||||||
|
$this->assertEmpty(DB::select("SELECT datname FROM pg_catalog.pg_database WHERE datname = '$db_name'"));
|
||||||
|
}
|
||||||
|
|
||||||
/** @test */
|
/** @test */
|
||||||
public function database_creation_can_be_queued()
|
public function database_creation_can_be_queued()
|
||||||
{
|
{
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue