oracleanswerdao.java

基于STRUTS的网络调查应用

/*
 * Created on 16-ene-2005 23:08:42
 *
 */
package com.martincuervo.javatest.business.dao.oracle;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

import com.martincuervo.javatest.business.dao.DAOHelper;
import com.martincuervo.javatest.business.dao.IAnswerDAO;
import com.martincuervo.javatest.business.dao.IResultSetWrapper;
import com.martincuervo.javatest.business.vo.AnswerVO;
import com.martincuervo.javatest.business.vo.QuestionVO;

/**
 * @author Jorge Martin Cuervo <[e-mail]>
 *
 */
public class OracleAnswerDAO implements IAnswerDAO {

	private Connection connection;
	private DAOHelper helper;  
	
	private static final IResultSetWrapper RS_WRAPPER = new IResultSetWrapper() {
		public Object transform (ResultSet rs) throws SQLException {
			
			return new AnswerVO(
					rs.getInt("ID"),
					rs.getString("TEXT"),
					rs.getString("CORRECT").equals("Y")?true:false
					);
		}
	
	};
	
	/**
	 * Constructor
	 * 
	 * @param connection
	 */
	public OracleAnswerDAO(Connection connection) {
		super();
		this.connection = connection;
		helper = new DAOHelper(this.getClass().getName(), connection);
	}
	
	/**
	 * 
	 */
	public void addAnswer(final AnswerVO answer, final QuestionVO question) {
		Object[] params = {
			new Integer(answer.getId()),
			answer.getText(), 
			answer.isCorrect()?"Y":"N",
			new Integer(question.getId())
		};
		
		helper.executeQuery("insert", params);
	}
	
	/**
	 * 
	 */
	public void delAnswer(final AnswerVO answer) {
		Object[] params = { new Integer(answer.getId()) };
			
			helper.executeQuery("delete", params);
	}
	
	/**
	 * 
	 */
	public AnswerVO getAnswer(final AnswerVO answer) {
		Object[] params = { new Integer(answer.getId()) };
		AnswerVO valRet = null;
		
		List list = helper.executeSelect("select.one", params, RS_WRAPPER);
		if (list != null && list.size()==1) {
			valRet = (AnswerVO)list.get(0);
		}
		
		return valRet;
	}
	
	/**
	 * 
	 */
	public List getAnswers(final QuestionVO question) {
		Object[] params = { new Integer(question.getId()) };
		
		return helper.executeSelect("select.question", params, RS_WRAPPER);
	}
	
	/**
	 * 
	 */
	public void modAnswer(final AnswerVO answer) {
		Object[] params = {
				answer.getText(), 
				answer.isCorrect()?"Y":"N",
				new Integer(answer.getId())
			};
			
			helper.executeQuery("update", params);
	}
}