/******************************************************************************
    * MosaicBatchesDaoJdbc.java - Implement the Dao interface for the MosaicBatches
    * 
    * PicMan - The BuckoSoft Picture Manager in Java
    * Copyright(c) 2008 - 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.jdbc.core.SqlParameter;
  import org.springframework.jdbc.object.MappingSqlQuery;
  import org.springframework.jdbc.object.SqlFunction;
  import org.springframework.jdbc.object.SqlUpdate;
  
  import com.buckosoft.PicMan.domain.Mosaic;
  import com.buckosoft.PicMan.domain.MosaicBatch;
  
  /** Implement the Dao Interface for the {@link com.buckosoft.PicMan.domain.MosaicBatch}es.
   * @author Dick Balaska
   * @since 2008/09/19
   * @see <a href="http://cvs.buckosoft.com/Projects/java/PicMan/PicMan/src/com/buckosoft/PicMan/db/MosaicBatchesDaoJdbc.java">MosaicBatchesDaoJdbc.java</a>
   */
  public class MosaicBatchesDaoJdbc implements MosaicBatchesDao {
  	private static final boolean DEBUG = true;
  	protected final Log logger = LogFactory.getLog(getClass());
  
  	private DataSource		ds;
  	private	MosaicsDao		mosaicsDao;
  	
  	/** 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;
  	}
  
  	/** AOP setter for the MosaicsDao
  	 * @param mosaicsDao The MosaicsDao from the Spring Database Setup
  	 */
  	public void setMosaicsDao(MosaicsDao mosaicsDao) {
  		this.mosaicsDao = mosaicsDao;
  	}
  	/* (non-Javadoc)
  	 * @see com.buckosoft.PicMan.db.MosaicBatchesDao#getMosaicBatches()
  	 */
  	@SuppressWarnings("unchecked")
  	public List<MosaicBatch> getMosaicBatches() {
  		if (DEBUG)
  			logger.info("GetMosaicBatchesList");
  		if (sql_getMosaicBatchesListQUERY == null)
  			sql_getMosaicBatchesListQUERY = new MosaicBatchesQuery(ds);
  		List<MosaicBatch> list = sql_getMosaicBatchesListQUERY.execute();
  		Iterator<MosaicBatch> iter = list.iterator();
  		while (iter.hasNext()) {
  			MosaicBatch mb = iter.next();
  			fillMosaic(mb);
  		}
  		return(list);
  	}
  	private	MosaicBatchesQuery	sql_getMosaicBatchesListQUERY = null;
  
  	/* (non-Javadoc)
  	 * @see com.buckosoft.PicMan.db.MosaicBatchesDao#getMosaicBatch(int)
  	 */
  	public MosaicBatch getMosaicBatch(int mbid) {
  		if (DEBUG)
  			logger.info("getMosaicBatch: " + mbid);
  		if (sql_getMosaicBatchQUERY == null)
  			sql_getMosaicBatchQUERY = new MosaicBatchesQuery(ds, mbid);
          MosaicBatch mb = (MosaicBatch)sql_getMosaicBatchQUERY.findObject(mbid);
          if (mb == null)
          	return(null);
          return(fillMosaic(mb));
  	}
  	private	MosaicBatchesQuery	sql_getMosaicBatchQUERY = null;
  
  	private	MosaicBatch fillMosaic(MosaicBatch mb) {
          Mosaic m = this.mosaicsDao.getMosaic(mb.getMid());
          mb.setBatch(true);
          mb.setName(m.getName());
          mb.setEngine(m.getEngine());
          mb.setMasterPic(m.getMasterPic());
          mb.setOutPic(m.getOutPic());
          mb.setSid(m.getSid());
          mb.setStartTime(m.getStartTime());
          mb.setEngineConfig(m.getEngineConfig());
          return(mb);
  	}
 	/* (non-Javadoc)
 	 * @see com.buckosoft.PicMan.db.MosaicBatchesDao#storeMosaicBatch(com.buckosoft.PicMan.domain.MosaicBatch)
 	 */
 	public void storeMosaicBatch(MosaicBatch mbatch) {
 		if (DEBUG)
 			logger.info("storeMosaic " + mbatch.getMbid());
 		this.mosaicsDao.storeMosaic(mbatch);
 		assert(mbatch.getMid() != 0);
 		if (mbatch.getMbid() <= 0) {
 			MosaicBatchesInsert mbi = new MosaicBatchesInsert(ds);
 			mbi.insert(mbatch);
 		} else {
 			MosaicBatchesUpdate mbu = new MosaicBatchesUpdate(ds);
 			mbu.update(mbatch);
 		}
 	}
 	/* (non-Javadoc)
 	 * @see com.buckosoft.PicMan.db.MosaicBatchesDao#deleteMosaicBatch(int)
 	 */
 	public void deleteMosaicBatch(int mbid) {
 		// TODO Auto-generated method stub
 
 	}
 
 	/**
 	 * Object to Query for MosaicBatches
 	 */
 	private class MosaicBatchesQuery extends MappingSqlQuery {
 		
 		MosaicBatchesQuery(DataSource ds) {
 			super(ds, "SELECT * from mosaicBatches");
 			compile();
 		}
 		
 		MosaicBatchesQuery(DataSource ds, int mbid) {
 			super(ds, "SELECT * from mosaicBatches where mbid = ?");
 			declareParameter(new SqlParameter(Types.INTEGER));
 			compile();
 		}
 
 		protected Object mapRow(ResultSet rs, int rowNum) throws SQLException {
 			MosaicBatch mb = new MosaicBatch();
 			mb.setMbid(rs.getInt("mbid"));
 			mb.setMid(rs.getInt("mid"));
 			mb.setSizes(rs.getString("sizes"));
 			return(mb);
 		}
 	}
 	/**
 	 * <code>Virgin</code> Count Object.
 	 */
 	class MosaicBatchesCount extends SqlFunction {
 		
 		MosaicBatchesCount(DataSource ds) {
 			super(ds, "SELECT COUNT(*) from mosaicBatches");
 			compile();
 		}		
 	}
 
 	/**
 	 * <code>Mosaic</code> Insert Object.
 	 */
 	private class MosaicBatchesInsert extends SqlUpdate {
 		
 		/**
 		 * Create a new instance of MosaicBatchesInsert.
 		 * @param ds the DataSource to use for the insert
 		 */
 		protected MosaicBatchesInsert(DataSource ds) {
 			super(ds, "INSERT INTO mosaicBatches VALUES(?,?,?)");
 			declareParameter(new SqlParameter(Types.INTEGER));
 			declareParameter(new SqlParameter(Types.INTEGER));
 			declareParameter(new SqlParameter(Types.VARCHAR));
 			compile();
 		}
 
 		protected void insert(MosaicBatch mb) {
 			Object[] objs = new Object[] {
 				null,
 				new Integer(mb.getMid()), 
 				mb.getSizes()
 			};
 			super.update(objs);
 		}
 	}
 	///////////////////////////////////////////////////////////////////////////////////////////////
 	/**
 	 * <code>Mosaic</code> Update Object.
 	 */
 	private class MosaicBatchesUpdate extends SqlUpdate {
 		//private	DataSource	ds;
 		
 		/**
 		 * Create a new instance of MosaicBatchesUpdate.
 		 * @param ds the DataSource to use for the update
 		 */
 		protected MosaicBatchesUpdate(DataSource ds) {
 			super(ds, "UPDATE mosaicBatches SET mid=?, sizes=? WHERE mbid = ? LIMIT 1");
 			declareParameter(new SqlParameter(Types.INTEGER));
 			declareParameter(new SqlParameter(Types.VARCHAR));
 			declareParameter(new SqlParameter(Types.INTEGER));
 			compile();
 		}
 		/**
 		 * Method to update the <code>Set</code>'s data.
 		 * @param List sets The sets that should be stored
 		 * @return 0
 		 */
 
 		protected int update(MosaicBatch mb) {
 			return this.update(new Object[] {
 					new Integer(mb.getMid()),
 					mb.getSizes(), 					
 					new Integer(mb.getMbid())
 			});
 		}
 	}
 }