From 65bc8192f0517c7fb6eb048891a43eb533f0c1e2 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Wed, 29 Nov 2017 11:28:10 +0800
Subject: [PATCH] =?UTF-8?q?DataJdbcSource=E5=A2=9E=E5=8A=A0preConstruct?=
 =?UTF-8?q?=E6=96=B9=E6=B3=95=EF=BC=8C=E6=96=B9=E4=BE=BF=E9=87=8D=E8=BD=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/org/redkale/source/DataJdbcSource.java | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/org/redkale/source/DataJdbcSource.java b/src/org/redkale/source/DataJdbcSource.java
index df1ca40ce..53495c45a 100644
--- a/src/org/redkale/source/DataJdbcSource.java
+++ b/src/org/redkale/source/DataJdbcSource.java
@@ -52,6 +52,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, DataC
     protected final BiFunction<DataSource, Class, List> fullloader = (s, t) -> querySheet(false, false, t, null, null, (FilterNode) null).list(true);
 
     public DataJdbcSource(String unitName, Properties readprop, Properties writeprop) {
+        this.preConstruct(unitName, readprop, writeprop);
         this.name = unitName;
         this.conf = null;
         this.readPool = new PoolJdbcSource(this, "read", readprop);
@@ -59,6 +60,10 @@ public class DataJdbcSource extends AbstractService implements DataSource, DataC
         this.cacheForbidden = "NONE".equalsIgnoreCase(readprop.getProperty(JDBC_CACHE_MODE));
     }
 
+    //构造前调用
+    protected void preConstruct(String unitName, Properties readprop, Properties writeprop) {
+    }
+
     @Override
     public final String resourceName() {
         return name;
@@ -2341,7 +2346,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, DataC
             final Statement statement = conn.createStatement();
             //final PreparedStatement statement = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
             final ResultSet set = statement.executeQuery(sql);// ps.executeQuery();
-            consumer.accept(set); 
+            consumer.accept(set);
             set.close();
             statement.close();
         } catch (Exception ex) {