departmentinfodao.java

来自「老牌java开发的物流管理系统 详细的我也没有怎么看 好像是恒基的」· Java 代码 · 共 280 行

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.Departmentinfo;

/**
 * 部门DAO
 * 
 * @author wangJianwei
 * 
 */
public class DepartmentinfoDAO {

	DBManager db = new DBManager();
	boolean flag;
	ResultSet rs = null;

	/**
	 * 添加一个部门
	 * 
	 * @param d
	 * @return boolean
	 */
	public boolean insertDepartment(Departmentinfo d) {
		flag = db.openDB();
		if (flag) {
			String sql = "insert into departmentinfotable values(?,?)";
			try {
				db.ps = db.conn.prepareStatement(sql);
				db.ps.setString(1, d.getDepartmentId());
				db.ps.setString(2, d.getDepartmentName());
				db.ps.executeUpdate();
			} catch (SQLException e) {
				e.printStackTrace();
			} finally {
				db.closeDB();
			}
			return true;
		} else {
			return false;
		}
	}

	/**
	 * 根据编号查询某个编号的详细信息
	 * 
	 * @param id
	 * @return d
	 */
	public Departmentinfo queryDepartmentId(int id) {
		flag = db.openDB();
		Departmentinfo d = null;
		if (flag) {
			String sql = "select * from departmentinfotable where Id=?";
			try {
				db.ps = db.conn.prepareStatement(sql);
				db.ps.setInt(1, id);
				rs = db.ps.executeQuery();
				while (rs.next()) {
					d = new Departmentinfo(rs.getInt(1), rs.getString(2), rs
							.getString(3));
				}
			} catch (SQLException e) {
				e.printStackTrace();
			} finally {
				db.closeDB();
			}
		}
		return d;
	}
	public Departmentinfo queryDepartmentId(String departmentId) {
		flag = db.openDB();
		Departmentinfo d = null;
		if(flag) {
			String sql = "select * from departmentinfotable where departmentId = ?";
			try {
				db.ps = db.conn.prepareStatement(sql);
				db.ps.setString(1, departmentId);
				rs = db.ps.executeQuery();
				while(rs.next()) {
					d = new Departmentinfo(rs.getInt(1), rs.getString(2), rs
							.getString(3));
				}
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			finally {
				db.closeDB();
			}
		}
		return d;
	}
    /**
     * 查询所有部门信息
     * @return list<all departMentinfo>
     */
	public List<Departmentinfo> questALLDepartmentinfo() {

		List<Departmentinfo> list = new ArrayList<Departmentinfo>();
		flag = db.openDB();
		Departmentinfo d = null;
		if (flag) {
			String sql = "select * from departmentinfotable";
			try {
				db.ps = db.conn.prepareStatement(sql);
				rs = db.ps.executeQuery();
				while (rs.next()) {
					d = new Departmentinfo(rs.getInt(1),rs.getString(2),rs.getString(3));
					list.add(d);
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
			finally {
				db.closeDB();
			}
		}
		return list;
	}
	/**
	 * 根据编号删除某个部门信息
	 * @param id
	 * @return boolean
	 */
	public boolean deleteDepartmentID(int id) {
		flag = db.openDB();
		if(flag)
		{
			String sql = "delete from departmentinfotable where Id=?";
			try {
				db.ps = db.conn.prepareStatement(sql);
				db.ps.setInt(1, id);
				db.ps.executeUpdate();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			return true;
		}
		else
		{
			return false;
		}
	}
	/**
	 * 修改部门信息
	 * @param args
	 */
	public int updateDepartment(Departmentinfo d)
	{
		flag = db.openDB();
		int rows = 0;
		if(flag)
		{
			String sql = "update departmentinfotable set departmentid=?,departmentname=? where Id=?";
			try {
				db.ps = db.conn.prepareStatement(sql);
				db.ps.setString(1, d.getDepartmentId());
				db.ps.setString(2, d.getDepartmentName());
				db.ps.setInt(3, d.getId());
			    rows = db.ps.executeUpdate();
			} catch (SQLException e) {
				
				e.printStackTrace();
			}
			finally{
				db.closeDB();
			}
		}
		return rows;
	}
//	// 得到所有记录数
//	public int getAll() {
//		int allNum = 0;
//		db.openDB();
//		try {
//			String sql = "select count(*) as cnt from departmentinfotable";
//			db.ps = db.conn.prepareStatement(sql);
//			db.rs = db.ps.executeQuery();
//			while (db.rs.next()) {
//				allNum = db.rs.getInt("cnt");
//			}
//		} catch (SQLException e) {
//			e.printStackTrace();
//		} finally {
//			db.closeDB();
//		}
//
//		return allNum;
//	}
//	public List<Departmentinfo> selecPage(PageInfo pageInfo) {
//		List<Departmentinfo> list = new ArrayList<Departmentinfo>();
//		flag = db.openDB();
//		int exclude = (pageInfo.getCurrentpage() - 1) * pageInfo.getPercut();
//		String sql = "select top " + pageInfo.getPercut()
//						+ " * from departmentinfotable where id  not in "
//						+ "(select top " + exclude
//						+ " id from departmentinfotable  order by id)"
//						+ " order by id";
//		if (flag) {
//			try {
//				  db.ps = db.conn.prepareStatement(sql);
//				  rs = db.ps.executeQuery();
//				  while (rs.next()) {
//					 Departmentinfo d = new Departmentinfo(rs.getInt(1), rs.getString(2), rs.getString(3));
//					 list.add(d);
//				}
//			} catch (SQLException e) {
//				e.printStackTrace();
//			} finally {
//				db.closeDB();
//			}
//		} else {
//			System.out.println("db not open");
//		}
//		return list;
//	}
	/**
	 * 分页查询商品信息(2009.2.17 袁新锋修改)
	 */
	public List<Departmentinfo> selectgoodsinfoPage(int pageSize, int pageNum){
		 List<Departmentinfo> list = new  ArrayList<Departmentinfo>();
		 db.openDB();// 打开数据库
			 try{
				 db.ps = db.conn.prepareStatement("select top " + pageSize
							+ "* from departmentinfotable where Id not in(select top "
							+ pageSize * pageNum
							+ " Id from departmentinfotable order by Id)order by Id");
				 rs=db.ps.executeQuery();
				 while (rs.next()) {
					 Departmentinfo d = new Departmentinfo(rs.getInt(1), rs.getString(2), rs.getString(3));
					 list.add(d);
				}
						
			 }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;
		 db.openDB();// 打开数据库
			try {
				db.ps=db.conn.prepareStatement("select count(*) from departmentinfotable");
				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;
		}
	

}