Spring webflux ReactiveMongoOperations ค้นหาโดย elemMatch

Question

ฉันมีคอลเลกชันเช่นนี้:

{"type": "bbb", "category": "aaa", "from": "eee", "INTERLOCUTOR": ["test1", "test2"]}

และฉันต้องการหาINTERLOCUTORมีtest1 ; วิธีการใช้งานโดยReactiveMongoOperations ?

Answer 1

db.collection.find({"INTERLOCUTOR" : "test1"})

Answer 2

การใช้ReactiveMongoOperationsและประมวลผลการส่งคืนreactor.core.publisher.Fluxเพื่อพิมพ์เอกสารที่ส่งคืนแบบสอบถาม:

ReactiveMongoOperations ops = new ReactiveMongoTemplate(MongoClients.create(), "test");
Criteria c = Criteria.where("INTERLOCUTOR").is("test1");
Query qry = new Query(c);

Flux<Document> flux = ops.find(qry, Document.class, "coll")
flux.subscribe(doc -> System.out.println(doc), throwable -> throwable.printStackTrace());

สังเกตว่าแบบสอบถามดำเนินการจริงเมื่อsubscribeวิธีการทำงาน เนื่องจากการสมัครใช้งานทำงานเป็นการดำเนินการแบบอะซิงโครนัสเมื่อคุณรันสิ่งนี้จะเพิ่มสิ่งต่อไปนี้ในเธรดปัจจุบัน (สำหรับการบล็อกจนกว่าการดำเนินการ async จะเสร็จสิ้น)

try {
  Thread.sleep(1000);
} catch(InterruptedException e ) {}