Merge pull request #424 from kdhrubo/feature/397_bulk_create

#397 - bulk create oracle

src/test/java/com/homihq/db2rest/rest/MySQLReadControllerTest.java → src/test/java/com/homihq/db2rest/rest/mysql/MySQLReadControllerTest.java

@@ -1,4 +1,4 @@
-package com.homihq.db2rest.rest;
+package com.homihq.db2rest.rest.mysql;
 
 import com.homihq.db2rest.MySQLBaseIntegrationTest;
 import org.junit.jupiter.api.*;

src/test/java/com/homihq/db2rest/rest/oracle/OracleBulkCreateControllerTest.java

@@ -0,0 +1,156 @@
+package com.homihq.db2rest.rest.oracle;
+
+import com.adelean.inject.resources.junit.jupiter.GivenJsonResource;
+import com.adelean.inject.resources.junit.jupiter.TestWithResources;
+import com.adelean.inject.resources.junit.jupiter.WithJacksonMapper;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
+import com.homihq.db2rest.OracleBaseIntegrationTest;
+import com.homihq.db2rest.utils.ITestUtil;
+import org.junit.jupiter.api.*;
+
+import java.util.List;
+import java.util.Map;
+
+import static java.nio.charset.StandardCharsets.UTF_8;
+import static org.hamcrest.Matchers.hasItem;
+import static org.hamcrest.Matchers.hasSize;
+import static org.springframework.http.MediaType.APPLICATION_JSON;
+import static org.springframework.restdocs.mockmvc.MockMvcRestDocumentation.document;
+import static org.springframework.restdocs.mockmvc.RestDocumentationRequestBuilders.post;
+import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.jsonPath;
+import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
+
+
+@TestClassOrder(ClassOrderer.OrderAnnotation.class)
+@Order(281)
+@TestWithResources
+class OracleBulkCreateControllerTest extends OracleBaseIntegrationTest {
+
+    @WithJacksonMapper
+    ObjectMapper objectMapper = new ObjectMapper()
+            .registerModule(new JavaTimeModule());
+
+    @GivenJsonResource("/testdata/BULK_CREATE_FILM_REQUEST.json")
+    List<Map<String,Object>> BULK_CREATE_FILM_REQUEST;
+
+    @GivenJsonResource("/testdata/BULK_CREATE_FILM_BAD_REQUEST.json")
+    List<Map<String,Object>> BULK_CREATE_FILM_BAD_REQUEST;
+
+    @Test
+    @DisplayName("Create many films.")
+    void create() throws Exception {
+
+        mockMvc.perform(post("/FILM/bulk")
+                        .queryParam("sequences", "film_id:film_sequence")
+                        .contentType(APPLICATION_JSON).accept(APPLICATION_JSON)
+                        .content(objectMapper.writeValueAsString(BULK_CREATE_FILM_REQUEST))
+                )
+                .andExpect(status().isCreated())
+                .andExpect(jsonPath("$.rows").isArray())
+                .andExpect(jsonPath("$.rows", hasSize(2)))
+                .andExpect(jsonPath("$.rows", hasItem(1)))
+                .andExpect(jsonPath("$.rows", hasItem(1)))
+                //.andExpect(jsonPath("$.generated_keys").isArray()) //TODO - push TSID columns
+                //.andExpect(jsonPath("$.generated_keys", hasSize(2)))
+                //.andExpect(jsonPath("$.generated_keys", allOf(notNullValue())))
+                //.andDo(print())
+                .andDo(document("oracle-bulk-create-films"));
+
+    }
+
+    @Test
+    @DisplayName("Create many films with CSV type.")
+    void createCSV() throws Exception {
+
+        mockMvc.perform(post("/FILM/bulk")
+                        .queryParam("sequences", "film_id:film_sequence")
+                        .contentType("text/csv").accept(APPLICATION_JSON)
+                        .content(ITestUtil.CREATE_FILM_REQUEST_CSV))
+                .andExpect(status().isCreated())
+                .andExpect(jsonPath("$.rows", hasSize(2)))
+                .andExpect(jsonPath("$.rows", hasItem(1)))
+                //.andExpect(jsonPath("$.generated_keys", hasSize(2)))
+                //.andExpect(jsonPath("$.generated_keys", allOf(notNullValue())))
+                //.andDo(print())
+                .andDo(document("oracle-bulk-create-films-csv"));
+
+    }
+
+    @Test
+    @DisplayName("Create many films with CSV type resulting error.")
+    void createCSVWithError() throws Exception {
+
+        mockMvc.perform(post("/FILM/bulk")
+                        .queryParam("sequences", "film_id:film_sequence")
+                        .contentType("text/csv")
+                        .accept(APPLICATION_JSON)
+                        .content(ITestUtil.CREATE_FILM_BAD_REQUEST_CSV))
+                .andExpect(status().isBadRequest())
+                //.andDo(print())
+                .andDo(document("oracle-bulk-create-films-csv-error"));
+
+    }
+
+    @Test
+    @DisplayName("Create many films with failure.")
+    void createError() throws Exception {
+
+        mockMvc.perform(post("/FILM/bulk")
+                        .queryParam("sequences", "film_id:film_sequence")
+                        .contentType(APPLICATION_JSON)
+                        .accept(APPLICATION_JSON)
+                        .content(objectMapper.writeValueAsString(BULK_CREATE_FILM_BAD_REQUEST)))
+                .andExpect(status().isBadRequest())
+                // .andDo(print())
+                .andDo(document("oracle-bulk-create-films-error"));
+
+    }
+
+    @Test
+    @DisplayName("Create many directors.")
+    void createDirector() throws Exception {
+
+        mockMvc.perform(post("/DIRECTOR/bulk")
+                        .contentType(APPLICATION_JSON).accept(APPLICATION_JSON)
+                        .param("tsIdEnabled", "true")
+                        .content(ITestUtil.BULK_CREATE_DIRECTOR_REQUEST))
+                .andExpect(status().isCreated())
+                //.andDo(print())
+                .andDo(document("oracle-bulk-create-directors"));
+
+    }
+
+    @Test
+    @DisplayName("Create many directors with wrong tsid type.")
+    void createDirectorWithWrongTsidType() throws Exception {
+
+        mockMvc.perform(post("/DIRECTOR/bulk")
+                        .characterEncoding(UTF_8)
+                        .contentType(APPLICATION_JSON)
+                        .accept(APPLICATION_JSON)
+                        .param("tsid", "director_id")
+                        .param("tsidType", "string")
+                        .header("Content-Profile", "sakila")
+                        .content(ITestUtil.BULK_CREATE_DIRECTOR_BAD_REQUEST))
+                .andExpect(status().isBadRequest())
+                //.andDo(print())
+                .andDo(document("oracle-bulk-create-directors-with-wrong-tsid-type"));
+
+    }
+
+    @Test
+    @DisplayName("Create reviews with default tsid type.")
+    void createReviewWithDefaultTsidType() throws Exception {
+
+        mockMvc.perform(post("/REVIEW/bulk")
+                        .contentType(APPLICATION_JSON).accept(APPLICATION_JSON)
+                        .param("tsIdEnabled", "true")
+                        .content(ITestUtil.BULK_CREATE_REVIEW_REQUEST))
+                .andExpect(status().isCreated())
+                //.andDo(print())
+                .andDo(document("oracle-bulk-create-reviews-with-default-tsid-type"));
+
+    }
+
+}