pageuserinfodao.java

一个简单的汽车租赁系统 jsp+struts+oracle

				startIndex = (lastPageNo - 1)*pageSize;
				endIndex = startIndex + pageSize;
				pageNo = lastPageNo;
			}
			/**
			 * 定位游标到分页的第一条记录之前的记录
			 */
			if(startIndex == 0){
				resultSet.beforeFirst();
			}else{
				resultSet.absolute(startIndex);
			}
			while(resultSet.next() && resultSet.getRow() <= endIndex){
				UserInfo user1 = new UserInfo();
				Role role = new Role();
				user1.setUsername(resultSet.getString("USERNAME"));
				user1.setIdentity(resultSet.getString("IDENTITY"));
				user1.setFullname(resultSet.getString("FULLNAME"));
				user1.setMale(resultSet.getInt("SEX") == 1?"true":"false");
				user1.setAddRess(resultSet.getString("ADDRESS"));
				role.setRoleid(resultSet.getInt("ROLEID"));
				role.setRolename(resultSet.getString("ROLENAME"));
				user1.setRole(role);
				
				user1.setPhone(resultSet.getString("PHONE"));
				user1.setPosition(resultSet.getString("POSITION"));
				
				user1.setUserpwd(resultSet.getString("USERPWD"));	
				userinfolist.add(user1);
			}
			
			page = new Page(userinfolist, pageNo, pageSize, recordSize);
		}
		resultSet.close();
		preparedStatement.close();
		connection.close();
		return page;
	}
	public Page browseCustomer(int pageNo,int pageSize,Customer customer) throws Exception{
		if(pageNo<1){
			pageNo = 1;
		}
		List<Object> customerlist = new ArrayList<Object>();
		int recordSize = 0;
		int startIndex = (pageNo-1) * pageSize;
		int endIndex = startIndex + pageSize;
		Page page = Page.EMPTY_PAGE;
		Connection connection = null;
		connection=JdbcUtil.getInstance().getConn();
		String sql = genSQLCustomer(customer);
		PreparedStatement preparedStatement = connection.prepareStatement(
				sql, ResultSet.TYPE_SCROLL_INSENSITIVE,
				ResultSet.CONCUR_READ_ONLY);
		
		ResultSet resultSet = preparedStatement.executeQuery();
		
		if(resultSet.last()){
			/**
			 * 得到最后记录的行号, 也就是记录总数
			 */
			recordSize = resultSet.getRow();
			/**
			 * 容错处理, 如果申请分页第一个记录超过记录总数, 使用上一个分页
			 */
			if(startIndex >= recordSize){
				int lastPageNo = (int) Math.ceil((double) recordSize/ pageSize);
				startIndex = (lastPageNo - 1)*pageSize;
				endIndex = startIndex + pageSize;
				pageNo = lastPageNo;
			}
			/**
			 * 定位游标到分页的第一条记录之前的记录
			 */
			if(startIndex == 0){
				resultSet.beforeFirst();
			}else{
				resultSet.absolute(startIndex);
			}
			while(resultSet.next() && resultSet.getRow() <= endIndex){
				Customer customer1 = new Customer();
				customer1.setAddress(resultSet.getString("ADDRESS"));
				customer1.setCareer(resultSet.getString("CAREER"));
				customer1.setCustname(resultSet.getString("CUSTNAME"));
				customer1.setCustpwd(resultSet.getString("CUSTPWD"));
				customer1.setIdentity(resultSet.getString("IDENTITY"));
				customer1.setPhone(resultSet.getString("PHONE"));
				customer1.setSex(resultSet.getInt("SEX") == 1?"true":"false");
				customerlist.add(customer1);
			}
			
			page = new Page(customerlist, pageNo, pageSize, recordSize);
		}
		resultSet.close();
		preparedStatement.close();
		connection.close();
		return page;
	}
	public Page browseCar(int pageNo,int pageSize,Car car) throws Exception{
		if(pageNo<1){
			pageNo = 1;
		}
		List<Object> carlist = new ArrayList<Object>();
		int recordSize = 0;
		int startIndex = (pageNo-1) * pageSize;
		int endIndex = startIndex + pageSize;
		Page page = Page.EMPTY_PAGE;
		Connection connection = null;
		connection=JdbcUtil.getInstance().getConn();
		String sql = genSQLCar(car);		
		PreparedStatement preparedStatement = connection.prepareStatement(
				sql, ResultSet.TYPE_SCROLL_INSENSITIVE,
				ResultSet.CONCUR_READ_ONLY);
		
		ResultSet resultSet = preparedStatement.executeQuery();
		
		if(resultSet.last()){
			/**
			 * 得到最后记录的行号, 也就是记录总数
			 */
			recordSize = resultSet.getRow();
			/**
			 * 容错处理, 如果申请分页第一个记录超过记录总数, 使用上一个分页
			 */
			if(startIndex >= recordSize){
				int lastPageNo = (int) Math.ceil((double) recordSize/ pageSize);
				startIndex = (lastPageNo - 1)*pageSize;
				endIndex = startIndex + pageSize;
				pageNo = lastPageNo;
			}
			/**
			 * 定位游标到分页的第一条记录之前的记录
			 */
			if(startIndex == 0){
				resultSet.beforeFirst();
			}else{
				resultSet.absolute(startIndex);
			}
			while(resultSet.next() && resultSet.getRow() <= endIndex){
				Car car1 = new Car();
				car1.setCarid(resultSet.getString("CARID"));
				car1.setCartype(resultSet.getString("CARTYPE"));
				car1.setCarlor(resultSet.getString("COLOR"));
				car1.setPrice(resultSet.getInt("PRICE"));
				car1.setRentprice(resultSet.getInt("RENTPRICE"));
				car1.setDeposit(resultSet.getInt("DEPOSIT"));
				car1.setIsrenting(resultSet.getString("ISRENTING") );
				car1.setDescription(resultSet.getString("DESCRIPTION"));
				carlist.add(car1);
			}
			
			page = new Page(carlist, pageNo, pageSize, recordSize);
		}
		resultSet.close();
		preparedStatement.close();
		connection.close();
		return page;
	}
	public Page browseCheckTable(int pageNo,int pageSize,Check check) throws Exception{
		if(pageNo<1){
			pageNo = 1;
		}
		List<Object> checklist = new ArrayList<Object>();
		int recordSize = 0;
		int startIndex = (pageNo-1) * pageSize;
		int endIndex = startIndex + pageSize;
		Page page = Page.EMPTY_PAGE;
		Connection connection = null;
		connection=JdbcUtil.getInstance().getConn();
		String sql = genSQLCheckTable(check);	
		PreparedStatement preparedStatement = connection.prepareStatement(
				sql, ResultSet.TYPE_SCROLL_INSENSITIVE,
				ResultSet.CONCUR_READ_ONLY);
		
		ResultSet resultSet = preparedStatement.executeQuery();
		
		if(resultSet.last()){
			/**
			 * 得到最后记录的行号, 也就是记录总数
			 */
			recordSize = resultSet.getRow();
			/**
			 * 容错处理, 如果申请分页第一个记录超过记录总数, 使用上一个分页
			 */
			if(startIndex >= recordSize){
				int lastPageNo = (int) Math.ceil((double) recordSize/ pageSize);
				startIndex = (lastPageNo - 1)*pageSize;
				endIndex = startIndex + pageSize;
				pageNo = lastPageNo;
			}
			/**
			 * 定位游标到分页的第一条记录之前的记录
			 */
			if(startIndex == 0){
				resultSet.beforeFirst();
			}else{
				resultSet.absolute(startIndex);
			}
			while(resultSet.next() && resultSet.getRow() <= endIndex){
				Check check1 = new Check();
				check1.setCheckdate(resultSet.getDate("CHECKDATE"));
				check1.setCheckid(resultSet.getInt("CHECKID"));
				check1.setCheckuserid(resultSet.getString("USERNAME"));
				check1.setRentid(resultSet.getString("TABLEID"));
				check1.setProblem(resultSet.getString("PROBLEM"));
				check1.setPaying(resultSet.getInt("PAYING"));
				checklist.add(check1);
			}
			
			page = new Page(checklist, pageNo, pageSize, recordSize);
		}
		resultSet.close();
		preparedStatement.close();
		connection.close();
		return page;
	}
}