connection = $connection; } /** * @param IOutput $output * @param Closure $schemaClosure The `\Closure` returns a `ISchemaWrapper` * @param array $options * @return null|ISchemaWrapper */ public function changeSchema(IOutput $output, Closure $schemaClosure, array $options) { /** @var ISchemaWrapper $schema */ $schema = $schemaClosure(); $personsTable = $schema->getTable('facerecog_persons'); $personsTable->changeColumn('name', [ 'notnull' => false, 'default' => null, ]); return $schema; } /** * @param IOutput $output * @param Closure $schemaClosure The `\Closure` returns a `ISchemaWrapper` * @param array $options * * @return void */ public function postSchemaChange(IOutput $output, Closure $schemaClosure, array $options) { $query = $this->connection->getQueryBuilder(); $query->update('facerecog_persons') ->set('name', $query->createNamedParameter(null)) ->where($query->expr()->iLike('name', $query->createNamedParameter('New person %'))); $query->execute(); } }