connection = $connection; } /** * @param IOutput $output * @param Closure $schemaClosure The `\Closure` returns a `ISchemaWrapper` * @param array $options * @return ISchemaWrapper */ public function changeSchema(IOutput $output, Closure $schemaClosure, array $options): ISchemaWrapper { /** @var ISchemaWrapper $schema */ $schema = $schemaClosure(); $accountsTable = $schema->getTable('mail_accounts'); $accountsTable->addColumn('drafts_mailbox_id', 'integer', [ 'notnull' => false, 'default' => null, 'length' => 20, ]); $accountsTable->addColumn('sent_mailbox_id', 'integer', [ 'notnull' => false, 'default' => null, 'length' => 20, ]); $accountsTable->addColumn('trash_mailbox_id', 'integer', [ 'notnull' => false, 'default' => null, 'length' => 20, ]); return $schema; } public function postSchemaChange(IOutput $output, Closure $schemaClosure, array $options) { // Force a re-sync, so the values are propagated ASAP $update = $this->connection->getQueryBuilder(); $update->update('mail_accounts') ->set('last_mailbox_sync', $update->createNamedParameter(0)); $update->execute(); } }