diff --git a/src/org/redkale/source/DataDefaultSource.java b/src/org/redkale/source/DataDefaultSource.java index 798656356..4a5c86dc2 100644 --- a/src/org/redkale/source/DataDefaultSource.java +++ b/src/org/redkale/source/DataDefaultSource.java @@ -1719,7 +1719,7 @@ public final class DataDefaultSource implements DataSource, Function consumer) { + public final void directQuery(String sql, Consumer consumer) { final Connection conn = createReadSQLConnection(); try { if (debug.get()) logger.finest("queryDirect sql=" + sql);