diff --git a/src/main/java/org/redkale/source/AbstractDataSqlSource.java b/src/main/java/org/redkale/source/AbstractDataSqlSource.java index aabb0d754..25a73c0df 100644 --- a/src/main/java/org/redkale/source/AbstractDataSqlSource.java +++ b/src/main/java/org/redkale/source/AbstractDataSqlSource.java @@ -159,7 +159,7 @@ public abstract class AbstractDataSqlSource extends AbstractDataSource readConfProps.getProperty(DATA_SOURCE_SLOWMS_ERROR, "3000").trim()); } - protected PageCountSql filterPageCountSql( + protected PageCountSql createPageCountSql( EntityInfo info, final boolean readCache, boolean needTotal, diff --git a/src/main/java/org/redkale/source/DataJdbcSource.java b/src/main/java/org/redkale/source/DataJdbcSource.java index ef0b2de6a..8f9d04a5f 100644 --- a/src/main/java/org/redkale/source/DataJdbcSource.java +++ b/src/main/java/org/redkale/source/DataJdbcSource.java @@ -2390,7 +2390,7 @@ public class DataJdbcSource extends AbstractDataSqlSource { try { conn = readPool.pollConnection(); conn.setAutoCommit(true); - PageCountSql sqls = filterPageCountSql(info, readCache, needTotal, distinct, sels, tables, flipper, node); + PageCountSql sqls = createPageCountSql(info, readCache, needTotal, distinct, sels, tables, flipper, node); try { return executeQuerySheet(info, needTotal, flipper, sels, s, conn, sqls); } catch (SQLException se) { @@ -2429,7 +2429,7 @@ public class DataJdbcSource extends AbstractDataSqlSource { } // 重新查询一次 - sqls = filterPageCountSql(info, readCache, needTotal, distinct, sels, tables, flipper, node); + sqls = createPageCountSql(info, readCache, needTotal, distinct, sels, tables, flipper, node); return executeQuerySheet(info, needTotal, flipper, sels, s, conn, sqls); } else { throw new SourceException(se);