diff --git a/src/main/java/com/alibaba/druid/pool/ha/node/PoolUpdater.java b/src/main/java/com/alibaba/druid/pool/ha/node/PoolUpdater.java index 95628822f5..e0e81d92f1 100644 --- a/src/main/java/com/alibaba/druid/pool/ha/node/PoolUpdater.java +++ b/src/main/java/com/alibaba/druid/pool/ha/node/PoolUpdater.java @@ -20,6 +20,7 @@ import com.alibaba.druid.pool.ha.DataSourceCreator; import com.alibaba.druid.pool.ha.HighAvailableDataSource; import com.alibaba.druid.support.logging.Log; import com.alibaba.druid.support.logging.LogFactory; +import com.alibaba.druid.util.JdbcUtils; import javax.sql.DataSource; import java.util.HashSet; @@ -205,13 +206,7 @@ public class PoolUpdater implements Observer { LOG.info("Creating Node " + nodeName + "[url: " + url + ", username: " + username + "]."); } catch (Exception e) { LOG.error("Can NOT create DataSource " + nodeName + ". IGNORE IT.", e); - if (dataSource != null) { - try { - dataSource.close(); - } catch (Exception ex) { - LOG.error("Exception occurred while closing the FAILURE DataSource.", ex); - } - } + JdbcUtils.close(dataSource); } }