225 lines
5.0 KiB
PHP
Executable File
225 lines
5.0 KiB
PHP
Executable File
<?php
|
|
|
|
namespace Illuminate\Database\Migrations;
|
|
|
|
use Illuminate\Database\ConnectionResolverInterface as Resolver;
|
|
|
|
class DatabaseMigrationRepository implements MigrationRepositoryInterface
|
|
{
|
|
/**
|
|
* The database connection resolver instance.
|
|
*
|
|
* @var \Illuminate\Database\ConnectionResolverInterface
|
|
*/
|
|
protected $resolver;
|
|
|
|
/**
|
|
* The name of the migration table.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $table;
|
|
|
|
/**
|
|
* The name of the database connection to use.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $connection;
|
|
|
|
/**
|
|
* Create a new database migration repository instance.
|
|
*
|
|
* @param \Illuminate\Database\ConnectionResolverInterface $resolver
|
|
* @param string $table
|
|
* @return void
|
|
*/
|
|
public function __construct(Resolver $resolver, $table)
|
|
{
|
|
$this->table = $table;
|
|
$this->resolver = $resolver;
|
|
}
|
|
|
|
/**
|
|
* Get the completed migrations.
|
|
*
|
|
* @return array
|
|
*/
|
|
public function getRan()
|
|
{
|
|
return $this->table()
|
|
->orderBy('batch', 'asc')
|
|
->orderBy('migration', 'asc')
|
|
->pluck('migration')->all();
|
|
}
|
|
|
|
/**
|
|
* Get the list of migrations.
|
|
*
|
|
* @param int $steps
|
|
* @return array
|
|
*/
|
|
public function getMigrations($steps)
|
|
{
|
|
$query = $this->table()->where('batch', '>=', '1');
|
|
|
|
return $query->orderBy('batch', 'desc')
|
|
->orderBy('migration', 'desc')
|
|
->take($steps)->get()->all();
|
|
}
|
|
|
|
/**
|
|
* Get the last migration batch.
|
|
*
|
|
* @return array
|
|
*/
|
|
public function getLast()
|
|
{
|
|
$query = $this->table()->where('batch', $this->getLastBatchNumber());
|
|
|
|
return $query->orderBy('migration', 'desc')->get()->all();
|
|
}
|
|
|
|
/**
|
|
* Get the completed migrations with their batch numbers.
|
|
*
|
|
* @return array
|
|
*/
|
|
public function getMigrationBatches()
|
|
{
|
|
return $this->table()
|
|
->orderBy('batch', 'asc')
|
|
->orderBy('migration', 'asc')
|
|
->pluck('batch', 'migration')->all();
|
|
}
|
|
|
|
/**
|
|
* Log that a migration was run.
|
|
*
|
|
* @param string $file
|
|
* @param int $batch
|
|
* @return void
|
|
*/
|
|
public function log($file, $batch)
|
|
{
|
|
$record = ['migration' => $file, 'batch' => $batch];
|
|
|
|
$this->table()->insert($record);
|
|
}
|
|
|
|
/**
|
|
* Remove a migration from the log.
|
|
*
|
|
* @param object $migration
|
|
* @return void
|
|
*/
|
|
public function delete($migration)
|
|
{
|
|
$this->table()->where('migration', $migration->migration)->delete();
|
|
}
|
|
|
|
/**
|
|
* Get the next migration batch number.
|
|
*
|
|
* @return int
|
|
*/
|
|
public function getNextBatchNumber()
|
|
{
|
|
return $this->getLastBatchNumber() + 1;
|
|
}
|
|
|
|
/**
|
|
* Get the last migration batch number.
|
|
*
|
|
* @return int
|
|
*/
|
|
public function getLastBatchNumber()
|
|
{
|
|
return $this->table()->max('batch');
|
|
}
|
|
|
|
/**
|
|
* Create the migration repository data store.
|
|
*
|
|
* @return void
|
|
*/
|
|
public function createRepository()
|
|
{
|
|
$schema = $this->getConnection()->getSchemaBuilder();
|
|
|
|
$schema->create($this->table, function ($table) {
|
|
// The migrations table is responsible for keeping track of which of the
|
|
// migrations have actually run for the application. We'll create the
|
|
// table to hold the migration file's path as well as the batch ID.
|
|
$table->increments('id');
|
|
$table->string('migration');
|
|
$table->integer('batch');
|
|
});
|
|
}
|
|
|
|
/**
|
|
* Determine if the migration repository exists.
|
|
*
|
|
* @return bool
|
|
*/
|
|
public function repositoryExists()
|
|
{
|
|
$schema = $this->getConnection()->getSchemaBuilder();
|
|
|
|
return $schema->hasTable($this->table);
|
|
}
|
|
|
|
/**
|
|
* Delete the migration repository data store.
|
|
*
|
|
* @return void
|
|
*/
|
|
public function deleteRepository()
|
|
{
|
|
$schema = $this->getConnection()->getSchemaBuilder();
|
|
|
|
$schema->drop($this->table);
|
|
}
|
|
|
|
/**
|
|
* Get a query builder for the migration table.
|
|
*
|
|
* @return \Illuminate\Database\Query\Builder
|
|
*/
|
|
protected function table()
|
|
{
|
|
return $this->getConnection()->table($this->table)->useWritePdo();
|
|
}
|
|
|
|
/**
|
|
* Get the connection resolver instance.
|
|
*
|
|
* @return \Illuminate\Database\ConnectionResolverInterface
|
|
*/
|
|
public function getConnectionResolver()
|
|
{
|
|
return $this->resolver;
|
|
}
|
|
|
|
/**
|
|
* Resolve the database connection instance.
|
|
*
|
|
* @return \Illuminate\Database\Connection
|
|
*/
|
|
public function getConnection()
|
|
{
|
|
return $this->resolver->connection($this->connection);
|
|
}
|
|
|
|
/**
|
|
* Set the information source to gather data.
|
|
*
|
|
* @param string $name
|
|
* @return void
|
|
*/
|
|
public function setSource($name)
|
|
{
|
|
$this->connection = $name;
|
|
}
|
|
}
|