Java 类com.mongodb.ConnectionString 实例源码

项目：goomusic 文件：MongoSongStore.java

public MongoSongStore() {
    String connectionString = System.getProperty(CONNECTION_STRING_PROPERTY, "mongodb://localhost");
    String databaseName = System.getProperty(DATABASE_NAME_PROPERTY, "default");
    String collectionName = System.getProperty(COLLECTION_NAME_PROPERTY, "default");

    mongoClient = MongoClients.create(new ConnectionString(connectionString));
    mongoDatabase = mongoClient.getDatabase(databaseName);
    mongoCollection = mongoDatabase.getCollection(collectionName);

    logger.info("Initialized Mongo Driver with databaseName=" + databaseName + " collectionName=" + collectionName);

}

项目：flink-mingo-tail 文件：ShardSetFinder.java

private List<MongoClientWrapper> getMongoClient(List<ConnectionString> shardSet) {
   mongoClients = new ArrayList<>();
   try {
      for (ConnectionString address : shardSet) {
         com.mongodb.reactivestreams.client.MongoClient client = MongoClients.create(address);
         mongoClients.add(new MongoClientWrapper(address.getConnectionString(), client));
         Thread.sleep(100); // allow the client to establish prior to being
      }
   } catch (InterruptedException e) {
      e.printStackTrace();
   }
   return mongoClients;
}

项目：flink-mingo-tail 文件：ShardSetFinder.java

private List<ConnectionString> buildServerAddressList(DBObject next) {
   List<ConnectionString> hosts = new ArrayList<>();
   for (String host : Arrays.asList(((String) next.get("host")).split("/")[1].split(","))) {
      hosts.add(new ConnectionString("mongodb://" + host));
   }
   return hosts;
}

项目：mongowg 文件：MongoWGPlugin.java

/**
 * {@inheritDoc}
 */
@Override
public void onEnable() {
    saveDefaultConfig();

    CodecRegistry codecRegistry = createCodecRegistry();
    MongoClientSettings settings = MongoClientSettings.builder()
            .clusterSettings(ClusterSettings.builder().applyConnectionString(new ConnectionString(getConfig().getString("mongodb.uri"))).build())
            .codecRegistry(codecRegistry)
            .build();
    client = MongoClients.create(settings);
    MongoDatabase database = client.getDatabase(getConfig().getString("mongodb.database"));
    if (!testConnection(database))
        return;
    RegionStorageAdapter storageAdapter = new RegionStorageAdapter(database);
    MongoRegionDriver driver = new MongoRegionDriver(getServer(), storageAdapter);

    WorldGuardPlugin wgPlugin = WorldGuardPlugin.inst();
    if (getConfig().getBoolean("mongodb.use_oplog")) {
        getLogger().info("OpLog usage enabled.");
        WorldGuardOpLogHandler opLogHandler = new WorldGuardOpLogHandler(codecRegistry.get(ProcessingProtectedRegion.class), storageAdapter, wgPlugin);
        getServer().getScheduler().runTaskAsynchronously(this, new OpLogRetriever(
                OpLogUtils.getCollection(client),
                new OpLogParser(opLogHandler),
                getConfig().getString("mongodb.database") + "." + RegionStorageAdapter.COLLECTION_NAME
        ));
        storageAdapter.setListener(opLogHandler);
    }

    ConfigurationManager config = wgPlugin.getGlobalStateManager();
    RegionContainer container = wgPlugin.getRegionContainer();
    InjectionUtils.injectRegionDriver(container, driver);
    InjectionUtils.callUnload(container);
    InjectionUtils.callLoadWorlds(container);
    config.selectedRegionStoreDriver = driver;
}

项目：vertx-mongo-client 文件：ClusterSettingsParser.java

public ClusterSettingsParser(ConnectionString connectionString, JsonObject config) {
  ClusterSettings.Builder settings = ClusterSettings.builder();
  // ConnectionString takes precedence
  if (connectionString != null) {
    settings.applyConnectionString(connectionString);
  } else {
    // hosts
    List<ServerAddress> hosts = parseHosts(config);
    settings.hosts(hosts);

    // replica set / mode
    String replicaSet = config.getString("replicaSet");
    if (hosts.size() == 1 && replicaSet == null) {
      settings.mode(ClusterConnectionMode.SINGLE);
    } else {
      settings.mode(ClusterConnectionMode.MULTIPLE);
    }
    if (replicaSet != null) {
      settings.requiredReplicaSetName(replicaSet);
    }

    // serverSelectionTimeoutMS
    Long serverSelectionTimeoutMS = config.getLong("serverSelectionTimeoutMS");
    if(serverSelectionTimeoutMS != null) {
      settings.serverSelectionTimeout(serverSelectionTimeoutMS, MILLISECONDS);
    }

    Integer waitQueueMultiple = config.getInteger("waitQueueMultiple");
    if (waitQueueMultiple != null) {
      Integer waitQueueSize = waitQueueMultiple * DEFAULT_MONGO_DRIVER_WAIT_Q_SIZE;
      settings.maxWaitQueueSize(waitQueueSize);
    }
  }

  this.settings = settings.build();
}

项目：vertx-mongo-client 文件：ReadPreferenceParser.java

ReadPreferenceParser(ConnectionString connectionString, JsonObject config) {
  ReadPreference connStringReadPreference = connectionString != null ? connectionString.getReadPreference() : null;
  if (connStringReadPreference != null) {
    // Prefer connection string's read preference
    readPreference = connStringReadPreference;
  } else {
    ReadPreference rp;
    String rps = config.getString("readPreference");
    if (rps != null) {
      JsonArray readPreferenceTags = config.getJsonArray("readPreferenceTags");
      if (readPreferenceTags == null) {
        rp = ReadPreference.valueOf(rps);
        if (rp == null) throw new IllegalArgumentException("Invalid ReadPreference " + rps);
      } else {
        // Support advanced ReadPreference Tags
        List<TagSet> tagSet = new ArrayList<>();
        readPreferenceTags.forEach(o -> {
          String tagString = (String) o;
          List<Tag> tags = Stream.of(tagString.trim().split(","))
              .map(s -> s.split(":"))
              .filter(array -> {
                if (array.length != 2) {
                  throw new IllegalArgumentException("Invalid readPreferenceTags value '" + tagString + "'");
                }
                return true;
              }).map(array -> new Tag(array[0], array[1])).collect(Collectors.toList());

          tagSet.add(new TagSet(tags));
        });
        rp = ReadPreference.valueOf(rps, tagSet);
      }
    } else {
      rp = null;
    }

    readPreference = rp;
  }
}

项目：vertx-mongo-client 文件：SocketSettingsParser.java

public SocketSettingsParser(ConnectionString connectionString, JsonObject config) {
  SocketSettings.Builder settings = SocketSettings.builder();
  if (connectionString != null) {
    settings.applyConnectionString(connectionString);
  } else {
    Integer connectTimeoutMS = config.getInteger("connectTimeoutMS");
    if (connectTimeoutMS != null) {
      settings.connectTimeout(connectTimeoutMS, MILLISECONDS);
    }
    Integer socketTimeoutMS = config.getInteger("socketTimeoutMS");
    if (socketTimeoutMS != null) {
      settings.readTimeout(socketTimeoutMS, MILLISECONDS);
    }
    Boolean keepAlive = config.getBoolean("keepAlive");
    if (keepAlive != null) {
      settings.keepAlive(keepAlive);
    }
    Integer receiveBufferSize = config.getInteger("receiveBufferSize");
    if (receiveBufferSize != null) {
      settings.receiveBufferSize(receiveBufferSize);
    }
    Integer sendBufferSize = config.getInteger("sendBufferSize");
    if (sendBufferSize != null) {
      settings.sendBufferSize(sendBufferSize);
    }
  }

  this.settings = settings.build();
}

项目：vertx-mongo-client 文件：SSLSettingsParser.java

public SSLSettingsParser(ConnectionString connectionString, JsonObject config) {
  SslSettings.Builder settings = SslSettings.builder();
  Boolean ssl;
  if (connectionString != null) {
    ssl = connectionString.getSslEnabled();
  } else {
    ssl = config.getBoolean("ssl");
  }

  if (ssl != null) {
    settings.enabled(ssl);
  }
  this.settings = settings.build();
}

项目：vertx-mongo-client 文件：WriteConcernParserTest.java

@Test
public void testConnStringWriteConcern() {
  final ConnectionString connString = new ConnectionString("mongodb://localhost:27017/mydb?replicaSet=myapp&safe=true");
  WriteConcern wc = new WriteConcernParser(connString, new JsonObject()).writeConcern();

  assertNotNull(wc);
  assertEquals(WriteConcern.ACKNOWLEDGED, wc);
}

项目：vertx-mongo-client 文件：WriteConcernParserTest.java

@Test
public void testConnStringSimpleAndAdvancedWriteConcern() {
  final ConnectionString connString = new ConnectionString("mongodb://localhost:27017/mydb?replicaSet=myapp" +
      "&w=majority&wtimeoutms=20&journal=false");
  WriteConcern expected = new WriteConcern("majority").withWTimeout(20, TimeUnit.MILLISECONDS).withJournal(false);
  WriteConcern wc = new WriteConcernParser(connString, new JsonObject()).writeConcern();
  assertNotNull(wc);
  assertEquals(expected, wc);
}

项目：jooby 文件：MongoRx.java

static SocketSettings socket(final String path, final ConnectionString cstr,
    final Config dbconf) {
  SocketSettings.Builder settings = SocketSettings.builder().applyConnectionString(cstr);
  withConf(path, dbconf, c -> {
    withMs("connectTimeout", c,
        s -> settings.connectTimeout(s.intValue(), TimeUnit.MILLISECONDS));
    withBool("keepAlive", c, settings::keepAlive);
    withMs("readTimeout", c,
        s -> settings.readTimeout(s.intValue(), TimeUnit.MILLISECONDS));
    withInt("receiveBufferSize", c, settings::receiveBufferSize);
    withInt("sendBufferSize", c, settings::sendBufferSize);
  });
  return settings.build();
}