|
|
|
@ -1816,7 +1816,8 @@ public class CommonEnumUtil {
|
|
|
|
|
SOURCE_MARIA_DB(100, "MariaDB", "MariaDB 10.1","com.mysql.jdbc.Driver",3306,null),
|
|
|
|
|
SOURCE_SQL_SERVER(200, "SQL Server", "SQL Server 2017","com.microsoft.sqlserver.jdbc.SQLServerDriver",1433,"dbo"),
|
|
|
|
|
SOURCE_ORACLE(300, "Oracle", "Oralce 12C","oracle.jdbc.driver.OracleDriver",1521,null),
|
|
|
|
|
SOURCE_POSTGRE_SQL(400, "PostgreSql", "PostgreSql 10.5","org.postgresql.Driver",5432,"public");
|
|
|
|
|
SOURCE_POSTGRE_SQL(400, "PostgreSql", "PostgreSql 10.5","org.postgresql.Driver",5432,"public"),
|
|
|
|
|
SOURCE_SAP_HANA(500, "SapHana", "SapHana","com.sap.db.jdbc.Driver",39015,null);
|
|
|
|
|
|
|
|
|
|
private int value;
|
|
|
|
|
private String code;
|
|
|
|
@ -1908,6 +1909,13 @@ public class CommonEnumUtil {
|
|
|
|
|
return tmp;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public String getSchemaPattern(String schema) {
|
|
|
|
|
if(this.equals(SOURCE_SAP_HANA)){
|
|
|
|
|
return schema;
|
|
|
|
|
}
|
|
|
|
|
return defaultSchemaPattern;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public String getJDBCUrl(String database,String host,Integer port){
|
|
|
|
|
if(this.getValue() == SOURCE_MARIA_DB.getValue()){
|
|
|
|
|
return getJDBCUrlMySQL(database,host,port);
|
|
|
|
@ -1917,6 +1925,8 @@ public class CommonEnumUtil {
|
|
|
|
|
return getJDBCUrlPostgreSQL(database,host,port);
|
|
|
|
|
}else if(this.getValue() == SOURCE_SQL_SERVER.getValue()){
|
|
|
|
|
return getJDBCUrlSQLServer(database,host,port);
|
|
|
|
|
}else if(this.getValue() == SOURCE_SAP_HANA.getValue()){
|
|
|
|
|
return getJDBCUrlSapHana(database,host,port);
|
|
|
|
|
}
|
|
|
|
|
return null;
|
|
|
|
|
}
|
|
|
|
@ -1944,6 +1954,8 @@ public class CommonEnumUtil {
|
|
|
|
|
return SOURCE_POSTGRE_SQL;
|
|
|
|
|
}else if(databaseProductName.indexOf(":sqlserver:") != -1){
|
|
|
|
|
return SOURCE_SQL_SERVER;
|
|
|
|
|
}else if(databaseProductName.indexOf(":sap:") != -1){
|
|
|
|
|
return SOURCE_SAP_HANA;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return null;
|
|
|
|
@ -1965,6 +1977,10 @@ public class CommonEnumUtil {
|
|
|
|
|
return "jdbc:sqlserver://" + host + ":" + port + ";database=" + database+";autoReconnect=true";
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private String getJDBCUrlSapHana(String database,String host,Integer port){
|
|
|
|
|
return "jdbc:sap://" + host + ":" + port + "?reconnect=true";
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private String getJDBCUrlSQLServer(String database,String host,Integer port,String instanceName){
|
|
|
|
|
StringBuffer sb = new StringBuffer();
|
|
|
|
|
sb.append("jdbc:sqlserver://").append(host);
|
|
|
|
|