pagedbbean.java

通用的jsp分页组件

package Action;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Vector;

public class PageDbBean {
	private Connection con;
	private Statement stmt;
	private ResultSet rs;
	
	public PageDbBean(Connection pm_objCon)
	{
		con = pm_objCon;
	}
	
	/**
	 * @param pm_sSql sql语句
	 * @param pm_sTitle 设置标题
	 * @return 结果集
	 */
	public Vector getResultBySql(String pm_sSql,String [] pm_sTitle)
	{
		try
		{
			stmt = this.con.createStatement();
			rs = stmt.executeQuery(pm_sSql);
			Vector result = new Vector();
			
			ResultSetMetaData meta = rs.getMetaData();
			int colNum = meta.getColumnCount();
			for(int j=0;j<colNum;j++)
			{
				pm_sTitle[j] = meta.getColumnName(j+1);
			}
			while(rs.next())
			{
				Vector rowVector = new Vector();
				for(int i=0;i<colNum;i++)
				{
					rowVector.add(rs.getString(i+1));
				}
				result.add(rowVector);
				
			}
			return result;
		}
		catch(SQLException es)
		{
			System.out.println("PageDbBean:SQL操作异常！");
			es.printStackTrace();
			return null;
		}
		finally
		{
			try {
				rs.close();
				stmt.close();
			} 
			catch (SQLException e) 
			{
				System.out.println("资源回收失败！");
				e.printStackTrace();
				
			}
			
		}
	}
	
	/**
	 * @param pm_sSql sql语句
	 * @param pm_sTitle 设置标题
	 * @return 结果集
	 */
	public Vector getResultBySql2(String pm_sSql,String [] pm_sTitle)
	{
		try
		{
			stmt = this.con.createStatement();
			rs = stmt.executeQuery(pm_sSql);
			Vector result = new Vector();
			
			ResultSetMetaData meta = rs.getMetaData();
			int colNum = meta.getColumnCount();
			for(int j=1;j<colNum;j++)
			{
				pm_sTitle[j-1] = meta.getColumnName(j+1);
			}
			while(rs.next())
			{
				Vector rowVector = new Vector();
				for(int i=1;i<colNum;i++)
				{
					rowVector.add(rs.getString(i+1));
				}
				result.add(rowVector);
				
			}
			return result;
		}
		catch(SQLException es)
		{
			System.out.println("PageDbBean:SQL操作异常！");
			es.printStackTrace();
			return null;
		}
		finally
		{
			try {
				rs.close();
				stmt.close();
			} 
			catch (SQLException e) 
			{
				System.out.println("资源回收失败！");
				e.printStackTrace();
				
			}
			
		}
	}
	/**
	 * @param pm_sSql
	 * @return 总记录数
	 */
	public int getTotalCount(String pm_sSql)
	{
		try
		{
			stmt = con.createStatement();
			rs = stmt.executeQuery("select count(*) from ("+pm_sSql+")");
			rs.next();
			int rowTotal = rs.getInt(1);
			return rowTotal;
		}
		catch(SQLException es)
		{
			System.out.println("PageDbBean:SQL操作异常");
			es.printStackTrace();
			return -1;
		}
		finally
		{
			try
			{
				this.rs.close();
				this.stmt.close();
			}
			catch(SQLException es2)
			{
				System.out.println("PageDbBean:资源回收失败！");
				es2.printStackTrace();
				
			}
		}
	}

}