pagequery.java

本程序使用struts+hibernate实现的oa办公系统

package com.km.util;

import java.sql.*;

public class PageQuery {

	public ResultSet sqlQueryPage(Statement statement, String pageSql,String addsql,
			PageListData pageList) throws SQLException {

		ResultSet resultSet = null;
                int countNum = 0;
                if(addsql == null)
                  addsql = "";

		try {

			//获得总的记录的数目，并且把总的记录数目封装入page
			String countSql = "";
			countSql = "select count(1) as NUM "
					+ pageSql.substring(pageSql.indexOf("from"), pageSql
							.length());
			resultSet = statement.executeQuery(countSql);

			while (resultSet.next()) {
				countNum = resultSet.getInt("NUM");
			}
			pageList.clearDataArray();
			pageList.setCount(countNum);

			//执行数据库查询的基类
			resultSet = statement.executeQuery(pageSql+addsql);

			//设置总的页数
			pageList.setPageCount(((pageList.getCount() + pageList
					.getPageSize()) - 1)
					/ pageList.getPageSize());

			if (pageList.getPage() > pageList.getPageCount())
				pageList.setPage(pageList.getPageCount());

			if (pageList.getPage() != -1 && pageList.getPage() != 1
					&& pageList.getPage() != 0)
				for (int i = 0; i < (pageList.getPage() - 1)
						* pageList.getPageSize(); i++)
					resultSet.next();
			//Sybase的驱动程序没有提供支持absolute的方法，以后如果提供可以采用下面的方法
			//resultSet.absolute((page.getPage() - 1) * page.getPageSize());

		} catch (SQLException sqlException) {
			sqlException.printStackTrace();
			throw sqlException;
		}

		return resultSet;

	}

}