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

  * SystemDaoJdbc.java - Implement the Dao interface for the System bean

  * 

  * PicMan - The BuckoSoft Picture Manager in Java

  * Copyright(c) 2005 - Dick Balaska

  * 

  */

 package com.buckosoft.PicMan.db;

 import java.util.List;

 import java.util.Iterator;

 import javax.sql.DataSource;

 import java.sql.ResultSet;

 import java.sql.SQLException;

 import java.sql.Types;

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

 import org.springframework.jdbc.object.MappingSqlQuery;

 import com.buckosoft.PicMan.domain.System;

 import com.buckosoft.PicMan.db.SystemDao;

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

  * This table is key / value pairs so that {@link com.buckosoft.PicMan.domain.System} can be extended without

  * altering the table. 

  * @author Dick Balaska

  * @since 2005/07/25

  * @see <a href="http://cvs.buckosoft.com/Projects/java/PicMan/PicMan/src/com/buckosoft/PicMan/db/SystemDaoJdbc.java">SystemDaoJdbc.java</a>

  */

 public class SystemDaoJdbc implements SystemDao {

         private final static boolean DEBUG = false;

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

     private DataSource ds;

     private        System        systemCache;

     /** Set the database reference

      * @param ds The DataSource as generated by the Spring config/setup.

      */

     public void setDataSource(DataSource ds) {

             if (DEBUG)

                     logger.info("Set Datasource.");

         this.ds = ds;

     }

     /** Return a copy of the PicMan System attributes.

      * @return The System

      */

         public System getSystem() throws DataAccessException {

                 if (DEBUG)

                         logger.info("getSystem()");

                 if (systemCache != null)

                         return(systemCache);

                 SystemQuery sq = new SystemQuery(ds);

                 @SuppressWarnings("unchecked")

                 List<KeyValue> l = sq.execute();

                 systemCache = new System();

                 Iterator<KeyValue> it = l.iterator();

                 while (it.hasNext()) {

                 KeyValue k = (KeyValue)it.next();

                     //logger.info("getSystem() k=" + k.key + " v=" + k.value );

 //                if (k.key.equals("root"))

  //                       systemCache.addRoot(k.value);

                 if (k.key.equals("picExtension"))

                         systemCache.addPicExtension(k.value);

                 else if (k.key.equals("thumbHeight"))

                         systemCache.setThumbHeight(new Integer(k.value).intValue());

                 else if (k.key.equals("mosaicDepth"))

                         systemCache.setMosaicDepth(new Integer(k.value).intValue());

                 else if (k.key.equals("mosaicThumbHeight"))

                         systemCache.setMosaicThumbHeight(new Integer(k.value).intValue());

                 else if (k.key.equals("mosaicPicsPerPage"))

                         systemCache.setMosaicPicsPerPage(new Integer(k.value).intValue());

                 else if (k.key.equals("useThumbCache"))

                         systemCache.setUseThumbCache(new Boolean(k.value).booleanValue());

                 else if (k.key.equals("thumbCacheDirectory"))

                         systemCache.setThumbCacheDirectory(k.value);

                 else if (k.key.equals("thumbCacheSize"))

                         systemCache.setThumbCacheSize(new Integer(k.value).intValue());

                 else if (k.key.equals("importDirectory"))

                         systemCache.setImportDirectory(k.value);

                 else if (k.key.equals("importsToDo"))

                         systemCache.setImportsToDo(new Integer(k.value).intValue());

                 else if (k.key.equals("virginsToDo"))

                         systemCache.setVirginsToDo(new Integer(k.value).intValue());

                 else if (k.key.equals("engineOn"))

                         systemCache.setEngineOn(new Boolean(k.value).booleanValue());

                 else if (k.key.equals("engineRunOnce"))

                         systemCache.setEngineRunOnce(new Boolean(k.value).booleanValue());

                 else if (k.key.equals("skipXThumbs"))

                         systemCache.setSkipXThumbs(new Boolean(k.value).booleanValue());

                 else if (k.key.equals("showRateOnPics"))

                         systemCache.setShowRateOnPics(new Boolean(k.value).booleanValue());

                 else if (k.key.equals("jobLogSummaryOnly"))

                         systemCache.setJobLogSummaryOnly(new Boolean(k.value).booleanValue());

                 else if (k.key.equals("engineCronExpression"))

                         systemCache.setEngineCronExpression(k.value);

                 else if (k.key.equals("mosaicThumbCacheDir"))

                         systemCache.setMosaicThumbCacheDir(k.value);

                 else if (k.key.equals("mosThumbCacheHeight"))

                         systemCache.setMosaicThumbCacheHeight(new Integer(k.value).intValue());

                 else if (k.key.equals("syncEnable"))

                         systemCache.setSyncEnable(new Boolean(k.value).booleanValue());

                 else if (k.key.equals("syncUrl"))

                         systemCache.setSyncUrl(k.value);

         }

         return (systemCache);

         }

         /** Save the System to the database

          * @param system The System to write

          * @throws DataAccessException whatever.

          */

         public void setSystem(System system) throws DataAccessException {

                 SystemUpdate au = new SystemUpdate(ds);

                 au.update(system);

                 systemCache = null;

         }

         private class KeyValue {

                 public String        key;

                 public String        value;

         }

         private class SystemQuery extends MappingSqlQuery {

                 SystemQuery(DataSource ds) {

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

             compile();

         }

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

                 KeyValue k = new KeyValue();

                 k.key = rs.getString("key");

                 k.value = rs.getString("value");

                 return(k);

         }

         }

         /**

          * <code>System</code> Update Object.

          */

         private class SystemUpdate extends SqlUpdate {

                 private        DataSource        ds;

                 /**

                  * Create a new instance of OwnerUpdate.

                  * @param ds the DataSource to use for the update

                  */

                 protected SystemUpdate(DataSource ds) {

                         this.ds = ds;

                 }

                 /**

                  * Method to update the <code>System</code>'s data.

                  * @param System

                  * @return 0

                  */

                 protected int update(System sys) {

                         // Empty the existing table

                         SqlUpdate sf = new SqlUpdate(ds, "TRUNCATE TABLE system");

                         sf.compile();

                         int ret = sf.update();

                         if (DEBUG)

                                 logger.info("sf.empty() returned" + ret);

                         // Save each of our attributes

                         SystemInsert si = new SystemInsert(ds);

                         Iterator<String> it;

                         KeyValue kv = new KeyValue();

                         it = sys.getPicExtensions().iterator();

                         kv.key = "picExtension";

                         while (it.hasNext())

                         {

                                 kv.value = (String)it.next();

                                 si.insert(kv);

                         }

                         kv.key = "thumbHeight";

                         kv.value = String.valueOf(sys.getThumbHeight());

                         si.insert(kv);

                         kv.key = "mosaicDepth";

                         kv.value = String.valueOf(sys.getMosaicDepth());

                         si.insert(kv);

                         kv.key = "mosaicThumbHeight";

                         kv.value = String.valueOf(sys.getMosaicThumbHeight());

                         si.insert(kv);

                         kv.key = "mosaicPicsPerPage";

                         kv.value = String.valueOf(sys.getMosaicPicsPerPage());

                         si.insert(kv);

                         kv.key = "mosThumbCacheHeight";

                         kv.value = String.valueOf(sys.getMosaicThumbCacheHeight());

                         si.insert(kv);

                         kv.key = "useThumbCache";

                         kv.value = String.valueOf(sys.isUseThumbCache());

                         si.insert(kv);

                         kv.key = "thumbCacheDirectory";

                         kv.value = sys.getThumbCacheDirectory();

                         si.insert(kv);

                         kv.key = "mosaicThumbCacheDir";

                         kv.value = sys.getMosaicThumbCacheDir();

                         si.insert(kv);

                         kv.key = "thumbCacheSize";

                         kv.value = String.valueOf(sys.getThumbCacheSize());

                         si.insert(kv);

                         kv.key = "importDirectory";

                         kv.value = sys.getImportDirectory();

                         si.insert(kv);

                         kv.key = "importsToDo";

                         kv.value = String.valueOf(sys.getImportsToDo());

                         si.insert(kv);

                         kv.key = "virginsToDo";

                         kv.value = String.valueOf(sys.getVirginsToDo());

                         si.insert(kv);

                         kv.key = "engineOn";

                         kv.value = String.valueOf(sys.isEngineOn());

                         si.insert(kv);

                         kv.key = "engineRunOnce";

                         kv.value = String.valueOf(sys.isEngineRunOnce());

                         si.insert(kv);

                         kv.key = "skipXThumbs";

                         kv.value = String.valueOf(sys.isSkipXThumbs());

                         si.insert(kv);

                         kv.key = "showRateOnPics";

                         kv.value = String.valueOf(sys.isShowRateOnPics());

                         si.insert(kv);

                         kv.key = "jobLogSummaryOnly";

                         kv.value = String.valueOf(sys.isJobLogSummaryOnly());

                         si.insert(kv);

                         kv.key = "engineCronExpression";

                         kv.value = sys.getEngineCronExpression();

                         si.insert(kv);

                         kv.key = "syncEnable";

                         kv.value = String.valueOf(sys.isSyncEnable());

                         si.insert(kv);

                         kv.key = "syncUrl";

                         kv.value = sys.getSyncUrl();

                         si.insert(kv);

                         return(0);

                 }

         }

         /**

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

          */

         private class SystemInsert extends SqlUpdate {

                 /**

                  * Create a new instance of SystemInsert.

                  * @param ds the DataSource to use for the insert

                  */

                 protected SystemInsert(DataSource ds) {

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

                         declareParameter(new SqlParameter(Types.VARCHAR));

                         declareParameter(new SqlParameter(Types.VARCHAR));

                         compile();

                 }

                 protected void insert(KeyValue kv) {

                         Object[] objs = new Object[] {

                                 kv.key, kv.value};

                         super.update(objs);

                 }

         }

 }