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

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

                 }

         }

 }