lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改DataJdbcSource的directQuery实现

Browse Source
This commit is contained in:
Redkale
2017-11-15 17:12:49 +08:00
parent 945f9f9ef5
commit 3c0609fa0e
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/org/redkale/source/DataJdbcSource.java
View File

@@ -2338,11 +2338,12 @@ public class DataJdbcSource extends AbstractService implements DataSource, DataC
try { try {
if (logger.isLoggable(Level.FINEST)) logger.finest("direct query sql=" + sql); if (logger.isLoggable(Level.FINEST)) logger.finest("direct query sql=" + sql);
conn.setReadOnly(true); conn.setReadOnly(true);
final PreparedStatement ps = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY); final Statement statement = conn.createStatement();
final ResultSet set = ps.executeQuery(); //final PreparedStatement statement = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
consumer.accept(set); final ResultSet set = statement.executeQuery(sql);// ps.executeQuery();
consumer.accept(set);
set.close(); set.close();
ps.close(); statement.close();
} catch (Exception ex) { } catch (Exception ex) {
throw new RuntimeException(ex); throw new RuntimeException(ex);
} finally { } finally {