added mongodb integration test cases

src/test/java/com/nisum/webfluxmongodbordermanagement/service/OrderControllerIntTest.java

+package com.nisum.webfluxmongodbordermanagement.service;
+
+import com.nisum.webfluxmongodbordermanagement.entity.Order;
+import com.nisum.webfluxmongodbordermanagement.service.OrdersService;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.data.mongo.DataMongoTest;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.test.context.ActiveProfiles;
+import org.springframework.test.context.junit.jupiter.SpringExtension;
+import reactor.core.publisher.Flux;
+import reactor.test.StepVerifier;
+import java.io.IOException;
+
+@DataMongoTest
+@ExtendWith(SpringExtension.class)
+@ActiveProfiles("test")
+public class OrderControllerIntTest {
+
+    static {
+        System.setProperty("spring.mongodb.embedded.version","5.0.0");
+    }
+
+    @Autowired
+    MongoTemplate mongoTemplate;
+    @Autowired(required=true)
+    OrdersService orderService;
+
+    @BeforeEach
+    public void setup() throws IOException {
+
+        mongoTemplate.getCollection("orders").drop();
+        //mongoTemplate.insert(new User("23563456", "01", "samab12344","sarika@123456","1"));
+        mongoTemplate.insert(new Order("2356781", "01", "1","ooppo122356","oppo123456","sucess"));
+
+    }
+
+    @Test
+    public void getOrderControllerTest(@Autowired MongoTemplate mongoTemplate) {
+
+        Flux<Order> result = orderService.getOrders();
+
+        StepVerifier.create(result)
+                .expectNextMatches(order -> order.getOrderId().equals("01"))
+                .expectComplete()
+                .verify();
+    }
+
+}

src/test/java/com/nisum/webfluxmongodbordermanagement/service/OrdersServiceIntTest.java

+package com.nisum.webfluxmongodbordermanagement.service;
+
+import com.nisum.webfluxmongodbordermanagement.entity.Order;
+import com.nisum.webfluxmongodbordermanagement.entity.User;
+import com.nisum.webfluxmongodbordermanagement.repository.OrderRepository;
+import com.nisum.webfluxmongodbordermanagement.repository.UserRepository;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.data.mongo.DataMongoTest;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.test.context.ActiveProfiles;
+import org.springframework.test.context.junit.jupiter.SpringExtension;
+import reactor.core.publisher.Flux;
+import reactor.test.StepVerifier;
+
+import java.io.IOException;
+@DataMongoTest
+@ExtendWith(SpringExtension.class)
+@ActiveProfiles("test")
+public class OrdersServiceIntTest {
+
+    static {
+        System.setProperty("spring.mongodb.embedded.version","5.0.0");
+    }
+
+    @Autowired
+    MongoTemplate mongoTemplate;
+    @Autowired
+    OrderRepository orderRepository;
+
+    @BeforeEach
+    public void setup() throws IOException {
+
+        mongoTemplate.getCollection("orders").drop();
+        //mongoTemplate.insert(new User("23563456", "01", "samab12344","sarika@123456","1"));
+        mongoTemplate.insert(new Order("2356781", "01", "1","ooppo122356","oppo123456","sucess"));
+
+    }
+
+    @Test
+    public void testGetOrders(@Autowired MongoTemplate mongoTemplate) {
+
+        Flux<Order> result = orderRepository.findAll();
+
+        StepVerifier.create(result)
+                .expectNextMatches(order -> order.getUserId().equals("1"))
+                .expectComplete()
+                .verify();
+    }
+
+}
+

src/test/java/com/nisum/webfluxmongodbordermanagement/service/UsersServiceIntTest.java

@@ -17,25 +17,15 @@ import java.io.IOException;
 
 
 @DataMongoTest
-//@AutoConfigureWebTestClient
-//@DataMongoTest
 @ExtendWith(SpringExtension.class)
 @ActiveProfiles("test")
 public class UsersServiceIntTest {
 
-
-
-   // private static final String CONNECTION_STRING = "mongodb://%s:%d";
     static {
         System.setProperty("spring.mongodb.embedded.version","5.0.0");
     }
 
 
-
- // private WebTestClient webTestClient=WebTestClient.bindToServer().build();
-
-    //private MongoTemplate mongoTemplate;
-
     @Autowired
     MongoTemplate mongoTemplate;
     @Autowired
@@ -44,14 +34,8 @@ public class UsersServiceIntTest {
     @BeforeEach
     public void setup() throws IOException {
 
-//        MongoClient mongoClient = MongoClientsients.create(
-//                MongoClientSettings.builder()
-//                        .applyToClusterSettings(builder ->
-//                                builder.hosts(Arrays.asList(new ServerAddress("hostOne", 27018))))
-//                        .build());
-
         mongoTemplate.getCollection("user").drop();
-        //mongoTemplate.insert(new Order("6479de74df9120c3dc8ed1a5", "101", "01", "sama927365","oppo099876","success"));
+        //mongoTemplate.insert(new User("23563456", "01", "samab12344","sarika@123456","1"));
         mongoTemplate.insert(new User("2356781", "01", "samasarika","sama@123456","1"));
 
     }
@@ -63,55 +47,11 @@ public class UsersServiceIntTest {
         Flux<User> result = userRepository.findAll();
 
         StepVerifier.create(result)
-                // .expectNextMatches(order -> order.getOrderId().equals("101"))
                 .expectNextMatches(user -> user.getUserId().equals("01"))
                 .expectComplete()
                 .verify();
-
-
-
     }
 
-
-
-
-
-
-//        User user1 = new User("1", "01","sama0921","sama@gmail.com","1");
-//        //User user2 = new User("2","02","sam900921","smkj@gmail.com","1" );
-//        mongoTemplate.save(user1);
-//        //  mongoTemplate.save(user2);
-//        DBObject objectToSave = BasicDBObjectBuilder.start()
-//                .add("userId", "01")
-//                .get();
-//
-//        // when
-//        mongoTemplate.save(objectToSave, "user");
-//
-//        // then
-//        assertThat(mongoTemplate.findAll(DBObject.class, "user")).extracting("userId")
-//                .as("01");
-//    }
-//
-//
-//        // Call the getUsers API endpoint
-//        Flux<User> result = (Flux<User>) webTestClient.get().uri("/users")
-//                .exchange()
-//                .expectStatus().isOk()
-//                .expectBodyList(User.class)
-//                .returnResult()
-//                .getResponseBody();
-
-
-
-
-
-
-
-// Verify the emitted User objects using StepVerifier
-
-
-
     }