初始提交

src/main/java/com/tykj/datahouse/controller/DataController.java

+package com.tykj.datahouse.controller;
+
+import com.tykj.datahouse.base.result.ResultObj;
+import com.tykj.datahouse.base.result.ResultUtil;
+import com.tykj.datahouse.service.TableInfoService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+
+@Api(tags = "数据操作API")
+@CrossOrigin
+@RequestMapping("/data")
+@RestController
+public class DataController {
+
+    @Autowired
+    private TableInfoService tableInfoService;
+
+
+    @PostMapping("/{tableId}")
+    @ApiOperation("在指定表中新插入一条数据")
+    public ResponseEntity<ResultObj<Object>> createTable(@PathVariable Integer tableId, @RequestBody Map<String, Object> row) {
+        tableInfoService.insertData(tableId, row);
+        return ResultUtil.success("操作成功");
+    }
+
+    @PutMapping("/{tableId}")
+    @ApiOperation("在指定表中修改一条数据")
+    public ResponseEntity<ResultObj<Object>> alterTable(@PathVariable Integer tableId, @RequestBody Map<String, Object> row) {
+        tableInfoService.updateData(tableId, row);
+        return ResultUtil.success("操作成功");
+    }
+
+    @DeleteMapping("/{tableId}")
+    @ApiOperation("在指定表中删除一条数据")
+    public ResponseEntity<ResultObj<Object>> dropTable(@PathVariable Integer tableId, @RequestBody Map<String, Object> row) {
+        tableInfoService.deleteData(tableId, row);
+        return ResultUtil.success("操作成功");
+    }
+
+
+}

src/main/java/com/tykj/datahouse/controller/TableInfoController.java

@@ -13,7 +13,7 @@ import org.springframework.web.bind.annotation.*;
 import java.util.List;
 
 
-@Api(tags = "基础模型接口")
+@Api(tags = "表信息API")
 @CrossOrigin
 @RequestMapping("/table")
 @RestController

src/test/java/com/tykj/datahouse/DatahouseApplicationTests.java

 package com.tykj.datahouse;
 
+import com.tykj.datahouse.entity.ColumnInfo;
+import com.tykj.datahouse.entity.TableInfo;
+import com.tykj.datahouse.repository.ColumnInfoRepository;
+import com.tykj.datahouse.repository.TableInfoRepository;
+import com.tykj.datahouse.service.TableInfoService;
+import org.assertj.core.util.Lists;
 import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.jdbc.core.JdbcTemplate;
+
+import java.util.HashMap;
+import java.util.Map;
 
 @SpringBootTest
 class DatahouseApplicationTests {
 
+    @Autowired
+    JdbcTemplate jdbcTemplate;
+    @Autowired
+    TableInfoService tableInfoService;
+
     @Test
-    void contextLoads() {
+    void test() {
+        tableInfoService.updateData(2, row());
+        print();
+    }
+
+    Map<String, Object> row() {
+        Map<String, Object> row = new HashMap<>();
+        row.put("id", 1);
+        row.put("name", "c");
+        row.put("age", 20);
+        return row;
+    }
+
+    ColumnInfo columnInfo() {
+        return new ColumnInfo(
+                null,
+                false,
+                "name",
+                "名字",
+                "varchar",
+                255,
+                true,
+                "",
+                1
+        );
+    }
+
+    ColumnInfo columnInfo2() {
+        return new ColumnInfo(
+                null,
+                false,
+                "name2",
+                "名字",
+                "varchar",
+                255,
+                true,
+                "",
+                1
+        );
+    }
+
+    ColumnInfo columnInfo3() {
+        return new ColumnInfo(
+                null,
+                false,
+                "name3",
+                "名字",
+                "varchar",
+                255,
+                true,
+                "",
+                1
+        );
+    }
+
+    TableInfo oTableInfo() {
+        return new TableInfo(
+                null,
+                null,
+                null,
+                "student",
+                "学生",
+                "",
+                Lists.newArrayList(
+                        new ColumnInfo(
+                                null,
+                                true,
+                                "id",
+                                "主键",
+                                "int",
+                                null,
+                                true,
+                                "",
+                                1
+                        ),
+                        new ColumnInfo(
+                                null,
+                                false,
+                                "name",
+                                "名字",
+                                "varchar",
+                                255,
+                                true,
+                                "",
+                                1
+                        ),
+                        new ColumnInfo(
+                                null,
+                                false,
+                                "age",
+                                "年龄",
+                                "int",
+                                null,
+                                false,
+                                "",
+                                1
+                        )
+                )
+        );
+    }
+
+    TableInfo tableInfo() {
+        return new TableInfo(
+                1,
+                null,
+                null,
+                "student",
+                "学生",
+                "",
+                Lists.newArrayList(
+                        new ColumnInfo(
+                                1,
+                                true,
+                                "id",
+                                "主键",
+                                "int",
+                                null,
+                                true,
+                                "",
+                                1
+                        ),
+                        new ColumnInfo(
+                                2,
+                                false,
+                                "name2",
+                                "名字",
+                                "varchar",
+                                11,
+                                true,
+                                "",
+                                1
+                        ),
+                        new ColumnInfo(
+                                null,
+                                false,
+                                "age2",
+                                "年龄",
+                                "int",
+                                null,
+                                false,
+                                "",
+                                1
+                        )
+                )
+        );
+    }
+
+    void print() {
+        for (TableInfo tableInfo : tableInfoService.findAll()) {
+            System.out.println("-----------------------------------");
+            System.out.println(tableInfo);
+            for (ColumnInfo columnInfo : tableInfo.getColumnInfos()) {
+                System.out.println(columnInfo);
+            }
+        }
     }
 
 }