mec-cloud_IntelligentManufacturing_DB/src/main/java/com/customer/controller/TableInfoController.java

package com.customer.controller;


import com.customer.config.DynamicDataSource;
import com.customer.config.GenConfig;
import com.customer.service.ITableInfoService;
import com.customer.utils.AjaxResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.util.Map;

@RestController
@RequestMapping("tableInfo")
public class TableInfoController {

    @Resource
    private ITableInfoService tableInfoService;

    @Autowired
    private DynamicDataSource dynamicDataSource;

    @PostMapping("/createDatabase")
    public AjaxResult crateDatabase(@RequestBody Map<String, Object> map){
        String dataBaseName = (String) map.get("dataBaseName");
        String tableName = (String) map.get("tableName");
        if(tableInfoService.mysqlTableExist(dataBaseName,tableName)>0){
            return AjaxResult.warn("当前数据库中表已存在");
        }
        tableInfoService.createMysqlDataBase(map);
         return AjaxResult.success();
    }

    @PostMapping("/createSqlServerDataBase")
    public AjaxResult createSqlServerDataBase(@RequestBody Map<String, Object> map) throws Exception {
        String dataBaseName = (String) map.get("dataBaseName");
        String tableName = (String) map.get("tableName");
        if(tableInfoService.sqlServerTableExist(dataBaseName,tableName)>0){
            return AjaxResult.warn("当前数据库中表已存在");
        }
        tableInfoService.createSqlServerDataBase(map);
        return AjaxResult.success();
    }

    @PostMapping("/createDmDataBase")
    public AjaxResult createDmDataBase(@RequestBody Map<String, Object> map){
        String dataBaseName = (String) map.get("dataBaseName");
        String tableName = (String) map.get("tableName");
        if(tableInfoService.dmTableExist(dataBaseName,tableName)>0){
            return AjaxResult.warn("当前数据库中表已存在");
        }
        tableInfoService.createDmDataBase(map);
        return AjaxResult.success();
    }

    @PostMapping("/createOracleTable")
    public AjaxResult createOracleTable(@RequestBody Map<String, Object> map){
        String tableName = (String) map.get("tableName");
        if(tableInfoService.oracleTableExist(tableName)>0){
            return AjaxResult.warn("当前数据库中表已存在");
        }
        return AjaxResult.success();
    }

}