storagedao.java

固定资产管理系统 资产的增删改查 借出 管理 自动报废 统计功能等等

package com.qrsx.asset.dao;

import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

import com.qrsx.asset.model.Page;
import com.qrsx.asset.model.Storage;
/**
 * 
 * @author 马利永
 *
 */
public class StorageDAO extends BaseDAO {

	/**
	 * 创建仓库信息
	 */
	public void create(Storage storage) throws Exception {
		String sql = "insert into storage(name,description) values(?,?)";

		ps = conn.prepareStatement(sql);
		processStatement1(storage, ps, sql);

		ps.executeUpdate();
	}

	/**
	 * 删除仓库信息
	 */
	public void delete(Integer id) throws Exception {
		String sql = "delete from storage where id = ?";

		ps = conn.prepareStatement(sql);
		ps.setInt(1, id);

		ps.executeUpdate();
	}

	/**
	 * 更新仓库信息
	 */
	public void update(Storage storage) throws Exception {
		String sql = "update storage set name=?, description=? where id=?";

		ps = conn.prepareStatement(sql);
		processStatement1(storage, ps, sql);

		ps.executeUpdate();
	}

	/**
	 * 根据ID检索仓库信息
	 */
	public Storage findById(Integer id) throws Exception {
		String sql = "select * from storage where id = ? ";

		ps = conn.prepareStatement(sql);
		ps.setInt(1, id);

		ResultSet rs = ps.executeQuery();
        
		Storage storage = new Storage();
		if (rs.next()) {
			processResultset(storage, rs);
		}
		return storage;
	}

	/**
	 * 检索全部仓库信息
	 */
	public List<Storage> findAll() throws Exception {
		String sql = "select * from storage ";

		ps = conn.prepareStatement(sql);
		ResultSet rs = ps.executeQuery();
		List<Storage> list = new ArrayList<Storage>();
		while (rs.next()) {
			Storage storage1 = new Storage();
			processResultset(storage1, rs);
			list.add(storage1);
		}
		return list;

	}

	/**
	 * 动态检索仓库信息
	 */
	public Object[] list(Storage storage, Integer currentpage) throws Exception {
		String sql = "select * from storage where 1=1 ";
		if (storage.getName() != null) {
			sql = sql + " and name like'%"+storage.getName()+"%' ";
		}
		ps = conn.prepareStatement(sql);
		ResultSet rs = ps.executeQuery();
		
		Page page = new Page();
		pageIndex(page,rs,currentpage);      
		List<Storage> list = new ArrayList<Storage>();		
		while (rs.next()&&list.size()< page.getSize()){
			Storage storage1 = new Storage();
			processResultset(storage1, rs);
			list.add(storage1);		
		}	
		Object[] object = {list,page};
		return object;
	}
	


}