deptdaooracleimp.java

用java开发的QQ管理系统

package com.zlf.dao;

import java.sql.*;
import java.util.*;

import com.zlf.dao.vo.Dept;

/**
 * 
 * 部门操作类，DAO (Data Access Object)数据访问对象
 * 
 * @author zlf
 * 
 */
public class DeptDaoOracleImp implements DeptDao {
	/**
	 * 
	 * 增加部门
	 * @param dept
	 * @return 1 0
	 * 1成功
	 * 0失败
	 */
	public int addDept(Dept dept) {
		Connection conn = DBUtil.getConnection();
		PreparedStatement pStatm = null;
		try {
			pStatm = conn.prepareStatement("insert into t_dept values(?,?,?)");
			pStatm.setString(1, dept.getDeptId());
			pStatm.setString(2, dept.getDeptName());
			pStatm.setString(3, dept.getDeptRemark());
			pStatm.executeUpdate();
			return 1;
		} catch (SQLException e) {
			e.printStackTrace();
			return 0;
		} finally {
			DBUtil.close(pStatm);
			DBUtil.close(conn);
		}
	}

	/**
	 * 
	 * 删除部门
	 * @param id
	 * @return 1 0
	 * 1成功
	 * 0失败
	 */
	public int deleteDept(String id) {
		Connection conn = DBUtil.getConnection();
		PreparedStatement pStatm = null;

		try {
			pStatm = conn
					.prepareStatement("delete from t_dept where dept_id = ?");
			pStatm.setString(1, id);
			pStatm.executeUpdate();
			return 1;

		} catch (SQLException e) {
			e.printStackTrace();
			return 0;
		} finally {
			DBUtil.close(pStatm);
			DBUtil.close(conn);
		}

	}

	/**
	 * 
	 * 修改部门
	 * @param dept
	 * @return 1,0
	 * 1成功
	 * 0失败
	 */
	public int updateDept(Dept dept) {
		Connection conn = DBUtil.getConnection();
		PreparedStatement pStatm = null;
		try {
			pStatm = conn
					.prepareStatement("update t_dept set dept_name = ?, dept_remark=? where  dept_id= ?  ");
			pStatm.setString(1, dept.getDeptName());
			pStatm.setString(2, dept.getDeptRemark());
			pStatm.setString(3, dept.getDeptId());
			pStatm.executeUpdate();
			return 1;
		} catch (SQLException e) {
			e.printStackTrace();
			return 0;
		} finally {
			DBUtil.close(pStatm);
			DBUtil.close(conn);
		}
	}

	/**
	 * 
	 * 部门Oracle实现类查询方法
	 * @param hashmap
	 * @return  Vector
	 * 
	 */
	public Vector selectDept(HashMap hashMap) {
		Connection conn = DBUtil.getConnection();
		PreparedStatement pStatm = null;
		ResultSet rs = null;
		Vector data = new Vector();

		Set set = hashMap.keySet();
		Iterator iter = set.iterator();
		while (iter.hasNext()) {
			String st=(String) iter.next();
			if (st.equals("1")) {
			/** 1.表示查找出所有的字段*/
				Vector row = null;
				try {
					pStatm = conn.prepareStatement("select * from t_dept");
					rs = pStatm.executeQuery();
					while (rs.next()) {
						int i = 1;
						row = new Vector();
						row.add(rs.getString(i++));
						row.add(rs.getString(i++));
						row.add(rs.getString(i++));
						data.add(row);
					}
				} catch (SQLException e) {
					e.printStackTrace();
				}

			} else if (st.equals("2")) {
				/** 2 自动生成编号*/
				try {
					pStatm = conn
							.prepareStatement("select trim(to_char(to_number(max(t.dept_id))+1,'000000')) maxNo from t_dept t ");
					rs = pStatm.executeQuery();
					while (rs.next()) {
						if (rs.getString(1) == null) {
							data.add("000001");
						} else {
							data.add(rs.getString("maxNo"));
						}
					}
				} catch (SQLException e) {
					e.printStackTrace();
				}

			} else if (st.equals("3")) {
				 /**3返回部门所有名称*/
				int i = 0;
				String[] deptName = null;
				int index = 1;
				try {
					pStatm = conn
							.prepareStatement("select count(*) from t_dept");
					rs = pStatm.executeQuery();
					while (rs.next()) {
						i = rs.getInt(1);
					}
					DBUtil.close(rs);
					DBUtil.close(pStatm);

					pStatm = conn
							.prepareStatement("select t.dept_name from t_dept t");
					rs = pStatm.executeQuery();
					deptName = new String[i+1];
					deptName[0]="";
					while (rs.next()) {
						deptName[index] = rs.getString(1);
						index++;
					}
					data.add(deptName);
				} catch (SQLException e) {
					e.printStackTrace();
				}
			} else if (st.equals("4")) {
				/** 4 根据部门的编号，到数据库中查找出部门信息*/
				Vector row = new Vector();
				try {
					pStatm = conn
							.prepareStatement("select * from t_dept where dept_id = ?");
					pStatm.setString(1, (String) hashMap.get("4"));
					rs = pStatm.executeQuery();
					while (rs.next()) {
						int i = 1;
						row = new Vector();
						row.add(rs.getString(i++));
						row.add(rs.getString(i++));
						row.add(rs.getString(i++));
						data.add(row);
					}
				} catch (SQLException e) {
					e.printStackTrace();
				}

			} else if (st.equals("5")) {
				/** 5 根据编号查到部门的名称*/
				try {
					pStatm = conn
							.prepareStatement("select t.dept_name from t_dept t where t.dept_id=?");
					pStatm.setString(1, (String) hashMap.get("5"));
					rs = pStatm.executeQuery();
					while (rs.next()) {
						data.add(rs.getString(1));
					}
				} catch (SQLException e) {
					e.printStackTrace();
				}

			} else if (st.equals("6")) {
				/** 6 根据名称查到编号 */
				try {
					pStatm = conn
							.prepareStatement("select t.dept_id from t_dept t where t.dept_name=?");
					pStatm.setString(1, (String) hashMap.get("6"));
					rs = pStatm.executeQuery();
					while (rs.next()) {
						data.add(rs.getString(1));
					}
				} catch (SQLException e) {
					e.printStackTrace();
				}

			}

		}

		return data;

	}


}