Spring Boot WebFlux | Spring Data Reactive MongoDB -CRUD Example | JavaTechie

This tutorial will walk you through how to write CRUD operations for a Spring Boot application using reactive mongodb driver.
#javatechie #reactive #mongoDB #Webflux
GitHub:
github.com/Java-Techie-jt/spr...
Blogs:
/ javatechie4u
Facebook:
/ 919464521471923
guys if you like this video please do subscribe now and press the bell icon to not miss any update from Java Techie
Disclaimer/Policy:
--------------------------------
Note : All uploaded content in this channel is mine and its not copied from any community , you are free to use source code from above mentioned GitHub account

[@samuelsodagudi]

Thank you soo much for making this video. 🙏🙏🙏

[@javatutorialshub8896]

You are explaining very easy way. keep growing. 👍 👍

[@PavelQuezada]

nice tutorial, thank you soo much, greetings from Perú

[@mahimakaushal7381]

very very nice video everything was so clear reactive was new for me but this video cleared everything.

[@amitkumar7566]

Very clear. Waiting for your video on SAGA pattern of microservices.

[@johncerpa3782]

Great video!

[@gabrielgitonga1252]

Awesome, this is awesome. I love the way you teach. Always following you.

[@Javatechie]

Thanks Gabriel ,👍

[@gabrielgitonga1252]

@@Javatechie You are welcome.

[@diggusbickus]

Genius, thank you.

[@ogabeksaidov1986]

Simple GREAT👍

[@karismachoudhury222]

Thanks for the nice video

[@sreesri8492]

Your videos are very easy to understand, even for freshers. I always advice my frd to watch your videos. Thank you

[@elizeuramos2371]

thanks so much, very very nice video

[@HallOfMemeYT]

no tutorial can be better than this.i used traditonal mysql database with the reactive rest service..Thnx for the tutorial

[@Javatechie]

Thanks buddy . If you want to use traditional MySQL DB then please go with R2DBC

[@vengateshm2122]

Well said

[@raghuvardhansaripalli9636]

Hi Basanth, if you have time, could you please do a complete spring cloud gateway with resilence4j, load balancing, security, authentication, routing, filters using 2 Microservices..thank you in advance..stay safe..🙏❤️

[@AshishYadav-se4db]

Thank you so much sir.

[@khemchandkolhe3]

great tutorial

[@bryanseros]

Thanks!!! for you help

[@musa4747]

Thank you brother

[@tamizhvananasaithami5021]

thanks for your material looks pretty simple and easy understandable. need your input the below example

[@michaeldeng1981]

Great. Only thing want to point out is the controller class path is not fully restful, should follow the rest urls conventions. For example, no need to write "update" in the url.

[@Javatechie]

Thanks but once I defined root url as /products then do you really need to define /product again ?

[@michaeldeng1981]

@@Javatechie /products should be fine.

[@pratishrutipanda6461]

Nice video sir

[@SivaKumar-gl9ty]

Thanks!!..

[@krishind99]

Great work. Thanks for putting this together. How do you do error handling in each stamp. What happens if insert or update fails. What if, ID you are looking for is not found?

[@subramanianchenniappan4059]

Thanks

[@mayanksharmaisrolling]

Hi nice video, do you see any performance improvement while using reactive programming ? I mean in this example although you are using reactive programming , the responses are not streamed(as you did in the previous tutorial). so what benefit you see for using reactive for this use case vs traditional rest and non reactive programming?

[@edgarfranklizarragaugarte1191]

same question here... I used APPLICATION_STREAM_JSON_VALUE to produce it an it works but it is deprecated

[@rajkumardas8776]

same question from my side as well.

[@rajkumardas8776]

I know the answer now! By default browser donesn't understand that this is a stream API so you are not seering the streaming behavior though it is in really. You need to include the produces as APPLICATION_JSON_STREAM_VALUE if you want to see the behavior in browser. In practical, we don't need that becuase the call happens in services only.

[@ainigma100]

Great job!!! Thank you for your video! I just have one question. Maybe it is a better (safer) approach to use a constructor-based injection. What do you think?

[@Javatechie]

I am directly using annotation approach

[@javabites]

In general, constructor based annotation is for mandatory dependencies. Setter Injection is used for optional dependencies.

[@ainigma100]

@@javabites Thank you!!!

[@thefaizanakhtar]

If we are returning content type application/octane stream file in return from server to client using web client what return we should give in bodytoflux()

[@ajinkyarawankar3245]

Can you make video on how to save and retrieve nested objects. Saving nested objects separately and build the complete object while retrieving parent object.

[@ShauryaChawlaprayforplagues]

Hey thanks for this tutorial! I made a mini app with a Thymeleaf form to input data. When I call the save method, the data is not saved. But when I add a .subscribe() method after the actual repo insert(), it saves. I don't see you using the subscribe() method. What am I missing here? Please help!

[@chiragmatta9171]

Can you please make tutorial on reactive programing with Kafka and ActiveMQ

[@bharatbhaisolanki3081]

Reactive Repositories are not supported by JPA. Offending repository with mysql - @Query("from Product where price between ?1 and ?2 ")

[@Javatechie]

Not sure about current version

[@shivaniKadali]

we are created the Entity. then what is the use of create DTO with same fields? and another question is i am trying to postmapping it gives responce as 200 but its not saving to DB , rest of the endpoints are working properly

[@Born_2_Reflect]

please provide the link for using Mongo DB using Docker Compose and integrate testing webclient for webflux ?

[@debasismaharana2314]

We need mongo db vedio. Please make one .

[@Javatechie]

Please check in my spring boot playlist it's already there kzbin.info/www/bejne/oWazlqytmMeJj8U

[@vinodhreddy6227]

How we can exstract mono to pojo ans flux to list of pojo?

[@jaganreddy17]

Can you do Video on Spring webflux with reactive rabbitmq?

[@vemulavamsikoundinya]

Hi Basanth, you are doing great job. How to work with entity mapping with ReactiveCrudRepositoy, isit same as JPARepository?

[@Javatechie]

Yes same only it will differ with return type like mono and flux other than that not much difference

[@vemulavamsikoundinya]

Hi Basant, if possible could you please provide example on mapping with ReactiveCrudRepositoy.

[@Javatechie]

Okay i will

[@tamizhvananasaithami5021]

Spring Data Reactive MongoDB -CRUD Example for one to many or many to many examples relation . can you give some inputs

[@reddy8870]

Great, how to convert Mono to List ? Without using block()

[@prileepmathan8144]

Can you add videos about Spring Reactive R2DBC with Oracle Database?

[@Javatechie]

Yes I will add buddy

[@edgarfranklizarragaugarte1191]

is the JSON that returns to the client(browser) blocking others requests? I raised this question since you used TEXT_EVENT_STREAM_VALUE to provide values...

[@Javatechie]

No it won't Block it keep publish stream to the client

[@fipabrate]

I had the same question

[@severessnape9821]

Nice video, but I don't understand why you took entity and dto separately (and performing conversion operations separately in utils) ? Is that a convention or something? Can we not use Entity directly?

[@Javatechie]

No this is the recommended industry standard you shouldn't use Entity directly

[@manikantatikkisetty3594]

I do have same question. What is the difference between both.

[@josephjesusflorianflores7089]

hi, how would he use the saveAll method that saves several documents but not DTOS?

[@Javatechie]

For several documents you must need to create multiple repository .so each repo have their save all method

[@ARPITGUPTA-sx1hr]

Hi when i try to run the application It is showing error: cannot find symbol .doOnNext(e->e.setId(id))) ^ symbol: method setId(java.lang.String) location: variable e of type com.example.demo.entity.Product Could you please tell me how to resolve this ??

[@prateeknima3388]

Hi Basant, Thanks for the video. I have tried creating a sample application but I get the socket connection error [localhost:27017] org.mongodb.driver.cluster: Exception in monitor thread while connecting to server localhost:27017 com.mongodb.MongoSocketOpenException: Exception opening socket Do you have any idea regarding this?

[@Javatechie]

Check whether your mong server is up and running or not?

[@prateeknima3388]

@@Javatechie Thank you for your reply. I was trying to utilize only the embedded repository so was wondering if spring would do the installation of embedded mongoDB?

[@bikashpatra119]

@@prateeknima3388 For embedded mongodb to work, you need to do the following changes in your application configuration Please note, I am using Spring 3.2.2. 1) Use the following dependency for embedded mongo in your pom.xml de.flapdoodle.embed de.flapdoodle.embed.mongo.spring3x 4.12.2 2. The flapdoodle would need the mongo version that it can bring up. We need to provide the mongo version in application.properties. de.flapdoodle.mongodb.embedded.version=7.0.0

[@bikashpatra119]

@@prateeknima3388 Seems someone deleted by reply here. Let me put it again. I am using spring 3.2.2 on mac In pom.xml you will have to use the below dependency de.flapdoodle.embed de.flapdoodle.embed.mongo.spring3x 4.12.2 In application.properties, we will have to provide version of mongodb de.flapdoodle.mongodb.embedded.version=7.0.0 Both these changes are needed to enable spring to start embedded mongo in your spring boot application.

[@vinayakkajagar188]

Hi @JAVA_techie can you ans me , even if we don't send any body in put method means without json if we hit put api to update , it's saying 200 ok as response code , can you please explain what might be reason

[@Javatechie]

It should give bad request error 405

[@vinayakkajagar188]

@@Javatechie but its not giving me bad request , it's responding with 200 ok

[@vinayakkajagar188]

It's depends on router function , is it?

[@Javatechie]

Let me check if that is the case then we didn't implement properly

[@vinayakkajagar188]

@@Javatechie ok

[@rajkumardas8776]

Can you please give your answer on Mayank's question below please?

[@rajkumardas8776]

I know the answer now! By default browser donesn't understand that this is a stream API so you are not seering the streaming behavior though it is in really. You need to include the produces as APPLICATION_JSON_STREAM_VALUE if you want to see the behavior in browser. In practical, we don't need that becuase the call happens in services only.

[@sushilmadankar53]

HI...How that findByPriceBetween is being executed? I meant where is its implementation code?..How it returns data exactly between those price ranges...some miracle is it?? please reply asap.Thank you in advance. Also, suggest where I can get familiar with these type of reactive coding

[@Javatechie]

This is inbuilt code of spring data jpa and it's syntax

[@sushilmadankar53]

@@Javatechie Okay..but how that code knows I have to pick price field values, could you please suggest any link for reference??

[@Javatechie]

Can you please check my spring data jpa tutorial

[@sushilmadankar53]

@@Javatechie please reply with the exact link of video, there are so many

[@kwadwodwomoii8916]

It's auto-implemented by Spring Data. It's the same for the other annotations.

[@avinashavi6176]

Hi Sir, i have some douts, how can i contact you. is there any package,course, like that

[@Javatechie]

[e-mail]

[@nhatvu868]

Thank you for those videos; they helped me a lot. But now I am struggling to solve my task which is: how to make the browser displays new document along with the old ones every time I insert a new document into my MongoDB, without refreshing my browser. Any solutions or keywords will help, thank you.

[@Javatechie]

You need to use SSE (Server Sent Event) concept

[@nhatvu868]

@@Javatechie Thank you so much, I will check that out now

[@itscaesar.794]

Hi, I am getting the following error :- java.lang.NullPointerException: null at java.base/java.util.Objects.requireNonNull(Objects.java:208) ~[na:na] Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: Error has been observed at the following site(s): *__checkpoint ? HTTP POST "/games" [ExceptionHandlingWebHandler] Original Stack Trace: at java.base/java.util.Objects.requireNonNull(Objects.java:208) ~[na:na] at com.SpringWebFluxExample.service.gameService.saveGames(gameService.java:27) ~[main/:na] at com.SpringWebFluxExample.controller.gameController.saveGame(gameController.java:30) ~[main/:na] at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:na] at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[na:na] at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:na] at java.base/java.lang.reflect.Method.invoke(Method.java:568) ~[na:na] at org.springframework.web.reactive.result.method.InvocableHandlerMethod.lambda$invoke$0 Can you please help me out with this.

[@Javatechie]

Please debug and check

[@itscaesar.794]

@Java Techie Yes, done that. It turns out that the project structure was the culprit here. Thanks for the tutorial 👍