如何在 mongodb java 驱动程序中使用编解码器设置 ClusterSettings 的 URI

Question

我正在使用编解码器进行 POJO 的序列化和反序列化，使用 4.3/driver-reactive http://mongodb.github.io/mongo-java-driver/4.3/driver-reactive/getting-started/quick-start-pojo/

@Singleton
public record Repository(MongodbConfiguration mongodbConfiguration) implements IRepository {
    @Override
    public <T> MongoCollection<T> getCollection(String collectionName, Class<T> typeParameterClass) {
        // create codec registry for POJOs
        CodecRegistry pojoCodecRegistry = fromProviders(PojoCodecProvider.builder().automatic(true).build());
        CodecRegistry codecRegistry = fromRegistries(MongoClientSettings.getDefaultCodecRegistry(), pojoCodecRegistry);

        MongoClientSettings clientSettings = MongoClientSettings.builder()
                .applyToClusterSettings() // need to set the URI
                .codecRegistry(codecRegistry)
                .addCommandListener(new MongoCommand())
                .build();
        MongoClient mongoClient = MongoClients.create(clientSettings);

        return mongoClient
                .getDatabase(mongodbConfiguration.database())
                .getCollection(collectionName, typeParameterClass);
    }
}

尝试设置applyToClusterSettings，但不太确定如何设置 MongoDB URI

Answer 1

.applyConnectionString(new ConnectionString(mongodbConfiguration.uri()))