Entrypoints

Reactive Mongo DSL 1.0.0で実行コンテキストとQuery、Search、Vector Search、ルート集約を開始する公開エントリーポイントです。

ReactiveMongoDslを生成

java

MongoTemplateResolver<MongoTemplateName> resolver = key -> contextByKey(key);

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

MongoTemplateResolver<K>#getTemplate(K)

keyに対応するMongoExecutionContextを返します

getMongoTemplate(K)

resolverを通じて現在のkeyのMongoExecutionContextを取得

getTxJob(K, Supplier<Mono<...>>)

ClientSessionベースのDSLトランザクションを実行

Executionビルダー

executeEntity(Class<E>, K)

エンティティクラスとresolver keyでコレクション/マッピングコンテキストを選択

executeCustomClass(Class<E>, K, String)

結果タイプと物理コレクション名を直接指定

java

var users = dsl.executeEntity(User.class, MongoTemplateName.FRONT);

var archive = dsl.executeCustomClass(
    Document.class,
    MongoTemplateName.FRONT,
    "user_archive"
);

ビルダーエントリーポイント

fields(...) / fields()

FieldsPairと論理グルーピングで一般的なMongo条件を構成

driverFilter(Bson)

MongoDB Driverフィルターをそのまま一般クエリ条件に渡す

search([index])

Atlas Search専用ビルダーを開始

vectorSearch(index)

Vector Search専用ビルダーを開始

aggregation()

パイプラインの最初のステージからDriver-native Bsonでルート集約を構成する

条件ビルダーなしで可能な操作

save(E) / saveAll(...)

エンティティ単位のinsert/replaceとsaveライフサイクルフックを適用

saveAllBulk(...)

insertManyベースのバルク挿入

saveAllBulkUpsert(...)

エンティティID基準の無順序バルクアップサート

saveAllBulkUpsertByKey(...)

業務複合キー基準の無順序バルクアップサート

delete(entity[, backup]) / deleteBulk(...)

entity 삭제와 optional <collection>_remove 백업

createHistory(entity[, prefix])

別の履歴コレクションに現在のドキュメントスナップショットを保存