32 questions
0
votes
1
answer
248
views
how to write my mongodb query in springboot reactive mongodb
well below is my implementation
db.services_performed.aggregate([{$match:{status:{$in:
["INVOICING","outbound","accepted","PENDING APPROVAL"]}}},{$group:{...
1
vote
1
answer
1k
views
How do you throw exceptions within Webflux Mono and Flux streams to the caller?
I have a service that handles the insertion of a new record into a MongoDB collection:
public Mono<ProductDto> insertProduct(Mono<ProductDto> in) {
//TODO Must handle Duplicate key ...
0
votes
1
answer
530
views
Why filtering does not work with Spring Boot and MongoDB
Why filtering by import_created_at does not work?
I have a Spring Boot Application and MongoDB as database.
I have Mongo collection items and 2 documents there:
{
"_id": {
"...
- 95
1
vote
1
answer
1k
views
saving a Flux of items in reactive mongo db
i'm having a flux of items returned from another service
Flux<Tweet> tweetsByUserId = restUtils.getTweetsByUserId(userId);
I want this flux to paralamlely be saved in database and send to the ...
- 435
2
votes
1
answer
2k
views
Spring Webflux Reactive Mongo Bulk Operations (Java)
https://github.com/spring-projects/spring-data-mongodb/issues/2821
https://jira.spring.io/browse/DATAMONGO-1922?redirect=false
I have been looking for ReactiveBulk operations to update documents as a ...
- 89
0
votes
1
answer
952
views
org/bson/internal/CodecRegistryHelper with Micronaut data MongoDB
Using the latest Micronaut 3.4.1 with micronaut data and MongoDB. Keep getting the exception as java.lang.NoClassDefFoundError: org/bson/internal/CodecRegistryHelper
Gradle Dependencies
dependencies {
...
- 17.4k
3
votes
1
answer
2k
views
Bulk Update with ReactiveMongoTemplate
In a reactive spring boot application, I have a list of items to update. I want to send a SINGLE command to my DB to apply the changes on different items. An equivalent to db.collection.updateMany if ...
- 406
0
votes
1
answer
2k
views
In Spring WebFlux, How to chaining methods from multiple services/repo, in order to 'delete' elements in multiples DB-Collections'?
1) Contextualization about the problem:
I am trying 'delete' items in 03 different DB-Collections(Reactive MongoDB), using 03 different services/repo (userService + postService + userRepo);
My Goal is ...
- 956
0
votes
1
answer
1k
views
Problem Parsing request body of type json, containing a list of string to Flux of string in Spring reactive
I have a DTO as below:
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import reactor.core.publisher.Flux;
@Data
@NoArgsConstructor
@AllArgsConstructor
public ...
- 476
0
votes
1
answer
362
views
Springboot ignores the MongoDB atlas uri, trying to connect hosts=[127.0.0.1:27017]
I have been working in a application with Spring webflux and reactive mongo DB. in there i used mongo DB atlas as the database and it worked fine.
Recently i had to introduce mongo custom conversion ...
- 825
0
votes
0
answers
168
views
Filtering on a Mongo DB capped Collection using Flux
I have defined my capped collection as below.
@Document("#{@environment.getProperty('customProperties.cappedCollection')}")
@Data
@NoArgsConstructor
@Builder
@AllArgsConstructor
public ...
- 165
1
vote
0
answers
41
views
Updating multi level Embedded document in Mongo using reactivemongotemplate
I have an embedded document. How can I update the multilevel document? At the time of insert, using Document to store the document. When updating the embedded document with update.set(), I can only do ...
- 11
-1
votes
1
answer
320
views
Cannot convert from Flux<A> to Mono<? extends Object>
public Flux<A> updateByFindById(String gsisKey, A a) {
return repository.findAllByVesselCode(a.getVesselCode())
.collectList().flatMap(list->{
return ...
- 23
2
votes
1
answer
3k
views
How we can compare two values of flux using springreactor
Currently I am new in reactive programming ,
I have added data in 2 documents, so currently what I am trying to do is to return only those data to client whose tokenIdentifier is same in both document....
1
vote
1
answer
2k
views
MongoDb Java driver reactive with POJO mapping find List of documents in a type safe way
I have a bunch of Document in a Collection and would like to retrieve all of them. This is my situation:
I am using the Java Reactive Streams driver
I am using the CodecRegistry to get my Document ...
- 1,381
1
vote
1
answer
1k
views
how retrieve and add new document to MongoDb collection throw com.mongodb.reactivestreams.client.MongoClient
Context: I coded a Kafka Consumer which receives a simple message and I want to insert it to MongoDb using com.mongodb.reactivestreams.client.MongoClient. Althought I understand my issue is all about ...
- 4,455