From c11b004e04361e8ecd78aad36cff9185aa79c25b Mon Sep 17 00:00:00 2001 From: "heavyrain.lee" Date: Wed, 15 Apr 2020 10:34:33 +0800 Subject: [PATCH] update --- broker/src/main/java/win/liyufan/im/DBUtil.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/broker/src/main/java/win/liyufan/im/DBUtil.java b/broker/src/main/java/win/liyufan/im/DBUtil.java index 0a07b4d7..09ad81fd 100755 --- a/broker/src/main/java/win/liyufan/im/DBUtil.java +++ b/broker/src/main/java/win/liyufan/im/DBUtil.java @@ -80,12 +80,10 @@ public class DBUtil { comboPooledDataSource = new ComboPooledDataSource("mysql"); try { String url01 = comboPooledDataSource.getJdbcUrl().substring(0,comboPooledDataSource.getJdbcUrl().indexOf("?")); - - String url02 = url01.substring(0,url01.lastIndexOf("/")); - String datasourceName = url01.substring(url01.lastIndexOf("/")+1); // 连接已经存在的数据库，如：mysql - Connection connection = DriverManager.getConnection(url02, comboPooledDataSource.getUser(), comboPooledDataSource.getPassword()); + String jdbc = comboPooledDataSource.getJdbcUrl().replace(datasourceName, ""); + Connection connection = DriverManager.getConnection(jdbc, comboPooledDataSource.getUser(), comboPooledDataSource.getPassword()); Statement statement = connection.createStatement(); // 创建数据库