ensureOpen method

@override Future<bool> ensureOpen(QueryExecutorUser user)

Opens the executor, if it has not yet been opened.

Implementation

@override
Future<bool> ensureOpen(QueryExecutorUser user) {
  return _openingLock.synchronized(() async {
    if (_closed) {
      return Future.error(StateError(
          "Can't re-open a database after closing it. Please create a new "
          'database connection and open that instead.'));
    }

    final alreadyOpen = await delegate.isOpen;
    if (alreadyOpen) {
      _ensureOpenCalled = true;
      return true;
    }

    await delegate.open(user);
    _ensureOpenCalled = true;
    await _runMigrations(user);
    return true;
  });
}