Check if Document in MongoDB exists, using reactive-streams

Question

I'm trying to check if a document already exits, but I'm having some problems. I tried different solutions:

Using findOne() and checking if output is null (doesn’t work)
Using countDocument() (doesn’t work) The error that is saw the most is that I can’t cast for example: Publisher to long or Publisher to Document

Thanks.

Method 1:

Document d = collection.find(eq("UUID", id)).first();
if (d == null) {
    System.out.println("document = null");
    return;
}
System.out.println("document exists");

Method 2:

if (collection.countDocuments(query) < 1) {
    System.out.println("Document exists");
}

Volodya Lombrozo · Accepted Answer · 2023-02-05 16:10:22Z

2

To check if a document exists you can use the exists() method from the ReactiveMongoTemplate class. The method takes a Query object as its parameter, which is used to specify the conditions to match the document. You can read about the exists() method right here.

Here is an example of how you can use the exists() method to check if a document with a specific id field exists in a collection called docs:

Query query = new Query(Criteria.where("id").is("unique-id-123"));
Mono<Boolean> exists = reactiveMongoTemplate.exists(query, “docs”);

Where query is org.springframework.data.mongodb.core.query.Query and reactiveMongoTemplate is org.springframework.data.mongodb.core.ReactiveMongoTemplate

Another solutions that you mentioned actually have to work too, for example:

Using findOne() method:

Query query = new Query(Criteria.where("id").is("unique-id-123"));
Mono<Document> documentMono = reactiveMongoTemplate.findOne(query, Document.class, "docs");
documentMono.subscribe(doc -> {
    if (doc != null) {
        System.out.println("Document exists!");
    } else {
        System.out.println("Document does not exist!");
    }
});

You can read about findOne() method here.

Update for [1]: findOne():

As kerbermeister mentioned, That approach will not work:

reactor does not allow null values, so if publisher completes with empty, there will be no null value

and

When Publisher completes with empty it instantly completes with onComplete signal, not onNext. Also, as documentation of subscribe(Consumer) suggests: consumer – the consumer to invoke on each value (onNext signal). So this callback will never be called if publisher completes with empty.

Using count() method:

Query query = new Query(Criteria.where("id").is("unique-id-123"));
Mono<Long> count = reactiveMongoTemplate.count(query, "docs");
count.subscribe(cnt -> {
    if (cnt > 0) {
        System.out.println("Document exists!");
    } else {
        System.out.println("Document does not exist!");
    }
});

You can read about count() method here

edited Feb 5, 2023 at 16:10

answered Jan 24, 2023 at 10:12

Volodya Lombrozo

3,6264 gold badges28 silver badges54 bronze badges

Sign up to request clarification or add additional context in comments.

6 Comments

Jackolix Over a year ago

Thanks for your detailed reply! Unfortunately, I get an error message within my IDE with 'Mono': Cannot access reactor.core.publisher.Mono

Jackolix Over a year ago

Fixed it. I didn't imported the reactor api, only the springframework. But how do I cast Mono<Boolean> to boolean?

Volodya Lombrozo Over a year ago

@Jackolix you can use subscribe(), or block() methods. stackoverflow.com/questions/47179937/…

kerbermeister Over a year ago

@VolodyaLombrozo "another" solution 1 would not work, reactor does not allow null values, so if publisher completes with empty, there will be no null value

Volodya Lombrozo Over a year ago

@kerbermeister Thank you. Have you check that? If it is so, I'll update my answer

|

Collectives™ on Stack Overflow

Check if Document in MongoDB exists, using reactive-streams

1 Answer 1

6 Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

6 Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related