阿里巴巴国际站怎么运营,虚拟主机如何搭建网站,首钢建设网站,柳州网站建设多少钱需求
springboot设计开发一个系统#xff0c;在这个系统的数据库表中存放着2000个数据库实例#xff0c;有MySQL、Oracle、sql server3种数据库类型#xff0c;用户可以在页面上选择不同的实例#xff0c;连接这些实例上的数据库#xff0c;来执行业务sql
实现
Service…需求
springboot设计开发一个系统在这个系统的数据库表中存放着2000个数据库实例有MySQL、Oracle、sql server3种数据库类型用户可以在页面上选择不同的实例连接这些实例上的数据库来执行业务sql
实现
Service
public class DatabaseService {Autowiredprivate DynamicDataSource dynamicDataSource;Autowiredprivate JdbcTemplate jdbcTemplate;public void executeSqlOnDatabase(int instanceId, String sql) {// 根据实例ID获取数据库实例信息DatabaseInstance instance databaseInstanceService.getInstanceById(instanceId);if (instance null) {throw new IllegalArgumentException(Invalid database instance ID: instanceId);}// 构建数据源配置HikariConfig config new HikariConfig();config.setJdbcUrl(generateJdbcUrl(instance));config.setUsername(instance.getUsername());config.setPassword(instance.getPassword());config.setDriverClassName(getDriverClassName(instance.getDatabaseType()));// 创建数据源HikariDataSource dataSource new HikariDataSource(config);// 动态添加数据源String dataSourceKey instance.getIp() : instance.getPort();dynamicDataSource.addTargetDataSource(dataSourceKey, dataSource);try {// 切换到新的数据源DynamicDataSourceContextHolder.setDataSourceKey(dataSourceKey);// 执行SQLjdbcTemplate.execute(sql);} catch (DataAccessException e) {// 处理异常e.printStackTrace();} finally {// 操作完成后切换回默认数据源或清理当前数据源DynamicDataSourceContextHolder.clearDataSourceKey();dynamicDataSource.removeTargetDataSource(dataSourceKey);// 关闭数据源dataSource.close();}}private String generateJdbcUrl(DatabaseInstance instance) {String databaseType instance.getDatabaseType();String ip instance.getIp();int port instance.getPort();String databaseName instance.getDatabaseName();switch (databaseType.toLowerCase()) {case mysql:return jdbc:mysql:// ip : port / databaseName;case oracle:return jdbc:oracle:thin: ip : port : databaseName;case sqlserver:return jdbc:sqlserver:// ip : port ;databaseName databaseName;default:throw new IllegalArgumentException(Unsupported database type: databaseType);}}private String getDriverClassName(String databaseType) {switch (databaseType.toLowerCase()) {case mysql:return com.mysql.cj.jdbc.Driver;case oracle:return oracle.jdbc.driver.OracleDriver;case sqlserver:return com.microsoft.sqlserver.jdbc.SQLServerDriver;default:throw new IllegalArgumentException(Unsupported database type: databaseType);}}
}public class DynamicDataSourceContextHolder {private static final ThreadLocalString CONTEXT_HOLDER new ThreadLocal();public static void setDataSourceKey(String key) {CONTEXT_HOLDER.set(key);}public static String getDataSourceKey() {return CONTEXT_HOLDER.get();}public static void clearDataSourceKey() {CONTEXT_HOLDER.remove();}
}
