oraclecategorydao.java

基于STRUTS的网络调查应用

/*
 * Created on 29-ene-2005 17:12:17
 *
 */
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.ICategoryDAO;
import com.martincuervo.javatest.business.dao.IResultSetWrapper;
import com.martincuervo.javatest.business.vo.CategoryVO;

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

	private Connection connection;
	private DAOHelper helper;  
	
	private static final IResultSetWrapper RS_WRAPPER = new IResultSetWrapper() {
		public Object transform (ResultSet rs) throws SQLException {
			
			return new CategoryVO(
					rs.getInt("ID"),
					rs.getString("TEXT"),
					rs.getString("TYPE").charAt(0)
					);
		}
	
	};
	
	
	/**
	 * Constructor
	 * 
	 * @param connection
	 */
	public OracleCategoryDAO(Connection connection) {
		super();
		this.connection = connection;
		helper = new DAOHelper(this.getClass().getName(), connection);
	}
	
	
	/**
	 * Obtiene los datos de una categoria en concreto
	 */
	public CategoryVO getCategory(CategoryVO category) {
		Object[] params = {	new Integer(category.getId()) };
		
		CategoryVO c = null;
		
		List list = helper.executeSelect("select.one", params, RS_WRAPPER );
		if (list != null && list.size() == 1) {
			c = (CategoryVO)list.get(0);
		}
		
		return c;	
	}

	/**
	 * Obtiene todas las categorias
	 */
	public List getCategories() {
		return helper.executeSelect("select.all", null, RS_WRAPPER );
	}


	/**
	 * Añade una categoria
	 */
	public void addCategory(CategoryVO category) {
		Object[] params = {	
				new Integer(category.getId()),
				category.getText(),
				new Character(category.getType()).toString()
		};
		
		helper.executeQuery("insert", params);
	}

	/**
	 * Modifica una categoria
	 */
	public void modCategory(CategoryVO category) {
		Object[] params = {	
				category.getText(),
				new Character(category.getType()).toString(),
				new Integer(category.getId())
		};
		helper.executeQuery("update", params);
	}

	/**
	 * Elimina una categoria
	 */
	public void delCategory(CategoryVO category) {
		Object[] params = {	new Integer(category.getId()) };
		
		helper.executeQuery("delete", params);
	}

}