DbConnectionStringParser

import java.util.ArrayList;
import java.util.List;
import java.util.regex.Matcher;
import java.util.regex.Pattern;


public class DbConnectionStringParser {
public static String parserDbConnection(String connectionString) {
// 检查是否为 SQL Server
if (connectionString.toLowerCase().contains("data source") && connectionString.toLowerCase().contains("initial catalog")) {
DatabaseConfig config = new DatabaseConfig();

// 正则表达式匹配所有的参数键值对
Pattern pattern = Pattern.compile("([^=;]+)=([^;]*)");
Matcher matcher = pattern.matcher(connectionString);

while (matcher.find()) {
String key = matcher.group(1).trim();
String value = matcher.group(2).trim();

switch (key) {
case "Data source":
config.dataSource = value;
break;
case "Initial Catalog":
config.initialCatalog = value;
break;
case "user ID":
config.userId = value;
break;
case "password":
config.password = value;
break;
case "Connect Timeout":
config.connectTimeout = value;
break;
}
}
// 打印配置对象
System.out.println(config);
return "SQL Server";
}
// 检查是否为 Oracle
else if (connectionString.toLowerCase().contains("description")) {
OracleConnectionInfo connectionInfo = new OracleConnectionInfo();

// 正则表达式匹配 HOST 和 PORT
Pattern hostPortPattern = Pattern.compile("\\(HOST\\s*=\\s*(.*?)\\)\\(PORT\\s*=\\s*(\\d+)\\)");
Matcher hostPortMatcher = hostPortPattern.matcher(connectionString);

while (hostPortMatcher.find()) {
connectionInfo.addServer(hostPortMatcher.group(1), Integer.parseInt(hostPortMatcher.group(2)));
}

// 正则表达式匹配 SERVICE_NAME
Pattern serviceNamePattern = Pattern.compile("\\(SERVICE_NAME\\s*=\\s*(.*?)\\)");
Matcher serviceNameMatcher = serviceNamePattern.matcher(connectionString);

if (serviceNameMatcher.find()) {
connectionInfo.setServiceName(serviceNameMatcher.group(1));
}

System.out.println(connectionInfo);
return "Oracle";
}

return "Unknown Database Type";
}

public static void main(String[] args) {
String sqlServerConnectionString = "Data source=10.0.26.21;Initial Catalog=121333;user ID=111;password=222;Connect Timeout=90";
String oracleConnectionString = "User ID=111;Password=222;Data Source=(DESCRIPTION = (ADDRESS_LIST= (ADDRESS = (PROTOCOL = TCP)(HOST = 10.100.28.21)(PORT = 1521)) (ADDRESS = (PROTOCOL = TCP)(HOST= 10.100.28.22)(PORT =1522))) (CONNECT_DATA = (SERVICE_NAME=myService)));Connect Timeout=";

parserDbConnection(sqlServerConnectionString);
parserDbConnection(oracleConnectionString);


}

}

class DatabaseConfig {
String dataSource;
String initialCatalog;
String userId;
String password;
String connectTimeout;

@Override
public String toString() {
return "DataSource: " + dataSource + ", InitialCatalog: " + initialCatalog + ", UserID: " + userId + ", Password: " + password + ", ConnectTimeout: " + connectTimeout;
}
}

class ServerInfo {
String host;
int port;

public ServerInfo(String host, int port) {
this.host = host;
this.port = port;
}

@Override
public String toString() {
return "Host: " + host + ", Port: " + port;
}
}

class OracleConnectionInfo {
List<ServerInfo> servers = new ArrayList<>();
String serviceName;

public void addServer(String host, int port) {
servers.add(new ServerInfo(host, port));
}

public void setServiceName(String serviceName) {
this.serviceName = serviceName;
}

@Override
public String toString() {
return "Servers: " + servers + ", Service Name: " + serviceName;
}
}