بدء سريع

MongoClient mongoClient = MongoClients.create(connectionString);
MongoDatabase mongoDatabase = mongoClient.getDatabase("app");

MongoExecutionContext context =
    new DriverMongoExecutionContext(mongoClient, mongoDatabase);

public enum MongoTemplateName {
  FRONT,
  BACK
}

MongoTemplateResolver<MongoTemplateName> resolver = key ->
    key == MongoTemplateName.BACK ? backContext : frontContext;

ReactiveMongoDsl<MongoTemplateName> dsl = new ReactiveMongoDsl<>(resolver);

Flux<User> users = dsl
    .executeEntity(User.class, MongoTemplateName.FRONT)
    .fields(
        pair("status", "ACTIVE"),
        minAge == null ? null : pair("age", minAge, gte)
    )
    .end()
    .findAll()
    .sorts(sort -> sort.desc("createdAt"))
    .execute();

@Configuration
public class ReactiveMongoDslConfiguration {

  @Bean
  public ReactiveMongoDsl<MongoTemplateName> reactiveMongoDsl(
      MongoTemplateResolver<MongoTemplateName> resolver
  ) {
    return new ReactiveMongoDsl<>(resolver);
  }
}