Démarrage rapide

Nous connectons DriverMongoExecutionContext et MongoTemplateResolver et exécutons la première requête de Reactive Mongo DSL 1.0.0.

1. Configuration de MongoExecutionContext

MongoConfig.java

java

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

MongoExecutionContext context =
    new DriverMongoExecutionContext(mongoClient, mongoDatabase);

Le DriverMongoExecutionContext par défaut utilise directement le pilote MongoDB Reactive Streams. Si les règles de nommage des collections diffèrent, un résolveur de nom de collection distinct peut être fourni.

2. Connexion de MongoTemplateResolver

MongoTemplateNameResolver.java

java

public enum MongoTemplateName {
  FRONT,
  BACK
}

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

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

Ce que le résolveur retourne est MongoExecutionContext.

MongoTemplateResolver#getTemplate(...) de la version 1.0.0 retourne un MongoExecutionContext correspondant à la clé, et non un ReactiveMongoTemplate ou un objet de transaction Spring.

3. Première consultation

UserService.java

java

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();

Un null dans les conditions dynamiques sera ignoré dans la liste des conditions.

Une forme condition ? pair(...) : null peut être passée à fields(...). Cela n'est pas lié à l'émission de null par le publisher Reactor.

Lors de l'utilisation comme Spring Bean

ReactiveMongoDslConfiguration.java

java

@Configuration
public class ReactiveMongoDslConfiguration {

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

Spring Integration

Vérifiez la configuration de l'adaptateur de mapping/audit Spring Data.

Flux de requête

Comparez le flux d'entrée des requêtes générales, de l'agrégation racine, de la recherche/vecteur.