初始化

ny

23 小时以前 b6f169fe43a2b13f351aefc152374fc7f0bc8cb7

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
package jnpf.base.model.dblink;
 
import cn.hutool.json.JSONUtil;
 
import jnpf.database.constant.DbConst;
import jnpf.database.model.entity.DbLinkEntity;
import jnpf.database.source.impl.DbOracle;
import jnpf.util.DesUtil;
import jnpf.util.JsonUtil;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
 
import jakarta.validation.constraints.NotBlank;
import java.util.HashMap;
import java.util.Map;
 
/**
 * 数据库基础表单对象
 *
 * @author JNPF开发平台组
 * @version V3.1.0
 * @copyright 引迈信息技术有限公司
 * @date 2021/3/12 15:31
 */
@Data
public class DbLinkBaseForm {
 
    /**
     * 排序码
     */
    @Schema(description ="排序码")
    private long sortCode;
 
    @Schema(description ="连接名")
    @NotBlank(message = "必填")
    private String fullName;
 
    @Schema(description ="数据库类型编码")
    @NotBlank(message = "必填")
    private String dbType;
 
    @Schema(description ="用户")
    @NotBlank(message = "必填")
    private String userName;
 
    @Schema(description ="数据库名")
    private String serviceName;
 
    @Schema(description ="密码")
    @NotBlank(message = "必填")
    private String password;
 
    @Schema(description ="端口")
    @NotBlank(message = "必填")
    private String port;
 
    @Schema(description ="ip地址")
    @NotBlank(message = "必填")
    private String host;
 
    @Schema(description ="模式")
    private String dbSchema;
 
    @Schema(description ="表空间")
    private String tableSpace;
 
    @Schema(description ="oracle扩展（true:开启，false:关闭）")
    private Boolean oracleExtend;
 
    @Schema(description ="oracle连接类型")
    private String oracleLinkType;
 
    @Schema(description ="oracle服务名")
    private String oracleService;
 
    @Schema(description ="oracle角色")
    private String oracleRole;
 
    @Schema(description = "转码客户端编码")
    private String clientEncoding;
 
    @Schema(description = "转码数据库编码")
    private String serverEncoding;
 
 
 
    /**
     * 根据表单对象返回连接实体类
     * @param dbLinkBaseForm 连接表单对象
     * @return 连接实体对象
     */
    public DbLinkEntity getDbLinkEntity(DbLinkBaseForm dbLinkBaseForm){
        DbLinkEntity entity = JsonUtil.getJsonToBean(dbLinkBaseForm, DbLinkEntity.class);
        entity.setPassword(DesUtil.aesOrDecode(entity.getPassword(), false, true));
        if (dbLinkBaseForm.getOracleExtend()) {
            entity.setOracleExtend(1);
        } else {
            entity.setOracleExtend(0);
        }
        entity.setDbTableSpace(dbLinkBaseForm.getTableSpace());
        entity.setDbName(dbLinkBaseForm.getServiceName());
        Map<String,String> oracleParam = new HashMap<>(16);
        oracleParam.put(DbOracle.ORACLE_LINK_TYPE,dbLinkBaseForm.getOracleLinkType());
        oracleParam.put(DbOracle.ORACLE_SERVICE,dbLinkBaseForm.getOracleService());
        oracleParam.put(DbOracle.ORACLE_ROLE,dbLinkBaseForm.getOracleRole());
        oracleParam.put(DbConst.ENCODING_CONVERT_CLIENT,dbLinkBaseForm.getClientEncoding());
        oracleParam.put(DbConst.ENCODING_CONVERT_SERVER,dbLinkBaseForm.getServerEncoding());
        entity.setOracleParam(JSONUtil.toJsonStr(oracleParam));
        return entity;
    }
 
}