.#userinfodao.java.1.5

J2ee开发的 人事管理系统 使用oracle数据库 myeclips平台开发

package com.galaxy.dao;

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

import com.galaxy.base.DaoInterface;
import com.galaxy.db.ConnectDB;
import com.galaxy.vo.DeptInfoVO;
import com.galaxy.vo.RoleInfoVO;
import com.galaxy.vo.UserInfoVO;

public class UserInfoDAO extends ConnectDB implements DaoInterface{

	public int addObject(Object ob) 
	{
		UserInfoVO userinfovo = (UserInfoVO)ob;
		int i = 0;		
		super.openDBConnection();
		String sql = "insert into user_info values(seq.nextval,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";				
		try 
		{
			PreparedStatement pst = super.dbConnection.prepareStatement(sql);			
			pst.setLong(1, userinfovo.getRoleInfo().getRiId());
			pst.setLong(2, userinfovo.getDeptInfo().getDiId());
			pst.setString(3, userinfovo.getUiLoadname());
			pst.setString(4, userinfovo.getUiPassword());
			pst.setString(5, userinfovo.getUiRealname());
			pst.setString(6, userinfovo.getUiState());
			pst.setString(7, userinfovo.getUiSex());
			pst.setString(8, userinfovo.getUiXueli());
			pst.setString(9, userinfovo.getUiDegree());
			pst.setString(10, userinfovo.getUiZhiwu());
			pst.setString(11, userinfovo.getUiDuty());
			pst.setString(12, userinfovo.getUiPhoto());
			pst.setLong(13, 13213321);
			pst.setLong(14, userinfovo.getUiAge());
			pst.setString(15, userinfovo.getUiExtend());			
						
			i = pst.executeUpdate();		
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		super.closeDBConnection();	
		return i;
	}

	public int deleteObject(Object cond) 
	{
		String sql="delete from user_info where ui_id in(" + (String)cond +")";		
		super.openDBConnection();
		try {
			super.dbStatement.executeUpdate(sql);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		super.closeDBConnection();
		return 0;
	}

	public List queryByCondition(Object cond)
	{
		List userlist = new ArrayList();
		String psql = "select * from user_info u join dept_info d on u.di_id=d.di_id where 1=1" + (String)cond;
		Long depid = 0l;
		Long roleid = 0l;
		super.openDBConnection();
		try
		{
			super.dbResultSet = super.dbStatement.executeQuery(psql);
			while(super.dbResultSet.next())
			{
				UserInfoVO uservo = new UserInfoVO();
				uservo.setUiLoadname(dbResultSet.getString("ui_loadname"));
				uservo.setUiId(dbResultSet.getLong("ui_id"));
				uservo.setUiPassword(dbResultSet.getString("ui_password"));
				uservo.setUiRealname(dbResultSet.getString("ui_realname"));
				uservo.setUiState(dbResultSet.getString("ui_state"));
				uservo.setUiSex(dbResultSet.getString("ui_sex"));
				uservo.setUiXueli(dbResultSet.getString("ui_xueli"));
				uservo.setUiDegree(dbResultSet.getString("ui_degree"));
				uservo.setUiZhiwu(dbResultSet.getString("ui_zhiwu"));
				uservo.setUiDuty(dbResultSet.getString("ui_duty"));
				uservo.setUiPhoto(dbResultSet.getString("ui_photo"));
				uservo.setUiPersonid(dbResultSet.getLong("ui_personid"));
				uservo.setUiAge(dbResultSet.getLong("ui_age"));
				uservo.setUiExtend(dbResultSet.getString("ui_extend"));
				
				depid = dbResultSet.getLong("di_id");
				roleid = dbResultSet.getLong("ri_id");
				
				DeptInfoDAO depdao = new DeptInfoDAO();
				DeptInfoVO depvo = new DeptInfoVO();
				RoleInfoDAO roledao = new RoleInfoDAO();
				RoleInfoVO rolevo = new RoleInfoVO();
				
				rolevo.setRiId(roleid);
				depvo.setDiId(depid);
				
				depvo = (DeptInfoVO)depdao.readObject(depvo);								
				rolevo = (RoleInfoVO)roledao.readObject(rolevo);
				uservo.setDeptInfo(depvo);
				uservo.setRoleInfo(rolevo);
				userlist.add(uservo);
			}
		}
		catch(SQLException e)
		{
			e.printStackTrace();
		}
		super.closeDBConnection();
		return userlist;
	}

	//参数为UserInfoVO
	public Object readObject(Object cond) {
		UserInfoVO uivo = new UserInfoVO();
		
		String psql = "select * from user_info where ui_id=?";
		super.openDBConnection();
		try {
			PreparedStatement pst = super.dbConnection.prepareStatement(psql);
			pst.setLong(1, ((UserInfoVO)cond).getUiId());
			
			super.dbResultSet = pst.executeQuery();
			while(super.dbResultSet.next())
			{
				uivo.setUiLoadname(dbResultSet.getString("ui_loadname"));
				uivo.setUiId(dbResultSet.getLong("ui_id"));
				uivo.setUiPassword(dbResultSet.getString("ui_password"));
				uivo.setUiRealname(dbResultSet.getString("ui_realname"));
				uivo.setUiState(dbResultSet.getString("ui_state"));
				uivo.setUiSex(dbResultSet.getString("ui_sex"));
				uivo.setUiXueli(dbResultSet.getString("ui_xueli"));
				uivo.setUiDegree(dbResultSet.getString("ui_degree"));
				uivo.setUiZhiwu(dbResultSet.getString("ui_zhiwu"));
				uivo.setUiDuty(dbResultSet.getString("ui_duty"));
				uivo.setUiPhoto(dbResultSet.getString("ui_photo"));
				uivo.setUiPersonid(dbResultSet.getLong("ui_personid"));
				uivo.setUiAge(dbResultSet.getLong("ui_age"));
				uivo.setUiExtend(dbResultSet.getString("ui_extend"));
				
				Long depid = dbResultSet.getLong("di_id");
				Long roleid = dbResultSet.getLong("ri_id");
				
				DeptInfoDAO depdao = new DeptInfoDAO();
				DeptInfoVO depvo = new DeptInfoVO();
				RoleInfoDAO roledao = new RoleInfoDAO();
				RoleInfoVO rolevo = new RoleInfoVO();
				
				rolevo.setRiId(roleid);
				depvo.setDiId(depid);
				
				depvo = (DeptInfoVO)depdao.readObject(depvo);								
				rolevo = (RoleInfoVO)roledao.readObject(rolevo);
				uivo.setDeptInfo(depvo);
				uivo.setRoleInfo(rolevo);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		super.closeDBConnection();
		return uivo;
	}

	public int updateObject(Object ob) {
		int result = 0;//更新失败
		UserInfoVO uivo = (UserInfoVO)ob;
		
		String psql = "update user_info set ri_id = ?, di_id=?, ui_loadname=?," +
				"ui_password=?,ui_realname=?,ui_state=?,ui_sex=?,ui_xueli=?," +
				"ui_degree=?,ui_zhiwu=?,ui_duty=?,ui_photo=?,ui_personid=?," +
				"ui_age=?,ui_extend=? where ui_id=?";
		super.openDBConnection();
		try {
			PreparedStatement pst = dbConnection.prepareStatement(psql);
			pst.setLong(1, uivo.getRoleInfo().getRiId());
			pst.setLong(2, uivo.getDeptInfo().getDiId());
			pst.setString(3, uivo.getUiLoadname());
			pst.setString(4, uivo.getUiPassword());
			pst.setString(5, uivo.getUiRealname());
			pst.setString(6, uivo.getUiState());
			pst.setString(7, uivo.getUiSex());
			pst.setString(8, uivo.getUiXueli());
			pst.setString(9, uivo.getUiDegree());
			pst.setString(10, uivo.getUiZhiwu());
			pst.setString(11, uivo.getUiDuty());
			pst.setString(12, uivo.getUiPhoto());
			pst.setLong(13, uivo.getUiPersonid());
			pst.setLong(14, uivo.getUiAge());
			pst.setString(15, uivo.getUiExtend());
			pst.setLong(16, uivo.getUiId());
			
			result = pst.executeUpdate();			
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		super.closeDBConnection();
		return result;
	}
	
	/**
	 * 
	 * @for debug
	 */
	public static void main(String [] Args)
	{
		/**测试更新UpdateObject()
			 
		UserInfoDAO uiDao = new UserInfoDAO();
		UserInfoVO uivot = new UserInfoVO();
		RoleInfoVO roleinfo = new RoleInfoVO();
		roleinfo.setRiId(3L);
		DeptInfoVO dvo = new DeptInfoVO();
		dvo.setDiId(65L);
		
		uivot.setUiId(72L);
		uivot.setRoleInfo(roleinfo);
		uivot.setDeptInfo(dvo);
		uivot.setUiLoadname("Yaoxiufeng");
		uivot.setUiPassword("yaoxiufeng");
		uivot.setUiRealname("yaoxiufeng");
		uivot.setUiState("离职");
		uivot.setUiSex("男");
		uivot.setUiXueli("博士");
		uivot.setUiDegree("博士");
		uivot.setUiZhiwu("员工");
		uivot.setUiDuty("员工");
		uivot.setUiPhoto("asdfsafasf");
		uivot.setUiPersonid(20055220L);
		uivot.setUiAge(24L);
		uivot.setUiExtend("");
			
		int re = uiDao.updateObject(uivot);
		System.out.println(re);
		*/
	}

}