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

createPageCountSql

Browse Source
This commit is contained in:
redkale
2024-06-06 14:56:32 +08:00
parent a358e5bf01
commit f3896483ad
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/redkale/source/AbstractDataSqlSource.java
View File

@@ -159,7 +159,7 @@ public abstract class AbstractDataSqlSource extends AbstractDataSource
readConfProps.getProperty(DATA_SOURCE_SLOWMS_ERROR, "3000").trim()); readConfProps.getProperty(DATA_SOURCE_SLOWMS_ERROR, "3000").trim());
} }
protected <T> PageCountSql filterPageCountSql( protected <T> PageCountSql createPageCountSql(
EntityInfo<T> info, EntityInfo<T> info,
final boolean readCache, final boolean readCache,
boolean needTotal, boolean needTotal,

4
src/main/java/org/redkale/source/DataJdbcSource.java
View File

@@ -2390,7 +2390,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
try { try {
conn = readPool.pollConnection(); conn = readPool.pollConnection();
conn.setAutoCommit(true); 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 { try {
return executeQuerySheet(info, needTotal, flipper, sels, s, conn, sqls); return executeQuerySheet(info, needTotal, flipper, sels, s, conn, sqls);
} catch (SQLException se) { } 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); return executeQuerySheet(info, needTotal, flipper, sels, s, conn, sqls);
} else { } else {
throw new SourceException(se); throw new SourceException(se);