add refresh database function

pom.xml

@@ -46,6 +46,21 @@
 			<artifactId>spring-boot-starter-test</artifactId>
 			<scope>test</scope>
 		</dependency>
+		<dependency>
+			<groupId>com.fasterxml.jackson.core</groupId>
+			<artifactId>jackson-databind</artifactId>
+			<version>2.13.3</version>
+		</dependency>
+		<dependency>
+			<groupId>org.json</groupId>
+			<artifactId>json</artifactId>
+			<version>20180130</version>
+		</dependency>
+		<dependency>
+			<groupId>com.vaadin.external.google</groupId>
+			<artifactId>android-json</artifactId>
+			<version>0.0.20131108.vaadin1</version>
+		</dependency>
 	</dependencies>
 
 	<build>

src/main/java/com/secondtest/secondtest/SecondtestApplication.java

@@ -1,17 +1,41 @@
 package com.secondtest.secondtest;
 
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.util.JSONPObject;
+import com.secondtest.secondtest.controller.InfoColumnController;
+import com.secondtest.secondtest.model.Employee;
+import com.secondtest.secondtest.model.InfoColumn;
+import com.secondtest.secondtest.model.InfoTable;
+import com.secondtest.secondtest.service.InfoColumnService;
+import com.secondtest.secondtest.service.InfoTableService;
+import com.secondtest.secondtest.service.LinkInfoService;
+import org.apache.tomcat.util.json.JSONParser;
+import org.json.JSONArray;
+import org.json.JSONObject;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.annotation.Bean;
 import org.springframework.web.cors.CorsConfiguration;
 import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
 import org.springframework.web.filter.CorsFilter;
+
+import java.io.File;
+import java.io.FileReader;
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.Iterator;
+import java.util.List;
+
 @SpringBootApplication
 public class SecondtestApplication {
 
-	public static void main(String[] args) {
+	public static void main(String[] args) throws IOException {
 		SpringApplication.run(SecondtestApplication.class, args);
+
 	}
 
 	@Bean

src/main/java/com/secondtest/secondtest/controller/InfoColumnController.java

@@ -63,5 +63,11 @@ public class InfoColumnController {
         return infoColumnService.getColumnsForJoinTwo(tablesList, schemasList);
     }
 
+    @DeleteMapping("/columns/deleteAll")
+    public void deleteAllColumns() {
+        infoColumnService.deleteAllColumn();
+    }
+
+
 
 }

src/main/java/com/secondtest/secondtest/controller/InfoTableController.java

@@ -5,10 +5,7 @@ import com.secondtest.secondtest.model.InfoTable;
 import com.secondtest.secondtest.repository.InfoTableRepository;
 import com.secondtest.secondtest.service.InfoTableService;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import java.util.Optional;
 
@@ -61,4 +58,9 @@ public class InfoTableController {
         return infoTableService.getTablesBySchemaName(schema);
     }
 
+    @DeleteMapping("/tables/deleteAll")
+    public void deleteAllTables() {
+        infoTableService.deleteAllTable();
+    }
+
 }

src/main/java/com/secondtest/secondtest/controller/LinkInfoController.java

@@ -3,6 +3,7 @@ package com.secondtest.secondtest.controller;
 import com.secondtest.secondtest.model.LinkInfo;
 import com.secondtest.secondtest.service.LinkInfoService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.DeleteMapping;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 
@@ -38,4 +39,8 @@ public class LinkInfoController {
         return linkInfoService.getAllLinksInfos();
     }
 
+    @DeleteMapping("/links/deleteAll")
+    public void deleteAllLinks() {
+        linkInfoService.deleteAllLinks();
+    }
 }

src/main/java/com/secondtest/secondtest/controller/ResetDataController.java

@@ -0,0 +1,25 @@
+package com.secondtest.secondtest.controller;
+
+import java.io.IOException;
+import java.util.Optional;
+import com.secondtest.secondtest.service.InfoColumnService;
+import com.secondtest.secondtest.service.InfoTableService;
+import com.secondtest.secondtest.service.LinkInfoService;
+import com.secondtest.secondtest.service.ResetDataService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequestMapping("/api")
+public class ResetDataController {
+    @Autowired
+    private ResetDataService resetDataService;
+
+
+    @PostMapping("/reset")
+    public void resetData() throws IOException {
+        resetDataService.deleteEverything();
+        resetDataService.insertEverything();
+        resetDataService.checkAndInsertLinks();
+    }
+}

src/main/java/com/secondtest/secondtest/repository/InfoColumnRepository.java

@@ -1,10 +1,12 @@
 package com.secondtest.secondtest.repository;
 
 import com.secondtest.secondtest.model.InfoColumn;
+import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.CrudRepository;
 import org.springframework.data.repository.query.Param;
 import org.springframework.stereotype.Repository;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.RequestParam;
 
 import java.util.List;
@@ -23,4 +25,11 @@ public interface InfoColumnRepository extends CrudRepository<InfoColumn, Long> {
             "(SELECT column_id FROM link_informations WHERE name_table IN :tables AND name_schema IN :schemas GROUP BY column_id  HAVING COUNT(column_id) > 1)", nativeQuery = true)
     Iterable<InfoColumn> getColumnsForJoinTwo(@RequestParam("tables") List<String> tables, @RequestParam("schemas") List<String> schemas);
 
+    @Query(value = "SELECT * FROM informations_column WHERE name_column = :namecol AND data_type = :datatype AND length_column = :lengthcol AND column_text = :columntext", nativeQuery = true)
+    InfoColumn getSpecColumn(@Param("namecol") String nameCol, @Param("datatype") String dataType, @Param("lengthcol") int lengthCol, @Param("columntext") String columnText);
+
+    @Modifying
+    @Transactional
+    @Query(value = "TRUNCATE TABLE informations_column", nativeQuery = true)
+    void truncateMyColumn();
 }

src/main/java/com/secondtest/secondtest/repository/InfoTableRepository.java

@@ -2,10 +2,12 @@ package com.secondtest.secondtest.repository;
 
 import com.secondtest.secondtest.model.InfoTable;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.CrudRepository;
 import org.springframework.data.repository.query.Param;
 import org.springframework.stereotype.Repository;
+import org.springframework.transaction.annotation.Transactional;
 
 @Repository
 public interface InfoTableRepository extends CrudRepository<InfoTable, Long> {
@@ -18,4 +20,9 @@ public interface InfoTableRepository extends CrudRepository<InfoTable, Long> {
             value = "SELECT * FROM informations_table WHERE name_schema=:schema",
             nativeQuery = true)
     Iterable<InfoTable> getTablesBySchemaName(@Param("schema") String schema);
+
+    @Modifying
+    @Transactional
+    @Query(value = "TRUNCATE TABLE informations_table", nativeQuery = true)
+    void truncateMyTable();
 }

src/main/java/com/secondtest/secondtest/repository/LinkInfoRepository.java

@@ -1,10 +1,17 @@
 package com.secondtest.secondtest.repository;
 
 import com.secondtest.secondtest.model.LinkInfo;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.CrudRepository;
 import org.springframework.stereotype.Repository;
+import org.springframework.transaction.annotation.Transactional;
 
 @Repository
 public interface LinkInfoRepository extends CrudRepository<LinkInfo, Long>{
 
+    @Modifying
+    @Transactional
+    @Query(value = "TRUNCATE TABLE link_informations", nativeQuery = true)
+    void truncateMyLink();
 }

src/main/java/com/secondtest/secondtest/service/InfoColumnService.java

@@ -39,8 +39,20 @@ public class InfoColumnService {
         infoColumnRepository.deleteById(id);
     }
 
-    public InfoColumn addOrUpdateTable(InfoColumn infoColumn) {
+    public void deleteAllColumn() {
+        infoColumnRepository.deleteAll();
+    }
+
+    public InfoColumn addOrUpdateColumn(InfoColumn infoColumn) {
         InfoColumn savedInfoColumn = infoColumnRepository.save(infoColumn);
         return savedInfoColumn;
     }
+
+    public InfoColumn getSpecCol(String nameCol, String dataType, int lengthCol, String columnText){
+        return infoColumnRepository.getSpecColumn(nameCol, dataType, lengthCol, columnText);
+    }
+
+    public void truncateMyColumn(){
+        infoColumnRepository.truncateMyColumn();
+    }
 }

src/main/java/com/secondtest/secondtest/service/InfoTableService.java

@@ -32,10 +32,17 @@ public class InfoTableService {
         infoTableRepository.deleteById(id);
     }
 
+    public void deleteAllTable() {
+        infoTableRepository.deleteAll();
+    }
+
     public InfoTable addOrUpdateTable(InfoTable infoTable) {
         InfoTable savedInfoTable = infoTableRepository.save(infoTable);
         return savedInfoTable;
     }
 
+    public void truncateMyTable(){
+        infoTableRepository.truncateMyTable();
+    }
 
 }

src/main/java/com/secondtest/secondtest/service/LinkInfoService.java

@@ -27,8 +27,16 @@ public class LinkInfoService {
         linkInfoRepository.deleteById(id);
     }
 
-    public LinkInfo addOrUpdateEmployee(LinkInfo linkInfo) {
+    public void deleteAllLinks() {
+        linkInfoRepository.deleteAll();
+    }
+
+    public LinkInfo addOrUpdateLink(LinkInfo linkInfo) {
         LinkInfo savedLinkInfo = linkInfoRepository.save(linkInfo);
         return savedLinkInfo;
     }
+
+    public void truncateMyLink(){
+        linkInfoRepository.truncateMyLink();
+    }
 }

src/main/java/com/secondtest/secondtest/service/ResetDataService.java

@@ -0,0 +1,171 @@
+package com.secondtest.secondtest.service;
+
+import com.secondtest.secondtest.model.InfoColumn;
+import com.secondtest.secondtest.model.InfoTable;
+import com.secondtest.secondtest.model.LinkInfo;
+import lombok.Data;
+import org.json.JSONArray;
+import org.json.JSONObject;
+import org.springframework.stereotype.Service;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Paths;
+
+@Data
+@Service
+public class ResetDataService {
+
+    @Autowired
+    private InfoTableService infoTableService;
+    @Autowired
+    private InfoColumnService infoColumnService;
+    @Autowired
+    private LinkInfoService linkInfoService;
+
+    public void deleteEverything(){
+        infoColumnService.truncateMyColumn();
+        infoTableService.truncateMyTable();
+        linkInfoService.truncateMyLink();
+    }
+
+    public void insertEverything() throws IOException {
+        String result = new String(Files.readAllBytes(Paths.get("src/main/resources/testTable.json")));
+        JSONArray jo = new JSONArray(result);
+        System.out.println("ca marche");
+        for (int i=0; i<jo.length(); i++){
+            JSONObject schema = jo.getJSONObject(i);
+            String schemaName = schema.getString("schema");
+            JSONArray data = schema.getJSONArray("data");
+
+            for (int ia = 0; ia<data.length(); ia++){
+                JSONObject apra = data.getJSONObject(ia);
+                String tableText, tableName;
+                if(apra.has("table_text")){
+                    tableText = apra.getString("table_text");
+                } else {
+                    tableText = "";
+                }
+                if(apra.has("table")){
+                    tableName = apra.getString("table");
+                } else {
+                    tableName = "";
+                }
+
+                JSONArray col = apra.getJSONArray("columns");
+                InfoTable infoTable = new InfoTable();
+                infoTable.setNameTable(tableName);
+                infoTable.setNameSchema(schemaName);
+                infoTable.setTableText(tableText);
+                infoTableService.addOrUpdateTable(infoTable);
+
+                for (int ib =0; ib<col.length(); ib++){
+                    JSONObject colData = col.getJSONObject(ib);
+                    String nameCol, dataType, columnText;
+                    int lengthCol;
+                    if(colData.has("name")){
+                        nameCol = colData.getString("name");
+                    } else {
+                        nameCol = "";
+                    }
+                    if (colData.has("data_type")){
+                        dataType = colData.getString("data_type");
+                    } else {
+                        dataType = "";
+                    }
+                    if (colData.has("length")){
+                        lengthCol = colData.getInt("length");
+                    } else {
+                        lengthCol = 0;
+                    }
+                    if(colData.has("column_text")) {
+                        columnText = colData.getString("column_text");
+                    } else {
+                        columnText = "";
+                    }
+
+                    InfoColumn infoColumn = new InfoColumn();
+                    infoColumn.setNameColumn(nameCol);
+                    infoColumn.setDataType(dataType);
+                    infoColumn.setLengthColumn(lengthCol);
+                    infoColumn.setColumnText(columnText);
+
+                    InfoColumn findCol = infoColumnService.getSpecCol(nameCol, dataType, lengthCol, columnText);
+
+                    if(findCol == null){
+                        infoColumnService.addOrUpdateColumn(infoColumn);
+                    }
+                }
+            }
+        }
+
+    }
+
+    public void checkAndInsertLinks() throws IOException {
+        String result = new String(Files.readAllBytes(Paths.get("src/main/resources/testTable.json")));
+        JSONArray jo = new JSONArray(result);
+
+        for (int i=0; i<jo.length(); i++){
+            JSONObject schema = jo.getJSONObject(i);
+            String schemaName = schema.getString("schema");
+            JSONArray data = schema.getJSONArray("data");
+
+            for (int ia = 0; ia<data.length(); ia++){
+                JSONObject apra = data.getJSONObject(ia);
+                String tableText, tableName;
+                if(apra.has("table_text")){
+                    tableText = apra.getString("table_text");
+                } else {
+                    tableText = "";
+                }
+                if(apra.has("table")){
+                    tableName = apra.getString("table");
+                } else {
+                    tableName = "";
+                }
+                JSONArray col = apra.getJSONArray("columns");
+
+                for (int ib =0; ib<col.length(); ib++){
+                    JSONObject colData = col.getJSONObject(ib);
+                    String nameCol, dataType, columnText;
+                    int lengthCol;
+                    if(colData.has("name")){
+                        nameCol = colData.getString("name");
+                    } else {
+                        nameCol = "";
+                    }
+                    if (colData.has("data_type")){
+                        dataType = colData.getString("data_type");
+                    } else {
+                        dataType = "";
+                    }
+                    if (colData.has("length")){
+                        lengthCol = colData.getInt("length");
+                    } else {
+                        lengthCol = 0;
+                    }
+                    if(colData.has("column_text")) {
+                        columnText = colData.getString("column_text");
+                    } else {
+                        columnText = "";
+                    }
+
+                    InfoColumn findCol = infoColumnService.getSpecCol(nameCol, dataType, lengthCol, columnText);
+                    Long idCol = findCol.getId();
+                    int intId = Math.toIntExact(idCol);
+
+                    if (findCol != null){
+                        LinkInfo linkInfo = new LinkInfo();
+                        linkInfo.setNameSchema(schemaName);
+                        linkInfo.setNameTable(tableName);
+                        linkInfo.setColumnId(intId);
+                        linkInfoService.addOrUpdateLink(linkInfo);
+                    }
+                }
+            }
+        }
+    }
+
+
+}

src/test/java/com/secondtest/secondtest/SecondtestApplicationTests.java

@@ -19,11 +19,11 @@ class SecondtestApplicationTests {
 	@Autowired
 	private MockMvc mockMvc;
 
-	@Test
+	/*@Test
 	public void testGetEmployees() throws Exception {
 		mockMvc.perform(get("/api/employee/all"))
 				.andExpect(status().isOk())
 				.andExpect(jsonPath("$[0].firstName", is("Laurent")));
-	}
+	}*/
 
 }