日期:2014-05-16 浏览次数:20557 次
/**
* 分页查询函数
*
* @param hql
* @param pageNo
* 页号,从1开始
* @param pageSize
* 每页尺寸
* @param values
* @return 总记录数和当前页数据的Page对象。
*/
@SuppressWarnings("unchecked")
public Page superPagedQuery(String hql, int pageNo, int pageSize,
Object... values) {
Page page = null;
try {
Session session = this.getSession(false);
// Count查询
String countQueryString = " select count (*) "
+ removeSelect(removeOrders(hql));
List countlist = this.find(session, countQueryString, values);
int totalCount = 0;
Object obj = countlist.get(0);
if (obj instanceof String) {
totalCount = Integer.parseInt((String) obj);
}
if (obj instanceof Integer) {
totalCount = (Integer) obj;
}
if (obj instanceof Long) {
totalCount = Integer.parseInt("" + obj);
}
if (totalCount < 1)
return new Page();
// 实际查询返回分页对象
int startIndex = Page.getStartOfPage(pageNo, pageSize);
Query query = createQuery(session, hql, values);
// 新加入设置查询缓存
query.setCacheable(false);
List list = null;
list = query.setFirstResult(startIndex).setMaxResults(pageSize)
.list();
page = new Page(startIndex, totalCount, pageSize, list);
} catch (Exception e) {
e.printStackTrace();
}
return page;
}
/**
* 分页查询函数(Oracle Sql)
*
* @param hql
* @param pageNo
* 页号,从1开始
* @param pageSize
* 每页尺寸
* @param values
* @return 总记录数和当前页数据的Page对象。
*/
@SuppressWarnings("unchecked")
public Page superSqlPagedQuery(String sql, int pageNo, int pageSize,
Object... values) {
if (log.isDebugEnabled()) {
log.debug("superSqlPagedQuery() start...");
}
Page page = null;
try {
// Count查询
String countQueryString = " select count(0) as cnt "
+ removeSelect(removeOrders(sql));
if(log.isInfoEnabled()){
log.info("countQueryString:"+countQueryString);
}
List countlist = this.jdbcTemplate.queryForList(countQueryString,
values);
int totalCount = 0;
Object obj = countlist.get(0);
if (obj instanceof String) {
totalCount = Integer.parseInt((String) obj);
}
if (obj instanceof Integer) {
totalCount = (Integer) obj;
}
if (obj instanceof Long) {
totalCount = Integer.parseInt("" + obj);
}
if (obj instanceof Map) {
totalCount = Integer.parseInt("" + ((Map)obj).get("cnt"));
}
if (totalCount < 1)
return new Page();
// 实际查询返回分页对象
int startIndex = Page.getStartOfPage(pageNo, pageSize);
String sqlQueryString = createSqlQuery("ora", sql, startIndex,
startIndex + pageSize);
if(log.isInfoEnabled()){
log.info("sqlQueryString:"+sqlQueryString);
}
List list = this.jdbcTemplate.queryForList(sqlQueryString, values);
page = new Page(startIndex, totalCount, pageSize, list);
} catch (Exception e) {
e.printStackTrace();
}
if (log.isDebugEnabled()) {
log.debug("superSqlPagedQuery() end");
}
return page;
}
/**
* 创建查询脚本
*
* @param session
* @param hql
* @param values
* @return
*/
public Query createQuery(Session session, String hql, Object... values) {
Query query = session.createQuery(hql);
for (int i = 0; i < values.length; i++) {
query.setParameter(i, values[i]);
}
return query;
}
/**
* 创建查询脚本(Sql)
*
*
* @param type
* ora: oracle <br/>
* mss: microsoft sql server <br/>
* mys: my sql <br/>
* db2: ibm db2<br/>
* @param sql
* @param pageStart
* @param pageEnd
* @return
*/
public String createSqlQuery(String type, String sql, int pageStart,
int pageEnd) {
if ("ora".equals(type)) {
sql = "select * from (select pTable_.*, rownum rNum_ from (" + sql
+ ") pTable_ where rownum<=" + pageEnd + ") where rNum_>="
+ pageStart;
} e