Início Rápido
Conectamos DriverMongoExecutionContext e MongoTemplateResolver e executamos a primeira consulta do Reactive Mongo DSL 1.0.0.
1. Configuração do MongoExecutionContext
MongoConfig.java
javaMongoClient mongoClient = MongoClients.create(connectionString);
MongoDatabase mongoDatabase = mongoClient.getDatabase("app");
MongoExecutionContext context =
new DriverMongoExecutionContext(mongoClient, mongoDatabase);O DriverMongoExecutionContext padrão usa diretamente o MongoDB Reactive Streams Driver. Se as regras de nomenclatura da coleção forem diferentes, você pode fornecer um resolvedor de nome de coleção separado.
2. Conexão do MongoTemplateResolver
MongoTemplateNameResolver.java
javapublic enum MongoTemplateName {
FRONT,
BACK
}
MongoTemplateResolver<MongoTemplateName> resolver = key ->
key == MongoTemplateName.BACK ? backContext : frontContext;
ReactiveMongoDsl<MongoTemplateName> dsl = new ReactiveMongoDsl<>(resolver);O que o resolvedor retorna é o MongoExecutionContext.
O
MongoTemplateResolver#getTemplate(...) da versão 1.0.0 retorna um MongoExecutionContext correspondente à chave, e não um ReactiveMongoTemplate ou objeto de transação do Spring.3. Primeira consulta
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 em condições dinâmicas será ignorado na lista de condições.
Você pode passar a forma
condition ? pair(...) : null para fields(...). Isso não está relacionado ao comportamento de emitir null em um publisher do Reactor.Quando usado como um Bean do Spring
ReactiveMongoDslConfiguration.java
java@Configuration
public class ReactiveMongoDslConfiguration {
@Bean
public ReactiveMongoDsl<MongoTemplateName> reactiveMongoDsl(
MongoTemplateResolver<MongoTemplateName> resolver
) {
return new ReactiveMongoDsl<>(resolver);
}
}