Questions tagged [r2dbc]
R2DBC (Reactive Relational Database Connectivity) is an SPI which enables interacting with SQL database servers by executing SQL statements using a non-blocking reactive programming model with the Java programming language.
r2dbc
392
questions
0
votes
1
answer
25
views
Micronaut R2DBC Parent Child Relationship Parent ID not getting inserted into child (One to Many)
I am new to R2DBC and I have a fairly standard parent child relationship Person / Address and when attempting to save a person object with an address both the person and the address get saved but the ...
- 1
0
votes
1
answer
32
views
Duplicate entries using Spring Batch and R2DBC
I'm new in the R2DBC environment and i'm afraid using it along Spring Batch to findAll the rows in a table with more than 8 million records can duplicate some rows in the process since R2DBC don't use ...
- 21
1
vote
0
answers
77
views
LEAK: ByteBuf.release() was not called before it's garbage-collected in spring webflux project
I keep getting leakbuffer error just by invoking my rest api, sometimes connection closed exception. I am not using any bytebuff exclusively in my code. I have rest api, on calling it should fetch ...
- 21
0
votes
1
answer
53
views
How to use relationships using R2DBC driver in springboot?
I have a project in spring boot 2.7 with java 11. Currently I am using JPA in spring boot to interact with DB. Since I use reactive library, I am thinking to upgrade to reactive drivers i.e. r2dbc. ...
0
votes
0
answers
30
views
AWS RDS DB Connection not restarting
In reactive spring boot service, use case is like we are trying to receive message from SQS and process it but we are observing that the db connections are getting closed once queue is empty and ...
0
votes
1
answer
55
views
Spring Data R2DBC: Saving Department with Empty Employee List (Unsupported array type)
I'm encountering an error while saving a Department object with Spring Data R2DBC. My Department model has an employees property that can hold a list of Employee objects. However, when I try to create ...
0
votes
1
answer
48
views
Spring R2DBC repository.save() not working inside flatMap()
Following is the function written in a service.
public Mono<BrandRest> createBrand(CreateBrandRequest request) {
record BrandCategoryRest(Brand brandRest, List<CategoryRest> ...
0
votes
1
answer
38
views
Pagination when entity has relations in Spring Data R2DBC
I have an entity
@Getter
@Setter
@ToString
@AllArgsConstructor
@NoArgsConstructor
@Table(name = "employees")
public class EmployeeEntity implements Persistable<String> {
@Id
@...
- 1
0
votes
0
answers
118
views
Failed to obtain R2DBC connection when running dockerized spring boot application
I am getting Failed to obtain R2DBC connection error message when sending POST request to feed some data into the database.
Here is the docker compose configuration of my microservice2 where I am ...
0
votes
0
answers
83
views
How to Escape Reserved Words in SQL Queries with R2DBC for SQL Server?
I'm working with a Spring Webflux application and using R2DBC to connect to a SQL Server database. I've encountered an issue when trying to perform a query that includes a reserved word as a column ...
-1
votes
1
answer
43
views
String refernce is held in heap after sql execution
Lately I have encountered a really strange memory leak.
I would appreciate if someone helps me resolve it.
public Mono<Boolean> insertOrders(List<ClientOrder> orders) {
if (orders....
- 142
1
vote
1
answer
29
views
jOOQ select Master-Details filter by details's property
Currently I am using the latest jOOQ 3.19.5(R2dbc/Postgres) in my project.
I encountered an issue like this.
Given master and details` table.
|master |
id,
type
|details|
id,
master_id,
other_id ...
- 8,897
0
votes
2
answers
116
views
How to process flux in batches and have each batch processed in parallel
There are 5,000,000 entities in my database. I am connecting to the database via a reactive driver (r2dbc). Next, I want to split it on 100,000 entities, split them into bundles of 1,000 entities and ...
0
votes
0
answers
131
views
r2dbc-pool: Using the r2dbc connection pool slows down the execution of parallel transactions
I am trying to optimize the reuse of PostgreSQL connections by implementing the r2dbc Connection Pool for jOOQ. But I noticed that transaction execution speed tends to be better whenever I use just a ...
- 1
1
vote
2
answers
74
views
POST with autogenerated id in r2dbc
I have spring boot/r2dbc application
My controller:
@PostMapping("/add")
public ResponseEntity<String> create(@RequestBody NotificationEntity e) {
notificationDAO.save(e).subscribe(...
- 927