lywsvip/magic-api
1
0
Fork 0
mirror of https://gitee.com/ssssssss-team/magic-api.git synced 2026-06-20 12:32:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

新增db.page(countSql,sql)方法

Browse Source
This commit is contained in:
mxd
2021-10-10 09:55:24 +08:00
parent cec9bfbf6e
commit aacecc759c
1 changed files with 25 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
magic-api/src/main/java/org/ssssssss/magicapi/modules/SQLModule.java
View File

@@ -430,14 +430,23 @@ public class SQLModule extends HashMap<String, SQLModule> implements MagicModule
return this.dataSourceNode == null ? "unknown" : dataSourceNode.getName();
}
@UnableCall
public Object page(BoundSql boundSql, Page page) {
assertDatasourceNotNull();
Dialect dialect = dataSourceNode.getDialect(dialectAdapter);
BoundSql countBoundSql = boundSql.copy(dialect.getCountSql(boundSql.getSql()));
int count = countBoundSql.getCacheValue(this.sqlInterceptors, () -> dataSourceNode.getJdbcTemplate().query(countBoundSql.getSql(), new SingleRowResultSetExtractor<>(Integer.class), countBoundSql.getParameters()));
/**
* 分页查询（手动传入分页SQL语句）
*/
@Comment("执行分页查询，分页`SQL`语句手动传入")
public Object page(String countSql, String sql){
int count = selectInt(new BoundSql(countSql, this));
Page page = pageProvider.getPage(MagicScriptContext.get());
BoundSql boundSql = new BoundSql(sql, this);
return page(count, boundSql, page, null);
}
private Object page(int count, BoundSql boundSql, Page page, Dialect dialect) {
List<Map<String, Object>> list = null;
if (count > 0) {
if(count > 0){
if(dialect == null){
dialect = dataSourceNode.getDialect(dialectAdapter);
}
BoundSql pageBoundSql = buildPageBoundSql(dialect, boundSql, page.getOffset(), page.getLimit());
list = pageBoundSql.getCacheValue(this.sqlInterceptors, () -> queryForList(pageBoundSql));
}
@@ -445,6 +454,15 @@ public class SQLModule extends HashMap<String, SQLModule> implements MagicModule
return resultProvider.buildPageResult(requestEntity, page, count, list);
}
@UnableCall
public Object page(BoundSql boundSql, Page page) {
assertDatasourceNotNull();
Dialect dialect = dataSourceNode.getDialect(dialectAdapter);
BoundSql countBoundSql = boundSql.copy(dialect.getCountSql(boundSql.getSql()));
int count = countBoundSql.getCacheValue(this.sqlInterceptors, () -> selectInt(countBoundSql));
return page(count, boundSql, page, dialect);
}
/**
* 查询int值
*/