merage

kimi

2020-05-27 c007f0ca1785db093d48f4846cda82fe8e955765

 src/main/java/com/highdatas/mdm/controller/SysAssembleDbController.java

@@ -42,7 +42,7 @@
@RestController
@Slf4j
@RequestMapping("/assemble/db")
public class SysAssembleDbController {
public class   SysAssembleDbController {
    @Autowired
    ISysAssembleDbService dbService;
    @Autowired
@@ -53,9 +53,16 @@
    @Autowired
    ISysAssembleService assembleService;


    /**
     *
     * @description: 通过汇集id获取保存的源信息
     * @param id 汇集id
     * @return: 源list
     *
     */
    @RequestMapping(value = "/get/parent/{id}", method = RequestMethod.GET)
    public Result get(@PathVariable String id, HttpServletRequest request) {
        //通过assemble 获取汇集信息
        SysAssemble assemble = assembleService.selectById(id);
        if (assemble == null) {
            return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
@@ -77,13 +84,25 @@
        return Result.success(result);

    }

    /**
     *
     * @description: 测试连接
     * @param id 数据源id
     * @return: 测试连接结果
     *
     */
    @RequestMapping(value = "/testConnection/{id}", method = RequestMethod.GET)
    public Result testConnection(@PathVariable String id, HttpServletRequest request) {
        boolean b = dbService.testConnection(id);
        return Result.success(b);
    }

    /**
     *
     * @description: 测试连接
     * @param id 数据源id
     * @return: 测试连接结果
     *
     */
    @ResponseBody
    @RequestMapping(value = "/testConnection", method = RequestMethod.POST)
    public Result testConnection(@RequestBody SysAssembleDb sysAssembleDb) {
@@ -93,7 +112,12 @@
        boolean b =  dbService.testConnection(sysAssembleDb);
        return Result.success(b);
    }

    /**
     *
     * @description: 获取目前用到的数据源list
     * @return: 数据源list
     *
     */
    @RequestMapping(value = "/getSet", method = RequestMethod.GET)
    public Result getSet(HttpServletRequest request) {
        List<SysAssembleDb> dbList = dbService.selectList(null);
@@ -105,7 +129,13 @@
    }



    /**
     *
     * @description: 数据源获取表list
     * @param id 数据源id
     * @return: 源表list
     *
     */
    @RequestMapping(value = "/getTableList/{id}", method = RequestMethod.GET)
    public Result getTable(@PathVariable String id, HttpServletRequest request) {
        Connection connection = null;
@@ -147,7 +177,13 @@
        }
    }


    /**
     *
     * @description: 源表获取字段list
     * @param id 数据源表id
     * @return: 源表字段list
     *
     */
    @RequestMapping(value = "/getFields/{id}", method = RequestMethod.GET)
    public Result getFields(@PathVariable String id, @RequestParam String tableName, HttpServletRequest request) {
        List<String> fieldsByTableName = dbService.getFieldsByTableName(id, tableName);
@@ -157,7 +193,13 @@
        return Result.success(fieldsByTableName);
    }


    /**
     *
     * @description: 删除数据源
     * @param id 数据源id
     * @return: 删除结果
     *
     */
    @Transactional(rollbackFor=Exception.class)
    @RequestMapping(value = "/delete/{id}", method = RequestMethod.GET)
    public Result delete(@PathVariable String id) {
@@ -189,7 +231,12 @@
        }
    }


    /**
     *
     * @description: 添加数据源
     * @return: 数据源添加结果
     *
     */
    @ResponseBody
    @RequestMapping(value = "/addOrUpdate", method = RequestMethod.POST)
    public Result addOne(@RequestBody SysAssembleDb sysAssembleDb) {