/******************************************************************************

  * 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())

                         });

                 }

         }

 }