Quick Start
DriverMongoExecutionContext와 MongoTemplateResolver를 연결하고 Reactive Mongo DSL 1.0.0의 첫 query를 실행합니다.
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 naming 규칙이 다르면 별도의 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(...)은 ReactiveMongoTemplate이나 Spring transaction 객체가 아니라 key에 대응하는 MongoExecutionContext를 반환합니다.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을 emit하는 동작과는 관계없습니다.Spring Bean으로 사용할 때
ReactiveMongoDslConfiguration.java
java@Configuration
public class ReactiveMongoDslConfiguration {
@Bean
public ReactiveMongoDsl<MongoTemplateName> reactiveMongoDsl(
MongoTemplateResolver<MongoTemplateName> resolver
) {
return new ReactiveMongoDsl<>(resolver);
}
}