進入點

Reactive Mongo DSL 1.0.0 的公開進入點，用於啟動執行上下文、查詢、搜索、向量搜索和根聚合。

創建 ReactiveMongoDsl。

java

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

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

MongoTemplateResolver<K>#getTemplate(K)

返回對應於 key 的 MongoExecutionContext。

getMongoTemplate(K)。

通過解析器查詢當前 key 的 MongoExecutionContext。

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

基於 ClientSession 的 DSL 事務執行。

執行構建器。

executeEntity(Class<E>, K)

根據實體類和解析器 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 驅動過濾器直接傳遞為一般查詢條件。

search([index])。

啟動 Atlas Search 專用構建器。

向量搜索(索引)

啟動 Vector Search 專用構建器。

聚合()

從管道的第一階段開始，使用 Driver-native Bson 組成根聚合。

無條件構建器的操作。

save(E) / saveAll(...)。

應用實體單位插入/替換和保存生命週期鉤子。

saveAllBulk(...)。

基於 insertMany 的批量插入。

saveAllBulkUpsert(...)。

基於實體 id 的無序批量 upsert。

saveAllBulkUpsertByKey(...)。

基於業務複合鍵的無序批量 upsert。

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

entity 삭제와 optional <collection>_remove 백업

createHistory(entity[, prefix])。

將當前文檔快照保存到單獨的歷史集合中。