nextcloud / server

core/Migrations/Version13000Date20170718121200.php

Indentation +884 added lines, -884 removed lines

@@ -10,888 +10,888 @@
  */
 class Version13000Date20170718121200 extends SimpleMigrationStep {
 
-	/**
-	 * @param IOutput $output
-	 * @param \Closure $schemaClosure The `\Closure` returns a `Schema`
-	 * @param array $options
-	 * @since 13.0.0
-	 */
-	public function preSchemaChange(IOutput $output, \Closure $schemaClosure, array $options) {
-	}
-
-	/**
-	 * @param IOutput $output
-	 * @param \Closure $schemaClosure The `\Closure` returns a `Schema`
-	 * @param array $options
-	 * @return null|Schema
-	 * @since 13.0.0
-	 */
-	public function changeSchema(IOutput $output, \Closure $schemaClosure, array $options) {
-		/** @var Schema $schema */
-		$schema = $schemaClosure();
-
-		if (!$schema->hasTable('appconfig')) {
-			$table = $schema->createTable('appconfig');
-			$table->addColumn('appid', 'string', [
-				'notnull' => true,
-				'length' => 32,
-				'default' => '',
-			]);
-			$table->addColumn('configkey', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('configvalue', 'text', [
-				'notnull' => false,
-			]);
-			$table->setPrimaryKey(['appid', 'configkey']);
-			$table->addIndex(['configkey'], 'appconfig_config_key_index');
-			$table->addIndex(['appid'], 'appconfig_appid_key');
-		}
-
-		if (!$schema->hasTable('storages')) {
-			$table = $schema->createTable('storages');
-			$table->addColumn('id', 'string', [
-				'notnull' => false,
-				'length' => 64,
-			]);
-			$table->addColumn('numeric_id', 'integer', [
-				'autoincrement' => true,
-				'notnull' => true,
-				'length' => 4,
-			]);
-			$table->addColumn('available', 'integer', [
-				'notnull' => true,
-				'default' => 1,
-			]);
-			$table->addColumn('last_checked', 'integer', [
-				'notnull' => false,
-			]);
-			$table->setPrimaryKey(['numeric_id']);
-			$table->addUniqueIndex(['id'], 'storages_id_index');
-		}
-
-		if (!$schema->hasTable('mounts')) {
-			$table = $schema->createTable('mounts');
-			$table->addColumn('id', 'integer', [
-				'autoincrement' => true,
-				'notnull' => true,
-				'length' => 4,
-			]);
-			$table->addColumn('storage_id', 'integer', [
-				'notnull' => true,
-			]);
-			$table->addColumn('root_id', 'integer', [
-				'notnull' => true,
-			]);
-			$table->addColumn('user_id', 'string', [
-				'notnull' => true,
-				'length' => 64,
-			]);
-			$table->addColumn('mount_point', 'string', [
-				'notnull' => true,
-				'length' => 4000,
-			]);
-			$table->addColumn('mount_id', 'integer', [
-				'notnull' => false,
-			]);
-			$table->setPrimaryKey(['id']);
-			$table->addIndex(['user_id'], 'mounts_user_index');
-			$table->addIndex(['storage_id'], 'mounts_storage_index');
-			$table->addIndex(['root_id'], 'mounts_root_index');
-			$table->addIndex(['mount_id'], 'mounts_mount_id_index');
-			$table->addUniqueIndex(['user_id', 'root_id'], 'mounts_user_root_index');
-		}
-
-		if (!$schema->hasTable('mimetypes')) {
-			$table = $schema->createTable('mimetypes');
-			$table->addColumn('id', 'integer', [
-				'autoincrement' => true,
-				'notnull' => true,
-				'length' => 4,
-			]);
-			$table->addColumn('mimetype', 'string', [
-				'notnull' => true,
-				'length' => 255,
-				'default' => '',
-			]);
-			$table->setPrimaryKey(['id']);
-			$table->addUniqueIndex(['mimetype'], 'mimetype_id_index');
-		}
-
-		if (!$schema->hasTable('filecache')) {
-			$table = $schema->createTable('filecache');
-			$table->addColumn('fileid', 'integer', [
-				'autoincrement' => true,
-				'notnull' => true,
-				'length' => 4,
-			]);
-			$table->addColumn('storage', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('path', 'string', [
-				'notnull' => false,
-				'length' => 4000,
-			]);
-			$table->addColumn('path_hash', 'string', [
-				'notnull' => true,
-				'length' => 32,
-				'default' => '',
-			]);
-			$table->addColumn('parent', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('name', 'string', [
-				'notnull' => false,
-				'length' => 250,
-			]);
-			$table->addColumn('mimetype', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('mimepart', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('size', 'bigint', [
-				'notnull' => true,
-				'length' => 8,
-				'default' => 0,
-			]);
-			$table->addColumn('mtime', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('storage_mtime', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('encrypted', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('unencrypted_size', 'bigint', [
-				'notnull' => true,
-				'length' => 8,
-				'default' => 0,
-			]);
-			$table->addColumn('etag', 'string', [
-				'notnull' => false,
-				'length' => 40,
-			]);
-			$table->addColumn('permissions', 'integer', [
-				'notnull' => false,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('checksum', 'string', [
-				'notnull' => false,
-				'length' => 255,
-			]);
-			$table->setPrimaryKey(['fileid']);
-			$table->addUniqueIndex(['storage', 'path_hash'], 'fs_storage_path_hash');
-			$table->addIndex(['parent', 'name'], 'fs_parent_name_hash');
-			$table->addIndex(['storage', 'mimetype'], 'fs_storage_mimetype');
-			$table->addIndex(['storage', 'mimepart'], 'fs_storage_mimepart');
-			$table->addIndex(['storage', 'size', 'fileid'], 'fs_storage_size');
-		}
-
-		if (!$schema->hasTable('group_user')) {
-			$table = $schema->createTable('group_user');
-			$table->addColumn('gid', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('uid', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->setPrimaryKey(['gid', 'uid']);
-			$table->addIndex(['uid'], 'gu_uid_index');
-		}
-
-		if (!$schema->hasTable('group_admin')) {
-			$table = $schema->createTable('group_admin');
-			$table->addColumn('gid', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('uid', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->setPrimaryKey(['gid', 'uid']);
-			$table->addIndex(['uid'], 'group_admin_uid');
-		}
-
-		if (!$schema->hasTable('groups')) {
-			$table = $schema->createTable('groups');
-			$table->addColumn('gid', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->setPrimaryKey(['gid']);
-		}
-
-		if (!$schema->hasTable('preferences')) {
-			$table = $schema->createTable('preferences');
-			$table->addColumn('userid', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('appid', 'string', [
-				'notnull' => true,
-				'length' => 32,
-				'default' => '',
-			]);
-			$table->addColumn('configkey', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('configvalue', 'text', [
-				'notnull' => false,
-			]);
-			$table->setPrimaryKey(['userid', 'appid', 'configkey']);
-		}
-
-		if (!$schema->hasTable('properties')) {
-			$table = $schema->createTable('properties');
-			$table->addColumn('id', 'integer', [
-				'autoincrement' => true,
-				'notnull' => true,
-				'length' => 4,
-			]);
-			$table->addColumn('userid', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('propertypath', 'string', [
-				'notnull' => true,
-				'length' => 255,
-				'default' => '',
-			]);
-			$table->addColumn('propertyname', 'string', [
-				'notnull' => true,
-				'length' => 255,
-				'default' => '',
-			]);
-			$table->addColumn('propertyvalue', 'text', [
-				'notnull' => true,
-			]);
-			$table->setPrimaryKey(['id']);
-			$table->addIndex(['userid'], 'property_index');
-		}
-
-		if (!$schema->hasTable('share')) {
-			$table = $schema->createTable('share');
-			$table->addColumn('id', 'integer', [
-				'autoincrement' => true,
-				'notnull' => true,
-				'length' => 4,
-			]);
-			$table->addColumn('share_type', 'smallint', [
-				'notnull' => true,
-				'length' => 1,
-				'default' => 0,
-			]);
-			$table->addColumn('share_with', 'string', [
-				'notnull' => false,
-				'length' => 255,
-			]);
-			$table->addColumn('password', 'string', [
-				'notnull' => false,
-				'length' => 255,
-			]);
-			$table->addColumn('uid_owner', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('uid_initiator', 'string', [
-				'notnull' => false,
-				'length' => 64,
-			]);
-			$table->addColumn('parent', 'integer', [
-				'notnull' => false,
-				'length' => 4,
-			]);
-			$table->addColumn('item_type', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('item_source', 'string', [
-				'notnull' => false,
-				'length' => 255,
-			]);
-			$table->addColumn('item_target', 'string', [
-				'notnull' => false,
-				'length' => 255,
-			]);
-			$table->addColumn('file_source', 'integer', [
-				'notnull' => false,
-				'length' => 4,
-			]);
-			$table->addColumn('file_target', 'string', [
-				'notnull' => false,
-				'length' => 512,
-			]);
-			$table->addColumn('permissions', 'smallint', [
-				'notnull' => true,
-				'length' => 1,
-				'default' => 0,
-			]);
-			$table->addColumn('stime', 'bigint', [
-				'notnull' => true,
-				'length' => 8,
-				'default' => 0,
-			]);
-			$table->addColumn('accepted', 'smallint', [
-				'notnull' => true,
-				'length' => 1,
-				'default' => 0,
-			]);
-			$table->addColumn('expiration', 'datetime', [
-				'notnull' => false,
-			]);
-			$table->addColumn('token', 'string', [
-				'notnull' => false,
-				'length' => 32,
-			]);
-			$table->addColumn('mail_send', 'smallint', [
-				'notnull' => true,
-				'length' => 1,
-				'default' => 0,
-			]);
-			$table->addColumn('share_name', 'string', [
-				'notnull' => false,
-				'length' => 64,
-			]);
-			$table->setPrimaryKey(['id']);
-			$table->addIndex(['item_type', 'share_type'], 'item_share_type_index');
-			$table->addIndex(['file_source'], 'file_source_index');
-			$table->addIndex(['token'], 'token_index');
-		}
-
-		if (!$schema->hasTable('jobs')) {
-			$table = $schema->createTable('jobs');
-			$table->addColumn('id', 'integer', [
-				'autoincrement' => true,
-				'notnull' => true,
-				'length' => 4,
-			]);
-			$table->addColumn('class', 'string', [
-				'notnull' => true,
-				'length' => 255,
-				'default' => '',
-			]);
-			$table->addColumn('argument', 'string', [
-				'notnull' => true,
-				'length' => 4000,
-				'default' => '',
-			]);
-			$table->addColumn('last_run', 'integer', [
-				'notnull' => false,
-				'default' => 0,
-			]);
-			$table->addColumn('last_checked', 'integer', [
-				'notnull' => false,
-				'default' => 0,
-			]);
-			$table->addColumn('reserved_at', 'integer', [
-				'notnull' => false,
-				'default' => 0,
-			]);
-			$table->addColumn('execution_duration', 'integer', [
-				'notnull' => true,
-				'default' => 0,
-			]);
-			$table->setPrimaryKey(['id']);
-			$table->addIndex(['class'], 'job_class_index');
-		}
-
-		if (!$schema->hasTable('users')) {
-			$table = $schema->createTable('users');
-			$table->addColumn('uid', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('displayname', 'string', [
-				'notnull' => false,
-				'length' => 64,
-			]);
-			$table->addColumn('password', 'string', [
-				'notnull' => true,
-				'length' => 255,
-				'default' => '',
-			]);
-			$table->setPrimaryKey(['uid']);
-		}
-
-		if (!$schema->hasTable('authtoken')) {
-			$table = $schema->createTable('authtoken');
-			$table->addColumn('id', 'integer', [
-				'autoincrement' => true,
-				'notnull' => true,
-				'length' => 4,
-			]);
-			$table->addColumn('uid', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('login_name', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('password', 'text', [
-				'notnull' => false,
-			]);
-			$table->addColumn('name', 'text', [
-				'notnull' => true,
-				'default' => '',
-			]);
-			$table->addColumn('token', 'string', [
-				'notnull' => true,
-				'length' => 200,
-				'default' => '',
-			]);
-			$table->addColumn('type', 'smallint', [
-				'notnull' => true,
-				'length' => 2,
-				'default' => 0,
-			]);
-			$table->addColumn('remember', 'smallint', [
-				'notnull' => true,
-				'length' => 1,
-				'default' => 0,
-			]);
-			$table->addColumn('last_activity', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('last_check', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('scope', 'text', [
-				'notnull' => false,
-			]);
-			$table->setPrimaryKey(['id']);
-			$table->addUniqueIndex(['token'], 'authtoken_token_index');
-			$table->addIndex(['last_activity'], 'authtoken_last_activity_index');
-		}
-
-		if (!$schema->hasTable('bruteforce_attempts')) {
-			$table = $schema->createTable('bruteforce_attempts');
-			$table->addColumn('id', 'integer', [
-				'autoincrement' => true,
-				'notnull' => true,
-				'length' => 4,
-			]);
-			$table->addColumn('action', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('occurred', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('ip', 'string', [
-				'notnull' => true,
-				'length' => 255,
-				'default' => '',
-			]);
-			$table->addColumn('subnet', 'string', [
-				'notnull' => true,
-				'length' => 255,
-				'default' => '',
-			]);
-			$table->addColumn('metadata', 'string', [
-				'notnull' => true,
-				'length' => 255,
-				'default' => '',
-			]);
-			$table->setPrimaryKey(['id']);
-			$table->addIndex(['ip'], 'bruteforce_attempts_ip');
-			$table->addIndex(['subnet'], 'bruteforce_attempts_subnet');
-		}
-
-		if (!$schema->hasTable('vcategory')) {
-			$table = $schema->createTable('vcategory');
-			$table->addColumn('id', 'integer', [
-				'autoincrement' => true,
-				'notnull' => true,
-				'length' => 4,
-			]);
-			$table->addColumn('uid', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('type', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('category', 'string', [
-				'notnull' => true,
-				'length' => 255,
-				'default' => '',
-			]);
-			$table->setPrimaryKey(['id']);
-			$table->addIndex(['uid'], 'uid_index');
-			$table->addIndex(['type'], 'type_index');
-			$table->addIndex(['category'], 'category_index');
-		}
-
-		if (!$schema->hasTable('vcategory_to_object')) {
-			$table = $schema->createTable('vcategory_to_object');
-			$table->addColumn('objid', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('categoryid', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('type', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->setPrimaryKey(['categoryid', 'objid', 'type']);
-			$table->addIndex(['objid', 'type'], 'vcategory_objectd_index');
-		}
-
-		if (!$schema->hasTable('systemtag')) {
-			$table = $schema->createTable('systemtag');
-			$table->addColumn('id', 'integer', [
-				'autoincrement' => true,
-				'notnull' => true,
-				'length' => 4,
-			]);
-			$table->addColumn('name', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('visibility', 'smallint', [
-				'notnull' => true,
-				'length' => 1,
-				'default' => 1,
-			]);
-			$table->addColumn('editable', 'smallint', [
-				'notnull' => true,
-				'length' => 1,
-				'default' => 1,
-			]);
-			$table->setPrimaryKey(['id']);
-			$table->addUniqueIndex(['name', 'visibility', 'editable'], 'tag_ident');
-		}
-
-		if (!$schema->hasTable('systemtag_object_mapping')) {
-			$table = $schema->createTable('systemtag_object_mapping');
-			$table->addColumn('objectid', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('objecttype', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('systemtagid', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addUniqueIndex(['objecttype', 'objectid', 'systemtagid'], 'mapping');
-		}
-
-		if (!$schema->hasTable('systemtag_group')) {
-			$table = $schema->createTable('systemtag_group');
-			$table->addColumn('systemtagid', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('gid', 'string', [
-				'notnull' => true,
-			]);
-			$table->setPrimaryKey(['gid', 'systemtagid']);
-		}
-
-		if (!$schema->hasTable('file_locks')) {
-			$table = $schema->createTable('file_locks');
-			$table->addColumn('id', 'integer', [
-				'autoincrement' => true,
-				'notnull' => true,
-				'length' => 4,
-			]);
-			$table->addColumn('lock', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('key', 'string', [
-				'notnull' => true,
-				'length' => 64,
-			]);
-			$table->addColumn('ttl', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => -1,
-			]);
-			$table->setPrimaryKey(['id']);
-			$table->addUniqueIndex(['key'], 'lock_key_index');
-			$table->addIndex(['ttl'], 'lock_ttl_index');
-		}
-
-		if (!$schema->hasTable('comments')) {
-			$table = $schema->createTable('comments');
-			$table->addColumn('id', 'integer', [
-				'autoincrement' => true,
-				'notnull' => true,
-				'length' => 4,
-			]);
-			$table->addColumn('parent_id', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('topmost_parent_id', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('children_count', 'integer', [
-				'notnull' => true,
-				'length' => 4,
-				'default' => 0,
-			]);
-			$table->addColumn('actor_type', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('actor_id', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('message', 'text', [
-				'notnull' => false,
-			]);
-			$table->addColumn('verb', 'string', [
-				'notnull' => false,
-				'length' => 64,
-			]);
-			$table->addColumn('creation_timestamp', 'datetime', [
-				'notnull' => false,
-			]);
-			$table->addColumn('latest_child_timestamp', 'datetime', [
-				'notnull' => false,
-			]);
-			$table->addColumn('object_type', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('object_id', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->setPrimaryKey(['id']);
-			$table->addIndex(['parent_id'], 'comments_parent_id_index');
-			$table->addIndex(['topmost_parent_id'], 'comments_topmost_parent_id_idx');
-			$table->addIndex(['object_type', 'object_id', 'creation_timestamp'], 'comments_object_index');
-			$table->addIndex(['actor_type', 'actor_id'], 'comments_actor_index');
-		}
-
-		if (!$schema->hasTable('comments_read_markers')) {
-			$table = $schema->createTable('comments_read_markers');
-			$table->addColumn('user_id', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('marker_datetime', 'datetime', [
-				'notnull' => false,
-			]);
-			$table->addColumn('object_type', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('object_id', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addIndex(['object_type', 'object_id'], 'comments_marker_object_index');
-			$table->addUniqueIndex(['user_id', 'object_type', 'object_id'], 'comments_marker_index');
-		}
-
-		if (!$schema->hasTable('credentials')) {
-			$table = $schema->createTable('credentials');
-			$table->addColumn('user', 'string', [
-				'notnull' => true,
-				'length' => 64,
-			]);
-			$table->addColumn('identifier', 'string', [
-				'notnull' => true,
-				'length' => 64,
-			]);
-			$table->addColumn('credentials', 'text', [
-				'notnull' => false,
-			]);
-			$table->setPrimaryKey(['user', 'identifier']);
-			$table->addIndex(['user'], 'credentials_user');
-		}
-
-		if (!$schema->hasTable('admin_sections')) {
-			$table = $schema->createTable('admin_sections');
-			$table->addColumn('id', 'string', [
-				'notnull' => true,
-				'length' => 64,
-			]);
-			$table->addColumn('class', 'string', [
-				'notnull' => true,
-				'length' => 255,
-				'default' => '',
-			]);
-			$table->addColumn('priority', 'smallint', [
-				'notnull' => true,
-				'length' => 1,
-				'default' => 0,
-			]);
-			$table->setPrimaryKey(['id']);
-			$table->addUniqueIndex(['class'], 'admin_sections_class');
-		}
-
-		if (!$schema->hasTable('admin_settings')) {
-			$table = $schema->createTable('admin_settings');
-			$table->addColumn('id', 'integer', [
-				'autoincrement' => true,
-				'notnull' => true,
-				'length' => 4,
-			]);
-			$table->addColumn('class', 'string', [
-				'notnull' => true,
-				'length' => 255,
-				'default' => '',
-			]);
-			$table->addColumn('section', 'string', [
-				'notnull' => false,
-				'length' => 64,
-			]);
-			$table->addColumn('priority', 'smallint', [
-				'notnull' => true,
-				'length' => 1,
-				'default' => 0,
-			]);
-			$table->setPrimaryKey(['id']);
-			$table->addUniqueIndex(['class'], 'admin_settings_class');
-			$table->addIndex(['section'], 'admin_settings_section');
-		}
-
-		if (!$schema->hasTable('personal_sections')) {
-			$table = $schema->createTable('personal_sections');
-			$table->addColumn('id', 'string', [
-				'notnull' => true,
-				'length' => 64,
-			]);
-			$table->addColumn('class', 'string', [
-				'notnull' => true,
-				'length' => 255,
-				'default' => '',
-			]);
-			$table->addColumn('priority', 'smallint', [
-				'notnull' => true,
-				'length' => 1,
-				'default' => 0,
-			]);
-			$table->setPrimaryKey(['id']);
-			$table->addUniqueIndex(['class'], 'personal_sections_class');
-		}
-
-		if (!$schema->hasTable('personal_settings')) {
-			$table = $schema->createTable('personal_settings');
-			$table->addColumn('id', 'integer', [
-				'autoincrement' => true,
-				'notnull' => true,
-				'length' => 4,
-			]);
-			$table->addColumn('class', 'string', [
-				'notnull' => true,
-				'length' => 255,
-				'default' => '',
-			]);
-			$table->addColumn('section', 'string', [
-				'notnull' => false,
-				'length' => 64,
-			]);
-			$table->addColumn('priority', 'smallint', [
-				'notnull' => true,
-				'length' => 1,
-				'default' => 0,
-			]);
-			$table->setPrimaryKey(['id']);
-			$table->addUniqueIndex(['class'], 'personal_settings_class');
-			$table->addIndex(['section'], 'personal_settings_section');
-		}
-
-		if (!$schema->hasTable('accounts')) {
-			$table = $schema->createTable('accounts');
-			$table->addColumn('uid', 'string', [
-				'notnull' => true,
-				'length' => 64,
-				'default' => '',
-			]);
-			$table->addColumn('data', 'text', [
-				'notnull' => true,
-				'default' => '',
-			]);
-			$table->setPrimaryKey(['uid']);
-		}
-		return $schema;
-	}
-
-	/**
-	 * @param IOutput $output
-	 * @param \Closure $schemaClosure The `\Closure` returns a `Schema`
-	 * @param array $options
-	 * @since 13.0.0
-	 */
-	public function postSchemaChange(IOutput $output, \Closure $schemaClosure, array $options) {
-	}
+    /**
+     * @param IOutput $output
+     * @param \Closure $schemaClosure The `\Closure` returns a `Schema`
+     * @param array $options
+     * @since 13.0.0
+     */
+    public function preSchemaChange(IOutput $output, \Closure $schemaClosure, array $options) {
+    }
+
+    /**
+     * @param IOutput $output
+     * @param \Closure $schemaClosure The `\Closure` returns a `Schema`
+     * @param array $options
+     * @return null|Schema
+     * @since 13.0.0
+     */
+    public function changeSchema(IOutput $output, \Closure $schemaClosure, array $options) {
+        /** @var Schema $schema */
+        $schema = $schemaClosure();
+
+        if (!$schema->hasTable('appconfig')) {
+            $table = $schema->createTable('appconfig');
+            $table->addColumn('appid', 'string', [
+                'notnull' => true,
+                'length' => 32,
+                'default' => '',
+            ]);
+            $table->addColumn('configkey', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('configvalue', 'text', [
+                'notnull' => false,
+            ]);
+            $table->setPrimaryKey(['appid', 'configkey']);
+            $table->addIndex(['configkey'], 'appconfig_config_key_index');
+            $table->addIndex(['appid'], 'appconfig_appid_key');
+        }
+
+        if (!$schema->hasTable('storages')) {
+            $table = $schema->createTable('storages');
+            $table->addColumn('id', 'string', [
+                'notnull' => false,
+                'length' => 64,
+            ]);
+            $table->addColumn('numeric_id', 'integer', [
+                'autoincrement' => true,
+                'notnull' => true,
+                'length' => 4,
+            ]);
+            $table->addColumn('available', 'integer', [
+                'notnull' => true,
+                'default' => 1,
+            ]);
+            $table->addColumn('last_checked', 'integer', [
+                'notnull' => false,
+            ]);
+            $table->setPrimaryKey(['numeric_id']);
+            $table->addUniqueIndex(['id'], 'storages_id_index');
+        }
+
+        if (!$schema->hasTable('mounts')) {
+            $table = $schema->createTable('mounts');
+            $table->addColumn('id', 'integer', [
+                'autoincrement' => true,
+                'notnull' => true,
+                'length' => 4,
+            ]);
+            $table->addColumn('storage_id', 'integer', [
+                'notnull' => true,
+            ]);
+            $table->addColumn('root_id', 'integer', [
+                'notnull' => true,
+            ]);
+            $table->addColumn('user_id', 'string', [
+                'notnull' => true,
+                'length' => 64,
+            ]);
+            $table->addColumn('mount_point', 'string', [
+                'notnull' => true,
+                'length' => 4000,
+            ]);
+            $table->addColumn('mount_id', 'integer', [
+                'notnull' => false,
+            ]);
+            $table->setPrimaryKey(['id']);
+            $table->addIndex(['user_id'], 'mounts_user_index');
+            $table->addIndex(['storage_id'], 'mounts_storage_index');
+            $table->addIndex(['root_id'], 'mounts_root_index');
+            $table->addIndex(['mount_id'], 'mounts_mount_id_index');
+            $table->addUniqueIndex(['user_id', 'root_id'], 'mounts_user_root_index');
+        }
+
+        if (!$schema->hasTable('mimetypes')) {
+            $table = $schema->createTable('mimetypes');
+            $table->addColumn('id', 'integer', [
+                'autoincrement' => true,
+                'notnull' => true,
+                'length' => 4,
+            ]);
+            $table->addColumn('mimetype', 'string', [
+                'notnull' => true,
+                'length' => 255,
+                'default' => '',
+            ]);
+            $table->setPrimaryKey(['id']);
+            $table->addUniqueIndex(['mimetype'], 'mimetype_id_index');
+        }
+
+        if (!$schema->hasTable('filecache')) {
+            $table = $schema->createTable('filecache');
+            $table->addColumn('fileid', 'integer', [
+                'autoincrement' => true,
+                'notnull' => true,
+                'length' => 4,
+            ]);
+            $table->addColumn('storage', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('path', 'string', [
+                'notnull' => false,
+                'length' => 4000,
+            ]);
+            $table->addColumn('path_hash', 'string', [
+                'notnull' => true,
+                'length' => 32,
+                'default' => '',
+            ]);
+            $table->addColumn('parent', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('name', 'string', [
+                'notnull' => false,
+                'length' => 250,
+            ]);
+            $table->addColumn('mimetype', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('mimepart', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('size', 'bigint', [
+                'notnull' => true,
+                'length' => 8,
+                'default' => 0,
+            ]);
+            $table->addColumn('mtime', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('storage_mtime', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('encrypted', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('unencrypted_size', 'bigint', [
+                'notnull' => true,
+                'length' => 8,
+                'default' => 0,
+            ]);
+            $table->addColumn('etag', 'string', [
+                'notnull' => false,
+                'length' => 40,
+            ]);
+            $table->addColumn('permissions', 'integer', [
+                'notnull' => false,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('checksum', 'string', [
+                'notnull' => false,
+                'length' => 255,
+            ]);
+            $table->setPrimaryKey(['fileid']);
+            $table->addUniqueIndex(['storage', 'path_hash'], 'fs_storage_path_hash');
+            $table->addIndex(['parent', 'name'], 'fs_parent_name_hash');
+            $table->addIndex(['storage', 'mimetype'], 'fs_storage_mimetype');
+            $table->addIndex(['storage', 'mimepart'], 'fs_storage_mimepart');
+            $table->addIndex(['storage', 'size', 'fileid'], 'fs_storage_size');
+        }
+
+        if (!$schema->hasTable('group_user')) {
+            $table = $schema->createTable('group_user');
+            $table->addColumn('gid', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('uid', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->setPrimaryKey(['gid', 'uid']);
+            $table->addIndex(['uid'], 'gu_uid_index');
+        }
+
+        if (!$schema->hasTable('group_admin')) {
+            $table = $schema->createTable('group_admin');
+            $table->addColumn('gid', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('uid', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->setPrimaryKey(['gid', 'uid']);
+            $table->addIndex(['uid'], 'group_admin_uid');
+        }
+
+        if (!$schema->hasTable('groups')) {
+            $table = $schema->createTable('groups');
+            $table->addColumn('gid', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->setPrimaryKey(['gid']);
+        }
+
+        if (!$schema->hasTable('preferences')) {
+            $table = $schema->createTable('preferences');
+            $table->addColumn('userid', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('appid', 'string', [
+                'notnull' => true,
+                'length' => 32,
+                'default' => '',
+            ]);
+            $table->addColumn('configkey', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('configvalue', 'text', [
+                'notnull' => false,
+            ]);
+            $table->setPrimaryKey(['userid', 'appid', 'configkey']);
+        }
+
+        if (!$schema->hasTable('properties')) {
+            $table = $schema->createTable('properties');
+            $table->addColumn('id', 'integer', [
+                'autoincrement' => true,
+                'notnull' => true,
+                'length' => 4,
+            ]);
+            $table->addColumn('userid', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('propertypath', 'string', [
+                'notnull' => true,
+                'length' => 255,
+                'default' => '',
+            ]);
+            $table->addColumn('propertyname', 'string', [
+                'notnull' => true,
+                'length' => 255,
+                'default' => '',
+            ]);
+            $table->addColumn('propertyvalue', 'text', [
+                'notnull' => true,
+            ]);
+            $table->setPrimaryKey(['id']);
+            $table->addIndex(['userid'], 'property_index');
+        }
+
+        if (!$schema->hasTable('share')) {
+            $table = $schema->createTable('share');
+            $table->addColumn('id', 'integer', [
+                'autoincrement' => true,
+                'notnull' => true,
+                'length' => 4,
+            ]);
+            $table->addColumn('share_type', 'smallint', [
+                'notnull' => true,
+                'length' => 1,
+                'default' => 0,
+            ]);
+            $table->addColumn('share_with', 'string', [
+                'notnull' => false,
+                'length' => 255,
+            ]);
+            $table->addColumn('password', 'string', [
+                'notnull' => false,
+                'length' => 255,
+            ]);
+            $table->addColumn('uid_owner', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('uid_initiator', 'string', [
+                'notnull' => false,
+                'length' => 64,
+            ]);
+            $table->addColumn('parent', 'integer', [
+                'notnull' => false,
+                'length' => 4,
+            ]);
+            $table->addColumn('item_type', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('item_source', 'string', [
+                'notnull' => false,
+                'length' => 255,
+            ]);
+            $table->addColumn('item_target', 'string', [
+                'notnull' => false,
+                'length' => 255,
+            ]);
+            $table->addColumn('file_source', 'integer', [
+                'notnull' => false,
+                'length' => 4,
+            ]);
+            $table->addColumn('file_target', 'string', [
+                'notnull' => false,
+                'length' => 512,
+            ]);
+            $table->addColumn('permissions', 'smallint', [
+                'notnull' => true,
+                'length' => 1,
+                'default' => 0,
+            ]);
+            $table->addColumn('stime', 'bigint', [
+                'notnull' => true,
+                'length' => 8,
+                'default' => 0,
+            ]);
+            $table->addColumn('accepted', 'smallint', [
+                'notnull' => true,
+                'length' => 1,
+                'default' => 0,
+            ]);
+            $table->addColumn('expiration', 'datetime', [
+                'notnull' => false,
+            ]);
+            $table->addColumn('token', 'string', [
+                'notnull' => false,
+                'length' => 32,
+            ]);
+            $table->addColumn('mail_send', 'smallint', [
+                'notnull' => true,
+                'length' => 1,
+                'default' => 0,
+            ]);
+            $table->addColumn('share_name', 'string', [
+                'notnull' => false,
+                'length' => 64,
+            ]);
+            $table->setPrimaryKey(['id']);
+            $table->addIndex(['item_type', 'share_type'], 'item_share_type_index');
+            $table->addIndex(['file_source'], 'file_source_index');
+            $table->addIndex(['token'], 'token_index');
+        }
+
+        if (!$schema->hasTable('jobs')) {
+            $table = $schema->createTable('jobs');
+            $table->addColumn('id', 'integer', [
+                'autoincrement' => true,
+                'notnull' => true,
+                'length' => 4,
+            ]);
+            $table->addColumn('class', 'string', [
+                'notnull' => true,
+                'length' => 255,
+                'default' => '',
+            ]);
+            $table->addColumn('argument', 'string', [
+                'notnull' => true,
+                'length' => 4000,
+                'default' => '',
+            ]);
+            $table->addColumn('last_run', 'integer', [
+                'notnull' => false,
+                'default' => 0,
+            ]);
+            $table->addColumn('last_checked', 'integer', [
+                'notnull' => false,
+                'default' => 0,
+            ]);
+            $table->addColumn('reserved_at', 'integer', [
+                'notnull' => false,
+                'default' => 0,
+            ]);
+            $table->addColumn('execution_duration', 'integer', [
+                'notnull' => true,
+                'default' => 0,
+            ]);
+            $table->setPrimaryKey(['id']);
+            $table->addIndex(['class'], 'job_class_index');
+        }
+
+        if (!$schema->hasTable('users')) {
+            $table = $schema->createTable('users');
+            $table->addColumn('uid', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('displayname', 'string', [
+                'notnull' => false,
+                'length' => 64,
+            ]);
+            $table->addColumn('password', 'string', [
+                'notnull' => true,
+                'length' => 255,
+                'default' => '',
+            ]);
+            $table->setPrimaryKey(['uid']);
+        }
+
+        if (!$schema->hasTable('authtoken')) {
+            $table = $schema->createTable('authtoken');
+            $table->addColumn('id', 'integer', [
+                'autoincrement' => true,
+                'notnull' => true,
+                'length' => 4,
+            ]);
+            $table->addColumn('uid', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('login_name', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('password', 'text', [
+                'notnull' => false,
+            ]);
+            $table->addColumn('name', 'text', [
+                'notnull' => true,
+                'default' => '',
+            ]);
+            $table->addColumn('token', 'string', [
+                'notnull' => true,
+                'length' => 200,
+                'default' => '',
+            ]);
+            $table->addColumn('type', 'smallint', [
+                'notnull' => true,
+                'length' => 2,
+                'default' => 0,
+            ]);
+            $table->addColumn('remember', 'smallint', [
+                'notnull' => true,
+                'length' => 1,
+                'default' => 0,
+            ]);
+            $table->addColumn('last_activity', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('last_check', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('scope', 'text', [
+                'notnull' => false,
+            ]);
+            $table->setPrimaryKey(['id']);
+            $table->addUniqueIndex(['token'], 'authtoken_token_index');
+            $table->addIndex(['last_activity'], 'authtoken_last_activity_index');
+        }
+
+        if (!$schema->hasTable('bruteforce_attempts')) {
+            $table = $schema->createTable('bruteforce_attempts');
+            $table->addColumn('id', 'integer', [
+                'autoincrement' => true,
+                'notnull' => true,
+                'length' => 4,
+            ]);
+            $table->addColumn('action', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('occurred', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('ip', 'string', [
+                'notnull' => true,
+                'length' => 255,
+                'default' => '',
+            ]);
+            $table->addColumn('subnet', 'string', [
+                'notnull' => true,
+                'length' => 255,
+                'default' => '',
+            ]);
+            $table->addColumn('metadata', 'string', [
+                'notnull' => true,
+                'length' => 255,
+                'default' => '',
+            ]);
+            $table->setPrimaryKey(['id']);
+            $table->addIndex(['ip'], 'bruteforce_attempts_ip');
+            $table->addIndex(['subnet'], 'bruteforce_attempts_subnet');
+        }
+
+        if (!$schema->hasTable('vcategory')) {
+            $table = $schema->createTable('vcategory');
+            $table->addColumn('id', 'integer', [
+                'autoincrement' => true,
+                'notnull' => true,
+                'length' => 4,
+            ]);
+            $table->addColumn('uid', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('type', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('category', 'string', [
+                'notnull' => true,
+                'length' => 255,
+                'default' => '',
+            ]);
+            $table->setPrimaryKey(['id']);
+            $table->addIndex(['uid'], 'uid_index');
+            $table->addIndex(['type'], 'type_index');
+            $table->addIndex(['category'], 'category_index');
+        }
+
+        if (!$schema->hasTable('vcategory_to_object')) {
+            $table = $schema->createTable('vcategory_to_object');
+            $table->addColumn('objid', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('categoryid', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('type', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->setPrimaryKey(['categoryid', 'objid', 'type']);
+            $table->addIndex(['objid', 'type'], 'vcategory_objectd_index');
+        }
+
+        if (!$schema->hasTable('systemtag')) {
+            $table = $schema->createTable('systemtag');
+            $table->addColumn('id', 'integer', [
+                'autoincrement' => true,
+                'notnull' => true,
+                'length' => 4,
+            ]);
+            $table->addColumn('name', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('visibility', 'smallint', [
+                'notnull' => true,
+                'length' => 1,
+                'default' => 1,
+            ]);
+            $table->addColumn('editable', 'smallint', [
+                'notnull' => true,
+                'length' => 1,
+                'default' => 1,
+            ]);
+            $table->setPrimaryKey(['id']);
+            $table->addUniqueIndex(['name', 'visibility', 'editable'], 'tag_ident');
+        }
+
+        if (!$schema->hasTable('systemtag_object_mapping')) {
+            $table = $schema->createTable('systemtag_object_mapping');
+            $table->addColumn('objectid', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('objecttype', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('systemtagid', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addUniqueIndex(['objecttype', 'objectid', 'systemtagid'], 'mapping');
+        }
+
+        if (!$schema->hasTable('systemtag_group')) {
+            $table = $schema->createTable('systemtag_group');
+            $table->addColumn('systemtagid', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('gid', 'string', [
+                'notnull' => true,
+            ]);
+            $table->setPrimaryKey(['gid', 'systemtagid']);
+        }
+
+        if (!$schema->hasTable('file_locks')) {
+            $table = $schema->createTable('file_locks');
+            $table->addColumn('id', 'integer', [
+                'autoincrement' => true,
+                'notnull' => true,
+                'length' => 4,
+            ]);
+            $table->addColumn('lock', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('key', 'string', [
+                'notnull' => true,
+                'length' => 64,
+            ]);
+            $table->addColumn('ttl', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => -1,
+            ]);
+            $table->setPrimaryKey(['id']);
+            $table->addUniqueIndex(['key'], 'lock_key_index');
+            $table->addIndex(['ttl'], 'lock_ttl_index');
+        }
+
+        if (!$schema->hasTable('comments')) {
+            $table = $schema->createTable('comments');
+            $table->addColumn('id', 'integer', [
+                'autoincrement' => true,
+                'notnull' => true,
+                'length' => 4,
+            ]);
+            $table->addColumn('parent_id', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('topmost_parent_id', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('children_count', 'integer', [
+                'notnull' => true,
+                'length' => 4,
+                'default' => 0,
+            ]);
+            $table->addColumn('actor_type', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('actor_id', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('message', 'text', [
+                'notnull' => false,
+            ]);
+            $table->addColumn('verb', 'string', [
+                'notnull' => false,
+                'length' => 64,
+            ]);
+            $table->addColumn('creation_timestamp', 'datetime', [
+                'notnull' => false,
+            ]);
+            $table->addColumn('latest_child_timestamp', 'datetime', [
+                'notnull' => false,
+            ]);
+            $table->addColumn('object_type', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('object_id', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->setPrimaryKey(['id']);
+            $table->addIndex(['parent_id'], 'comments_parent_id_index');
+            $table->addIndex(['topmost_parent_id'], 'comments_topmost_parent_id_idx');
+            $table->addIndex(['object_type', 'object_id', 'creation_timestamp'], 'comments_object_index');
+            $table->addIndex(['actor_type', 'actor_id'], 'comments_actor_index');
+        }
+
+        if (!$schema->hasTable('comments_read_markers')) {
+            $table = $schema->createTable('comments_read_markers');
+            $table->addColumn('user_id', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('marker_datetime', 'datetime', [
+                'notnull' => false,
+            ]);
+            $table->addColumn('object_type', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('object_id', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addIndex(['object_type', 'object_id'], 'comments_marker_object_index');
+            $table->addUniqueIndex(['user_id', 'object_type', 'object_id'], 'comments_marker_index');
+        }
+
+        if (!$schema->hasTable('credentials')) {
+            $table = $schema->createTable('credentials');
+            $table->addColumn('user', 'string', [
+                'notnull' => true,
+                'length' => 64,
+            ]);
+            $table->addColumn('identifier', 'string', [
+                'notnull' => true,
+                'length' => 64,
+            ]);
+            $table->addColumn('credentials', 'text', [
+                'notnull' => false,
+            ]);
+            $table->setPrimaryKey(['user', 'identifier']);
+            $table->addIndex(['user'], 'credentials_user');
+        }
+
+        if (!$schema->hasTable('admin_sections')) {
+            $table = $schema->createTable('admin_sections');
+            $table->addColumn('id', 'string', [
+                'notnull' => true,
+                'length' => 64,
+            ]);
+            $table->addColumn('class', 'string', [
+                'notnull' => true,
+                'length' => 255,
+                'default' => '',
+            ]);
+            $table->addColumn('priority', 'smallint', [
+                'notnull' => true,
+                'length' => 1,
+                'default' => 0,
+            ]);
+            $table->setPrimaryKey(['id']);
+            $table->addUniqueIndex(['class'], 'admin_sections_class');
+        }
+
+        if (!$schema->hasTable('admin_settings')) {
+            $table = $schema->createTable('admin_settings');
+            $table->addColumn('id', 'integer', [
+                'autoincrement' => true,
+                'notnull' => true,
+                'length' => 4,
+            ]);
+            $table->addColumn('class', 'string', [
+                'notnull' => true,
+                'length' => 255,
+                'default' => '',
+            ]);
+            $table->addColumn('section', 'string', [
+                'notnull' => false,
+                'length' => 64,
+            ]);
+            $table->addColumn('priority', 'smallint', [
+                'notnull' => true,
+                'length' => 1,
+                'default' => 0,
+            ]);
+            $table->setPrimaryKey(['id']);
+            $table->addUniqueIndex(['class'], 'admin_settings_class');
+            $table->addIndex(['section'], 'admin_settings_section');
+        }
+
+        if (!$schema->hasTable('personal_sections')) {
+            $table = $schema->createTable('personal_sections');
+            $table->addColumn('id', 'string', [
+                'notnull' => true,
+                'length' => 64,
+            ]);
+            $table->addColumn('class', 'string', [
+                'notnull' => true,
+                'length' => 255,
+                'default' => '',
+            ]);
+            $table->addColumn('priority', 'smallint', [
+                'notnull' => true,
+                'length' => 1,
+                'default' => 0,
+            ]);
+            $table->setPrimaryKey(['id']);
+            $table->addUniqueIndex(['class'], 'personal_sections_class');
+        }
+
+        if (!$schema->hasTable('personal_settings')) {
+            $table = $schema->createTable('personal_settings');
+            $table->addColumn('id', 'integer', [
+                'autoincrement' => true,
+                'notnull' => true,
+                'length' => 4,
+            ]);
+            $table->addColumn('class', 'string', [
+                'notnull' => true,
+                'length' => 255,
+                'default' => '',
+            ]);
+            $table->addColumn('section', 'string', [
+                'notnull' => false,
+                'length' => 64,
+            ]);
+            $table->addColumn('priority', 'smallint', [
+                'notnull' => true,
+                'length' => 1,
+                'default' => 0,
+            ]);
+            $table->setPrimaryKey(['id']);
+            $table->addUniqueIndex(['class'], 'personal_settings_class');
+            $table->addIndex(['section'], 'personal_settings_section');
+        }
+
+        if (!$schema->hasTable('accounts')) {
+            $table = $schema->createTable('accounts');
+            $table->addColumn('uid', 'string', [
+                'notnull' => true,
+                'length' => 64,
+                'default' => '',
+            ]);
+            $table->addColumn('data', 'text', [
+                'notnull' => true,
+                'default' => '',
+            ]);
+            $table->setPrimaryKey(['uid']);
+        }
+        return $schema;
+    }
+
+    /**
+     * @param IOutput $output
+     * @param \Closure $schemaClosure The `\Closure` returns a `Schema`
+     * @param array $options
+     * @since 13.0.0
+     */
+    public function postSchemaChange(IOutput $output, \Closure $schemaClosure, array $options) {
+    }
 }

core/Command/Db/ConvertType.php

Indentation +405 added lines, -405 removed lines

@@ -49,409 +49,409 @@
 use Symfony\Component\Console\Question\Question;
 
 class ConvertType extends Command implements CompletionAwareInterface {
-	/**
-	 * @var \OCP\IConfig
-	 */
-	protected $config;
-
-	/**
-	 * @var \OC\DB\ConnectionFactory
-	 */
-	protected $connectionFactory;
-
-	/** @var array */
-	protected $columnTypes;
-
-	/**
-	 * @param \OCP\IConfig $config
-	 * @param \OC\DB\ConnectionFactory $connectionFactory
-	 */
-	public function __construct(IConfig $config, ConnectionFactory $connectionFactory) {
-		$this->config = $config;
-		$this->connectionFactory = $connectionFactory;
-		parent::__construct();
-	}
-
-	protected function configure() {
-		$this
-			->setName('db:convert-type')
-			->setDescription('Convert the Nextcloud database to the newly configured one')
-			->addArgument(
-				'type',
-				InputArgument::REQUIRED,
-				'the type of the database to convert to'
-			)
-			->addArgument(
-				'username',
-				InputArgument::REQUIRED,
-				'the username of the database to convert to'
-			)
-			->addArgument(
-				'hostname',
-				InputArgument::REQUIRED,
-				'the hostname of the database to convert to'
-			)
-			->addArgument(
-				'database',
-				InputArgument::REQUIRED,
-				'the name of the database to convert to'
-			)
-			->addOption(
-				'port',
-				null,
-				InputOption::VALUE_REQUIRED,
-				'the port of the database to convert to'
-			)
-			->addOption(
-				'password',
-				null,
-				InputOption::VALUE_REQUIRED,
-				'the password of the database to convert to. Will be asked when not specified. Can also be passed via stdin.'
-			)
-			->addOption(
-				'clear-schema',
-				null,
-				InputOption::VALUE_NONE,
-				'remove all tables from the destination database'
-			)
-			->addOption(
-				'all-apps',
-				null,
-				InputOption::VALUE_NONE,
-				'whether to create schema for all apps instead of only installed apps'
-			)
-			->addOption(
-				'chunk-size',
-				null,
-				InputOption::VALUE_REQUIRED,
-				'the maximum number of database rows to handle in a single query, bigger tables will be handled in chunks of this size. Lower this if the process runs out of memory during conversion.',
-				1000
-			)
-		;
-	}
-
-	protected function validateInput(InputInterface $input, OutputInterface $output) {
-		$type = $this->connectionFactory->normalizeType($input->getArgument('type'));
-		if ($type === 'sqlite3') {
-			throw new \InvalidArgumentException(
-				'Converting to SQLite (sqlite3) is currently not supported.'
-			);
-		}
-		if ($type === $this->config->getSystemValue('dbtype', '')) {
-			throw new \InvalidArgumentException(sprintf(
-				'Can not convert from %1$s to %1$s.',
-				$type
-			));
-		}
-		if ($type === 'oci' && $input->getOption('clear-schema')) {
-			// Doctrine unconditionally tries (at least in version 2.3)
-			// to drop sequence triggers when dropping a table, even though
-			// such triggers may not exist. This results in errors like
-			// "ORA-04080: trigger 'OC_STORAGES_AI_PK' does not exist".
-			throw new \InvalidArgumentException(
-				'The --clear-schema option is not supported when converting to Oracle (oci).'
-			);
-		}
-	}
-
-	protected function readPassword(InputInterface $input, OutputInterface $output) {
-		// Explicitly specified password
-		if ($input->getOption('password')) {
-			return;
-		}
-
-		// Read from stdin. stream_set_blocking is used to prevent blocking
-		// when nothing is passed via stdin.
-		stream_set_blocking(STDIN, 0);
-		$password = file_get_contents('php://stdin');
-		stream_set_blocking(STDIN, 1);
-		if (trim($password) !== '') {
-			$input->setOption('password', $password);
-			return;
-		}
-
-		// Read password by interacting
-		if ($input->isInteractive()) {
-			/** @var QuestionHelper $helper */
-			$helper = $this->getHelper('question');
-			$question = new Question('What is the database password?');
-			$question->setHidden(true);
-			$question->setHiddenFallback(false);
-			$password = $helper->ask($input, $output, $question);
-			$input->setOption('password', $password);
-			return;
-		}
-	}
-
-	protected function execute(InputInterface $input, OutputInterface $output) {
-		$this->validateInput($input, $output);
-		$this->readPassword($input, $output);
-
-		$fromDB = \OC::$server->getDatabaseConnection();
-		$toDB = $this->getToDBConnection($input, $output);
-
-		if ($input->getOption('clear-schema')) {
-			$this->clearSchema($toDB, $input, $output);
-		}
-
-		$this->createSchema($fromDB, $toDB, $input, $output);
-
-		$toTables = $this->getTables($toDB);
-		$fromTables = $this->getTables($fromDB);
-
-		// warn/fail if there are more tables in 'from' database
-		$extraFromTables = array_diff($fromTables, $toTables);
-		if (!empty($extraFromTables)) {
-			$output->writeln('<comment>The following tables will not be converted:</comment>');
-			$output->writeln($extraFromTables);
-			if (!$input->getOption('all-apps')) {
-				$output->writeln('<comment>Please note that tables belonging to available but currently not installed apps</comment>');
-				$output->writeln('<comment>can be included by specifying the --all-apps option.</comment>');
-			}
-
-			/** @var QuestionHelper $helper */
-			$helper = $this->getHelper('question');
-			$question = new ConfirmationQuestion('Continue with the conversion (y/n)? [n] ', false);
-
-			if (!$helper->ask($input, $output, $question)) {
-				return;
-			}
-		}
-		$intersectingTables = array_intersect($toTables, $fromTables);
-		$this->convertDB($fromDB, $toDB, $intersectingTables, $input, $output);
-	}
-
-	protected function createSchema(Connection $fromDB, Connection $toDB, InputInterface $input, OutputInterface $output) {
-		$output->writeln('<info>Creating schema in new database</info>');
-
-		$fromMS = new MigrationService('core', $fromDB);
-		$currentMigration = $fromMS->getMigration('current');
-		if ($currentMigration !== '0') {
-			$toMS = new MigrationService('core', $toDB);
-			$toMS->migrate($currentMigration);
-		}
-
-		$schemaManager = new \OC\DB\MDB2SchemaManager($toDB);
-		$apps = $input->getOption('all-apps') ? \OC_App::getAllApps() : \OC_App::getEnabledApps();
-		foreach($apps as $app) {
-			if (file_exists(\OC_App::getAppPath($app).'/appinfo/database.xml')) {
-				$schemaManager->createDbFromStructure(\OC_App::getAppPath($app).'/appinfo/database.xml');
-			} else {
-				// Make sure autoloading works...
-				\OC_App::loadApp($app);
-				$fromMS = new MigrationService($app, $fromDB);
-				$currentMigration = $fromMS->getMigration('current');
-				if ($currentMigration !== '0') {
-					$toMS = new MigrationService($app, $toDB);
-					$toMS->migrate($currentMigration);
-				}
-			}
-		}
-	}
-
-	protected function getToDBConnection(InputInterface $input, OutputInterface $output) {
-		$type = $input->getArgument('type');
-		$connectionParams = $this->connectionFactory->createConnectionParams();
-		$connectionParams = array_merge($connectionParams, [
-			'host' => $input->getArgument('hostname'),
-			'user' => $input->getArgument('username'),
-			'password' => $input->getOption('password'),
-			'dbname' => $input->getArgument('database'),
-		]);
-		if ($input->getOption('port')) {
-			$connectionParams['port'] = $input->getOption('port');
-		}
-		return $this->connectionFactory->getConnection($type, $connectionParams);
-	}
-
-	protected function clearSchema(Connection $db, InputInterface $input, OutputInterface $output) {
-		$toTables = $this->getTables($db);
-		if (!empty($toTables)) {
-			$output->writeln('<info>Clearing schema in new database</info>');
-		}
-		foreach($toTables as $table) {
-			$db->getSchemaManager()->dropTable($table);
-		}
-	}
-
-	protected function getTables(Connection $db) {
-		$filterExpression = '/^' . preg_quote($this->config->getSystemValue('dbtableprefix', 'oc_')) . '/';
-		$db->getConfiguration()->
-			setFilterSchemaAssetsExpression($filterExpression);
-		return $db->getSchemaManager()->listTableNames();
-	}
-
-	/**
-	 * @param Connection $fromDB
-	 * @param Connection $toDB
-	 * @param Table $table
-	 * @param InputInterface $input
-	 * @param OutputInterface $output
-	 * @suppress SqlInjectionChecker
-	 */
-	protected function copyTable(Connection $fromDB, Connection $toDB, Table $table, InputInterface $input, OutputInterface $output) {
-		if ($table->getName() === $toDB->getPrefix() . 'migrations') {
-			$output->writeln('<comment>Skipping migrations table because it was already filled by running the migrations</comment>');
-			return;
-		}
-
-		$chunkSize = $input->getOption('chunk-size');
-
-		$query = $fromDB->getQueryBuilder();
-		$query->automaticTablePrefix(false);
-		$query->selectAlias($query->createFunction('COUNT(*)'), 'num_entries')
-			->from($table->getName());
-		$result = $query->execute();
-		$count = $result->fetchColumn();
-		$result->closeCursor();
-
-		$numChunks = ceil($count/$chunkSize);
-		if ($numChunks > 1) {
-			$output->writeln('chunked query, ' . $numChunks . ' chunks');
-		}
-
-		$progress = new ProgressBar($output, $count);
-		$progress->start();
-		$redraw = $count > $chunkSize ? 100 : ($count > 100 ? 5 : 1);
-		$progress->setRedrawFrequency($redraw);
-
-		$query = $fromDB->getQueryBuilder();
-		$query->automaticTablePrefix(false);
-		$query->select('*')
-			->from($table->getName())
-			->setMaxResults($chunkSize);
-
-		try {
-			$orderColumns = $table->getPrimaryKeyColumns();
-		} catch (DBALException $e) {
-			$orderColumns = [];
-			foreach ($table->getColumns() as $column) {
-				$orderColumns[] = $column->getName();
-			}
-		}
-
-		foreach ($orderColumns as $column) {
-			$query->addOrderBy($column);
-		}
-
-		$insertQuery = $toDB->getQueryBuilder();
-		$insertQuery->automaticTablePrefix(false);
-		$insertQuery->insert($table->getName());
-		$parametersCreated = false;
-
-		for ($chunk = 0; $chunk < $numChunks; $chunk++) {
-			$query->setFirstResult($chunk * $chunkSize);
-
-			$result = $query->execute();
-
-			while ($row = $result->fetch()) {
-				$progress->advance();
-				if (!$parametersCreated) {
-					foreach ($row as $key => $value) {
-						$insertQuery->setValue($key, $insertQuery->createParameter($key));
-					}
-					$parametersCreated = true;
-				}
-
-				foreach ($row as $key => $value) {
-					$type = $this->getColumnType($table, $key);
-					if ($type !== false) {
-						$insertQuery->setParameter($key, $value, $type);
-					} else {
-						$insertQuery->setParameter($key, $value);
-					}
-				}
-				$insertQuery->execute();
-			}
-			$result->closeCursor();
-		}
-		$progress->finish();
-	}
-
-	protected function getColumnType(Table $table, $columnName) {
-		$tableName = $table->getName();
-		if (isset($this->columnTypes[$tableName][$columnName])) {
-			return $this->columnTypes[$tableName][$columnName];
-		}
-
-		$type = $table->getColumn($columnName)->getType()->getName();
-
-		switch ($type) {
-			case Type::BLOB:
-			case Type::TEXT:
-				$this->columnTypes[$tableName][$columnName] = IQueryBuilder::PARAM_LOB;
-				break;
-			default:
-				$this->columnTypes[$tableName][$columnName] = false;
-		}
-
-		return $this->columnTypes[$tableName][$columnName];
-	}
-
-	protected function convertDB(Connection $fromDB, Connection $toDB, array $tables, InputInterface $input, OutputInterface $output) {
-		$this->config->setSystemValue('maintenance', true);
-		$schema = $fromDB->createSchema();
-
-		try {
-			// copy table rows
-			foreach($tables as $table) {
-				$output->writeln($table);
-				$this->copyTable($fromDB, $toDB, $schema->getTable($table), $input, $output);
-			}
-			if ($input->getArgument('type') === 'pgsql') {
-				$tools = new \OC\DB\PgSqlTools($this->config);
-				$tools->resynchronizeDatabaseSequences($toDB);
-			}
-			// save new database config
-			$this->saveDBInfo($input);
-		} catch(\Exception $e) {
-			$this->config->setSystemValue('maintenance', false);
-			throw $e;
-		}
-		$this->config->setSystemValue('maintenance', false);
-	}
-
-	protected function saveDBInfo(InputInterface $input) {
-		$type = $input->getArgument('type');
-		$username = $input->getArgument('username');
-		$dbHost = $input->getArgument('hostname');
-		$dbName = $input->getArgument('database');
-		$password = $input->getOption('password');
-		if ($input->getOption('port')) {
-			$dbHost .= ':'.$input->getOption('port');
-		}
-
-		$this->config->setSystemValues([
-			'dbtype'		=> $type,
-			'dbname'		=> $dbName,
-			'dbhost'		=> $dbHost,
-			'dbuser'		=> $username,
-			'dbpassword'	=> $password,
-		]);
-	}
-
-	/**
-	 * Return possible values for the named option
-	 *
-	 * @param string $optionName
-	 * @param CompletionContext $context
-	 * @return string[]
-	 */
-	public function completeOptionValues($optionName, CompletionContext $context) {
-		return [];
-	}
-
-	/**
-	 * Return possible values for the named argument
-	 *
-	 * @param string $argumentName
-	 * @param CompletionContext $context
-	 * @return string[]
-	 */
-	public function completeArgumentValues($argumentName, CompletionContext $context) {
-		if ($argumentName === 'type') {
-			return ['mysql', 'oci', 'pgsql'];
-		}
-		return [];
-	}
+    /**
+     * @var \OCP\IConfig
+     */
+    protected $config;
+
+    /**
+     * @var \OC\DB\ConnectionFactory
+     */
+    protected $connectionFactory;
+
+    /** @var array */
+    protected $columnTypes;
+
+    /**
+     * @param \OCP\IConfig $config
+     * @param \OC\DB\ConnectionFactory $connectionFactory
+     */
+    public function __construct(IConfig $config, ConnectionFactory $connectionFactory) {
+        $this->config = $config;
+        $this->connectionFactory = $connectionFactory;
+        parent::__construct();
+    }
+
+    protected function configure() {
+        $this
+            ->setName('db:convert-type')
+            ->setDescription('Convert the Nextcloud database to the newly configured one')
+            ->addArgument(
+                'type',
+                InputArgument::REQUIRED,
+                'the type of the database to convert to'
+            )
+            ->addArgument(
+                'username',
+                InputArgument::REQUIRED,
+                'the username of the database to convert to'
+            )
+            ->addArgument(
+                'hostname',
+                InputArgument::REQUIRED,
+                'the hostname of the database to convert to'
+            )
+            ->addArgument(
+                'database',
+                InputArgument::REQUIRED,
+                'the name of the database to convert to'
+            )
+            ->addOption(
+                'port',
+                null,
+                InputOption::VALUE_REQUIRED,
+                'the port of the database to convert to'
+            )
+            ->addOption(
+                'password',
+                null,
+                InputOption::VALUE_REQUIRED,
+                'the password of the database to convert to. Will be asked when not specified. Can also be passed via stdin.'
+            )
+            ->addOption(
+                'clear-schema',
+                null,
+                InputOption::VALUE_NONE,
+                'remove all tables from the destination database'
+            )
+            ->addOption(
+                'all-apps',
+                null,
+                InputOption::VALUE_NONE,
+                'whether to create schema for all apps instead of only installed apps'
+            )
+            ->addOption(
+                'chunk-size',
+                null,
+                InputOption::VALUE_REQUIRED,
+                'the maximum number of database rows to handle in a single query, bigger tables will be handled in chunks of this size. Lower this if the process runs out of memory during conversion.',
+                1000
+            )
+        ;
+    }
+
+    protected function validateInput(InputInterface $input, OutputInterface $output) {
+        $type = $this->connectionFactory->normalizeType($input->getArgument('type'));
+        if ($type === 'sqlite3') {
+            throw new \InvalidArgumentException(
+                'Converting to SQLite (sqlite3) is currently not supported.'
+            );
+        }
+        if ($type === $this->config->getSystemValue('dbtype', '')) {
+            throw new \InvalidArgumentException(sprintf(
+                'Can not convert from %1$s to %1$s.',
+                $type
+            ));
+        }
+        if ($type === 'oci' && $input->getOption('clear-schema')) {
+            // Doctrine unconditionally tries (at least in version 2.3)
+            // to drop sequence triggers when dropping a table, even though
+            // such triggers may not exist. This results in errors like
+            // "ORA-04080: trigger 'OC_STORAGES_AI_PK' does not exist".
+            throw new \InvalidArgumentException(
+                'The --clear-schema option is not supported when converting to Oracle (oci).'
+            );
+        }
+    }
+
+    protected function readPassword(InputInterface $input, OutputInterface $output) {
+        // Explicitly specified password
+        if ($input->getOption('password')) {
+            return;
+        }
+
+        // Read from stdin. stream_set_blocking is used to prevent blocking
+        // when nothing is passed via stdin.
+        stream_set_blocking(STDIN, 0);
+        $password = file_get_contents('php://stdin');
+        stream_set_blocking(STDIN, 1);
+        if (trim($password) !== '') {
+            $input->setOption('password', $password);
+            return;
+        }
+
+        // Read password by interacting
+        if ($input->isInteractive()) {
+            /** @var QuestionHelper $helper */
+            $helper = $this->getHelper('question');
+            $question = new Question('What is the database password?');
+            $question->setHidden(true);
+            $question->setHiddenFallback(false);
+            $password = $helper->ask($input, $output, $question);
+            $input->setOption('password', $password);
+            return;
+        }
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output) {
+        $this->validateInput($input, $output);
+        $this->readPassword($input, $output);
+
+        $fromDB = \OC::$server->getDatabaseConnection();
+        $toDB = $this->getToDBConnection($input, $output);
+
+        if ($input->getOption('clear-schema')) {
+            $this->clearSchema($toDB, $input, $output);
+        }
+
+        $this->createSchema($fromDB, $toDB, $input, $output);
+
+        $toTables = $this->getTables($toDB);
+        $fromTables = $this->getTables($fromDB);
+
+        // warn/fail if there are more tables in 'from' database
+        $extraFromTables = array_diff($fromTables, $toTables);
+        if (!empty($extraFromTables)) {
+            $output->writeln('<comment>The following tables will not be converted:</comment>');
+            $output->writeln($extraFromTables);
+            if (!$input->getOption('all-apps')) {
+                $output->writeln('<comment>Please note that tables belonging to available but currently not installed apps</comment>');
+                $output->writeln('<comment>can be included by specifying the --all-apps option.</comment>');
+            }
+
+            /** @var QuestionHelper $helper */
+            $helper = $this->getHelper('question');
+            $question = new ConfirmationQuestion('Continue with the conversion (y/n)? [n] ', false);
+
+            if (!$helper->ask($input, $output, $question)) {
+                return;
+            }
+        }
+        $intersectingTables = array_intersect($toTables, $fromTables);
+        $this->convertDB($fromDB, $toDB, $intersectingTables, $input, $output);
+    }
+
+    protected function createSchema(Connection $fromDB, Connection $toDB, InputInterface $input, OutputInterface $output) {
+        $output->writeln('<info>Creating schema in new database</info>');
+
+        $fromMS = new MigrationService('core', $fromDB);
+        $currentMigration = $fromMS->getMigration('current');
+        if ($currentMigration !== '0') {
+            $toMS = new MigrationService('core', $toDB);
+            $toMS->migrate($currentMigration);
+        }
+
+        $schemaManager = new \OC\DB\MDB2SchemaManager($toDB);
+        $apps = $input->getOption('all-apps') ? \OC_App::getAllApps() : \OC_App::getEnabledApps();
+        foreach($apps as $app) {
+            if (file_exists(\OC_App::getAppPath($app).'/appinfo/database.xml')) {
+                $schemaManager->createDbFromStructure(\OC_App::getAppPath($app).'/appinfo/database.xml');
+            } else {
+                // Make sure autoloading works...
+                \OC_App::loadApp($app);
+                $fromMS = new MigrationService($app, $fromDB);
+                $currentMigration = $fromMS->getMigration('current');
+                if ($currentMigration !== '0') {
+                    $toMS = new MigrationService($app, $toDB);
+                    $toMS->migrate($currentMigration);
+                }
+            }
+        }
+    }
+
+    protected function getToDBConnection(InputInterface $input, OutputInterface $output) {
+        $type = $input->getArgument('type');
+        $connectionParams = $this->connectionFactory->createConnectionParams();
+        $connectionParams = array_merge($connectionParams, [
+            'host' => $input->getArgument('hostname'),
+            'user' => $input->getArgument('username'),
+            'password' => $input->getOption('password'),
+            'dbname' => $input->getArgument('database'),
+        ]);
+        if ($input->getOption('port')) {
+            $connectionParams['port'] = $input->getOption('port');
+        }
+        return $this->connectionFactory->getConnection($type, $connectionParams);
+    }
+
+    protected function clearSchema(Connection $db, InputInterface $input, OutputInterface $output) {
+        $toTables = $this->getTables($db);
+        if (!empty($toTables)) {
+            $output->writeln('<info>Clearing schema in new database</info>');
+        }
+        foreach($toTables as $table) {
+            $db->getSchemaManager()->dropTable($table);
+        }
+    }
+
+    protected function getTables(Connection $db) {
+        $filterExpression = '/^' . preg_quote($this->config->getSystemValue('dbtableprefix', 'oc_')) . '/';
+        $db->getConfiguration()->
+            setFilterSchemaAssetsExpression($filterExpression);
+        return $db->getSchemaManager()->listTableNames();
+    }
+
+    /**
+     * @param Connection $fromDB
+     * @param Connection $toDB
+     * @param Table $table
+     * @param InputInterface $input
+     * @param OutputInterface $output
+     * @suppress SqlInjectionChecker
+     */
+    protected function copyTable(Connection $fromDB, Connection $toDB, Table $table, InputInterface $input, OutputInterface $output) {
+        if ($table->getName() === $toDB->getPrefix() . 'migrations') {
+            $output->writeln('<comment>Skipping migrations table because it was already filled by running the migrations</comment>');
+            return;
+        }
+
+        $chunkSize = $input->getOption('chunk-size');
+
+        $query = $fromDB->getQueryBuilder();
+        $query->automaticTablePrefix(false);
+        $query->selectAlias($query->createFunction('COUNT(*)'), 'num_entries')
+            ->from($table->getName());
+        $result = $query->execute();
+        $count = $result->fetchColumn();
+        $result->closeCursor();
+
+        $numChunks = ceil($count/$chunkSize);
+        if ($numChunks > 1) {
+            $output->writeln('chunked query, ' . $numChunks . ' chunks');
+        }
+
+        $progress = new ProgressBar($output, $count);
+        $progress->start();
+        $redraw = $count > $chunkSize ? 100 : ($count > 100 ? 5 : 1);
+        $progress->setRedrawFrequency($redraw);
+
+        $query = $fromDB->getQueryBuilder();
+        $query->automaticTablePrefix(false);
+        $query->select('*')
+            ->from($table->getName())
+            ->setMaxResults($chunkSize);
+
+        try {
+            $orderColumns = $table->getPrimaryKeyColumns();
+        } catch (DBALException $e) {
+            $orderColumns = [];
+            foreach ($table->getColumns() as $column) {
+                $orderColumns[] = $column->getName();
+            }
+        }
+
+        foreach ($orderColumns as $column) {
+            $query->addOrderBy($column);
+        }
+
+        $insertQuery = $toDB->getQueryBuilder();
+        $insertQuery->automaticTablePrefix(false);
+        $insertQuery->insert($table->getName());
+        $parametersCreated = false;
+
+        for ($chunk = 0; $chunk < $numChunks; $chunk++) {
+            $query->setFirstResult($chunk * $chunkSize);
+
+            $result = $query->execute();
+
+            while ($row = $result->fetch()) {
+                $progress->advance();
+                if (!$parametersCreated) {
+                    foreach ($row as $key => $value) {
+                        $insertQuery->setValue($key, $insertQuery->createParameter($key));
+                    }
+                    $parametersCreated = true;
+                }
+
+                foreach ($row as $key => $value) {
+                    $type = $this->getColumnType($table, $key);
+                    if ($type !== false) {
+                        $insertQuery->setParameter($key, $value, $type);
+                    } else {
+                        $insertQuery->setParameter($key, $value);
+                    }
+                }
+                $insertQuery->execute();
+            }
+            $result->closeCursor();
+        }
+        $progress->finish();
+    }
+
+    protected function getColumnType(Table $table, $columnName) {
+        $tableName = $table->getName();
+        if (isset($this->columnTypes[$tableName][$columnName])) {
+            return $this->columnTypes[$tableName][$columnName];
+        }
+
+        $type = $table->getColumn($columnName)->getType()->getName();
+
+        switch ($type) {
+            case Type::BLOB:
+            case Type::TEXT:
+                $this->columnTypes[$tableName][$columnName] = IQueryBuilder::PARAM_LOB;
+                break;
+            default:
+                $this->columnTypes[$tableName][$columnName] = false;
+        }
+
+        return $this->columnTypes[$tableName][$columnName];
+    }
+
+    protected function convertDB(Connection $fromDB, Connection $toDB, array $tables, InputInterface $input, OutputInterface $output) {
+        $this->config->setSystemValue('maintenance', true);
+        $schema = $fromDB->createSchema();
+
+        try {
+            // copy table rows
+            foreach($tables as $table) {
+                $output->writeln($table);
+                $this->copyTable($fromDB, $toDB, $schema->getTable($table), $input, $output);
+            }
+            if ($input->getArgument('type') === 'pgsql') {
+                $tools = new \OC\DB\PgSqlTools($this->config);
+                $tools->resynchronizeDatabaseSequences($toDB);
+            }
+            // save new database config
+            $this->saveDBInfo($input);
+        } catch(\Exception $e) {
+            $this->config->setSystemValue('maintenance', false);
+            throw $e;
+        }
+        $this->config->setSystemValue('maintenance', false);
+    }
+
+    protected function saveDBInfo(InputInterface $input) {
+        $type = $input->getArgument('type');
+        $username = $input->getArgument('username');
+        $dbHost = $input->getArgument('hostname');
+        $dbName = $input->getArgument('database');
+        $password = $input->getOption('password');
+        if ($input->getOption('port')) {
+            $dbHost .= ':'.$input->getOption('port');
+        }
+
+        $this->config->setSystemValues([
+            'dbtype'		=> $type,
+            'dbname'		=> $dbName,
+            'dbhost'		=> $dbHost,
+            'dbuser'		=> $username,
+            'dbpassword'	=> $password,
+        ]);
+    }
+
+    /**
+     * Return possible values for the named option
+     *
+     * @param string $optionName
+     * @param CompletionContext $context
+     * @return string[]
+     */
+    public function completeOptionValues($optionName, CompletionContext $context) {
+        return [];
+    }
+
+    /**
+     * Return possible values for the named argument
+     *
+     * @param string $argumentName
+     * @param CompletionContext $context
+     * @return string[]
+     */
+    public function completeArgumentValues($argumentName, CompletionContext $context) {
+        if ($argumentName === 'type') {
+            return ['mysql', 'oci', 'pgsql'];
+        }
+        return [];
+    }
 }

Spacing +8 added lines, -8 removed lines

@@ -233,7 +233,7 @@ 
 
 		$schemaManager = new \OC\DB\MDB2SchemaManager($toDB);
 		$apps = $input->getOption('all-apps') ? \OC_App::getAllApps() : \OC_App::getEnabledApps();
-		foreach($apps as $app) {
+		foreach ($apps as $app) {
 			if (file_exists(\OC_App::getAppPath($app).'/appinfo/database.xml')) {
 				$schemaManager->createDbFromStructure(\OC_App::getAppPath($app).'/appinfo/database.xml');
 			} else {
@@ -269,13 +269,13 @@ 
 		if (!empty($toTables)) {
 			$output->writeln('<info>Clearing schema in new database</info>');
 		}
-		foreach($toTables as $table) {
+		foreach ($toTables as $table) {
 			$db->getSchemaManager()->dropTable($table);
 		}
 	}
 
 	protected function getTables(Connection $db) {
-		$filterExpression = '/^' . preg_quote($this->config->getSystemValue('dbtableprefix', 'oc_')) . '/';
+		$filterExpression = '/^'.preg_quote($this->config->getSystemValue('dbtableprefix', 'oc_')).'/';
 		$db->getConfiguration()->
 			setFilterSchemaAssetsExpression($filterExpression);
 		return $db->getSchemaManager()->listTableNames();
@@ -290,7 +290,7 @@ 
 	 * @suppress SqlInjectionChecker
 	 */
 	protected function copyTable(Connection $fromDB, Connection $toDB, Table $table, InputInterface $input, OutputInterface $output) {
-		if ($table->getName() === $toDB->getPrefix() . 'migrations') {
+		if ($table->getName() === $toDB->getPrefix().'migrations') {
 			$output->writeln('<comment>Skipping migrations table because it was already filled by running the migrations</comment>');
 			return;
 		}
@@ -305,9 +305,9 @@ 
 		$count = $result->fetchColumn();
 		$result->closeCursor();
 
-		$numChunks = ceil($count/$chunkSize);
+		$numChunks = ceil($count / $chunkSize);
 		if ($numChunks > 1) {
-			$output->writeln('chunked query, ' . $numChunks . ' chunks');
+			$output->writeln('chunked query, '.$numChunks.' chunks');
 		}
 
 		$progress = new ProgressBar($output, $count);
@@ -394,7 +394,7 @@ 
 
 		try {
 			// copy table rows
-			foreach($tables as $table) {
+			foreach ($tables as $table) {
 				$output->writeln($table);
 				$this->copyTable($fromDB, $toDB, $schema->getTable($table), $input, $output);
 			}
@@ -404,7 +404,7 @@ 
 			}
 			// save new database config
 			$this->saveDBInfo($input);
-		} catch(\Exception $e) {
+		} catch (\Exception $e) {
 			$this->config->setSystemValue('maintenance', false);
 			throw $e;
 		}

lib/private/Setup/PostgreSQL.php

Indentation +133 added lines, -133 removed lines

@@ -32,137 +32,137 @@
 use OCP\IDBConnection;
 
 class PostgreSQL extends AbstractDatabase {
-	public $dbprettyname = 'PostgreSQL';
-
-	/**
-	 * @param string $username
-	 * @throws \OC\DatabaseSetupException
-	 * @suppress SqlInjectionChecker
-	 */
-	public function setupDatabase($username) {
-		try {
-			$connection = $this->connect([
-				'dbname' => 'postgres'
-			]);
-			//check for roles creation rights in postgresql
-			$builder = $connection->getQueryBuilder();
-			$builder->automaticTablePrefix(false);
-			$query = $builder
-				->select('rolname')
-				->from('pg_roles')
-				->where($builder->expr()->eq('rolcreaterole', new Literal('TRUE')))
-				->andWhere($builder->expr()->eq('rolname', $builder->createNamedParameter($this->dbUser)));
-
-			try {
-				$result = $query->execute();
-				$canCreateRoles = $result->rowCount() > 0;
-			} catch (DatabaseException $e) {
-				$canCreateRoles = false;
-			}
-
-			if ($canCreateRoles) {
-				//use the admin login data for the new database user
-
-				//add prefix to the postgresql user name to prevent collisions
-				$this->dbUser = 'oc_' . strtolower($username);
-				//create a new password so we don't need to store the admin config in the config file
-				$this->dbPassword = \OC::$server->getSecureRandom()->generate(30, \OCP\Security\ISecureRandom::CHAR_LOWER . \OCP\Security\ISecureRandom::CHAR_DIGITS);
-
-				$this->createDBUser($connection);
-			}
-
-			$this->config->setValues([
-				'dbuser' => $this->dbUser,
-				'dbpassword' => $this->dbPassword,
-			]);
-
-			//create the database
-			$this->createDatabase($connection);
-			$query = $connection->prepare("select count(*) FROM pg_class WHERE relname=? limit 1");
-			$query->execute([$this->tablePrefix . "users"]);
-			$tablesSetup = $query->fetchColumn() > 0;
-
-			// the connection to dbname=postgres is not needed anymore
-			$connection->close();
-		} catch (\Exception $e) {
-			$this->logger->logException($e);
-			$this->logger->warning('Error trying to connect as "postgres", assuming database is setup and tables need to be created');
-			$tablesSetup = false;
-			$this->config->setValues([
-				'dbuser' => $this->dbUser,
-				'dbpassword' => $this->dbPassword,
-			]);
-		}
-
-		// connect to the ownCloud database (dbname=$this->dbname) and check if it needs to be filled
-		$this->dbUser = $this->config->getValue('dbuser');
-		$this->dbPassword = $this->config->getValue('dbpassword');
-		$connection = $this->connect();
-		try {
-			$connection->connect();
-		} catch (\Exception $e) {
-			$this->logger->logException($e);
-			throw new \OC\DatabaseSetupException($this->trans->t('PostgreSQL username and/or password not valid'),
-				$this->trans->t('You need to enter details of an existing account.'));
-		}
-	}
-
-	private function createDatabase(IDBConnection $connection) {
-		if (!$this->databaseExists($connection)) {
-			//The database does not exists... let's create it
-			$query = $connection->prepare("CREATE DATABASE " . addslashes($this->dbName) . " OWNER " . addslashes($this->dbUser));
-			try {
-				$query->execute();
-			} catch (DatabaseException $e) {
-				$this->logger->error('Error while trying to create database');
-				$this->logger->logException($e);
-			}
-		} else {
-			$query = $connection->prepare("REVOKE ALL PRIVILEGES ON DATABASE " . addslashes($this->dbName) . " FROM PUBLIC");
-			try {
-				$query->execute();
-			} catch (DatabaseException $e) {
-				$this->logger->error('Error while trying to restrict database permissions');
-				$this->logger->logException($e);
-			}
-		}
-	}
-
-	private function userExists(IDBConnection $connection) {
-		$builder = $connection->getQueryBuilder();
-		$builder->automaticTablePrefix(false);
-		$query = $builder->select('*')
-			->from('pg_roles')
-			->where($builder->expr()->eq('rolname', $builder->createNamedParameter($this->dbUser)));
-		$result = $query->execute();
-		return $result->rowCount() > 0;
-	}
-
-	private function databaseExists(IDBConnection $connection) {
-		$builder = $connection->getQueryBuilder();
-		$builder->automaticTablePrefix(false);
-		$query = $builder->select('datname')
-			->from('pg_database')
-			->where($builder->expr()->eq('datname', $builder->createNamedParameter($this->dbName)));
-		$result = $query->execute();
-		return $result->rowCount() > 0;
-	}
-
-	private function createDBUser(IDBConnection $connection) {
-		$dbUser = $this->dbUser;
-		try {
-			$i = 1;
-			while ($this->userExists($connection)) {
-				$i++;
-				$this->dbUser = $dbUser . $i;
-			};
-
-			// create the user
-			$query = $connection->prepare("CREATE USER " . addslashes($this->dbUser) . " CREATEDB PASSWORD '" . addslashes($this->dbPassword) . "'");
-			$query->execute();
-		} catch (DatabaseException $e) {
-			$this->logger->error('Error while trying to create database user');
-			$this->logger->logException($e);
-		}
-	}
+    public $dbprettyname = 'PostgreSQL';
+
+    /**
+     * @param string $username
+     * @throws \OC\DatabaseSetupException
+     * @suppress SqlInjectionChecker
+     */
+    public function setupDatabase($username) {
+        try {
+            $connection = $this->connect([
+                'dbname' => 'postgres'
+            ]);
+            //check for roles creation rights in postgresql
+            $builder = $connection->getQueryBuilder();
+            $builder->automaticTablePrefix(false);
+            $query = $builder
+                ->select('rolname')
+                ->from('pg_roles')
+                ->where($builder->expr()->eq('rolcreaterole', new Literal('TRUE')))
+                ->andWhere($builder->expr()->eq('rolname', $builder->createNamedParameter($this->dbUser)));
+
+            try {
+                $result = $query->execute();
+                $canCreateRoles = $result->rowCount() > 0;
+            } catch (DatabaseException $e) {
+                $canCreateRoles = false;
+            }
+
+            if ($canCreateRoles) {
+                //use the admin login data for the new database user
+
+                //add prefix to the postgresql user name to prevent collisions
+                $this->dbUser = 'oc_' . strtolower($username);
+                //create a new password so we don't need to store the admin config in the config file
+                $this->dbPassword = \OC::$server->getSecureRandom()->generate(30, \OCP\Security\ISecureRandom::CHAR_LOWER . \OCP\Security\ISecureRandom::CHAR_DIGITS);
+
+                $this->createDBUser($connection);
+            }
+
+            $this->config->setValues([
+                'dbuser' => $this->dbUser,
+                'dbpassword' => $this->dbPassword,
+            ]);
+
+            //create the database
+            $this->createDatabase($connection);
+            $query = $connection->prepare("select count(*) FROM pg_class WHERE relname=? limit 1");
+            $query->execute([$this->tablePrefix . "users"]);
+            $tablesSetup = $query->fetchColumn() > 0;
+
+            // the connection to dbname=postgres is not needed anymore
+            $connection->close();
+        } catch (\Exception $e) {
+            $this->logger->logException($e);
+            $this->logger->warning('Error trying to connect as "postgres", assuming database is setup and tables need to be created');
+            $tablesSetup = false;
+            $this->config->setValues([
+                'dbuser' => $this->dbUser,
+                'dbpassword' => $this->dbPassword,
+            ]);
+        }
+
+        // connect to the ownCloud database (dbname=$this->dbname) and check if it needs to be filled
+        $this->dbUser = $this->config->getValue('dbuser');
+        $this->dbPassword = $this->config->getValue('dbpassword');
+        $connection = $this->connect();
+        try {
+            $connection->connect();
+        } catch (\Exception $e) {
+            $this->logger->logException($e);
+            throw new \OC\DatabaseSetupException($this->trans->t('PostgreSQL username and/or password not valid'),
+                $this->trans->t('You need to enter details of an existing account.'));
+        }
+    }
+
+    private function createDatabase(IDBConnection $connection) {
+        if (!$this->databaseExists($connection)) {
+            //The database does not exists... let's create it
+            $query = $connection->prepare("CREATE DATABASE " . addslashes($this->dbName) . " OWNER " . addslashes($this->dbUser));
+            try {
+                $query->execute();
+            } catch (DatabaseException $e) {
+                $this->logger->error('Error while trying to create database');
+                $this->logger->logException($e);
+            }
+        } else {
+            $query = $connection->prepare("REVOKE ALL PRIVILEGES ON DATABASE " . addslashes($this->dbName) . " FROM PUBLIC");
+            try {
+                $query->execute();
+            } catch (DatabaseException $e) {
+                $this->logger->error('Error while trying to restrict database permissions');
+                $this->logger->logException($e);
+            }
+        }
+    }
+
+    private function userExists(IDBConnection $connection) {
+        $builder = $connection->getQueryBuilder();
+        $builder->automaticTablePrefix(false);
+        $query = $builder->select('*')
+            ->from('pg_roles')
+            ->where($builder->expr()->eq('rolname', $builder->createNamedParameter($this->dbUser)));
+        $result = $query->execute();
+        return $result->rowCount() > 0;
+    }
+
+    private function databaseExists(IDBConnection $connection) {
+        $builder = $connection->getQueryBuilder();
+        $builder->automaticTablePrefix(false);
+        $query = $builder->select('datname')
+            ->from('pg_database')
+            ->where($builder->expr()->eq('datname', $builder->createNamedParameter($this->dbName)));
+        $result = $query->execute();
+        return $result->rowCount() > 0;
+    }
+
+    private function createDBUser(IDBConnection $connection) {
+        $dbUser = $this->dbUser;
+        try {
+            $i = 1;
+            while ($this->userExists($connection)) {
+                $i++;
+                $this->dbUser = $dbUser . $i;
+            };
+
+            // create the user
+            $query = $connection->prepare("CREATE USER " . addslashes($this->dbUser) . " CREATEDB PASSWORD '" . addslashes($this->dbPassword) . "'");
+            $query->execute();
+        } catch (DatabaseException $e) {
+            $this->logger->error('Error while trying to create database user');
+            $this->logger->logException($e);
+        }
+    }
 }