import com.mongodb.ReadConcern; //导入依赖的package包/类
@Parameters(method = "validReadConcernValues")
@Test
public void should_parse_read_concern_from_connection_string(String readConcernString, ReadConcern expectedReadConcern) throws Exception {
  // given
  final JsonObject configWithConnectionString = new JsonObject().put(
    "connection_string",
    String.format("mongodb://localhost:27017/mydb?replicaSet=myRs&readconcernlevel=%s", readConcernString)
  );

  // when
  final ReadConcern parsedReadConcern = new MongoClientOptionsParser(configWithConnectionString)
    .settings()
    .getReadConcern();

  // then
  assertEquals(expectedReadConcern, parsedReadConcern);
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Parameters(method = "validReadConcernValues")
@Test
public void should_fallback_to_config_property_if_read_concern_not_present_in_connection_string(String readConcernString, ReadConcern expectedReadConcern) throws Exception {
  // given
  final JsonObject configWithReadConcernAsSeparateProperty = new JsonObject()
    .put("connection_string", "mongodb://localhost:27017/mydb?replicaSet=myRs")
    .put("readConcernLevel", readConcernString);

  // when
  final ReadConcern parsedReadConcern = new MongoClientOptionsParser(configWithReadConcernAsSeparateProperty)
    .settings()
    .getReadConcern();

  // then
  assertEquals(expectedReadConcern, parsedReadConcern);
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Test
public void should_return_default_read_concern_in_case_of_missing_read_concern_in_connection_string_or_config_object() throws Exception {
  // given
  final JsonObject configWithConnectionString = new JsonObject().put(
    "connection_string",
    "mongodb://localhost:27017/mydb?replicaSet=myRs"
  );

  // when
  final ReadConcern parsedReadConcern = new MongoClientOptionsParser(configWithConnectionString)
    .settings()
    .getReadConcern();

  // then
  assertEquals(ReadConcern.DEFAULT, parsedReadConcern);
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Test
public void passThrough() {
    Collation collation = Collation.builder()
                                   .locale("en")
                                   .caseLevel(true)
                                   .build();
    DBCollectionCountOptions options = new CountOptions()
        .collation(collation)
        .hint("i'm a hint")
        .limit(18)
        .maxTime(15, TimeUnit.MINUTES)
        .readPreference(ReadPreference.secondaryPreferred())
        .readConcern(ReadConcern.LOCAL)
        .skip(12)
        .getOptions();

    assertEquals(collation, options.getCollation());
    assertEquals("i'm a hint", options.getHintString());
    assertEquals(18, options.getLimit());
    assertEquals(15, options.getMaxTime(TimeUnit.MINUTES));
    assertEquals(ReadPreference.secondaryPreferred(), options.getReadPreference());
    assertEquals(ReadConcern.LOCAL, options.getReadConcern());
    assertEquals(12, options.getSkip());
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
private ReadConcern getReadConcern(String readConcern) {
	if ("LOCAL".equalsIgnoreCase(readConcern)) {
		return ReadConcern.LOCAL;
	}
	if ("MAJORITY".equalsIgnoreCase(readConcern)) {
		return ReadConcern.MAJORITY;
	}
	return ReadConcern.DEFAULT;
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Test
public void should_prefer_read_concern_passed_via_connection_string_over_property_value() throws Exception {
  // given
  final JsonObject configWithReadConcernPassedTwice = new JsonObject()
    .put("connection_string", "mongodb://localhost:27017/mydb?replicaSet=myRs&readconcernlevel=majority")
    .put("readConcernLevel", "linearizable");

  // when
  final ReadConcern parsedReadConcern = new MongoClientOptionsParser(configWithReadConcernPassedTwice)
    .settings()
    .getReadConcern();

  // then
  assertEquals(ReadConcern.MAJORITY, parsedReadConcern);
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
private Object[] validReadConcernValues() {
  return new Object[]{
    new Object[]{"local", ReadConcern.LOCAL},
    new Object[]{"majority", ReadConcern.MAJORITY},
    new Object[]{"linearizable", ReadConcern.LINEARIZABLE}
  };
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
private static ReadConcern readConcern(final String value) {
  return when(value.toUpperCase())
      .is("DEFAULT", ReadConcern.DEFAULT)
      .is("LOCAL", ReadConcern.LOCAL)
      .is("MAJORITY", ReadConcern.MAJORITY)
      .orElseThrow(() -> new IllegalArgumentException("readConcern: " + value));
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Override
public ReadConcern getReadConcern()
{
    return collection.getReadConcern();
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Override
public MongoCollection<TDocument> withReadConcern(ReadConcern arg0)
{
    return new ProfiledMongoCollection<TDocument>(collection.withReadConcern(arg0));
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Override
public ReadConcern getReadConcern()
{
    return database.getReadConcern();
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Override
public MongoDatabase withReadConcern(ReadConcern readConcern)
{
    return new ProfiledMongoDatabase(database.withReadConcern(readConcern));
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Override
public ReadConcern getReadConcern() {
    return wrapped.getReadConcern();
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Override
public MongoCollection<TDocument> withReadConcern(final ReadConcern readConcern) {
    return new MongoCollectionImpl<TDocument>(wrapped.withReadConcern(readConcern), observableAdapter);
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Override
public MongoDatabase withReadConcern(final ReadConcern readConcern) {
    return new MongoDatabaseImpl(wrapped.withReadConcern(readConcern), observableAdapter);
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Override
public GridFSBucket withReadConcern(final ReadConcern readConcern) {
    return new GridFSBucketImpl(wrapped.withReadConcern(readConcern), observableAdapter);
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Override
public MongoDatabase withReadConcern(ReadConcern readConcern) {
    return null;
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Override
public MongoCollection<TDocument> withReadConcern(final ReadConcern readConcern) {
    return new MongoCollectionImpl<TDocument>(wrapped.withReadConcern(readConcern));
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Override
public MongoDatabase withReadConcern(final ReadConcern readConcern) {
    return new MongoDatabaseImpl(wrapped.withReadConcern(readConcern));
}
 

import com.mongodb.ReadConcern; //导入依赖的package包/类
@Override
public GridFSBucket withReadConcern(final ReadConcern readConcern) {
    return new GridFSBucketImpl(wrapped.withReadConcern(readConcern));
}