MetaSetsDaoJdbc

/******************************************************************************
 * MetaSetsDaoJdbc.java - Implement the Dao interface for the MetaSets
 *
 * PicMan - The BuckoSoft Picture Manager in Java
 * Copyright(c) 2006 - Dick Balaska
 *
 */
package com.buckosoft.PicMan.db;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import java.util.Iterator;
import java.util.List;

import javax.sql.DataSource;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.SqlParameter;
import org.springframework.jdbc.object.MappingSqlQuery;
import org.springframework.jdbc.object.SqlUpdate;

import com.buckosoft.PicMan.domain.DataStrings;
import com.buckosoft.PicMan.domain.MetaSet;
import com.buckosoft.PicMan.domain.MetaSetRule;

/** Implement the Dao Interface for the {@link com.buckosoft.PicMan.domain.MetaSet}s.
 * @author Dick Balaska
 * @since 2006/07/04
 * @see <a href="http://cvs.buckosoft.com/Projects/java/PicMan/PicMan/src/com/buckosoft/PicMan/db/MetaSetsDaoJdbc.java">MetaSetsDaoJdbc.java</a>
 */
public class MetaSetsDaoJdbc implements MetaSetsDao, DataStrings {
	private static final boolean DEBUG = false;
	protected final Log logger = LogFactory.getLog(getClass());

	private DataSource ds;

	private	final static String	s_NAME		= "name";
	private	final static String	s_OPERATOR	= "operator";
	private	final static String	s_FUNC		= "func";

	/** Set the reference to the JDBC datasource.
	 * @param ds The datasource as configured by Spring.
	 * @see <a href="http://cvs.buckosoft.com/Projects/java/PicMan/PicMan/WebContent/WEB-INF/picManDatabase/picManDatabase.xml">picManDatabase.xml</a>
	 */
	public void setDataSource(DataSource ds) {
		this.ds = ds;
	}

	/* (non-Javadoc)
	 * @see com.buckosoft.PicMan.db.MetaSetsDao#getMetaSet(int)
	 */
	public MetaSet getMetaSet(int sid) {
		if (DEBUG)
			logger.info("getMetaSet: " + sid);
		if (sql_getMetaSetSidQUERY == null)
			sql_getMetaSetSidQUERY = new MetaSetsQuery(ds, sid);
        @SuppressWarnings("unchecked")
		List<MetaSetRule> list = sql_getMetaSetSidQUERY.execute(sid);
        MetaSet ms = new MetaSet();
        ms.setSid(sid);
        int	master = 0;
        while (master < list.size()) {
        	Iterator<MetaSetRule> iter = list.iterator();
        	boolean found = false;
        	while (iter.hasNext()) {
        		MetaSetRule msr = iter.next();
        		if (msr.getIndex() == master) {
        			ms.addRule(msr);
        			master++;
        			found = true;
        			break;
        		}
        	}
        	if (!found) {
        		throw new RuntimeException("Failed to parse up MetaSet: " + sid + " master=" + master);
        	}
        }
		return(ms);
	}
	private	MetaSetsQuery	sql_getMetaSetSidQUERY = null;

	/* (non-Javadoc)
	 * @see com.buckosoft.PicMan.db.MetaSetsDao#storeMetaSet(com.buckosoft.PicMan.domain.MetaSet)
	 */
	public void storeMetaSet(MetaSet mset) {
		if (mset.getSid() <= 0) {
			throw new RuntimeException("Bad sid");
		}
		if (sql_storeMetaSetINSERT == null)
			sql_storeMetaSetINSERT = new MetaSetInsert(ds);
		deleteMetaSet(mset);
		Iterator<MetaSetRule> iter = mset.getRules().iterator();
		while (iter.hasNext()) {
			MetaSetRule msr = iter.next();
			sql_storeMetaSetINSERT.insert(msr);

		}

	}
	private	MetaSetInsert	sql_storeMetaSetINSERT = null;

	/* (non-Javadoc)
	 * @see com.buckosoft.PicMan.db.MetaSetsDao#deleteMetaSet(com.buckosoft.PicMan.domain.MetaSet)
	 */
	public void	deleteMetaSet(MetaSet mset) throws DataAccessException {
		if (DEBUG)
			logger.info("deleteMetaSet: " + mset.getSid());
		MetaSetDelete msd = new MetaSetDelete(ds);
		msd.delete(mset);
	}

	/////////////////////////////////////////////////////////////////////////////////////
	/**
	 * <code>MetaSets</code> Query object.
	 */
	class MetaSetsQuery extends MappingSqlQuery {

/*		MetaSetsQuery(DataSource ds) {
            super(ds, "SELECT * from metaSets");
            compile();
        }
*/
		MetaSetsQuery(DataSource ds, int sid) {
            super(ds, "SELECT * from metaSets where sid = ? ORDER BY `index`");
			declareParameter(new SqlParameter(Types.INTEGER));
            compile();
        }

        protected Object mapRow(ResultSet rs, int rowNum) throws SQLException {
        	MetaSetRule msr = new MetaSetRule();
        	msr.setSid(rs.getInt("sid"));
        	msr.setIndex(rs.getInt("index"));
        	String s = rs.getString("type");
        	if (s.equals(s_NAME)) {
        		msr.setType(MetaSet.NAME);
        		msr.setRateOp(rs.getInt("rateOp"));
        		msr.setRateVal(rs.getInt("rateVal"));
        	} else if (s.equals(s_FUNC)) {
        		msr.setType(MetaSet.FUNCTION);
        		msr.setRateOp(rs.getInt("rateOp"));
        		msr.setRateVal(rs.getInt("rateVal"));
        	} else if (s.equals(s_OPERATOR)) {
        		msr.setType(MetaSet.OPERATOR);
        	}
        	s = rs.getString("value");
       		msr.setValue(s);
        	return(msr);
        }
	}
	/**
	 * <code>MetaSet</code> Delete Object.
	 */
	protected class MetaSetDelete extends SqlUpdate {

		/**
		 * Create a new instance of MetaSetRemove.
		 * @param ds the DataSource to use for the delete
		 */
		protected MetaSetDelete(DataSource ds) {
			super(ds, "DELETE FROM metaSets WHERE sid = (?)");
			declareParameter(new SqlParameter(Types.INTEGER));
			compile();
		}

		protected void delete(MetaSet ms) {
			super.update(ms.getSid());
		}
	}
	/**
	 * <code>MetaSet</code> Insert Object.
	 */
	protected class MetaSetInsert extends SqlUpdate {

		/**
		 * Create a new instance of MetaSetInsert.
		 * @param ds the DataSource to use for the insert
		 */
		protected MetaSetInsert(DataSource ds) {
			super(ds, "INSERT INTO metaSets VALUES(?,?,?,?,?,?)");
			declareParameter(new SqlParameter(Types.INTEGER));
			declareParameter(new SqlParameter(Types.INTEGER));
			declareParameter(new SqlParameter(Types.VARCHAR));
			declareParameter(new SqlParameter(Types.VARCHAR));
			declareParameter(new SqlParameter(Types.INTEGER));
			declareParameter(new SqlParameter(Types.INTEGER));
			compile();
		}

		protected void insert(MetaSetRule msr) {
			Object[] objs = new Object[] {
					new Integer(msr.getSid()),
					new Integer(msr.getIndex()),
					(msr.getType() == 0) ? s_NAME : ((msr.getType() == MetaSet.FUNCTION) ? s_FUNC : s_OPERATOR),
					msr.getValue(),
//					new Integer((msr.getType() == 0) ? msr.getRateOp() : 0),
//					new Integer((msr.getType() == 0) ? msr.getRateVal() : 0),
					new Integer(msr.getRateOp()),
					new Integer(msr.getRateVal()),
			};
			super.update(objs);
			// retrieveIdentity(owner);
		}
	}


}