From 954bc90e66f010c9046571dff96f767934f671b8 Mon Sep 17 00:00:00 2001
From: zhouhongfa <zhouhongfa@gz-yibo.com>
Date: Sat, 3 Aug 2019 16:24:54 +0800
Subject: [PATCH] =?UTF-8?q?update:=20=E6=94=B9=E7=94=A8=20HikariDataSource?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/wugui/tool/query/BaseQueryTool.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/datax-web/src/main/java/com/wugui/tool/query/BaseQueryTool.java b/datax-web/src/main/java/com/wugui/tool/query/BaseQueryTool.java
index 34ac6a22..1a4c061a 100644
--- a/datax-web/src/main/java/com/wugui/tool/query/BaseQueryTool.java
+++ b/datax-web/src/main/java/com/wugui/tool/query/BaseQueryTool.java
@@ -1,7 +1,6 @@
 package com.wugui.tool.query;
 
 import cn.hutool.core.util.StrUtil;
-import com.alibaba.druid.pool.DruidDataSource;
 import com.alibaba.druid.util.JdbcUtils;
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.Lists;
@@ -11,6 +10,7 @@ import com.wugui.tool.database.DasColumn;
 import com.wugui.tool.database.TableInfo;
 import com.wugui.tool.meta.DatabaseInterface;
 import com.wugui.tool.meta.DatabaseMetaFactory;
+import com.zaxxer.hikari.HikariDataSource;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -65,13 +65,13 @@ public abstract class BaseQueryTool implements QueryToolInterface {
      */
     BaseQueryTool(JobJdbcDatasource jobJdbcDatasource) throws SQLException {
         //这里默认使用 hikari 数据源
-        DruidDataSource dataSource = new DruidDataSource();
+        HikariDataSource dataSource = new HikariDataSource();
         dataSource.setUsername(jobJdbcDatasource.getJdbcUsername());
         dataSource.setPassword(jobJdbcDatasource.getJdbcPassword());
-        dataSource.setUrl(jobJdbcDatasource.getJdbcUrl());
+        dataSource.setJdbcUrl(jobJdbcDatasource.getJdbcUrl());
         dataSource.setDriverClassName(jobJdbcDatasource.getJdbcDriverClass());
         //设为只读
-        dataSource.setDefaultReadOnly(true);
+        dataSource.setReadOnly(true);
         this.jobJdbcDatasource = jobJdbcDatasource;
         this.datasource = dataSource;
         this.connection = this.datasource.getConnection();