warehousedao.java

老牌java开发的物流管理系统 详细的我也没有怎么看 好像是恒基的

package com.wl.dao;

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

import com.wl.dbconnection.DBManager;

import com.wl.entity.WareHouseInfo;

/**
 * 封装仓库位置信息DAO
 * @author tianxiaoshun
 *
 */
public class WarehouseDAO {
   DBManager dbmanager=new DBManager();
   boolean flage;
   /**
    * 查询仓库信息方法封装
    * @param warehouseinfo
    * @return
    */
   public boolean insertWarehouse(WareHouseInfo warehouseinfo){
	   flage=dbmanager.openDB();
	   if(flage){
		   try{
	   dbmanager.ps=dbmanager.conn.prepareStatement("insert into warehouseinfotable values(?,?,?,?)");
	   dbmanager.ps.setString(1, warehouseinfo.getWareHouseId());
	   dbmanager.ps.setString(2, warehouseinfo.getWareHouseName());
	   dbmanager.ps.setInt(3, warehouseinfo.getChargeId());
	   dbmanager.ps.setString(4, warehouseinfo.getWareHouseAddress());
	   dbmanager.ps.executeUpdate();
		   }
		   catch(Exception e){
			   return false;
		   }
		   finally{
			   dbmanager.closeDB();
		   }
		   return true;
	   }
	   else{
		
		   return false;
	   }
	   
   }
   /**
    * 封装查询所有仓库信息方法
    * @return list
    */
//   public List<WareHouseInfo> selectAllWarehouseInfo(){
//	   List<WareHouseInfo> list=new ArrayList<WareHouseInfo>();
//	   flage=dbmanager.openDB();
//	   WareHouseInfo warehouseinfo;
//	   if(flage){
//		   try{
//			   dbmanager.ps=dbmanager.conn.prepareStatement("select * from warehouseinfotable");
//			   ResultSet st=dbmanager.ps.executeQuery();
//			   while(st.next()){
//				   warehouseinfo=new WareHouseInfo(st.getInt(1),st.getString(2),st.getString(3),st.getInt(4),st.getString(5));
//				   list.add(warehouseinfo);
//			   }
//		   }
//		   catch(Exception e){
//			   System.out.print("查询仓库信息出错！");
//		   }
//		   finally{
//			dbmanager.closeDB();   
//		   }
//	   }
//	   else{
//		System.out.print("数据库打开失败！");   
//	   }
//	   return list;
//   }
   /**
    * 
    * @param warehouseId
    * @return boolean
    */
   public boolean deleteWarehouseInfoByWarehouseId(int id){
	   flage=dbmanager.openDB();
	   if(flage){
	   try{
			   dbmanager.ps=dbmanager.conn.prepareStatement("delete warehouseinfotable where Id=?");
			   dbmanager.ps.setInt(1, id);
			   dbmanager.ps.executeUpdate();
		   }
	   catch(Exception e){
			return false;   
		   }
	   finally{
		   dbmanager.closeDB();
	   }
		   return true;
	   }
	   else{
		   return false;
	   }	   
   }
   /**
    * 封装查询所有仓库信息方法
    * @return list
    */
   public List<WareHouseInfo> selectAllWarehouseInfo1(){
	   List<WareHouseInfo> list=new ArrayList<WareHouseInfo>();
	   String sql ="select w.id,warehouseid,warehousename,chargeid,warehouseadd,loginname from warehouseinfotable w join LoginTable l on w.chargeid=l.id";
	   flage=dbmanager.openDB();
	   if(flage){
		   try{
			   dbmanager.ps=dbmanager.conn.prepareStatement(sql);
			   ResultSet st=dbmanager.ps.executeQuery();
			   while(st.next()){
				   int id = st.getInt("Id");
				   String wareHouseid = st.getString("warehouseid");
				   String warehousename = st.getString("warehousename");
				   int chargeid = st.getInt("chargeid");
				   String name = st.getString("loginname");
				   String warehouseaddress = st.getString("warehouseadd");
				   WareHouseInfo warehouseinfo = new WareHouseInfo(id,wareHouseid,warehousename,
						   chargeid,name,warehouseaddress);
				   list.add(warehouseinfo);
			   }
		   }
		   catch(Exception e){
			   System.out.print("查询仓库信息出错！");
		   }
		   finally{
			dbmanager.closeDB();   
		   }
	   }
	   else{
		System.out.print("数据库打开失败！");   
	   }
	   return list;
   }
   
   public List<WareHouseInfo> selectAllWarehouseInfo(){
	   List<WareHouseInfo> list=new ArrayList<WareHouseInfo>();
	   String sql ="select w.Id,WareHouseId,WareHouseName,WareHouseAdd,EmployeeName from warehouseinfotable w join employeeinfotable e on w.chargeid=e.id";
	   flage=dbmanager.openDB();
	   if(flage){
		   try{
			   dbmanager.ps=dbmanager.conn.prepareStatement(sql);
			   ResultSet st=dbmanager.ps.executeQuery();
			   while(st.next()){
				   int id = st.getInt("Id");
				   String wareHouseid = st.getString("warehouseid");
				   String warehousename = st.getString("warehousename");
				   String cname = st.getString("cname");
				   String warehouseaddress = st.getString("warehouseadd");
				   WareHouseInfo warehouseinfo = new WareHouseInfo(id,wareHouseid,warehousename,
						  cname,warehouseaddress);
				   list.add(warehouseinfo);
			   }
		   }
		   catch(Exception e){
			   System.out.print("查询仓库信息出错！");
		   }
		   finally{
			dbmanager.closeDB();   
		   }
	   }
	   else{
		System.out.print("数据库打开失败！");   
	   }
	   return list;
   }
   
   /**
	 * 分页查询
	 */
	public List<WareHouseInfo> selectWareHousePage(int pageSize, int pageNum){
		 List<WareHouseInfo> list = new  ArrayList<WareHouseInfo>();
		 flage =dbmanager.openDB();// 打开数据库
		 if(flage){
			 
				 try {
					dbmanager.ps = dbmanager.conn.prepareStatement("select top " + pageSize
								+ "w.id,warehouseid,warehousename,chargeid,warehouseadd,loginname from warehouseinfotable w join LoginTable l on w.chargeid=l.id where w.Id not in(select top "
								+ pageSize * pageNum
								+ " w.Id from warehouseinfotable w join LoginTable l on w.chargeid=l.id order by w.Id)order by w.Id");
					 ResultSet st=dbmanager.ps.executeQuery();
					 while(st.next()){
						   int id = st.getInt("Id");
						   String wareHouseid = st.getString("warehouseid");
						   String warehousename = st.getString("warehousename");
						   int chargeid = st.getInt("chargeid");
						   String name = st.getString("loginname");
						   String warehouseaddress = st.getString("warehouseadd");
						   WareHouseInfo warehouseinfo = new WareHouseInfo(id,wareHouseid,warehousename,
								   chargeid,name,warehouseaddress);
						   list.add(warehouseinfo);
					 }
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				} finally{
					 dbmanager.closeDB();
				 }  
				
		 }
		return list;
			 
		}
//  public static void main(String [] args){
//	  WarehouseDAO dao = new WarehouseDAO();
//	  System.out.print("*********"+dao.selectWareHousePage(1, 1));
//  }
	/**
	 * 通过页面大小获取总页数(2009.2.17 袁新锋修改)
	 * 
	 * @param pageSize
	 * @return num
	 */
	public int getPageNum(int pageSize) {
		int num = 0;
		flage=dbmanager.openDB();// 打开数据库
		if(flage){
			try {
				dbmanager.ps = dbmanager.conn
				.prepareStatement("select count(*) from warehouseinfotable w join LoginTable");
				ResultSet rs = dbmanager.ps.executeQuery();
				while (rs.next()) {
					num = rs.getInt(1);
				}
				if (num % pageSize == 0) {
					return num / pageSize;
				} else {
					return num / pageSize + 1;
				}
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		}
		return num;
			}
	public static void main(String [] args){
		  WarehouseDAO dao = new WarehouseDAO();
		  System.out.print("*********"+dao.getPageNum(2));
	  }
	/**
	    * 
	    * @param warehouseId
	    * @return boolean
	    */
	   public boolean deleteWarehouseInfoByWarehouseId1(int id){
		   flage=dbmanager.openDB();
		   if(flage){
		   try{
				   dbmanager.ps=dbmanager.conn.prepareStatement("delete warehouseinfotable where Id=?");
				   dbmanager.ps.setInt(1, id);
				   dbmanager.ps.executeUpdate();
			   }
		   catch(Exception e){
				return false;   
			   }
		   finally{
			   dbmanager.closeDB();
		   }
			   return true;
		   }
		   else{
			   return false;
		   }
		   
	   }
	   /**
	    * 根据仓库编号查询仓库详细信息
	    * @param wareHouseId
	    * @return
	    */
	   public WareHouseInfo SeletewareHouseId(int wareHouseId){
		   String sql = "select * from warehouseinfotable where Id=?";
		   flage = dbmanager.openDB();
		   WareHouseInfo w = null;
		   if(flage){
			   try {
				dbmanager.ps = dbmanager.conn.prepareStatement(sql);
				dbmanager.ps.setInt(1, wareHouseId);
				ResultSet rs = dbmanager.ps.executeQuery();
				while(rs.next()){
				 w = new WareHouseInfo(rs.getInt(1),rs.getString(2),rs.getString(3),rs.getInt(4),rs.getString(5));
				}
			} catch (Exception e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			finally{
				dbmanager.closeDB();
			}		   
		   }
		return w;
	   }
	   /**
	    * 修改仓库的的方法
	    * @param w
	    * @return
	    */
	   public int UpdatewareHouse(WareHouseInfo w){
		   flage = dbmanager.openDB();
		   int rows= 0;
		   String sql = "update warehouseinfotable set wareHouseId=?,wareHouseName=?,chargeId=?,wareHouseAdd=? where Id=?";
		   if(flage){
			   try {
				dbmanager.ps = dbmanager.conn.prepareStatement(sql);
				dbmanager.ps.setString(1, w.getWareHouseId());
				dbmanager.ps.setString(2, w.getWareHouseName());
				dbmanager.ps.setInt(3, w.getChargeId());
				dbmanager.ps.setString(4, w.getWareHouseAddress());
	        	dbmanager.ps.setInt(5, w.getId());
				rows = dbmanager.ps.executeUpdate();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			 finally{
				 dbmanager.closeDB();
			 }  
		   }
		return rows;
	   }
		
}