userbeanpagemanage.java

来自「本方案是在与***信息技术（北京）有限公司相关人员协商并分析了北京****投资有」· Java 代码 · 共 74 行

package com.test.dao.userpage;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import com.test.model.UserBean;

public class UserBeanPageManage extends PageManage {
	private final String USERBEANTABLENAME = "insert_info";
	
	/**
	 * 使用默认参数构造一个分页管理器
	 */
	public UserBeanPageManage(){
		this.tableName = USERBEANTABLENAME;
	}
	
	/**
	 * 使用指定的参数构造一个分页管理器 
	 * @param rowsInPage 每页显示多少行
	 * @throws PageConfigException 每页显示行数小于1则抛出此异常
	 */
	public UserBeanPageManage(int rowsInPage) {
		if(this.rowsInPage==0){
			if(rowsInPage>0){
				this.rowsInPage = rowsInPage;	
			}
		}
		this.tableName = USERBEANTABLENAME;
	}
	
	//方法实现
	public IPage queryByPageIndex(Connection conn, int currPage) {
		this.currPage = currPage;//设置当前页码
		try {
			Statement stat = conn.createStatement();
			this.setRowsCount(stat);//设置总行数
			this.setPageCount();//设置总页数
			String sql = "select * from "+USERBEANTABLENAME+" limit "
				+(this.currPage-1)*this.rowsInPage+","+this.rowsInPage;
			ResultSet rs = stat.executeQuery(sql);
			List users = new ArrayList(this.rowsInPage+2);
			while(rs.next()){
				UserBean user = new UserBean();
				user.setPk_id(rs.getInt(1));
				user.setUsername(rs.getString(2));
				user.setStr_a(rs.getString(3));
				user.setStr_b(rs.getString(4));
				user.setCexist(rs.getBoolean(5));
				user.setCreateNow(rs.getInt(6));
				users.add(user);
			}
			rs.close();
			stat.close();
			this.data = users;
			return this;
		} catch (SQLException e) {
			e.printStackTrace();
			throw new RuntimeException("PageManage:数据读取错误，请重试");
		} finally{
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
	
}