Ümit Tunç
97 lines
2.9 KiB
PHP
97 lines
2.9 KiB
PHP
<?php
|
|
|
|
namespace App\Services\Database;
|
|
|
|
use App\Contracts\DatabaseDriverInterface;
|
|
use App\Contracts\SchemaDiscoveryInterface;
|
|
use Illuminate\Support\Facades\DB;
|
|
use Illuminate\Support\Facades\Config;
|
|
|
|
class MySqlDriver implements DatabaseDriverInterface, SchemaDiscoveryInterface
|
|
{
|
|
protected string $connectionName = 'mariavel_dynamic';
|
|
|
|
public function connect(array $config): bool
|
|
{
|
|
Config::set("database.connections.{$this->connectionName}", [
|
|
'driver' => 'mysql',
|
|
'host' => $config['host'] ?? '127.0.0.1',
|
|
'port' => $config['port'] ?? '3306',
|
|
'database' => $config['database'] ?? null,
|
|
'username' => $config['username'] ?? 'root',
|
|
'password' => $config['password'] ?? '',
|
|
'charset' => 'utf8mb4',
|
|
'collation' => 'utf8mb4_unicode_ci',
|
|
'prefix' => '',
|
|
'strict' => true,
|
|
'engine' => null,
|
|
]);
|
|
|
|
try {
|
|
DB::purge($this->connectionName);
|
|
DB::connection($this->connectionName)->getPdo();
|
|
return true;
|
|
} catch (\Exception $e) {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
public function query(string $sql, array $bindings = []): array
|
|
{
|
|
return DB::connection($this->connectionName)->select($sql, $bindings);
|
|
}
|
|
|
|
public function getConnection()
|
|
{
|
|
return DB::connection($this->connectionName);
|
|
}
|
|
|
|
public function getDatabases(): array
|
|
{
|
|
$results = $this->query('SHOW DATABASES');
|
|
return array_map(fn($db) => $db->Database, $results);
|
|
}
|
|
|
|
public function getTables(): array
|
|
{
|
|
$results = $this->query('SHOW TABLES');
|
|
$key = "Tables_in_" . DB::connection($this->connectionName)->getDatabaseName();
|
|
return array_map(fn($table) => $table->$key, $results);
|
|
}
|
|
|
|
public function getTableSchema(string $table): array
|
|
{
|
|
return $this->query("DESCRIBE `{$table}`");
|
|
}
|
|
|
|
public function getTableData(string $table, int $limit = 100, int $offset = 0): array
|
|
{
|
|
return $this->query("SELECT * FROM `{$table}` LIMIT ? OFFSET ?", [$limit, $offset]);
|
|
}
|
|
|
|
public function getTableCount(string $table): int
|
|
{
|
|
$result = $this->query("SELECT COUNT(*) as count FROM `{$table}`");
|
|
return (int) ($result[0]->count ?? 0);
|
|
}
|
|
|
|
public function getForeignKeys(string $table): array
|
|
{
|
|
$sql = "
|
|
SELECT
|
|
COLUMN_NAME,
|
|
REFERENCED_TABLE_NAME,
|
|
REFERENCED_COLUMN_NAME
|
|
FROM
|
|
INFORMATION_SCHEMA.KEY_COLUMN_USAGE
|
|
WHERE
|
|
TABLE_NAME = ? AND
|
|
REFERENCED_TABLE_NAME IS NOT NULL AND
|
|
TABLE_SCHEMA = ?
|
|
";
|
|
|
|
$dbName = DB::connection($this->connectionName)->getDatabaseName();
|
|
return $this->query($sql, [$table, $dbName]);
|
|
}
|
|
}
|