快速開始
連接 DriverMongoExecutionContext 和 MongoTemplateResolver，執行 Reactive Mongo DSL 1.0.0 的第一個查詢。
1. MongoExecutionContext 配置
MongoConfig.java
javaMongoClient mongoClient = MongoClients.create(connectionString);
MongoDatabase mongoDatabase = mongoClient.getDatabase("app");
MongoExecutionContext context =
new DriverMongoExecutionContext(mongoClient, mongoDatabase);基本的 DriverMongoExecutionContext 直接使用 MongoDB Reactive Streams Driver。如果集合命名規則不同，可以傳遞單獨的 collection-name resolver。
2. MongoTemplateResolver 連接
MongoTemplateNameResolver.java
javapublic enum MongoTemplateName {
FRONT,
BACK
}
MongoTemplateResolver<MongoTemplateName> resolver = key ->
key == MongoTemplateName.BACK ? backContext : frontContext;
ReactiveMongoDsl<MongoTemplateName> dsl = new ReactiveMongoDsl<>(resolver);Resolver 返回的是 MongoExecutionContext。
1.0.0 的
MongoTemplateResolver#getTemplate(...) 返回與鍵對應的 MongoExecutionContext，而不是 ReactiveMongoTemplate 或 Spring 事務對象。3. 首次查詢
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 將在條件列表中跳過。
可以將
condition ? pair(...) : null 形式傳遞給 fields(...)。這與 Reactor publisher 發出 null 的行為無關。作為 Spring Bean 使用時
ReactiveMongoDslConfiguration.java
java@Configuration
public class ReactiveMongoDslConfiguration {
@Bean
public ReactiveMongoDsl<MongoTemplateName> reactiveMongoDsl(
MongoTemplateResolver<MongoTemplateName> resolver
) {
return new ReactiveMongoDsl<>(resolver);
}
}