import org.apache.commons.lang3.StringUtils; import java.util.HashSet; import java.util.Set; /** * TODO * */ public class PageSelectSqlTest { public static void main(String[] args) { String table = "T_student"; Set<String> tableFieldSet = new HashSet<>(); tableFieldSet.add("name"); tableFieldSet.add("gender"); tableFieldSet.add("age"); String whereSql = "age >= 18"; String dbType = "oracle"; String sql = getSelectPageSql(table, tableFieldSet, 0, 2, whereSql, dbType); System.out.println(sql); } /** * 拼接分页查询SQL语句 * @param table 数据库表名 * @param tableFieldSet 要查询字段名集合 * @param pageNum 页数 * @param pageSize 每页查询数量 * @param whereSql where后面条件语句 * @param dbType 数据库类型 * @return */ private static String getSelectPageSql(String table, Set<String> tableFieldSet, int pageNum, int pageSize, String whereSql, String dbType) { // 拼接SQL StringBuffer fieldSb = new StringBuffer(); tableFieldSet.forEach(field -> { if (StringUtils.isNotBlank(field)) fieldSb.append(field).append(","); }); String fieldStr = fieldSb.toString().substring(0, fieldSb.toString().lastIndexOf(",")); StringBuffer sqlSb = new StringBuffer(); int start = pageNum * pageSize; if ("sql_server".equalsIgnoreCase(dbType)) { sqlSb.append("select top ").append(pageSize).append(" ").append(fieldStr).append(" from ").append(table); if (pageNum == 0) { if (StringUtils.isNotBlank(whereSql)) { sqlSb.append(" where ").append(whereSql); } } else { sqlSb.append(" t1 where t1.id > (select max(a.id) from (select top ").append(start).append(" t2.id from ").append(table).append(" t2"); if (StringUtils.isNotBlank(whereSql)) { sqlSb.append(" where ").append(whereSql); } sqlSb.append(" order by id) a)"); if (StringUtils.isNotBlank(whereSql)) { sqlSb.append(" and ").append(whereSql); } } sqlSb.append(" order by id"); } else if ("mysql".equalsIgnoreCase(dbType)) { sqlSb.append("select ").append(fieldStr).append(" from " ).append(table); if (StringUtils.isNotBlank(whereSql)) { sqlSb.append(" where ").append(whereSql); } sqlSb.append(" order by id limit ").append(start).append(", ").append(pageSize); } else if ("oracle".equalsIgnoreCase(dbType)) { int end = (pageNum + 1) * pageSize; sqlSb.append("select ").append(fieldStr).append(" from ("); sqlSb.append("select table1.*, ROWNUM rowno from ("); sqlSb.append("select ").append(fieldStr).append(" from ").append(table); if (StringUtils.isNotBlank(whereSql)) { sqlSb.append(" where ").append(whereSql); } sqlSb.append(" order by id) table1 where ROWNUM <= ").append(end); sqlSb.append(") table2 where table2.rowno > ").append(start); } else if ("db2".equalsIgnoreCase(dbType)) { int end = (pageNum + 1) * pageSize; sqlSb.append("select ").append(fieldStr).append(" from ("); sqlSb.append("select row_number() over() as rownum, ").append(fieldStr); sqlSb.append(" from ").append(table); if (StringUtils.isNotBlank(whereSql)) { sqlSb.append(" where ").append(whereSql); } sqlSb.append(" order by id) table1 where rownum > ").append(start).append(" and rownum <= ").append(end); } return sqlSb.toString(); } }
测试结果:
--sqlserver select top 2 gender,name,age from T_student where age >= 18 order by id select top 2 gender,name,age from T_student where id > ( select max(a.id) from (select top 2 t1.id from T_student t1 where age >= 18 order by id) a ) and age >= 18 order by id --mysql select gender,name,age from T_student where age >= 18 order by id limit 0, 2 --orcale select gender,name,age from ( select table1.*, ROWNUM rowno from ( select gender,name,age from T_student where age >= 18 order by id ) table1 where ROWNUM <= 2 ) table2 where table2.rowno > 0 --db2 select gender,name,age from ( select row_number() over() as rownum,gender,name,age from T_student where age >= 18 order by id ) table1 where rownum > 0 and rownum <= 2