open method

@override Future<bool> open()

Opens the repository, or just returns true if the repo is already open.

Implementation

@override
Future<bool> open() async {
  if (!shouldOpenOnNewConnection()) {
    return openCompleter!.future;
  }
  final path = await _getPath();
  await File(path).parent.create(recursive: true);
  db = await openDatabase(
    path,
    version: 3,
    onCreate: (Database db, int version) async {
      await db.execute('''
    create table $_tableCacheObject (
      ${CacheObject.columnId} integer primary key,
      ${CacheObject.columnUrl} text,
      ${CacheObject.columnKey} text,
      ${CacheObject.columnPath} text,
      ${CacheObject.columnETag} text,
      ${CacheObject.columnValidTill} integer,
      ${CacheObject.columnTouched} integer,
      ${CacheObject.columnLength} integer
      );
      create unique index $_tableCacheObject${CacheObject.columnKey}
      ON $_tableCacheObject (${CacheObject.columnKey});
    ''');
    },
    onUpgrade: (Database db, int oldVersion, int newVersion) async {
      // Migration for adding the optional key, does the following:
      // Adds the new column
      // Creates a unique index for the column
      // Migrates over any existing URLs to keys
      if (oldVersion <= 1) {
        var alreadyHasKeyColumn = false;
        try {
          await db.execute('''
          alter table $_tableCacheObject
          add ${CacheObject.columnKey} text;
          ''');
        } on DatabaseException catch (e) {
          if (!e.isDuplicateColumnError(CacheObject.columnKey)) rethrow;
          alreadyHasKeyColumn = true;
        }
        await db.execute('''
        update $_tableCacheObject
          set ${CacheObject.columnKey} = ${CacheObject.columnUrl}
          where ${CacheObject.columnKey} is null;
        ''');

        if (!alreadyHasKeyColumn) {
          await db.execute('''
          create index $_tableCacheObject${CacheObject.columnKey}
            on $_tableCacheObject (${CacheObject.columnKey});
          ''');
        }
      }
      if (oldVersion <= 2) {
        try {
          await db.execute('''
      alter table $_tableCacheObject
      add ${CacheObject.columnLength} integer;
      ''');
        } on DatabaseException catch (e) {
          if (!e.isDuplicateColumnError(CacheObject.columnLength)) rethrow;
        }
      }
    },
  );
  return opened();
}