package com.hundsun.fiam.service.generic;
import java.util.List;
import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import org.apache.commons.lang.ArrayUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.stereotype.Service;
/**
*
* JdbcTemplate增加分页查询
*
*
*/
@Service("jdbcTemplateWithPaging")
public class JdbcTemplateWithPaging {
private static final Logger logger = LoggerFactory.getLogger(JdbcTemplateWithPaging.class);
@Autowired
private JdbcTemplate jdbcTemplate;
public JdbcTemplateWithPaging() {
}
/**
* 分页查询
*
* @param sql
* 查询的sql语句
* @param args
* 参数
* @param start
* 起始行
* @param limit
* 获取的行数
* @return
* @throws DataAccessException
*/
public List<Map<String, Object>> queryPage(String sql, Object[] args,
int start, int limit) {
if (start <= 0 && limit <= 0) {
return (List<Map<String, Object>>) jdbcTemplate.queryForList(sql,
args);
}
if (start <= 1) {
sql = getLimitString(sql, false);
args = ArrayUtils.add(args, args.length, limit);
} else {
sql = getLimitString(sql, true);
args = ArrayUtils.add(args, args.length, start + limit);
args = ArrayUtils.add(args, args.length, start);
}
logger.info("paging sql : \n" + sql);
return (List<Map<String, Object>>) jdbcTemplate.queryForList(sql, args);
}
/**
* 分页查询
*
* @param sql
* 查询的sql语句
* @param start
* 起始行
* @param limit
* 获取的行数
* @return
*/
public List<Map<String, Object>> queryPage(String sql, int start, int limit) {
Object[] args = new Object[] {};
return this.queryPage(sql, args, start, limit);
}
/**
* 分页查询
*
* @param sql
* 查询的sql语句
* @param start
* 起始行
* @param limit
* 获取的行数
*
* @param RowMapper
* @return
*/
public <T> List<T> queryPage(String sql,int start, int limit, RowMapper<T> rowMapper) throws DataAccessException {
if (start <= 0 && limit <= 0) {
return jdbcTemplate.query(sql, rowMapper);
}
Object[] args = new Object[] {};
if (start <= 1) {
sql = getLimitString(sql, false);
args = ArrayUtils.add(args, args.length, limit);
} else {
sql = getLimitString(sql, true);
args = ArrayUtils.add(args, args.length, start + limit);
args = ArrayUtils.add(args, args.length, start);
}
Pattern pattern = Pattern.compile("\\?");
Matcher matcher = pattern.matcher(sql);
for(int i = 0 ; i<args.length ; i++,matcher = pattern.matcher(sql)){
sql = matcher.replaceFirst(args[i].toString()) ;
}
logger.info("paging sql : \n" + sql);
return jdbcTemplate.query(sql, rowMapper);
}
private String getLimitString(String sql, boolean hasOffset) {
sql = sql.trim();
boolean isForUpdate = false;
if ( sql.toLowerCase().endsWith(" for update") ) {
sql = sql.substring( 0, sql.length()-11 );
isForUpdate = true;
}
StringBuffer pagingSelect = new StringBuffer( sql.length()+100 );
if (hasOffset) {
pagingSelect.append("select * from ( select row_.*, rownum rownum_ from ( ");
}
else {
pagingSelect.append("select * from ( ");
}
pagingSelect.append(sql);
if (hasOffset) {
pagingSelect.append(" ) row_ where rownum <= ?) where rownum_ > ?");
}
else {
pagingSelect.append(" ) where rownum <= ?");
}
if ( isForUpdate ) {
pagingSelect.append( " for update" );
}
return pagingSelect.toString();
}
}
分享到:
相关推荐
使用Spring的JdbcTemplate实现分页功能
jdbcTemplate分页彻底解决,使用游标滚动jdbcTemplate分页彻底解决,使用游标滚动
NULL 博文链接:https://wangking717.iteye.com/blog/774953
1. Oracle 存储过程分页 2. Java 调用 Oracle 存储过程 3. Flex 分页
Spring 框架 JdbcTemplate 类中查询方法介绍 JdbcTemplate 是 Spring 框架中 org.springframework.jdbc.core 包提供的 JDBC 模板类,它是核心类,其他模板类都是基于它封装完成的。JdbcTemplate 类主要提供四类方法...
简单的jdbcTemplate预编译、回调等
JdbcTemplate是一个框架,是用来操作数据库的,有些羡慕就是用JdbcTemplate开发的所有我们有必要去了解
最近项目中的工作流需要查询多个数据源的数据,数据源可能是不同种类的:如sql server,oracl等等,一开始是用的配置实现,后来发现在项目运行中,可能需要动态的添加更多不同类型的数据源,所以最终的逻辑是将数据源...
利用mybatisplus插件实现完美实现分页,项目中真实案例使用,一看即懂,从controller到server到dao层,甚至pom依赖以及数据库配置,还有mybatisplus插件相关的方法 重点处还做了标记,拿下来可以直接运行实现查看...
SpringJdbcTemplate封装工具包,包括规范model格式接口,封装SpringJdbcTemplate,实现分页,自适应多种数据库
spring mvc框架 jdbcTemplate 里面有查询,删除,修改,增加操作。 jdbcTemplate dataSOURCE
jdbcTemplate常用的查询方法集锦
JdbcTemplate 调用存储过程
JdbcTemplate是spring-jdbc提供的数据库核心操作类,那对JdbcTemplate进行事务控制呢?
spring-jdbcTemplate实例工程
JdbcTemplate使用就是JdbcTemplate的使用 再说两遍JdbcTemplate使用就JdbcTemplate的使用 20字够了
NULL 博文链接:https://yunzhongxia.iteye.com/blog/611591
JdbcTemplate CRUD示例
利用spring boot的jdbctemplate实现大批量数据导出数据库道文件,及文件中大批量数据导入mysql数据库