activityreldaoimpl.java

来自「这是一个工作流管理的后端EJB实现」· Java 代码 · 共 158 行

package com.coshare.joyteam.projectMgr.dao.mssql;

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

import com.coshare.joyteam.projectMgr.dao.ActivityRelDAO;
import com.coshare.joyteam.projectMgr.dao.DAOException;
import com.coshare.joyteam.projectMgr.dto.ActivityRelDTO;
import com.coshare.joyteam.util.ID;

public class ActivityRelDAOImpl extends AbstractMssqlDAO implements
		ActivityRelDAO {

	static String SQL_INSERT = "insert into [WfActivityRel] ([SucActivity], [PreActivity]) values (?,?)";
	static String SQL_UPDATE = "update [WfActivityRel] set [SucActivity] = ?, [PreActivity] = ? where [ActivityRelId] = ?";
	static String SQL_DELETE = "delete from [WfActivityRel] where [ActivityRelId] = ?";
	static String SQL_SELECT_ByActivityRelId = "select * from [WfActivityRel] where [ActivityRelId] = ?";
	static String SQL_SELECT_ALL = "select * from [WfActivityRel]";
	static String SQL_SELECT_ByPRIMARYKEY = "select * from [WfActivityRel] where [SucActivity] = ? and [PreActivity] = ?";

	public boolean AddNew(ActivityRelDTO dtoObj) throws DAOException {
		PreparedStatement ps = da.prepareStatement(SQL_INSERT);		
		boolean rt = false;
		try {
			ps.setInt(1, dtoObj.getSucActivity().getId());
			ps.setInt(2, dtoObj.getPreActivity().getId());
			rt = ps.executeUpdate() > 0;
		} catch (SQLException e) {
			throw new DAOException("insert failed.", e);
		}
		finally {
			try {
				ps.close();
			} catch (SQLException e) {
			}
		}
		return rt;
	}

	public boolean Update(ActivityRelDTO dtoObj) throws DAOException {
		PreparedStatement ps = da.prepareStatement(SQL_UPDATE);		
		boolean rt = false;
		try {
			ps.setInt(1, dtoObj.getSucActivity().getId());
			ps.setInt(2, dtoObj.getPreActivity().getId());
			ps.setInt(3, dtoObj.getActivityRelId().getId());
			rt = ps.executeUpdate() > 0;
		} catch (SQLException e) {
			throw new DAOException("update failed.", e);
		}
		finally {
			try {
				ps.close();
			} catch (SQLException e) {
			}
		}
		return rt;
	}

	public boolean Delete(ActivityRelDTO dtoObj) throws DAOException {
		PreparedStatement ps = da.prepareStatement(SQL_DELETE);		
		boolean rt = false;
		try {
			ps.setInt(1, dtoObj.getActivityRelId().getId());
			rt = ps.executeUpdate() > 0;
		} catch (SQLException e) {
			throw new DAOException("delete failed.", e);
		}
		finally {
			try {
				ps.close();
			} catch (SQLException e) {
			}
		}
		return rt;
	}

	public ActivityRelDTO getActivityRel(ID activityRelId) throws DAOException {
		PreparedStatement ps = da.prepareStatement(SQL_SELECT_ByActivityRelId);
		ActivityRelDTO rt = null;
		try {
			ps.setInt(1, activityRelId.getId());
			ResultSet rs = ps.executeQuery();
			if (rs.next()) {
				rt = getDTOFromRs(rs);
			}
			else {
				throw new DAOException("not found.");
			}
		} catch (SQLException e) {
			throw new DAOException("select failed.", e);
		}
		finally {
			try {
				ps.close();
			} catch (SQLException e) {
			}
		}
		return rt;
	}

	public List getActivityRels() throws DAOException {
		PreparedStatement ps = da.prepareStatement(SQL_SELECT_ALL);
		ArrayList rt = new ArrayList();
		try {
			ResultSet rs = ps.executeQuery();
			while (rs.next()) {
				rt.add(getDTOFromRs(rs));
			}
		} catch (SQLException e) {
			throw new DAOException("select failed.", e);
		}
		finally {
			try {
				ps.close();
			} catch (SQLException e) {
			}
		}
		return rt;
	}

	public ActivityRelDTO getDTOFromRs(ResultSet rs) throws SQLException {
		ActivityRelDTO dto = new ActivityRelDTO();
		dto.setActivityRelId(rs.getInt("ActivityRelId"));
		dto.setPreActivity(rs.getInt("PreActivity"));
		dto.setSucActivity(rs.getInt("SucActivity"));
		return dto;
	}

	public ActivityRelDTO getActivityRel(ID sucActivity, ID preActivity) throws DAOException {
		PreparedStatement ps = da.prepareStatement(SQL_SELECT_ByPRIMARYKEY);
		ActivityRelDTO rt = null;
		try {
			ps.setInt(1, sucActivity.getId());
			ps.setInt(2, preActivity.getId());
			ResultSet rs = ps.executeQuery();
			if (rs.next()) {
				rt = getDTOFromRs(rs);
			}
			else {
				throw new DAOException("not found.");
			}
		} catch (SQLException e) {
			throw new DAOException("select failed.", e);
		}
		finally {
			try {
				ps.close();
			} catch (SQLException e) {
			}
		}
		return rt;
	}
}