From f75e15a375dc6c946ec8115fa3cde62f419312d5 Mon Sep 17 00:00:00 2001 From: Redkale <22250530@qq.com> Date: Fri, 4 May 2018 20:29:40 +0800 Subject: [PATCH] --- src/org/redkale/source/DataSqlJdbcSource.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/org/redkale/source/DataSqlJdbcSource.java b/src/org/redkale/source/DataSqlJdbcSource.java index e47af0e84..a353a42ba 100644 --- a/src/org/redkale/source/DataSqlJdbcSource.java +++ b/src/org/redkale/source/DataSqlJdbcSource.java @@ -180,6 +180,7 @@ public class DataSqlJdbcSource extends DataSqlSource { try { conn = writePool.poll(); conn.setReadOnly(false); + sql += ((flipper == null || flipper.getLimit() < 1) ? "" : (" LIMIT " + flipper.getLimit())); if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " delete sql=" + sql); final Statement stmt = conn.createStatement(); int c = stmt.executeUpdate(sql);