使用druid数据库连接池实现动态的配置数据源功能,在配置过程中出现一个问题既然是用户自己配置的数据源,就无法避免输入错误,连接失败等情况,关于这个问题怎么处理呢,今天小编通过本文给大家详细说明下,感兴趣的朋友一起看看吧
Druid动态数据源配置 主要是继承AbstractRoutingDataSource再通过AOP来实现动态数据源切换.
下面给大家介绍Druid动态配置数据源重复刷错误日志问题,具体内容如下所示:
问题描述
功能需求:
使用druid数据库连接池实现 动态的配置数据源功能:IP、端口、用户名、密码都是用户页面手动输入,可以测试连接,保存数据源。
问题说明:
既然是用户自己配置的数据源,就无法避免输入错误,连接失败等情况。
预期情况:用户输入的配置错误,测试连接时,会返回连接失败的信息。
实际情况:数据源测试连接,连接失败后:
【错误信息】:
com.alibaba.druid.pool.DruidDataSource-create connection sqlException, url:xxx, errorCode 0, state 08S01
The last packet sent successfully to the server was 0 milliseconds ago.
The driver has not received any packets from the server.
【原始代码】:
public static void getDataSource(DataConfig dataConfig) throws Exception{ try { Properties properties = new Properties(); properties.setProperty("driverClassName",dataConfig.getDriverClassName()); properties.setProperty("url",dataConfig.getUrl()); properties.setProperty("username",dataConfig.getUserName()); properties.setProperty("password",dataConfig.getpassWord()); DataSource ds = DruidDataSourceFactory.createDataSource(properties); } catch (Exception e) { e.printstacktrace(); } }
解决办法
【参数说明】
参数
解释
connectionErrorRetryAttempts
连接出错后再尝试连接次数
breakAfteracquireFailure
maxWait
超时等待时间
【修改后的代码】 public static void getDataSource(DataConfig dataConfig) throws Exception{ try { Properties properties = new Properties(); properties.setProperty("driverClassName",dataConfig.getDriverClassName()); properties.setProperty("url",dataConfig.getUrl()); properties.setProperty("username",dataConfig.getUserName()); properties.setProperty("password",dataConfig.getpassWord()); properties.setProperty("maxWait","500");//如果失败,当前的请求可以返回 DruidDataSource druidDataSource = (DruidDataSource)DruidDataSourceFactory.createDataSource(properties); druidDataSource.setConnectionErrorRetryAttempts(0);// 失败后重连的次数 druidDataSource.setBreakAfteracquireFailure(true);//请求失败之后中断 DataSource ds = druidDataSource;//如果有需要使用javax.sql.DataSource的话 } catch (Exception e) { e.printstacktrace(); } }
踩坑总结
不要在properties中配置connectionErrorRetryAttempts和breakAfteracquireFailure,没有效果