force method

Future force(DataAccessObject dataAccessObject)

Implementation

Future force(DataAccessObject dataAccessObject) async {
  final newSchema = dataAccessObject.schema;

  List checkTable = await database!.rawQuery(
      "SELECT name FROM sqlite_master WHERE name='${dataAccessObject.schema.table}'");

  if (checkTable.isNotEmpty) {
    final oldSchema = Schema((await database!.rawQuery(
            "SELECT sql FROM sqlite_master WHERE name = '${dataAccessObject.schema.table}'"))
        .first
        .values
        .first as String);

    if (newSchema.sql != oldSchema.sql) {
      final oldColumns =
          oldSchema.columns.map((column) => column.name).toList();
      final newColumns =
          newSchema.columns.map((column) => column.name).toList();

      /// Remove any new column not exists in previous sql
      oldColumns.removeWhere((oldColumn) => !newColumns.contains(oldColumn));

      await Future.forEach([
        /// Disable foreign key constraint check
        'PRAGMA foreign_keys=OFF',

        /// Start a transaction
        'BEGIN TRANSACTION',

        /// Suffex table with `_old`
        'ALTER TABLE ${oldSchema.table} RENAME TO ${oldSchema.table}_old',

        /// Creating the new table on its new format
        newSchema.sql,

        /// Populating the table with the data
        'INSERT INTO ${newSchema.table} (${oldColumns.join(', ')}) SELECT ${oldColumns.join(', ')} FROM ${oldSchema.table}_old',

        /// Drop old table
        'DROP TABLE ${oldSchema.table}_old',

        /// Commit the transaction
        'COMMIT',

        /// Enable foreign key constraint check
        'PRAGMA foreign_keys=ON',
      ], (dynamic sql) async {
        final completer = Completer()..complete(database!.execute(sql));

        if (logger!) Logger.sql(completer.future, sql);
        await completer.future;
      });
    }
  } else {
    List<DataAccessObject<dynamic>> dataAccessObjects = [dataAccessObject];
    await Future.forEach(
        dataAccessObjects.map((dao) => dao.schema.sql), database!.execute);
  }
}