Skip to content

N
Nse
Commit bc62febb by wuchao
Options

Merge remote-tracking branch 'origin/master'

parents a81d61db 6cb05759
正在显示 包含 130 行增加 和 105 行删除
pom.xml
...@@ -312,34 +312,11 @@ ...@@ -312,34 +312,11 @@
<artifactId>aspectjweaver</artifactId> <artifactId>aspectjweaver</artifactId>
<version>1.8.9</version> <version>1.8.9</version>
</dependency> </dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-api</artifactId>
<version>2.7</version>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
<version>2.7</version>
<exclusions>
<exclusion>
<artifactId>log4j-api</artifactId>
<groupId>org.apache.logging.log4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency> <dependency>
<groupId>org.jdom</groupId> <groupId>org.jdom</groupId>
<artifactId>jdom</artifactId> <artifactId>jdom</artifactId>
<version>2.0.2</version> <version>2.0.2</version>
</dependency> </dependency>
<!-- xml, castor --> <!-- xml, castor -->
<dependency> <dependency>
<groupId>org.codehaus.castor</groupId> <groupId>org.codehaus.castor</groupId>
...@@ -457,11 +434,11 @@ ...@@ -457,11 +434,11 @@
<dependency> <!-- <dependency>-->
<groupId>ch.qos.logback</groupId> <!-- <groupId>ch.qos.logback</groupId>-->
<artifactId>logback-core</artifactId> <!-- <artifactId>logback-core</artifactId>-->
<version>1.2.3</version> <!-- <version>1.2.3</version>-->
</dependency> <!-- </dependency>-->
<dependency> <dependency>
...@@ -782,12 +759,6 @@ ...@@ -782,12 +759,6 @@
<dependency> <dependency>
<groupId>org.springframework.boot</groupId> <groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-logging</artifactId> <artifactId>spring-boot-starter-logging</artifactId>
<exclusions>
<exclusion>
<artifactId>log4j-api</artifactId>
<groupId>org.apache.logging.log4j</groupId>
</exclusion>
</exclusions>
</dependency> </dependency>
<dependency> <dependency>
...@@ -1100,6 +1071,10 @@ ...@@ -1100,6 +1071,10 @@
<artifactId>commons-codec</artifactId> <artifactId>commons-codec</artifactId>
<groupId>commons-codec</groupId> <groupId>commons-codec</groupId>
</exclusion> </exclusion>
<exclusion>
<artifactId>commons-logging</artifactId>
<groupId>commons-logging</groupId>
</exclusion>
</exclusions> </exclusions>
</dependency> </dependency>
......
src/main/java/com/chenyang/nse/bussiness/entity/Table.java
...@@ -229,7 +229,7 @@ public class Table extends TCoreTablestructure { ...@@ -229,7 +229,7 @@ public class Table extends TCoreTablestructure {
String url_oracle = "jdbc:oracle:thin:@192.168.1.100:1521:orcl"; String url_oracle = "jdbc:oracle:thin:@192.168.1.100:1521:orcl";
String username_oracle = "c##ghca"; String username_oracle = "c##ghca";
String password_oracle = "ghca"; String password_oracle = "ghca";
String driverClass_mysql = "com.mysql.jdbc.Driver"; String driverClass_mysql = "com.mysql.cj.jdbc.Driver";
String url_mysql = "jdbc:mysql://192.168.1.100:3306/mysql"; String url_mysql = "jdbc:mysql://192.168.1.100:3306/mysql";
String username_mysql = "root"; String username_mysql = "root";
String password_mysql = "123"; String password_mysql = "123";
......
src/main/java/com/chenyang/nse/bussiness/entity/orm/table/core/TCoreScopeRegex.java
...@@ -6,7 +6,7 @@ import javax.persistence.Table; ...@@ -6,7 +6,7 @@ import javax.persistence.Table;
@Entity @Entity
@Table( @Table(
name = "T_CORE_SCOPE _REGEX" name = "T_CORE_SCOPE_REGEX"
) )
public class TCoreScopeRegex extends TBaseEntity { public class TCoreScopeRegex extends TBaseEntity {
private String regex_id; private String regex_id;
......
src/main/java/com/chenyang/nse/bussiness/enumeration/EdbType.java
...@@ -8,9 +8,9 @@ public enum EdbType { ...@@ -8,9 +8,9 @@ public enum EdbType {
DB2("DB2", "DB2", "com.ibm.db2.jcc.DB2Driver", "jdbc:db2://{ip}:{port}/{servername}"), DB2("DB2", "DB2", "com.ibm.db2.jcc.DB2Driver", "jdbc:db2://{ip}:{port}/{servername}"),
AS400("AS400", "AS400", "com.ibm.as400.access.AS400JDBCDriver", "jdbc:as400://{ip}"), AS400("AS400", "AS400", "com.ibm.as400.access.AS400JDBCDriver", "jdbc:as400://{ip}"),
MSSQLSERVER("MSSQLSERVER", "MSSQLSERVER", "com.microsoft.sqlserver.jdbc.SQLServerDriver", "jdbc:sqlserver://{ip}:{port};DatabaseName={servername};sendStringParametersAsUnicode=false"), MSSQLSERVER("MSSQLSERVER", "MSSQLSERVER", "com.microsoft.sqlserver.jdbc.SQLServerDriver", "jdbc:sqlserver://{ip}:{port};DatabaseName={servername};sendStringParametersAsUnicode=false"),
MYSQL("MYSQL", "MYSQL", "com.mysql.jdbc.Driver", "jdbc:mysql://{ip}:{port}/{servername}?zeroDateTimeBehavior=convertToNull"), MYSQL("MYSQL", "MYSQL", "com.mysql.cj.jdbc.Driver", "jdbc:mysql://{ip}:{port}/{servername}?zeroDateTimeBehavior=convertToNull"),
KINGBASE("KINGBASE", "KINGBASE", "com.kingbase8.Driver", "jdbc:kingbase8://{ip}:{port}/{servername}"), KINGBASE("KINGBASE", "KINGBASE", "com.kingbase8.Driver", "jdbc:kingbase8://{ip}:{port}/{servername}"),
MARIADB("MARIADB", "MYSQL", "com.mysql.jdbc.Driver", "jdbc:mysql://{ip}:{port}/{servername}?zeroDateTimeBehavior=convertToNull"), MARIADB("MARIADB", "MYSQL", "com.mysql.cj.jdbc.Driver", "jdbc:mysql://{ip}:{port}/{servername}?zeroDateTimeBehavior=convertToNull"),
ORACLE("ORACLE", "ORACLE", "oracle.jdbc.driver.OracleDriver", "jdbc:oracle:thin:@(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST={ip})(PORT={port}))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME={servername})))"), ORACLE("ORACLE", "ORACLE", "oracle.jdbc.driver.OracleDriver", "jdbc:oracle:thin:@(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST={ip})(PORT={port}))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME={servername})))"),
ORACLEINS("ORACLEINS", "ORACLE", "oracle.jdbc.driver.OracleDriver", "jdbc:oracle:thin:@{ip}:{port}:{servername}"), ORACLEINS("ORACLEINS", "ORACLE", "oracle.jdbc.driver.OracleDriver", "jdbc:oracle:thin:@{ip}:{port}:{servername}"),
HIVE("HIVE", "HIVE", "org.apache.hive.jdbc.HiveDriver", "jdbc:hive2://{ip}:{port}/{servername}"), HIVE("HIVE", "HIVE", "org.apache.hive.jdbc.HiveDriver", "jdbc:hive2://{ip}:{port}/{servername}"),
...@@ -21,7 +21,7 @@ public enum EdbType { ...@@ -21,7 +21,7 @@ public enum EdbType {
GREENPLUM("GREENPLUM", "GREENPLUM", "org.postgresql.Driver", "jdbc:postgresql://{ip}:{port}/{servername}"), GREENPLUM("GREENPLUM", "GREENPLUM", "org.postgresql.Driver", "jdbc:postgresql://{ip}:{port}/{servername}"),
POSTGRESQL("POSTGRESQL", "POSTGRESQL", "org.postgresql.Driver", "jdbc:postgresql://{ip}:{port}/{servername}"), POSTGRESQL("POSTGRESQL", "POSTGRESQL", "org.postgresql.Driver", "jdbc:postgresql://{ip}:{port}/{servername}"),
HANA("HANA", "HANA", "com.sap.db.jdbc.Driver", "jdbc:sap://{ip}:{port}?reconnect=true"), HANA("HANA", "HANA", "com.sap.db.jdbc.Driver", "jdbc:sap://{ip}:{port}?reconnect=true"),
RAPIDSDB("RAPIDSDB", "RAPIDSDB", "com.mysql.jdbc.Driver", "jdbc:mysql://{ip}:{port}"), RAPIDSDB("RAPIDSDB", "RAPIDSDB", "com.mysql.cj.jdbc.Driver", "jdbc:mysql://{ip}:{port}"),
MONGODB("MONGODB", "MONGODB", "com.mongodb.jdbc.MongoDriver", "mongodb://{ip}:{port}/admin"), MONGODB("MONGODB", "MONGODB", "com.mongodb.jdbc.MongoDriver", "mongodb://{ip}:{port}/admin"),
KAFKA("KAFKA", "KAFKA", "", "bootstrap.servers://{ip}:{port}?characterEncoding=utf-8"), KAFKA("KAFKA", "KAFKA", "", "bootstrap.servers://{ip}:{port}?characterEncoding=utf-8"),
GBASE8S("GBASE8S", "GBASE8S", "com.gbasedbt.jdbc.Driver", "jdbc:gbasedbt-sqli://{ip}:{port}/{servername}:GBASEDBTSERVER={server}"), GBASE8S("GBASE8S", "GBASE8S", "com.gbasedbt.jdbc.Driver", "jdbc:gbasedbt-sqli://{ip}:{port}/{servername}:GBASEDBTSERVER={server}"),
...@@ -29,7 +29,7 @@ public enum EdbType { ...@@ -29,7 +29,7 @@ public enum EdbType {
HIVE_TDH("HIVE_TDH", "HIVE_TDH", "org.apache.hive.jdbc.HiveDriver", "jdbc:hive2://{ip}:{port}/{servername};transportMode=http;httpPath=cliservice"), HIVE_TDH("HIVE_TDH", "HIVE_TDH", "org.apache.hive.jdbc.HiveDriver", "jdbc:hive2://{ip}:{port}/{servername};transportMode=http;httpPath=cliservice"),
GAUSS("GAUSS", "GAUSS", "org.opengauss.Driver", "jdbc:opengauss://{ip}:{port}/{servername}"), GAUSS("GAUSS", "GAUSS", "org.opengauss.Driver", "jdbc:opengauss://{ip}:{port}/{servername}"),
GAUSSDB("GAUSSDB", "GAUSSDB", "com.huawei.opengauss.jdbc.Driver", "jdbc:opengauss://{ipPorts}/{servername}?loadBalanceHosts=true&reWriteBatchedInserts=true"), GAUSSDB("GAUSSDB", "GAUSSDB", "com.huawei.opengauss.jdbc.Driver", "jdbc:opengauss://{ipPorts}/{servername}?loadBalanceHosts=true&reWriteBatchedInserts=true"),
OCEANBASE("OCEANBASE", "MYSQL", "com.mysql.jdbc.Driver", "jdbc:mysql://{ip}:{port}/{servername}?zeroDateTimeBehavior=convertToNull"); OCEANBASE("OCEANBASE", "MYSQL", "com.mysql.cj.jdbc.Driver", "jdbc:mysql://{ip}:{port}/{servername}?zeroDateTimeBehavior=convertToNull");
private String dbcode; private String dbcode;
private String dbname; private String dbname;
......
src/main/java/com/chenyang/nse/bussiness/kms/service/impl/SanWeiKmsServiceImpl.java
...@@ -29,7 +29,7 @@ public class SanWeiKmsServiceImpl implements SanWeiKmsService { ...@@ -29,7 +29,7 @@ public class SanWeiKmsServiceImpl implements SanWeiKmsService {
String swsdsPath = props.getProperty("swsdsPath"); String swsdsPath = props.getProperty("swsdsPath");
String config = swsdsPath + File.separator + "swsds.ini"; String config = swsdsPath + File.separator + "swsds.ini";
Security.addProvider(new SwxaProvider((String)null, config)); Security.addProvider(new SwxaProvider((String)null, config));
SecureRandom random = SecureRandom.getInstance("RND", "SwxaJCE"); SecureRandom random = SecureRandom.getInstance(RND, SWXA_JCE);
return ByteUtils.toHexString(random.generateSeed(length)); return ByteUtils.toHexString(random.generateSeed(length));
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
......
src/main/java/com/chenyang/nse/bussiness/service/webApi/business/KeyLoader.java
...@@ -7,9 +7,11 @@ import com.chenyang.nse.bussiness.entity.orm.table.core.dataproject.TCoreSecretk ...@@ -7,9 +7,11 @@ import com.chenyang.nse.bussiness.entity.orm.table.core.dataproject.TCoreSecretk
import com.chenyang.nse.bussiness.entity.orm.table.core.encryption.TCoreEncryption; import com.chenyang.nse.bussiness.entity.orm.table.core.encryption.TCoreEncryption;
import com.chenyang.nse.bussiness.entity.orm.table.core.encryption.TCoreEncryptionTypeField; import com.chenyang.nse.bussiness.entity.orm.table.core.encryption.TCoreEncryptionTypeField;
import com.chenyang.nse.bussiness.service.core.encryption.TCoreEncryptionService; import com.chenyang.nse.bussiness.service.core.encryption.TCoreEncryptionService;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import org.hibernate.criterion.Criterion; import org.hibernate.criterion.Criterion;
import org.hibernate.criterion.Restrictions; import org.hibernate.criterion.Restrictions;
...@@ -21,69 +23,69 @@ import org.springframework.stereotype.Component; ...@@ -21,69 +23,69 @@ import org.springframework.stereotype.Component;
@Component @Component
public class KeyLoader { public class KeyLoader {
private static final Logger LOGGER = LoggerFactory.getLogger(KeyLoader.class); private static final Logger LOGGER = LoggerFactory.getLogger(KeyLoader.class);
@Autowired @Autowired
private TCoreSecretkeyDao tCoreSecretkeyDao; private TCoreSecretkeyDao tCoreSecretkeyDao;
@Autowired @Autowired
TCoreEncryptionDao tCoreEncryptionDao; TCoreEncryptionDao tCoreEncryptionDao;
@Autowired @Autowired
@Qualifier("TCoreEncryptionContext") @Qualifier("TCoreEncryptionContext")
private TCoreEncryptionService service; private TCoreEncryptionService service;
@Autowired @Autowired
protected TCoreEncryptionTypeFieldDao tCoreEncryptionTypeFieldDao; protected TCoreEncryptionTypeFieldDao tCoreEncryptionTypeFieldDao;
public MulKey load() { public MulKey load() {
MulKey map = new MulKey(); MulKey map = new MulKey();
try { try {
List<TCoreEncryptionTypeField> fieldCfgs = this.tCoreEncryptionTypeFieldDao.queryAll(); List<TCoreEncryptionTypeField> fieldCfgs = this.tCoreEncryptionTypeFieldDao.queryAll();
if (fieldCfgs != null && fieldCfgs.size() != 0) { if (fieldCfgs != null && fieldCfgs.size() != 0) {
for(TCoreEncryptionTypeField fieldCfg : fieldCfgs) { for (TCoreEncryptionTypeField fieldCfg : fieldCfgs) {
String encSecId = fieldCfg.getEncryption_secretkey_id(); String encSecId = fieldCfg.getEncryption_secretkey_id();
if (encSecId != null && !encSecId.isEmpty()) { if (encSecId != null && !encSecId.isEmpty()) {
Map<String, String> secMap = this.service.queryEncryptionInfo(encSecId); Map<String, String> secMap = this.service.queryEncryptionInfo(encSecId);
if (secMap != null) { if (secMap != null) {
String key = (String)secMap.get("secretkey"); String key = (String) secMap.get("secretkey");
String id = String.format("%s#$#%s#$#%s#$#%s", fieldCfg.getTschemas(), fieldCfg.getNames(), fieldCfg.getTable_field_id(), fieldCfg.getProjectid()); String id = String.format("%s#$#%s#$#%s#$#%s", fieldCfg.getTschemas(), fieldCfg.getNames(), fieldCfg.getTable_field_id(), fieldCfg.getProjectid());
TCoreSecretkey tCoreSecretkey = (TCoreSecretkey)this.tCoreSecretkeyDao.queryUnique(new Criterion[]{Restrictions.eq("id", fieldCfg.getEncryption_secretkey_id())}); TCoreSecretkey tCoreSecretkey = (TCoreSecretkey) this.tCoreSecretkeyDao.queryUnique(new Criterion[]{Restrictions.eq("id", fieldCfg.getEncryption_secretkey_id())});
TCoreEncryption tCoreEncryp = new TCoreEncryption(); TCoreEncryption tCoreEncryp = new TCoreEncryption();
if (null != tCoreSecretkey) { if (null != tCoreSecretkey) {
tCoreEncryp = (TCoreEncryption)this.tCoreEncryptionDao.queryUnique(new Criterion[]{Restrictions.eq("id", tCoreSecretkey.getId())}); tCoreEncryp = (TCoreEncryption) this.tCoreEncryptionDao.queryUnique(new Criterion[]{Restrictions.eq("id", tCoreSecretkey.getId())});
} }
String type = ""; String type = "";
if (null != tCoreEncryp && null != tCoreEncryp.getEncryption_type() && !"".equals(tCoreEncryp.getEncryption_type())) { if (null != tCoreEncryp && null != tCoreEncryp.getEncryption_type() && !"".equals(tCoreEncryp.getEncryption_type())) {
type = tCoreEncryp.getEncryption_type(); type = tCoreEncryp.getEncryption_type();
} }
if (type == null || type.length() == 0) { if (type == null || type.length() == 0) {
type = "SM4"; type = "SM4";
} }
String tkey = ""; String tkey = "";
tkey = key + ":" + type + ":" + fieldCfg.getIslike() + ":" + (StringUtils.isEmpty(fieldCfg.getKeepfirst()) ? "0" : fieldCfg.getKeepfirst()) + ":" + (StringUtils.isEmpty(fieldCfg.getEncdigit()) ? "0" : fieldCfg.getEncdigit()) + ":" + (StringUtils.isEmpty(fieldCfg.getTwoindex()) ? "0" : fieldCfg.getTwoindex()); tkey = key + ":" + type + ":" + fieldCfg.getIslike() + ":" + (StringUtils.isEmpty(fieldCfg.getKeepfirst()) ? "0" : fieldCfg.getKeepfirst()) + ":" + (StringUtils.isEmpty(fieldCfg.getEncdigit()) ? "0" : fieldCfg.getEncdigit()) + ":" + (StringUtils.isEmpty(fieldCfg.getTwoindex()) ? "0" : fieldCfg.getTwoindex());
String pid = fieldCfg.getProjectid() + ":" + fieldCfg.getId(); String pid = fieldCfg.getProjectid() + ":" + fieldCfg.getId();
map.bKeys.put(id, tkey); map.bKeys.put(id, tkey);
map.pKeys.put(pid, key); map.pKeys.put(pid, key);
} }
} }
} }
return map; return map;
} else { } else {
return map; return map;
} }
} catch (Exception e) { } catch (Exception e) {
LOGGER.error(e.getMessage(), e); LOGGER.error(e.getMessage(), e);
MulKey var3 = new MulKey(); MulKey var3 = new MulKey();
return var3; return var3;
} finally { } finally {
; ;
} }
} }
static class MulKey { static class MulKey {
public Map<String, String> bKeys = new HashMap(); public Map<String, String> bKeys = new HashMap();
public Map<String, String> pKeys = new HashMap(); public Map<String, String> pKeys = new HashMap();
} }
} }
src/main/java/com/chenyang/nse/bussiness/test/Mysqltest.java
...@@ -11,7 +11,7 @@ import java.sql.SQLException; ...@@ -11,7 +11,7 @@ import java.sql.SQLException;
public class Mysqltest { public class Mysqltest {
public static void main(String[] args) throws ClassNotFoundException, SQLException, UnsupportedEncodingException { public static void main(String[] args) throws ClassNotFoundException, SQLException, UnsupportedEncodingException {
String url = "jdbc:mysql://192.168.2.202:3306/testcon?zeroDateTimeBehavior=convertToNull"; String url = "jdbc:mysql://192.168.2.202:3306/testcon?zeroDateTimeBehavior=convertToNull";
String driver = "com.mysql.jdbc.Driver"; String driver = "com.mysql.cj.jdbc.Driver";
String passwd = "root"; String passwd = "root";
String user = "root"; String user = "root";
Class.forName(driver); Class.forName(driver);
......
src/main/java/com/chenyang/nse/bussiness/webtools/enumeration/EdbType.java
...@@ -7,8 +7,8 @@ public enum EdbType { ...@@ -7,8 +7,8 @@ public enum EdbType {
DB2("DB2", "DB2", "com.ibm.db2.jcc.DB2Driver", "jdbc:db2://{ip}:{port}/{servername}"), DB2("DB2", "DB2", "com.ibm.db2.jcc.DB2Driver", "jdbc:db2://{ip}:{port}/{servername}"),
AS400("AS400", "AS400", "com.ibm.as400.access.AS400JDBCDriver", "jdbc:as400://{ip}"), AS400("AS400", "AS400", "com.ibm.as400.access.AS400JDBCDriver", "jdbc:as400://{ip}"),
MSSQLSERVER("MSSQLSERVER", "MSSQLSERVER", "com.microsoft.sqlserver.jdbc.SQLServerDriver", "jdbc:sqlserver://{ip}:{port};DatabaseName={servername}"), MSSQLSERVER("MSSQLSERVER", "MSSQLSERVER", "com.microsoft.sqlserver.jdbc.SQLServerDriver", "jdbc:sqlserver://{ip}:{port};DatabaseName={servername}"),
MYSQL("MYSQL", "MYSQL", "com.mysql.jdbc.Driver", "jdbc:mysql://{ip}:{port}/{servername}?zeroDateTimeBehavior=convertToNull"), MYSQL("MYSQL", "MYSQL", "com.mysql.cj.jdbc.Driver", "jdbc:mysql://{ip}:{port}/{servername}?zeroDateTimeBehavior=convertToNull"),
MARIADB("MARIADB", "MYSQL", "com.mysql.jdbc.Driver", "jdbc:mysql://{ip}:{port}/{servername}?zeroDateTimeBehavior=convertToNull"), MARIADB("MARIADB", "MYSQL", "com.mysql.cj.jdbc.Driver", "jdbc:mysql://{ip}:{port}/{servername}?zeroDateTimeBehavior=convertToNull"),
ORACLE("ORACLE", "ORACLE", "oracle.jdbc.driver.OracleDriver", "jdbc:oracle:thin:@(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST={ip})(PORT={port}))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME={servername})))"), ORACLE("ORACLE", "ORACLE", "oracle.jdbc.driver.OracleDriver", "jdbc:oracle:thin:@(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST={ip})(PORT={port}))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME={servername})))"),
ORACLEINS("ORACLEINS", "ORACLE", "oracle.jdbc.driver.OracleDriver", "jdbc:oracle:thin:@{ip}:{port}:{servername}"), ORACLEINS("ORACLEINS", "ORACLE", "oracle.jdbc.driver.OracleDriver", "jdbc:oracle:thin:@{ip}:{port}:{servername}"),
HIVE("HIVE", "HIVE", "org.apache.hive.jdbc.HiveDriver", "jdbc:hive2://{ip}:{port}/{servername}"), HIVE("HIVE", "HIVE", "org.apache.hive.jdbc.HiveDriver", "jdbc:hive2://{ip}:{port}/{servername}"),
...@@ -19,7 +19,7 @@ public enum EdbType { ...@@ -19,7 +19,7 @@ public enum EdbType {
GREENPLUM("GREENPLUM", "GREENPLUM", "org.postgresql.Driver", "jdbc:postgresql://{ip}:{port}/{servername}"), GREENPLUM("GREENPLUM", "GREENPLUM", "org.postgresql.Driver", "jdbc:postgresql://{ip}:{port}/{servername}"),
POSTGRESQL("POSTGRESQL", "GREENPLUM", "org.postgresql.Driver", "jdbc:postgresql://{ip}:{port}/{servername}"), POSTGRESQL("POSTGRESQL", "GREENPLUM", "org.postgresql.Driver", "jdbc:postgresql://{ip}:{port}/{servername}"),
HANA("HANA", "HANA", "com.sap.db.jdbc.Driver", "jdbc:sap://{ip}:{port}?reconnect=true"), HANA("HANA", "HANA", "com.sap.db.jdbc.Driver", "jdbc:sap://{ip}:{port}?reconnect=true"),
RAPIDSDB("RAPIDSDB", "RAPIDSDB", "com.mysql.jdbc.Driver", "jdbc:mysql://{ip}:{port}"), RAPIDSDB("RAPIDSDB", "RAPIDSDB", "com.mysql.cj.jdbc.Driver", "jdbc:mysql://{ip}:{port}"),
MONGODB("MONGODB", "MONGODB", "com.mongodb.jdbc.MongoDriver", "mongodb://{ip}:{port}/admin"), MONGODB("MONGODB", "MONGODB", "com.mongodb.jdbc.MongoDriver", "mongodb://{ip}:{port}/admin"),
OCEANBASE("OCEANBASE", "OCEANBASE", "com.alipay.oceanbase.obproxy.mysql.jdbc.Driver", "jdbc:oceanbase://{ip}:{port}/{servername}?useUnicode=true&characterEncoding=utf-8"), OCEANBASE("OCEANBASE", "OCEANBASE", "com.alipay.oceanbase.obproxy.mysql.jdbc.Driver", "jdbc:oceanbase://{ip}:{port}/{servername}?useUnicode=true&characterEncoding=utf-8"),
KAFKA("KAFKA", "KAFKA", "", "bootstrap.servers://{ip}:{port}?characterEncoding=utf-8"), KAFKA("KAFKA", "KAFKA", "", "bootstrap.servers://{ip}:{port}?characterEncoding=utf-8"),
......
src/main/java/com/chenyang/nse/bussiness/webtools/tools/jdbc/MysqlJdbc.java
...@@ -8,7 +8,7 @@ import java.sql.Statement; ...@@ -8,7 +8,7 @@ import java.sql.Statement;
public class MysqlJdbc { public class MysqlJdbc {
public static void main(String[] args) { public static void main(String[] args) {
try { try {
Class.forName("com.mysql.jdbc.Driver"); Class.forName("com.mysql.cj.jdbc.Driver");
System.out.println("Success loading Mysql Driver!"); System.out.println("Success loading Mysql Driver!");
} catch (Exception e) { } catch (Exception e) {
System.out.print("Error loading Mysql Driver!"); System.out.print("Error loading Mysql Driver!");
......
src/main/resources/ca.crt 0 → 100755
-----BEGIN CERTIFICATE-----
MIIByjCCAW+gAwIBAgIE6unFsjAKBggqgRzPVQGDdTBMMQ0wCwYDVQQKEwRLT0FM
MQswCQYDVQQIEwJTQzELMAkGA1UEBhMCQ04xDTALBgNVBAsTBEtPQUwxEjAQBgNV
BAMTCUtPQUwgQ0hTTTAeFw0yMzAzMTcwNzQ5MDZaFw00MzAzMTcwNzQ5MDZaMEwx
DTALBgNVBAoTBEtPQUwxCzAJBgNVBAgTAlNDMQswCQYDVQQGEwJDTjENMAsGA1UE
CxMES09BTDESMBAGA1UEAxMJS09BTCBDSFNNMFkwEwYHKoZIzj0CAQYIKoEcz1UB
gi0DQgAEc+lOMVbqoyJ8HDJCSwLp//zV3h7hIH2JWcoVZia1vBYSXvsEPnLQqAis
QT2+GgP0b3SO3m+4PGP3mVTYSR7JoKM/MD0wDgYDVR0PAQH/BAQDAgG+MAwGA1Ud
EwQFMAMBAf8wHQYDVR0OBBYEFPuSUcInn88YcXXRd6PJMe5dIIKoMAoGCCqBHM9V
AYN1A0kAMEYCIQCkJ+Bdrpxc2QAoKkVnEmt0IiDeNd0ahrBv6mGmc4WsMgIhAJhS
NcPntxhRr4P7KqnnJC5z6MC+I3k/FSu9EcbkfebX
-----END CERTIFICATE-----
src/main/resources/config.properties
...@@ -18,7 +18,7 @@ jdbc.dbname=public ...@@ -18,7 +18,7 @@ jdbc.dbname=public
basePath=D:/trustz basePath=D:/trustz
maskingPath=/home/masking maskingPath=/home/masking
#jdbc-mysql #jdbc-mysql
#jdbc.driver=com.mysql.jdbc.Driver #jdbc.driver=com.mysql.cj.jdbc.Driver
jdbc.driver= com.mysql.cj.jdbc.Driver jdbc.driver= com.mysql.cj.jdbc.Driver
#jdbc.driver=dm.jdbc.driver.DmDriver #jdbc.driver=dm.jdbc.driver.DmDriver
#jdbc.driver=org.h2.Driver #jdbc.driver=org.h2.Driver
......
src/main/resources/sm2pub.cer 0 → 100755
-----BEGIN CERTIFICATE-----
MIIDNjCCAtugAwIBAgISIQp5quPZoRBgU3GHogFP1/JPMAwGCCqBHM9VAYN1BQAwSTELMAkGA1UEBhMCQ04xDTALBgNVBAoMBFNJUE8xFDASBgNVBAsMC1NJUE8gU00yIENBMRUwEwYDVQQDDAxTSVBPIFRFU1QgQ0EwHhcNMjIwNDAxMDc0MDAyWhcNMjcwMzMxMDc0MDAyWjByMQswCQYDVQQGEwJDTjELMAkGA1UECAwCTE4xCzAJBgNVBAcMAlNZMQ0wCwYDVQQKDARHSENBMQ0wCwYDVQQLDARHSENBMQ0wCwYDVQQDDARHSENBMRwwGgYJKoZIhvcNAQkBFg1HSENBQEdIQ0EuQ09NMFkwEwYHKoZIzj0CAQYIKoEcz1UBgi0DQgAE30A6kIgKegDwc8kJ2CnbDLRytJmr/fOOaeFuSKHfIKXwLHiN2Sl0+Z1Lo8RRDoVq+B8ndVGDDQ5VECsLO6DcoqOCAXYwggFyMAsGA1UdDwQEAwIGwDAJBgNVHRMEAjAAMA8GCiqBHIbvMgYEAgEEATEwDwYKKoEchu8yAgEBFwQBMTAQBghghkgBhvhEAgQEWFhYWDCBjQYDVR0fBIGFMIGCMDugOaA3hjVodHRwOi8vMTcyLjE2LjQuMzE6ODAvY3JsL1NpcG9UZXN0Q2EvU2lwb1Rlc3RDYV8wLmNybDBDoEGgP4Y9aHR0cDovLzE3Mi4xNi40LjMxOjgwL2NybC9TaXBvVGVzdENhL2luYy9TaXBvVGVzdENhX2luY18wLmNybDAdBgNVHQ4EFgQU/O48cyaWSvnBO3OZ6oFvACtGhW8wHwYDVR0jBBgwFoAUZYuUvjmV/zU6OLWxOxYjt0qtKU8wVAYDVR0gBE0wSzBJBgoqgRyG7zIGBAEBMDswOQYIKwYBBQUHAgEWLWh0dHA6Ly8xNzIuMTYuNC4zMTo4MC9jcHMvU2lwb1Rlc3RDYS9jcHMuaHRtbDAMBggqgRzPVQGDdQUAA0cAMEQCIBUTNXcANKeXvbhigsLykXw+O8Pp957SeMHg9ZKsPbvLAiBe05KIhsohnqNk+F89NiATXjkNcnb/9NqL7Df4KoeDuA==
-----END CERTIFICATE-----
src/main/resources/swsds.ini 0 → 100755
[Device]
device=CMD
[ErrorLog]
level=2
logfile=/usr/local/sansec/tools/logs/swsds.log
maxsize=10
count=3
[HSM1]
ip=127.0.0.1
port=8020
passwd=11111111
[Timeout]
connect=100
service=8000
[ConnectionPool]
poolsize=1
[SSL]
ssl=0
ssllog=1
protocol=TLSv1.2
keystore=client.jks
keystorepassword=12345678
keystoretype=JKS
trustkeystore=trust.jks
trustkeystorepassword=12345678
trustkeystoretype=JKS
includeciphersuitefilter=*_RSA_*_SHA256$
src/main/resources/zdxlz.ini 0 → 100755
EnableSSL=false;
KeyPass=zdxlzA1234;
HsmIp=117.71.57.240;//密码机ip
HsmPort=6666;//端口
ConnectTimeOut=50;//连接超时时间
SessionSize=1000;//会话密钥连接池大小
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论