public enum DBTypeEnumPager {
MYSQL("MySQL") {
@Override
public String doPage(String sql, int rowPerPage, int page, DBETLOptional optional) {
int offset = (page - 1) * rowPerPage;
sql = sql + " LIMIT " + offset + "," + rowPerPage;
return sql;
}
},MSSQL("MsSql") {
@Override
public String doPage(String sql, int rowPerPage, int page, DBETLOptional optional) {
if(StringUtils.isEmpty(optional.fromTableName())
|| StringUtils.isEmpty(optional.inputPk())){
throw new DBETLException("sqlserver数据库使用分页，必须指定inputPk和fromTableName");
}
String pageSql = "SELECT TOP " + rowPerPage + " * FROM " + optional.fromTableName()
+ " WHERE " + optional.inputPk() + " NOT IN(SELECT TOP "
+ (page - 1)*rowPerPage + " " + optional.inputPk() + " FROM " + optional.fromTableName() + ")";
return pageSql;
}
},ORACLE("Oracle") {
@Override
public String doPage(String sql, int rowPerPage, int page, DBETLOptional optional) {
return toOraclePageSql(sql, page, rowPerPage);
}
},DM("DM DBMS") {
@Override
public String doPage(String sql, int rowPerPage, int page, DBETLOptional optional) {
return toOraclePageSql(sql, page, rowPerPage);
}
};
private static String toOraclePageSql(String sql, int page, int rowPerPage){
int startRowNum = (page - 1) * rowPerPage + 1;
int endRowNum = startRowNum + rowPerPage - 1;
String pageSql =
"SELECT * FROM ( "
+ " SELECT rownum r_,a.* "
+ " FROM ( "
+ sql
+ " ) a "
+ " ) b "
+ "WHERE b.r_>=" + startRowNum + " AND b.r_<=" + endRowNum;
return pageSql;
}
public abstract String doPage(String sql, int rowPerPage, int page, DBETLOptional optional);
public static DBTypeEnumPager convert(String desc){
for (DBTypeEnumPager em : DBTypeEnumPager.values()) {
if(em.desc.equals(desc)){
return em;
}
}
return null;
}
private String desc;
private DBTypeEnumPager(String desc){
this.desc = desc;
}
public String toString(){
return this.desc;
}
}
转载请注明原文地址: https://ju.6miu.com/read-678001.html
