connect method

  1. @override
Future<Db> connect(
  1. DatabaseSettings? settings
)
override

Implementation

@override
Future<Db> connect(DatabaseSettings? settings) async {
  if (settings == null) {
    throw NullableSettings(
        "Failed to create a instance of MongoDB when settings is null.");
  }

  var authString = '';
  if ((settings.user?.isNotEmpty ?? false) &&
      (settings.password?.isNotEmpty ?? false)) {
    authString = "${settings.user}${settings.password}@";
  }

  var db = Db(
      "mongodb://$authString${settings.host}:${settings.port}/${settings.db}");
  await db.open();

  conn = db;

  return db;
}