stockindao.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.StockInInfo;


/**
 * 入库单dao操作方法
 * 
 * @author yuan xinfeng
 * 
 */
public class StockInDAO {

	public StockInDAO() {

	}

	/**
	 * 添加入库单信息方法-
	 * 
	 * @param stockInId
	 * @param chargeId
	 * @param goodsId
	 * @param goodsInNumber
	 * @param typeId
	 * @param commodityId
	 * @param goodsInMemo
	 * @return boolean
	 */
	// ----------------------------添加入库单信息方法---------------------------------------
	public boolean addStockIn(String stockInId,String time, int chargeId, int goodsId,
			int goodsInNumber, int typeId, int commodityId, String goodsInMemo) {
		String stockinid = stockInId;
		int chargeid = chargeId;
		int goodsid = goodsId;
		int goodsinnum = goodsInNumber;
		int typeid = typeId;
		int commodityid = commodityId;
		String stockinmemo = goodsInMemo;
		String sql = "insert into stockininfotable(StockInId,StockInDate,ChargeId,GoodsId,GoodsInNumber,TypeId,CommodityId,GoodsInMemo) "
				+ "values (?,?,?,?,?,?,?,?)";
		DBManager db = new DBManager();// 实例化数据库对象
		db.openDB();// 打开数据库
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setString(1, stockinid);
			db.ps.setString(2,time);
			db.ps.setInt(3, chargeid);
			db.ps.setInt(4, goodsid);
			db.ps.setInt(5, goodsinnum);
			db.ps.setInt(6, typeid);
			db.ps.setInt(7, commodityid);
			db.ps.setString(8, stockinmemo);
			db.ps.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
			System.out.println("数据库连接失败!");
			return false;
		} finally {
			db.closeDB();// 最后关闭数据库
		}

		return true;
	}

	/**
	 * 根据入库单编号删除入库单信息方法
	 * 
	 * @param stockinid
	 * @return boolean
	 */
	// ---------------------------------根据入库单编号删除入库单信息方法-------------------------------------------
	public boolean delStockInBystockInId(String stockinid) {
		String sql = "delete from stockininfotable where StockInId=?";
		DBManager db = new DBManager();// 实例化数据库对象
		db.openDB();// 打开数据库
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setString(1, stockinid);
			db.ps.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
			System.out.println("数据库连接失败!");
			return false;
		} finally {
			db.closeDB();// 最后关闭数据库
		}

		return true;
	}

	/**
	 * 根据入库商品Id删除入库单信息方法(String goodsId)
	 * 
	 * @param goodsId
	 * @return boolean
	 */
	// -------------根据入库商品Id删除入库单信息方法(String goodsId)-----------
	public boolean delStockInBygoodsId(String goodsId) {
		String sql = "delete from stockininfotable where GoodsId=?";
		DBManager db = new DBManager();// 实例化数据库对象
		db.openDB();// 打开数据库
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setString(1, goodsId);
			db.ps.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
			System.out.println("数据库连接失败!");
			return false;
		} finally {
			db.closeDB();// 最后关闭数据库
		}

		return true;
	}

	/**
	 * 查询所有入库单信息的方法
	 * 
	 * @return list
	 */
	// ------------------------查询所有入库单信息的方法--------------------------------
	public List<StockInInfo> selectAllStockInInfo() {
		List<StockInInfo> list = new ArrayList<StockInInfo>();
		String sql = "select * from stockininfotable";
		DBManager db = new DBManager();// 实例化数据库对象
		db.openDB();// 打开数据库
		try {
			db.ps = db.conn.prepareStatement(sql);
			ResultSet rs = db.ps.executeQuery();
			while (rs.next()) {
				StockInInfo stockininfo = new StockInInfo(rs.getInt(1), rs
						.getString(2), rs.getString(3), rs.getInt(4), rs
						.getInt(5), rs.getInt(6), rs.getInt(7), rs.getInt(8),
						rs.getString(9));
				list.add(stockininfo);
			}
		} catch (SQLException e) {
			e.printStackTrace();
			System.out.println("数据库连接失败!");
		} finally {
			db.closeDB();// 关闭数据库
		}

		return list;
	}

	/**
	 * 根据入库单编号查询入库单的详细信息方法
	 * 
	 * @param stockinid
	 * @return list
	 */
	// ---------------------------根据入库单编号查询入库单的详细信息方法------------------------
	public List<StockInInfo> selectAllStockInInfoBystockInId(String stockinid) {
		List<StockInInfo> list = new ArrayList<StockInInfo>();
		String sql = "select * from stockininfotable where  StockInId=?";
		DBManager db = new DBManager();// 实例化数据库对象
		db.openDB();// 打开数据库
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setString(1, stockinid);
			ResultSet rs = db.ps.executeQuery();
			while (rs.next()) {
				int id = rs.getInt("id");
				stockinid = rs.getString("StockInId");
				String StockInDate = rs.getString("StockInDate");
				int ChargeId = rs.getInt("ChargeId");
				int GoodsId = rs.getInt("GoodsId");
				int GoodsInNumber = rs.getInt("GoodsInNumber");
				int TypeId = rs.getInt("TypeId");
				int CommodityId = rs.getInt("CommodityId");
				String GoodsInMemo = rs.getString("GoodsInMemo");
				StockInInfo stockininfo = new StockInInfo(id, stockinid,
						StockInDate, ChargeId, GoodsId, GoodsInNumber, TypeId,
						CommodityId, GoodsInMemo);
				list.add(stockininfo);
			}
		} catch (SQLException e) {
			e.printStackTrace();
			System.out.println("数据库连接失败!");
		} finally {
			db.closeDB();// 关闭数据库
		}
		return list;
	}
	/**
	 * 查询所有入库数据
	 * @return
	 */
	public List<StockInInfo> selectStockininfo(){
		DBManager db = new DBManager();// 实例化数据库对象
		List<StockInInfo> list = new ArrayList<StockInInfo>();
		boolean flag = db.openDB();
		String sql = "select stockininfotable.id," +
		"stockInId,stockInDate,chargeId,stockininfotable.goodsId,goodsInNumber," +
		"stockininfotable.typeId,stockininfotable.commodityId,goodsInMemo,goodsname from stockininfotable," +
		"goodsinfotable where goodsinfotable.id=stockininfotable.goodsId";
		if(flag){
			try {
				db.ps = db.conn.prepareStatement(sql);
				ResultSet rs=db.ps.executeQuery();
				while (rs.next()) {
					StockInInfo stockininfo = new StockInInfo(rs.getInt(1), rs
							.getString(2), rs.getString(3), rs.getInt(4), rs
							.getInt(5), rs.getInt(6), rs.getInt(7), rs.getInt(8),
							rs.getString(9),rs.getString(10));
				 list.add(stockininfo);
				}
			} catch (SQLException e) {
				System.out.println("查询出错");
			}
		    finally{
		    	db.closeDB();
		    }    
		}
		return list;
	}
	// ---------------------------根据id编号查询入库单的详细信息方法------------------------
	public List<StockInInfo> selectAllStockInInfoById(int id) {
		List<StockInInfo> list = new ArrayList<StockInInfo>();
		String sql = "select * from stockininfotable where  StockInId=?";
		DBManager db = new DBManager();// 实例化数据库对象
		db.openDB();// 打开数据库
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setInt(1, id);
			ResultSet rs = db.ps.executeQuery();
			while (rs.next()) {
				id = rs.getInt("id");
				String stockinid = rs.getString("StockInId");
				String StockInDate = rs.getString("StockInDate");
				int ChargeId = rs.getInt("ChargeId");
				int GoodsId = rs.getInt("GoodsId");
				int GoodsInNumber = rs.getInt("GoodsInNumber");
				int TypeId = rs.getInt("TypeId");
				int CommodityId = rs.getInt("CommodityId");
				String GoodsInMemo = rs.getString("GoodsInMemo");
				StockInInfo stockininfo = new StockInInfo(id, stockinid,
						StockInDate, ChargeId, GoodsId, GoodsInNumber, TypeId,
						CommodityId, GoodsInMemo);
				list.add(stockininfo);
			}
		} catch (SQLException e) {
			e.printStackTrace();
			System.out.println("数据库连接失败!");
		} finally {
			db.closeDB();// 关闭数据库
		}
		return list;
	}
	/**
	 * 分页查询
	 */
	public List<StockInInfo> selectstockinfoPage(int pageSize, int pageNum){
		 List<StockInInfo> list = new  ArrayList<StockInInfo>();
		 DBManager db = new DBManager();
		 db.openDB();// 打开数据库
		 
			 try{
				 db.ps = db.conn.prepareStatement("select top " + pageSize
							+ "* from stockininfotable where Id not in(select top "
							+ pageSize * pageNum
							+ " Id from stockininfotable order by Id)order by Id");
				 ResultSet rs=db.ps.executeQuery();
				 while (rs.next()) {
						StockInInfo stockininfo = new StockInInfo(rs.getInt(1), rs
								.getString(2), rs.getString(3), rs.getInt(4), rs
								.getInt(5), rs.getInt(6), rs.getInt(7), rs.getInt(8),
								rs.getString(9));
						list.add(stockininfo);
					}
			 }catch(Exception e){
				 System.out.print("数据库连接失败!！");
			 }finally {
					db.closeDB();// 关闭数据库
				}
		
		return list;
			 
			}

	/**
	 * 通过页面大小获取总页数(2009.2.17 袁新锋修改)
	 * 
	 * @param pageSize
	 * @return num
	 */
	public int getPageNum(int pageSize) {
		int num = 0;
		DBManager db = new DBManager();
		db.openDB();// 打开数据库
		try {
			db.ps = db.conn
					.prepareStatement("select count(*) from stockininfotable");
			ResultSet rs = db.ps.executeQuery();
			while (rs.next()) {
				num = rs.getInt(1);
			}
			if (num % pageSize == 0) {
				return num / pageSize;
			} else {
				return num / pageSize + 1;
			}
		} catch (SQLException e) {
			System.out.println("数据库连接失败！");
			e.printStackTrace();
		} finally {
			db.closeDB();
		}
		return num;
	}
}