From f3896483ad77e26928d8df092efc4a4f89ab783b Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Thu, 6 Jun 2024 14:56:32 +0800
Subject: [PATCH] createPageCountSql

---
 src/main/java/org/redkale/source/AbstractDataSqlSource.java | 2 +-
 src/main/java/org/redkale/source/DataJdbcSource.java        | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

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 <T> PageCountSql filterPageCountSql(
+    protected <T> PageCountSql createPageCountSql(
             EntityInfo<T> 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);