62 lines
2 KiB
PHP
62 lines
2 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
declare(strict_types=1);
|
||
|
|
|
||
|
|
namespace Pairity\Tests;
|
||
|
|
|
||
|
|
use PHPUnit\Framework\TestCase;
|
||
|
|
use Pairity\Database\ConnectionManager;
|
||
|
|
use Pairity\Schema\SchemaManager;
|
||
|
|
use Pairity\Schema\Blueprint;
|
||
|
|
|
||
|
|
final class PostgresSmokeTest extends TestCase
|
||
|
|
{
|
||
|
|
private function pgConfig(): array
|
||
|
|
{
|
||
|
|
$host = getenv('POSTGRES_HOST') ?: null;
|
||
|
|
if (!$host) {
|
||
|
|
$this->markTestSkipped('POSTGRES_HOST not set; skipping Postgres smoke test');
|
||
|
|
}
|
||
|
|
return [
|
||
|
|
'driver' => 'pgsql',
|
||
|
|
'host' => $host,
|
||
|
|
'port' => (int)(getenv('POSTGRES_PORT') ?: 5432),
|
||
|
|
'database' => getenv('POSTGRES_DB') ?: 'pairity',
|
||
|
|
'username' => getenv('POSTGRES_USER') ?: 'postgres',
|
||
|
|
'password' => getenv('POSTGRES_PASS') ?: 'postgres',
|
||
|
|
];
|
||
|
|
}
|
||
|
|
|
||
|
|
public function testCreateAlterDropCycle(): void
|
||
|
|
{
|
||
|
|
$cfg = $this->pgConfig();
|
||
|
|
$conn = ConnectionManager::make($cfg);
|
||
|
|
$schema = SchemaManager::forConnection($conn);
|
||
|
|
|
||
|
|
$suffix = substr(sha1((string)microtime(true)), 0, 6);
|
||
|
|
$table = 'pg_smoke_' . $suffix;
|
||
|
|
|
||
|
|
// Create
|
||
|
|
$schema->create($table, function (Blueprint $t) {
|
||
|
|
$t->increments('id');
|
||
|
|
$t->string('name', 100);
|
||
|
|
});
|
||
|
|
|
||
|
|
$rows = $conn->query('SELECT tablename FROM pg_tables WHERE tablename = :t', ['t' => $table]);
|
||
|
|
$this->assertNotEmpty($rows, 'Table should be created');
|
||
|
|
|
||
|
|
// Alter add column
|
||
|
|
$schema->table($table, function (Blueprint $t) {
|
||
|
|
$t->integer('qty');
|
||
|
|
});
|
||
|
|
$cols = $conn->query('SELECT column_name FROM information_schema.columns WHERE table_name = :t', ['t' => $table]);
|
||
|
|
$names = array_map(fn($r) => $r['column_name'] ?? '', $cols);
|
||
|
|
$this->assertContains('qty', $names);
|
||
|
|
|
||
|
|
// Drop
|
||
|
|
$schema->drop($table);
|
||
|
|
$rows = $conn->query('SELECT tablename FROM pg_tables WHERE tablename = :t', ['t' => $table]);
|
||
|
|
$this->assertEmpty($rows, 'Table should be dropped');
|
||
|
|
}
|
||
|
|
}
|