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

  * FiltersMicroSetsDaoJdbc.java - Implement the Dao interface for the FiltersMicroSets

  * 

  * 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.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.SqlUpdate;

 import com.buckosoft.PicMan.domain.FilterMicroSet;

 /** Implement the Dao Interface for the {@link com.buckosoft.PicMan.domain.FilterMicroSet}s.

  * @author Dick Balaska

  * @since 2008/06/09

  */

 public class FiltersMicroSetsDaoJdbc implements FiltersMicroSetsDao {

         private final static boolean DEBUG = false;

         private final Log logger = LogFactory.getLog(getClass());

         private DataSource ds;

         /** 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.FiltersMicroSetsDao#getFilterMicroSet(int, int)

          */

         public FilterMicroSet getFilterMicroSet(int pid, int sid) {

                 if (sql_getFMSQUERY == null)

                         sql_getFMSQUERY = new FiltersMicroSetsQuery(ds, pid, sid);

                 return((FilterMicroSet)sql_getFMSQUERY.findObject(pid, sid));

         }

         private        FiltersMicroSetsQuery        sql_getFMSQUERY = null;

         /* (non-Javadoc)

          * @see com.buckosoft.PicMan.db.FiltersMicroSetsDao#getFiltersInPid(int)

          */

         @SuppressWarnings("unchecked")

         public List<FilterMicroSet> getFiltersInPid(int pid) {

                 if (DEBUG)

                         logger.info("getFiltersInPid");

                 if (sql_getFMSListQUERY == null)

                         sql_getFMSListQUERY = new FiltersMicroSetsQuery(ds, pid);

                 return(sql_getFMSListQUERY.execute(pid));

         }

         private        FiltersMicroSetsQuery        sql_getFMSListQUERY = null;

         /* (non-Javadoc)

          * @see com.buckosoft.PicMan.db.FiltersMicroSetsDao#deleteFilters(int)

          */

         public void deleteFilters(int pid) {

                 FiltersMicroSetDelete fmsd = new FiltersMicroSetDelete(ds);

                 fmsd.delete(pid);

         }

         /* (non-Javadoc)

          * @see com.buckosoft.PicMan.db.FiltersMicroSetsDao#getPicsInSet(int)

          */

         @SuppressWarnings("unchecked")

         public List<FilterMicroSet> getPicsInSet(int sid) {

                 if (DEBUG)

                         logger.info("getPicsInSet: " + sid);

                 if (sql_getPISListQUERY == null)

                         sql_getPISListQUERY = new FiltersMicroSetsQuery(ds, "");

                 return(sql_getPISListQUERY.execute(sid));

         }

         private        FiltersMicroSetsQuery        sql_getPISListQUERY = null;

         /* (non-Javadoc)

          * @see com.buckosoft.PicMan.db.FiltersMicroSetsDao#getPicsInSet(int, int)

          */

         @SuppressWarnings("unchecked")

         public List<FilterMicroSet> getPicsInSet(int sid, int value) {

                 if (DEBUG)

                         logger.info("getPicsInSet: " + sid);

                 if (sql_getPISvListQUERY == null)

                         sql_getPISvListQUERY = new FiltersMicroSetsQuery(ds, "", value);

                 return(sql_getPISvListQUERY.execute(sid, value));

         }

         private        FiltersMicroSetsQuery        sql_getPISvListQUERY = null;

         /* (non-Javadoc)

          * @see com.buckosoft.PicMan.db.FiltersMicroSetsDao#storeFilter(int, int, int)

          */

         public void storeFilter(int sid, int pid, int value) {

                 if (DEBUG)

                         logger.info("addPic: " + sid);

                 FiltersMicroSetInsert pi = new FiltersMicroSetInsert(ds);

                 pi.insert(sid, pid, value);

         }

         /**

          * Object to Query for FiltersMicroSets

          */

         private class FiltersMicroSetsQuery extends MappingSqlQuery {

 /*                FiltersMicroSetsQuery(DataSource ds) {

                         super(ds, "SELECT * from pics");

                         compile();

                 }

 */                

                 FiltersMicroSetsQuery(DataSource ds, int pid) {

                         super(ds, "SELECT * from filtersMicroSets where pid = ?");

             declareParameter(new SqlParameter(Types.INTEGER));

                         compile();

                 }

                 FiltersMicroSetsQuery(DataSource ds, int pid, int sid) {

                         super(ds, "SELECT * from filtersMicroSets where pid = ? AND sid = ?");

             declareParameter(new SqlParameter(Types.INTEGER));

             declareParameter(new SqlParameter(Types.INTEGER));

                         compile();

                 }

                 FiltersMicroSetsQuery(DataSource ds, String unused) {

                         super(ds, "SELECT * from filtersMicroSets where sid = ?");

             declareParameter(new SqlParameter(Types.INTEGER));

                         compile();

                 }

                 FiltersMicroSetsQuery(DataSource ds, String unused, int value) {

                         super(ds, "SELECT * from filtersMicroSets where sid = ? AND value >= ?");

             declareParameter(new SqlParameter(Types.INTEGER));

             declareParameter(new SqlParameter(Types.INTEGER));

                         compile();

                 }

                 protected Object mapRow(ResultSet rs, int rowNum) throws SQLException {

                         FilterMicroSet fms = new FilterMicroSet();

                         fms.setSid(rs.getInt("sid"));

                         fms.setPid(rs.getInt("pid"));

                         fms.setValue(rs.getInt("value"));

                         return(fms);

                 }

         }

         /**

          * <code>FiltersMicroSet</code> Insert Object.

          */

         private class FiltersMicroSetInsert extends SqlUpdate {

                 /**

                  * Create a new instance of PicInsert.

                  * @param ds the DataSource to use for the insert

                  */

                 protected FiltersMicroSetInsert(DataSource ds) {

                         super(ds, "INSERT INTO filtersMicroSets VALUES(?,?,?)");

                         declareParameter(new SqlParameter(Types.INTEGER));

                         declareParameter(new SqlParameter(Types.INTEGER));

                         declareParameter(new SqlParameter(Types.INTEGER));

                         compile();

                 }

                 protected void insert(int sid, int pid, int value) {

                         Object[] objs = new Object[] {

                                 new Integer(sid), new Integer(pid), new Integer(value) };

                         super.update(objs);

                 }

         }

         /**

          * <code>FiltersMicroSet</code> Delete Object.

          */

         protected class FiltersMicroSetDelete extends SqlUpdate {

                 /**

                  * Create a new instance of FiltersMicroSetDelete.

                  * @param ds the DataSource to use for the delete

                  */

                 protected FiltersMicroSetDelete(DataSource ds) {

                         super(ds, "DELETE FROM filtersMicroSets WHERE pid = (?)");

                         declareParameter(new SqlParameter(Types.INTEGER));

                         compile();

                 }

                 protected void delete(int pid) {

                         super.update(pid);

                 }

         }

 }