删除机构

src/main/java/com/yeejoin/amos/api/tool/controller/AgencyTreeResource.java

+package com.yeejoin.amos.api.tool.controller;
+
+import com.yeejoin.amos.api.tool.face.model.AgencyTreeModel;
+import com.yeejoin.amos.api.tool.face.service.AgencyTreeService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import org.typroject.tyboot.core.foundation.enumeration.UserType;
+import org.typroject.tyboot.core.restful.doc.TycloudOperation;
+import org.typroject.tyboot.core.restful.utils.ResponseHelper;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.List;
+
+
+/**
+ * @author r
+ */
+@RestController
+@Api(tags = "机构树")
+@RequestMapping(value = "/demo/privilege_agency")
+public class AgencyTreeResource {
+
+    @Autowired
+    AgencyTreeService agencyTreeService;
+
+    /**
+     * 根据sequenceNbr删除
+     * @param sequenceNbr 主键
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
+    @DeleteMapping(value = "/{sequenceNbr}")
+    @ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除", notes = "根据sequenceNbr删除")
+    public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr){
+        return ResponseHelper.buildResponse(agencyTreeService.removeById(sequenceNbr));
+    }
+
+
+    /**
+     *列表全部数据查询
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
+    @ApiOperation(httpMethod = "GET",value = "列表全部数据查询",   notes = "列表全部数据查询")
+    @GetMapping(value = "/list")
+    public ResponseModel<List<AgencyTreeModel>>  selectForList()
+    {
+        return ResponseHelper.buildResponse(agencyTreeService.queryForAgencyTreeList());
+    }
+}

src/main/java/com/yeejoin/amos/api/tool/controller/ApiInfoResource.java

@@ -19,7 +19,7 @@ import org.typroject.tyboot.core.foundation.enumeration.UserType;
 @CrossOrigin
 @RestController
 @Api(tags = "接口管理Api")
-@RequestMapping(value = "/demo/api-info")
+@RequestMapping(value = "/api-info")
 public class ApiInfoResource {
 
     @Autowired

src/main/java/com/yeejoin/amos/api/tool/controller/ApiSourceResource.java

@@ -23,7 +23,7 @@ import org.typroject.tyboot.core.foundation.enumeration.UserType;
 @CrossOrigin
 @RestController
 @Api(tags = "接口来源管理Api")
-@RequestMapping(value = "/demo/api_source")
+@RequestMapping(value = "/api_source")
 public class ApiSourceResource {
 
     @Autowired

src/main/java/com/yeejoin/amos/api/tool/controller/DataBaseResource.java

+package com.yeejoin.amos.api.tool.controller;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.api.tool.face.model.DataBaseModel;
+import com.yeejoin.amos.api.tool.face.service.ConnectService;
+import com.yeejoin.amos.api.tool.face.service.DataBaseService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.apache.commons.beanutils.ConvertUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import org.typroject.tyboot.core.foundation.enumeration.UserType;
+import org.typroject.tyboot.core.restful.doc.TycloudOperation;
+import org.typroject.tyboot.core.restful.utils.ResponseHelper;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
+
+import javax.servlet.http.HttpServletRequest;
+import java.sql.SQLException;
+import java.util.List;
+
+
+/**
+ * @author r
+ */
+@RestController
+@Api(tags = "数据库信息")
+@RequestMapping(value = "/database_join_record")
+public class DataBaseResource {
+
+    @Autowired
+    DataBaseService dataBaseService;
+    @Autowired
+    ConnectService connectService ;
+
+    /**
+     * 新增
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
+    @PostMapping(value = "/save")
+    @ApiOperation(httpMethod = "POST", value = "新增", notes = "新增")
+    public ResponseModel<DataBaseModel> save(@RequestBody DataBaseModel dataBaseModel) throws SQLException, ClassNotFoundException {
+            if(connectService.connectNewDatabase(dataBaseModel) != null)
+               return ResponseHelper.buildResponse(dataBaseService.createWithModel(dataBaseModel));
+            else
+                return ResponseHelper.buildResponse(new DataBaseModel());
+    }
+
+    /**
+     * 根据sequenceNbr批量删除
+     *
+     * @param sequenceNbr 主键
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+    @DeleteMapping(value = "/s/{sequenceNbr}")
+    @ApiOperation(httpMethod = "DELETE", value = "批量删除", notes = "根据sequenceNbr删除")
+    public ResponseModel<Boolean[]> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") String sequenceNbr) {
+        String Nbr[] = sequenceNbr.split(",");
+        Long[] seq = (Long[]) ConvertUtils.convert(Nbr, Long.class);
+
+        Boolean Nbr2[] = new Boolean[Nbr.length];
+        for (int i = 0;i < Nbr.length;i++){
+            Nbr2[i] = dataBaseService.removeById(seq[i]);
+        }
+        return  ResponseHelper.buildResponse(Nbr2);
+    }
+
+    /**
+     * 列表分页查询
+     *@param current 当前页
+     *@param current 每页大小
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
+    @GetMapping(value = "/page")
+    @ApiOperation(httpMethod = "GET",value = "分页查询",  notes = "分页查询")
+    public ResponseModel<Page<DataBaseModel>> queryForPage(@RequestParam(value = "current") int current, @RequestParam(value = "size") int size)
+    {
+        Page<DataBaseModel> page=new Page<DataBaseModel>();
+        page.setCurrent(current);
+        page.setSize(size);
+        return ResponseHelper.buildResponse(dataBaseService.queryForDataBasePage(page));
+    }
+
+    /**
+     *列表全部数据查询
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
+    @ApiOperation(httpMethod = "GET",value = "列表全部数据查询",   notes = "列表全部数据查询")
+    @GetMapping(value = "/list")
+    public ResponseModel<List<DataBaseModel>>  selectForList()
+    {
+        return ResponseHelper.buildResponse(dataBaseService.queryForDataBaseList());
+    }
+}

src/main/java/com/yeejoin/amos/api/tool/controller/RelationResource.java

+package com.yeejoin.amos.api.tool.controller;
+
+import com.yeejoin.amos.api.tool.face.service.AgencyTreeService;
+import com.yeejoin.amos.api.tool.face.service.ConnectService;
+import com.yeejoin.amos.api.tool.face.service.DataBaseService;
+import com.yeejoin.amos.api.tool.face.service.RelationService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import org.typroject.tyboot.core.foundation.enumeration.UserType;
+import org.typroject.tyboot.core.foundation.utils.StringUtil;
+import org.typroject.tyboot.core.restful.doc.TycloudOperation;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.util.Arrays;
+
+@CrossOrigin
+@RestController
+@Api(tags = "机构管理Api")
+@RequestMapping(value = "/Agency")
+public class RelationResource {
+    @Autowired
+    RelationService relationService;
+    @Autowired
+    ConnectService connectService;
+    @Autowired
+    DataBaseService dataBaseService;
+    @Autowired
+    AgencyTreeService agencyTreeService;
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
+    @GetMapping(value = "/test")
+    @ApiOperation(httpMethod = "GET", value = "sql", notes = "sql")
+    public void joinSQL(@RequestParam(value = "agencyCodeId") Long agencyCodeId,@RequestParam(value = "sequenceNbrs") String sequenceNbrs) throws SQLException, ClassNotFoundException {
+        Long[] seqs = dataBaseService.stringToLong(sequenceNbrs);
+        for (Long seq : seqs) {
+            Connection connection = connectService.connectNewDatabase(dataBaseService.queryBySeq(seq));
+            System.out.println(connection);
+            relationService.deleteDataBaseByAgencyCode(connection, agencyTreeService.queryForAgencyCodeById(agencyCodeId));
+        }
+
+
+    }
+}

src/main/java/com/yeejoin/amos/api/tool/controller/TplCateResource.java

@@ -21,7 +21,7 @@ import java.util.List;
 @CrossOrigin
 @RestController
 @Api(tags = "模板分类管理Api")
-@RequestMapping(value = "/demo/tpl_cate")
+@RequestMapping(value = "/tpl_cate")
 public class TplCateResource {
 
     @Autowired

src/main/java/com/yeejoin/amos/api/tool/controller/TplResource.java

@@ -23,7 +23,7 @@ import java.util.*;
 @CrossOrigin
 @RestController
 @Api(tags = "模板管理Api")
-@RequestMapping(value = "/demo/tpl")
+@RequestMapping(value = "/tpl")
 public class TplResource {
 
     @Autowired
@@ -79,7 +79,7 @@ public class TplResource {
     @DeleteMapping(value = "/s/{sequenceNbr}")
     @ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除多项", notes = "根据sequenceNbr删除多项")
     public void deleteModelsBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr")String sequenceNbr){
-tplService.deleteByIds(sequenceNbr);
+        tplService.deleteByIds(sequenceNbr);
     }
     /**
      * 根据sequenceNbr查询

src/main/java/com/yeejoin/amos/api/tool/face/model/AgencyTreeModel.java

+package com.yeejoin.amos.api.tool.face.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import org.typroject.tyboot.core.rdbms.model.BaseModel;
+
+/**
+ * @author r
+ */
+@Data
+
+@ApiModel(value = "DataBaseModel", description = "")
+public class AgencyTreeModel extends BaseModel {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "机构名称")
+    private String agencyName;
+
+    @ApiModelProperty(value = "机构编码")
+    private String agencyCode;
+
+    @ApiModelProperty(value = "机构描述")
+    private String agencyDesc;
+}

src/main/java/com/yeejoin/amos/api/tool/face/model/ApiInfoModel.java

@@ -10,7 +10,7 @@ import java.util.Date;
 
 @Data
 @EqualsAndHashCode(callSuper = true)
-@ApiModel(value = "ApiInfoDto", description = "")
+@ApiModel(value = "ApiInfoModel", description = "")
 public class ApiInfoModel extends BaseModel {
 
 

src/main/java/com/yeejoin/amos/api/tool/face/model/ApiSourceModel.java

@@ -10,7 +10,7 @@ import java.util.Date;
 
 @Data
 @EqualsAndHashCode(callSuper = true)
-@ApiModel(value="ApiSourceDto", description="")
+@ApiModel(value="ApiSourceModel", description="")
 public class ApiSourceModel extends BaseModel {
 
     @ApiModelProperty(value = "接口来源名称")

src/main/java/com/yeejoin/amos/api/tool/face/model/DataBaseModel.java

+package com.yeejoin.amos.api.tool.face.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import org.typroject.tyboot.core.rdbms.model.BaseModel;
+
+/**
+ * @author r
+ */
+@Data
+
+@ApiModel(value = "DataBaseModel", description = "")
+public class DataBaseModel extends BaseModel {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "数据名称")
+    private String dataName;
+
+    @ApiModelProperty(value = "主机IP")
+    private String ip;
+
+    @ApiModelProperty(value = "端口")
+    private String port;
+
+    @ApiModelProperty(value = "数据库名")
+    private String dbName;
+
+    @ApiModelProperty(value = "用户名")
+    private String userName;
+
+    @ApiModelProperty(value = "密码")
+    private String passWord;
+}

src/main/java/com/yeejoin/amos/api/tool/face/model/RelationModel.java

+package com.yeejoin.amos.api.tool.face.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.typroject.tyboot.core.rdbms.model.BaseModel;
+
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value = "RelationModel", description = "")
+public class RelationModel extends BaseModel {
+
+    @ApiModelProperty(value = "表1名称")
+    private String table1;
+
+    @ApiModelProperty(value = "表1字段")
+    private String field1;
+
+    @ApiModelProperty(value = "表2名称")
+    private String table2;
+
+    @ApiModelProperty(value = "表2字段")
+    private String field2;
+
+}

src/main/java/com/yeejoin/amos/api/tool/face/model/TplCateTreeModel.java

@@ -10,7 +10,7 @@ import java.util.List;
 
 @Data
 @NoArgsConstructor
-@ApiModel(value="TplCateModel", description="")
+@ApiModel(value="TplCateTreeModel", description="")
 public class TplCateTreeModel {
     @ApiModelProperty(value = "物理主键")
     private Long sequenceNbr;

src/main/java/com/yeejoin/amos/api/tool/face/model/VisualDesignerModel.java

@@ -7,7 +7,7 @@ import org.typroject.tyboot.core.rdbms.model.BaseModel;
 
 @Data
 @EqualsAndHashCode(callSuper = true)
-@ApiModel(value="TplCateModel", description="")
+@ApiModel(value="VisualDesignerModel", description="")
 public class VisualDesignerModel extends BaseModel {
     @ApiModelProperty(value = "设计器名称")
     private String designerName;

src/main/java/com/yeejoin/amos/api/tool/face/orm/dao/AgencyTreeMapper.java

+package com.yeejoin.amos.api.tool.face.orm.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yeejoin.amos.api.tool.face.orm.entity.AgencyTree;
+
+/**
+ *  Mapper 接口
+ *
+ * @author r
+ */
+public interface AgencyTreeMapper extends BaseMapper<AgencyTree> {
+
+}

src/main/java/com/yeejoin/amos/api/tool/face/orm/dao/DataBaseMapper.java

+package com.yeejoin.amos.api.tool.face.orm.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yeejoin.amos.api.tool.face.orm.entity.DataBase;
+
+/**
+ *  Mapper 接口
+ *
+ * @author r
+ */
+public interface DataBaseMapper extends BaseMapper<DataBase> {
+
+}

src/main/java/com/yeejoin/amos/api/tool/face/orm/dao/RelationMapper.java

+package com.yeejoin.amos.api.tool.face.orm.dao;
+
+import com.baomidou.mybatisplus.annotation.SqlParser;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yeejoin.amos.api.tool.face.model.RelationModel;
+import com.yeejoin.amos.api.tool.face.orm.entity.Relation;
+import com.yeejoin.amos.api.tool.face.service.RelationService;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.SelectProvider;
+
+import java.util.HashMap;
+import java.util.List;
+public interface RelationMapper extends BaseMapper<Relation> {
+    @SelectProvider(type = RelationService.class, method = "deleteDataBaseByAgencyCode")
+    @SqlParser(filter = true)
+    List<Relation> deleteDataBaseByAgencyCode(@Param("maps") List<HashMap<String,String>> maps);
+
+
+}

src/main/java/com/yeejoin/amos/api/tool/face/orm/entity/AgencyTree.java

+package com.yeejoin.amos.api.tool.face.orm.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import org.typroject.tyboot.core.rdbms.orm.entity.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+/**
+ * @author r
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Accessors(chain = true)
+@TableName("privilege_agency")
+public class AgencyTree extends BaseEntity {
+
+    /**
+     *机构名称
+     */
+    @TableField("AGENCY_NAME")
+    private String agencyName;
+
+    /**
+     *机构编码
+     */
+    @TableField("AGENCY_CODE")
+    private String agencyCode;
+
+    /**
+     *机构描述
+     */
+    @TableField("AGENCY_DESC")
+    private String agencyDesc;
+
+}

src/main/java/com/yeejoin/amos/api/tool/face/orm/entity/DataBase.java

+package com.yeejoin.amos.api.tool.face.orm.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import org.typroject.tyboot.core.rdbms.orm.entity.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+/**
+ * @author r
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Accessors(chain = true)
+@TableName("database_join_record")
+public class DataBase extends BaseEntity {
+
+    /**
+     *数据名称
+     */
+    @TableField("dataName")
+    private String dataName;
+
+    /**
+     *主机IP
+     */
+    @TableField("ip")
+    private String ip;
+
+    /**
+     *端口
+     */
+    @TableField("port")
+    private String port;
+
+    /**
+     *数据库名
+     */
+    @TableField("dbName")
+    private String dbName;
+
+    /**
+     *用户名
+     */
+    @TableField("userName")
+    private String userName;
+
+    /**
+     *密码
+     */
+    @TableField("passWord")
+    private String passWord;
+}

src/main/java/com/yeejoin/amos/api/tool/face/orm/entity/Relation.java

+package com.yeejoin.amos.api.tool.face.orm.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import org.typroject.tyboot.core.rdbms.orm.entity.BaseEntity;
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Accessors(chain = true)
+@TableName("relation")
+public class Relation extends BaseEntity {
+
+    /**
+     * 表1
+     */
+    @TableField("table1")
+    private String table1;
+
+    /**
+     * 表1 字段
+     */
+    @TableField("table1_field")
+    private String field1;
+
+    /**
+     * 表2
+     */
+    @TableField("table2")
+    private String table2;
+
+    /**
+     * 表2 字段
+     */
+    @TableField("table2_field")
+    private String field2;
+
+}

src/main/java/com/yeejoin/amos/api/tool/face/service/AgencyTreeService.java

+package com.yeejoin.amos.api.tool.face.service;
+
+import com.yeejoin.amos.api.tool.face.model.AgencyTreeModel;
+import com.yeejoin.amos.api.tool.face.orm.dao.AgencyTreeMapper;
+import com.yeejoin.amos.api.tool.face.orm.entity.AgencyTree;
+import org.springframework.stereotype.Service;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
+
+import java.util.List;
+/**
+ * 服务实现类
+ *
+ * @author r
+ */
+@Service
+public class AgencyTreeService extends BaseService<AgencyTreeModel, AgencyTree, AgencyTreeMapper>  {
+
+    /**
+     * 列表查询 示例
+     */
+    public List<AgencyTreeModel> queryForAgencyTreeList()   {
+        return this.queryForList("" , false);
+    }
+
+    public String queryForAgencyCodeById(Long id){
+        return queryBySeq(id).getAgencyCode();
+    }
+
+}

src/main/java/com/yeejoin/amos/api/tool/face/service/ConnectService.java

+package com.yeejoin.amos.api.tool.face.service;
+
+import com.yeejoin.amos.api.tool.face.model.DataBaseModel;
+import com.yeejoin.amos.api.tool.face.orm.dao.DataBaseMapper;
+import com.yeejoin.amos.api.tool.face.orm.entity.DataBase;
+import org.springframework.stereotype.Service;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
+
+import java.sql.*;
+import java.util.ArrayList;
+import java.util.List;
+
+@Service
+public class ConnectService extends BaseService<DataBaseModel, DataBase, DataBaseMapper> {
+
+
+    public List<Connection> connectAllDatabases() {
+        List<Connection> connections = new ArrayList<>();
+
+        // JDBC连接
+        Connection connection = null;
+//        Statement statement = null;
+//        ResultSet resultSet = null;
+
+        try {
+            // 加载数据库驱动
+            Class.forName("com.mysql.cj.jdbc.Driver");
+
+            // 建立数据库连接
+//            connection = DriverManager.getConnection(url, username, password);
+
+            // 创建Statement对象
+//            statement = connection.createStatement();
+
+            // 执行查询语句
+//            String sql = "SELECT * FROM database_join_record";
+//            resultSet = statement.executeQuery(sql);
+            List<DataBaseModel> dataBaseModels = this.queryForList("",false);
+
+            // 处理查询结果
+            for (DataBaseModel dataBaseModel : dataBaseModels){
+                // 获取结果集中的数据
+//                String ip = dataBaseModel.getIp();
+//                String port = resultSet.getString("port");
+//                String dbName = resultSet.getString("dbName");
+//                String userName = resultSet.getString("userName");
+//                String passWord = resultSet.getString("passWord");
+
+                // 连接数据库
+                String dbUrl = "jdbc:mysql://" + dataBaseModel.getIp() + ":" + dataBaseModel.getPort() + "/" + dataBaseModel.getDbName();
+                Connection dbConnection = DriverManager.getConnection(dbUrl, dataBaseModel.getUserName(), dataBaseModel.getPassWord());
+
+                // 将连接添加到列表中
+                connections.add(dbConnection);
+            }
+        } catch (ClassNotFoundException | SQLException e) {
+            e.printStackTrace();
+        }
+
+        return connections;
+    }
+    public Connection connectNewDatabase(DataBaseModel dataBaseModel) throws SQLException, ClassNotFoundException {
+            // 加载数据库驱动
+            Class.forName("com.mysql.cj.jdbc.Driver");
+            // 连接新增的数据库
+            String dbUrl = "jdbc:mysql://" + dataBaseModel.getIp() + ":" + dataBaseModel.getPort() + "/" + dataBaseModel.getDbName();
+        return DriverManager.getConnection(dbUrl, dataBaseModel.getUserName(), dataBaseModel.getPassWord());
+    }
+
+}

src/main/java/com/yeejoin/amos/api/tool/face/service/DataBaseService.java

+package com.yeejoin.amos.api.tool.face.service;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.api.tool.face.model.DataBaseModel;
+import com.yeejoin.amos.api.tool.face.orm.dao.DataBaseMapper;
+import com.yeejoin.amos.api.tool.face.orm.entity.DataBase;
+import org.apache.commons.beanutils.ConvertUtils;
+import org.springframework.stereotype.Service;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
+
+import java.util.List;
+/**
+ * 服务实现类
+ *
+ * @author r
+ */
+@Service
+public class DataBaseService extends BaseService<DataBaseModel, DataBase, DataBaseMapper>  {
+    /**
+     * 分页查询
+     */
+    public Page<DataBaseModel> queryForDataBasePage(Page<DataBaseModel> page)   {
+        return this.queryForPage(page, null, false);
+    }
+
+    /**
+     * 列表查询 示例
+     */
+    public List<DataBaseModel> queryForDataBaseList()   {
+        return this.queryForList("" , false);
+    }
+    public List<DataBaseModel> queryForDbInfoListByApiSource(String apiSource){
+        return this.queryForList("" , false,apiSource);
+    }
+
+
+
+    public void deleteBySeqs(String sequenceNbrs) {
+        String Nbr[] = sequenceNbrs.split(",");
+        Long[] seq = (Long[]) ConvertUtils.convert(Nbr, Long.class);
+        Boolean Nbr2[] = new Boolean[Nbr.length];
+        for (int i = 0;i < Nbr.length;i++){
+            Nbr2[i] = this.removeById(seq[i]);
+        }
+    }
+
+    public Long[] stringToLong(String sequenceNbrs){
+        String[] seqs = sequenceNbrs.split(",");
+        Long[] seq = new Long[seqs.length];
+        for (int i = 0; i < seqs.length;i++) {
+            seq[i] = Long.parseLong(seqs[i]);
+        }
+        return seq;
+    }
+
+
+
+
+
+}

src/main/java/com/yeejoin/amos/api/tool/face/service/RelationService.java

+package com.yeejoin.amos.api.tool.face.service;
+
+import com.yeejoin.amos.api.tool.face.model.RelationModel;
+import com.yeejoin.amos.api.tool.face.orm.dao.RelationMapper;
+import com.yeejoin.amos.api.tool.face.orm.entity.Relation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
+
+import java.sql.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+
+@Service
+public class RelationService extends BaseService<RelationModel, Relation, RelationMapper> {
+
+    @Autowired
+    DataBaseService dataBaseService;
+    @Autowired
+    ConnectService connectService;
+
+    /**
+     * 读取Relation表
+     */
+//    public List<RelationModel> queryRelation() {
+//        return this.queryForList(null, false);
+//    }
+
+    /**
+     * 根据Relation删除数据库
+     */
+    public String deleteDataBaseByAgencyCode(Connection connection,String agencyCode) throws SQLException {
+        List<HashMap<String,String>> maps = this.queryRelation(connection);
+        List<String> rs = new ArrayList<>();
+        try {
+            // 加载数据库驱动
+            Class.forName("com.mysql.cj.jdbc.Driver");
+            if(!connection.isClosed())
+                System.out.println("Succeeded connecting to the Database!");
+        } catch (ClassNotFoundException | SQLException e) {
+            e.printStackTrace();
+        }
+        StringBuilder sql = new StringBuilder("DELETE ").append(maps.get(0).get("TABLE1"));
+        for (int i = 0; i < maps.size();i++){
+            sql.append(", ").append(maps.get(i).get("TABLE2"));
+        }
+        sql.append(" FROM ").append(maps.get(0).get("TABLE1"));
+        try {
+            for (HashMap<String,String> map : maps) {
+                if (map.get("TABLE1") != null)
+                    sql.append(" LEFT JOIN ").append(map.get("TABLE2")).append(" ON ").append(map.get("TABLE1")).append(".").append(map.get("TABLE1_FIELD")).append(" = ").append(map.get("TABLE2")).append(".").append(map.get("TABLE2_FIELD"));
+                else {
+                    StringBuilder extraSql = new StringBuilder("DELETE FROM ");
+                    extraSql.append(map.get("TABLE2")).append(" WHERE AGENCY_CODE = '").append(agencyCode).append("' ;");
+//                    statementSql(extraSql, connection, rs);
+                    System.out.println(extraSql);
+                }
+            }
+            sql.append(" WHERE ").append(maps.get(0).get("TABLE1")).append(".AGENCY_CODE = '").append(agencyCode).append("' ;");
+//            statementSql(sql, connection, rs);
+//            System.out.println(rs);
+            connection.close();
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+        System.out.println(sql.toString());
+        return null;
+    }
+
+    /**
+     * 执行sql
+     */
+    public void statementSql(StringBuilder sql, Connection connection,List<String> rs) {
+        try {
+            Statement statement = connection.createStatement();
+            ResultSet resultSet = statement.executeQuery(sql.toString());
+            while (resultSet.next()){
+                rs.add(resultSet.getString("id"));
+            }
+            resultSet.close();
+            statement.close();
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+
+    }
+
+    public List<HashMap<String,String>> queryRelation(Connection connection) throws SQLException{
+        Statement statement = connection.createStatement();
+        ResultSet resultSet = statement.executeQuery("SELECT * FROM relation ;");
+        ResultSetMetaData data = resultSet.getMetaData();
+        List<HashMap<String,String>> maps = new ArrayList<>();
+        while (resultSet.next()){
+            HashMap<String,String> map = new HashMap<>();
+            for (int i = 1; i <= data.getColumnCount(); i++){
+                map.put(data.getColumnName(i),resultSet.getString(data.getColumnName(i)));
+            }
+            maps.add(map);
+        }
+        resultSet.close();
+        statement.close();
+        return maps;
+    }
+}

src/main/resources/application-dev.properties

 #DB properties:
 # jdbc_config
-spring.datasource.url=jdbc:mysql://39.98.45.134:3306/amos_studio?allowMultiQueries=true
+spring.datasource.url=jdbc:mysql://39.98.45.134:3306/amos_project_copy?allowMultiQueries=true
 spring.datasource.username=root
 spring.datasource.password=Yeejoin@2020
 spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

src/main/resources/mapper/RelationMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.yeejoin.amos.api.tool.face.orm.dao.RelationMapper">
+</mapper>