204 lines
4.5 KiB
PHP
204 lines
4.5 KiB
PHP
<?php
|
|
|
|
namespace Illuminate\Database\Schema;
|
|
|
|
class PostgresBuilder extends Builder
|
|
{
|
|
/**
|
|
* Create a database in the schema.
|
|
*
|
|
* @param string $name
|
|
* @return bool
|
|
*/
|
|
public function createDatabase($name)
|
|
{
|
|
return $this->connection->statement(
|
|
$this->grammar->compileCreateDatabase($name, $this->connection)
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Drop a database from the schema if the database exists.
|
|
*
|
|
* @param string $name
|
|
* @return bool
|
|
*/
|
|
public function dropDatabaseIfExists($name)
|
|
{
|
|
return $this->connection->statement(
|
|
$this->grammar->compileDropDatabaseIfExists($name)
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Determine if the given table exists.
|
|
*
|
|
* @param string $table
|
|
* @return bool
|
|
*/
|
|
public function hasTable($table)
|
|
{
|
|
[$schema, $table] = $this->parseSchemaAndTable($table);
|
|
|
|
$table = $this->connection->getTablePrefix().$table;
|
|
|
|
return count($this->connection->select(
|
|
$this->grammar->compileTableExists(), [$schema, $table]
|
|
)) > 0;
|
|
}
|
|
|
|
/**
|
|
* Drop all tables from the database.
|
|
*
|
|
* @return void
|
|
*/
|
|
public function dropAllTables()
|
|
{
|
|
$tables = [];
|
|
|
|
$excludedTables = $this->connection->getConfig('dont_drop') ?? ['spatial_ref_sys'];
|
|
|
|
foreach ($this->getAllTables() as $row) {
|
|
$row = (array) $row;
|
|
|
|
$table = reset($row);
|
|
|
|
if (! in_array($table, $excludedTables)) {
|
|
$tables[] = $table;
|
|
}
|
|
}
|
|
|
|
if (empty($tables)) {
|
|
return;
|
|
}
|
|
|
|
$this->connection->statement(
|
|
$this->grammar->compileDropAllTables($tables)
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Drop all views from the database.
|
|
*
|
|
* @return void
|
|
*/
|
|
public function dropAllViews()
|
|
{
|
|
$views = [];
|
|
|
|
foreach ($this->getAllViews() as $row) {
|
|
$row = (array) $row;
|
|
|
|
$views[] = reset($row);
|
|
}
|
|
|
|
if (empty($views)) {
|
|
return;
|
|
}
|
|
|
|
$this->connection->statement(
|
|
$this->grammar->compileDropAllViews($views)
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Drop all types from the database.
|
|
*
|
|
* @return void
|
|
*/
|
|
public function dropAllTypes()
|
|
{
|
|
$types = [];
|
|
|
|
foreach ($this->getAllTypes() as $row) {
|
|
$row = (array) $row;
|
|
|
|
$types[] = reset($row);
|
|
}
|
|
|
|
if (empty($types)) {
|
|
return;
|
|
}
|
|
|
|
$this->connection->statement(
|
|
$this->grammar->compileDropAllTypes($types)
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Get all of the table names for the database.
|
|
*
|
|
* @return array
|
|
*/
|
|
public function getAllTables()
|
|
{
|
|
return $this->connection->select(
|
|
$this->grammar->compileGetAllTables((array) $this->connection->getConfig('schema'))
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Get all of the view names for the database.
|
|
*
|
|
* @return array
|
|
*/
|
|
public function getAllViews()
|
|
{
|
|
return $this->connection->select(
|
|
$this->grammar->compileGetAllViews((array) $this->connection->getConfig('schema'))
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Get all of the type names for the database.
|
|
*
|
|
* @return array
|
|
*/
|
|
public function getAllTypes()
|
|
{
|
|
return $this->connection->select(
|
|
$this->grammar->compileGetAllTypes()
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Get the column listing for a given table.
|
|
*
|
|
* @param string $table
|
|
* @return array
|
|
*/
|
|
public function getColumnListing($table)
|
|
{
|
|
[$schema, $table] = $this->parseSchemaAndTable($table);
|
|
|
|
$table = $this->connection->getTablePrefix().$table;
|
|
|
|
$results = $this->connection->select(
|
|
$this->grammar->compileColumnListing(), [$schema, $table]
|
|
);
|
|
|
|
return $this->connection->getPostProcessor()->processColumnListing($results);
|
|
}
|
|
|
|
/**
|
|
* Parse the table name and extract the schema and table.
|
|
*
|
|
* @param string $table
|
|
* @return array
|
|
*/
|
|
protected function parseSchemaAndTable($table)
|
|
{
|
|
$table = explode('.', $table);
|
|
|
|
if (is_array($schema = $this->connection->getConfig('schema'))) {
|
|
if (in_array($table[0], $schema)) {
|
|
return [array_shift($table), implode('.', $table)];
|
|
}
|
|
|
|
$schema = head($schema);
|
|
}
|
|
|
|
return [$schema ?: 'public', implode('.', $table)];
|
|
}
|
|
}
|