getConfiguration(); $this->version = $version; $this->connection = $config->getConnection(); $this->sm = $this->connection->getSchemaManager(); $this->platform = $this->connection->getDatabasePlatform(); $this->outputWriter = $config->getOutputWriter(); } /** * Indicates the transactional mode of this migration. * * If this function returns true (default) the migration will be executed * in one transaction, otherwise non-transactional state will be used to * execute each of the migration SQLs. * * Extending class should override this function to alter the return value. */ public function isTransactional() : bool { return true; } public function getDescription() : string { return ''; } public function warnIf(bool $condition, string $message = '') : void { if (! $condition) { return; } $message = $message ?: 'Unknown Reason'; $this->outputWriter->write(sprintf( ' Warning during %s: %s', $this->version->getExecutionState(), $message )); } /** * @throws AbortMigration */ public function abortIf(bool $condition, string $message = '') : void { if ($condition) { throw new AbortMigration($message ?: 'Unknown Reason'); } } /** * @throws SkipMigration */ public function skipIf(bool $condition, string $message = '') : void { if ($condition) { throw new SkipMigration($message ?: 'Unknown Reason'); } } /** * @throws MigrationException|DBALException */ public function preUp(Schema $schema) : void { } /** * @throws MigrationException|DBALException */ public function postUp(Schema $schema) : void { } /** * @throws MigrationException|DBALException */ public function preDown(Schema $schema) : void { } /** * @throws MigrationException|DBALException */ public function postDown(Schema $schema) : void { } /** * @throws MigrationException|DBALException */ abstract public function up(Schema $schema) : void; /** * @throws MigrationException|DBALException */ abstract public function down(Schema $schema) : void; /** * @param mixed[] $params * @param mixed[] $types */ protected function addSql( string $sql, array $params = [], array $types = [] ) : void { $this->version->addSql($sql, $params, $types); } protected function write(string $message) : void { $this->outputWriter->write($message); } /** * @throws IrreversibleMigration */ protected function throwIrreversibleMigrationException(?string $message = null) : void { if ($message === null) { $message = 'This migration is irreversible and cannot be reverted.'; } throw new IrreversibleMigration($message); } }