From 7084fb2ea24f77dd9ca955c89c79259904ebffb0 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Fri, 11 May 2018 08:18:50 +0800
Subject: [PATCH]

---
 src/org/redkale/source/DataJdbcSource.java | 28 +++++++++-------------
 1 file changed, 11 insertions(+), 17 deletions(-)

diff --git a/src/org/redkale/source/DataJdbcSource.java b/src/org/redkale/source/DataJdbcSource.java
index e88f0fb46..d458ebbf6 100644
--- a/src/org/redkale/source/DataJdbcSource.java
+++ b/src/org/redkale/source/DataJdbcSource.java
@@ -511,8 +511,18 @@ public class DataJdbcSource extends DataSqlSource<Connection> {
         }
     }
 
-    protected int[] directExecute(final Connection conn, String... sqls) {
+    /**
+     * 直接本地执行SQL语句进行增删改操作，远程模式不可用   <br>
+     * 通常用于复杂的更新操作   <br>
+     *
+     * @param sqls SQL语句
+     *
+     * @return 结果数组
+     */
+    @Local
+    public int[] directExecute(String... sqls) {
         if (sqls.length == 0) return new int[0];
+        Connection conn = writePool.poll();
         try {
             conn.setReadOnly(false);
             final Statement stmt = conn.createStatement();
@@ -525,22 +535,6 @@ public class DataJdbcSource extends DataSqlSource<Connection> {
             return rs;
         } catch (SQLException e) {
             throw new RuntimeException(e);
-        }
-    }
-
-    /**
-     * 直接本地执行SQL语句进行增删改操作，远程模式不可用   <br>
-     * 通常用于复杂的更新操作   <br>
-     *
-     * @param sqls SQL语句
-     *
-     * @return 结果数组
-     */
-    @Local
-    public int[] directExecute(String... sqls) {
-        Connection conn = writePool.poll();
-        try {
-            return directExecute(conn, sqls);
         } finally {
             if (conn != null) writePool.offerConnection(conn);
         }