From 3c0609fa0ed858e1dd86833d3ae852652f7e86e7 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Wed, 15 Nov 2017 17:12:49 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9DataJdbcSource=E7=9A=84direct?=
 =?UTF-8?q?Query=E5=AE=9E=E7=8E=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/org/redkale/source/DataJdbcSource.java | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/src/org/redkale/source/DataJdbcSource.java b/src/org/redkale/source/DataJdbcSource.java
index f2e541d5f..4e995ebd5 100644
--- a/src/org/redkale/source/DataJdbcSource.java
+++ b/src/org/redkale/source/DataJdbcSource.java
@@ -2338,11 +2338,12 @@ public class DataJdbcSource extends AbstractService implements DataSource, DataC
         try {
             if (logger.isLoggable(Level.FINEST)) logger.finest("direct query sql=" + sql);
             conn.setReadOnly(true);
-            final PreparedStatement ps = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
-            final ResultSet set = ps.executeQuery();
-            consumer.accept(set);
+            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); 
             set.close();
-            ps.close();
+            statement.close();
         } catch (Exception ex) {
             throw new RuntimeException(ex);
         } finally {