package com.walker.jdbc;
|
|
import com.walker.db.DatabaseType;
|
|
public class Constants {
|
|
public static final String SQL_ORDER_BY = " order by ";
|
|
public static final String getJdbcUrl(DatabaseType databaseType, String databaseName, String ip, int port){
|
StringBuilder url = new StringBuilder();
|
if(databaseType == DatabaseType.DERBY){
|
url.append("jdbc:derby:").append(databaseName);
|
|
} else if(databaseType == DatabaseType.MYSQL){
|
url.append("jdbc:mysql://").append(ip).append(":")
|
.append(port == 0 ? Constants.DEFAULT_PORT_MYSQL : port)
|
.append("/").append(databaseName);
|
// 因为oracle不支持这样设置参数，所以位置调换到这里 2016-11-30
|
if(url.indexOf("?") >= 0){
|
// url.append("&autoReconnect=true"); //当数据库连接异常中断时，是否自动重新连接
|
// url.append("&failOverReadOnly=false"); //自动重连成功后，连接是否设置为只读
|
url.append("&autoReconnect=true"); //当数据库连接异常中断时，是否自动重新连接
|
url.append("&failOverReadOnly=false"); //自动重连成功后，连接是否设置为只读
|
} else {
|
url.append("?autoReconnect=true");
|
// url.append("&failOverReadOnly=false");
|
url.append("&failOverReadOnly=false");
|
}
|
|
} else if(databaseType == DatabaseType.ORACLE){
|
url.append("jdbc:oracle:thin:@").append(ip).append(":")
|
.append(port == 0 ? Constants.DEFAULT_PORT_ORACLE : port)
|
.append(":").append(databaseName);
|
|
} else if(databaseType == DatabaseType.POSTGRES){
|
url.append("jdbc:postgresql://").append(ip).append(":")
|
.append(port == 0 ? Constants.DEFAULT_PORT_POSTGRES : port)
|
.append("/").append(databaseName);
|
|
} else if(databaseType == DatabaseType.SQLSERVER){
|
url.append("jdbc:sqlserver://").append(ip).append(":")
|
.append(port == 0 ? Constants.DEFAULT_PORT_POSTGRES : port)
|
.append(";DatabaseName=").append(databaseName);
|
|
} else if(databaseType == DatabaseType.DAMENG){
|
url.append("jdbc:dm://").append(ip).append(":")
|
.append(port == 0 ? Constants.DEFAULT_PORT_POSTGRES : port)
|
.append("?SCHEMA=").append(databaseName);
|
} else
|
throw new IllegalArgumentException("unsupported database type: " + databaseType);
|
return url.toString();
|
}
|
|
public static final String getDriverClassName(DatabaseType databaseType){
|
String driverName = null;
|
if(databaseType == DatabaseType.DERBY){
|
driverName = Constants.DRIVER_NAME_DERBY;
|
} else if(databaseType == DatabaseType.MYSQL){
|
driverName = Constants.DRIVER_NAME_MYSQL;
|
} else if(databaseType == DatabaseType.ORACLE){
|
driverName = Constants.DRIVER_NAME_ORACLE;
|
} else if(databaseType == DatabaseType.POSTGRES){
|
driverName = Constants.DRIVER_NAME_POSTGRES;
|
} else if(databaseType == DatabaseType.SQLSERVER){
|
driverName = Constants.DRIVER_NAME_SQLSERVER;
|
} else if(databaseType == DatabaseType.DAMENG){
|
driverName = Constants.DRIVER_NAME_DAMENG;
|
} else
|
throw new IllegalArgumentException("unsupported database type: " + databaseType);
|
return driverName;
|
}
|
|
public static final String DRIVER_NAME_DERBY = "org.apache.derby.jdbc.EmbeddedDriver";
|
// public static final String DRIVER_NAME_MYSQL = "com.mysql.jdbc.Driver";
|
public static final String DRIVER_NAME_MYSQL = "com.mysql.cj.jdbc.Driver";
|
public static final String DRIVER_NAME_ORACLE = "oracle.jdbc.driver.OracleDriver";
|
public static final String DRIVER_NAME_POSTGRES = "org.postgresql.Driver";
|
public static final String DRIVER_NAME_SQLSERVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
|
public static final String DRIVER_NAME_DAMENG = "dm.jdbc.driver.DmDriver";
|
|
public static final int DEFAULT_PORT_DERBY = 0;
|
public static final int DEFAULT_PORT_MYSQL = 3306;
|
public static final int DEFAULT_PORT_ORACLE = 1521;
|
public static final int DEFAULT_PORT_POSTGRES = 5432;
|
public static final int DEFAULT_PORT_SQLSERVER = 1433;
|
public static final int DEFAULT_PORT_DAMENG = 5236;
|
|
/**
|
* PO中加入的'parameter'(Map)字段名字。
|
* @date 2023-03-24
|
*/
|
public static final String PO_FIELD_PARAMETER = "parameter";
|
|
public static final String SQL_NAME_WHERE = "where";
|
public static final String SQL_NAME_AND = "and";
|
public static final String SQL_NAME_LIKE = "like";
|
}
|
