Schnellstart
Verknüpfen Sie DriverMongoExecutionContext und MongoTemplateResolver und führen Sie die erste Abfrage von Reactive Mongo DSL 1.0.0 aus.
1. MongoExecutionContext Konfiguration
MongoConfig.java
javaMongoClient mongoClient = MongoClients.create(connectionString);
MongoDatabase mongoDatabase = mongoClient.getDatabase("app");
MongoExecutionContext context =
new DriverMongoExecutionContext(mongoClient, mongoDatabase);Der Standard DriverMongoExecutionContext verwendet direkt den MongoDB Reactive Streams Driver. Wenn die Namenskonventionen für Sammlungen unterschiedlich sind, kann ein separater Collection-Name-Resolver übergeben werden.
2. MongoTemplateResolver Verbindung
MongoTemplateNameResolver.java
javapublic enum MongoTemplateName {
FRONT,
BACK
}
MongoTemplateResolver<MongoTemplateName> resolver = key ->
key == MongoTemplateName.BACK ? backContext : frontContext;
ReactiveMongoDsl<MongoTemplateName> dsl = new ReactiveMongoDsl<>(resolver);Das, was der Resolver zurückgibt, ist MongoExecutionContext.
MongoTemplateResolver#getTemplate(...) in Version 1.0.0 gibt nicht ReactiveMongoTemplate oder ein Spring-Transaktionsobjekt zurück, sondern den MongoExecutionContext, der dem Schlüssel entspricht.3. Erste Abfrage
UserService.java
javaFlux<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();Null für dynamische Bedingungen überspringt die Bedingungsliste.
Die Form
condition ? pair(...) : null kann an fields(...) übergeben werden. Dies hat nichts mit dem Emitieren von null durch den Reactor-Publisher zu tun.Wenn als Spring Bean verwendet.
ReactiveMongoDslConfiguration.java
java@Configuration
public class ReactiveMongoDslConfiguration {
@Bean
public ReactiveMongoDsl<MongoTemplateName> reactiveMongoDsl(
MongoTemplateResolver<MongoTemplateName> resolver
) {
return new ReactiveMongoDsl<>(resolver);
}
}