对数据库查询添加前缀和后缀

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

@@ -3,6 +3,7 @@ package com.yeejoin.amos.api.tool.face.model;
 import com.yeejoin.amos.api.tool.face.orm.entity.DataBaseLink;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.NoArgsConstructor;
@@ -14,6 +15,7 @@ import org.typroject.tyboot.core.rdbms.model.BaseModel;
 @EqualsAndHashCode(callSuper = true)
 @Data
 @NoArgsConstructor
+//@AllArgsConstructor
 @ApiModel(value = "DataBaseLinkModel", description = "")
 public class DataBaseLinkModel extends BaseModel {
 
@@ -32,12 +34,20 @@ public class DataBaseLinkModel extends BaseModel {
     @ApiModelProperty(value = "密码")
     private String passWord;
 
-    public DataBaseLinkModel(String ip, String port, String dbName, String userName, String passWord) {
+    @ApiModelProperty(value = "前缀")
+    private String prefix;
+
+    @ApiModelProperty(value = "后缀")
+    private String postfix;
+
+    public DataBaseLinkModel(String ip, String port, String dbName, String userName, String passWord,String prefix,String postfix) {
         this.ip = ip;
         this.port = port;
         this.dbName = dbName;
         this.userName = userName;
         this.passWord = passWord;
+        this.prefix=prefix;
+        this.postfix = postfix;
     }
     
 

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

@@ -49,4 +49,10 @@ public class DataBaseLink extends BaseEntity {
     @TableField("PASSWORD")
     private String passWord;
 
+    @TableField("PREFIX")
+    private String prefix;
+
+    @TableField("POSTFIX")
+    private String postfix;
+
 }

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

@@ -16,6 +16,7 @@ import org.typroject.tyboot.core.foundation.utils.Bean;
 import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
 import org.typroject.tyboot.core.rdbms.service.BaseService;
 
+import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
 import javax.sql.DataSource;
 import java.io.IOException;
@@ -38,6 +39,7 @@ public class DataBaseLinkService extends BaseService<DataBaseLinkModel, DataBase
     private static final Logger log = LogManager.getLogger(DataBaseLinkService.class);
 
     @Autowired
+//    @Resource
     private DataSource dataSource;
     /**
      * 新增
@@ -148,7 +150,9 @@ public class DataBaseLinkService extends BaseService<DataBaseLinkModel, DataBase
             // 加载数据库驱动
             Class.forName("com.mysql.cj.jdbc.Driver");
             // 连接新增的数据库
-            String dbUrl = "jdbc:mysql://" + model.getIp() + ":" + model.getPort() + "/" + model.getDbName();
+            String dbUrl = "jdbc:mysql://" + model.getIp() + ":" + model.getPort() + "/" +
+                    model.getPrefix()+model.getDbName()+model.getPostfix();
+//                    model.getDbName();
             // 解密pwd，并连接
             return DriverManager.getConnection(dbUrl, model.getUserName(), AESUtils.decrypt(model.getPassWord()));
         } catch (SQLException | ClassNotFoundException e) {

src/main/resources/application.properties

@@ -3,7 +3,8 @@ server.servlet.context-path=/atl
 #server.servlet.context-path=/jcs
 server.port=30002
 #server.port=20000
-spring.profiles.active=dev
+#spring.profiles.active=dev
+spring.profiles.active=qa
 
 management.health.elasticsearch.enabled=false
 spring.jackson.time-zone=GMT+8