/*
    * The contents of this file are subject to the terms 
    * of the Common Development and Distribution License 
    * (the "License").  You may not use this file except 
    * in compliance with the License.
    * 
    * You can obtain a copy of the license at 
    * http://www.sun.com/cddl/cddl.html. 
    * See the License for the specific language governing 
   * permissions and limitations under the License.
   * 
   * When distributing Covered Code, include this CDDL 
   * HEADER in each file and include the License file at 
   * license.txt.  If applicable, add the following below 
   * this CDDL HEADER, with the fields enclosed by brackets 
   * "[]" replaced with your own identifying information: 
   * Portions Copyright [yyyy] [name of copyright owner]
   * 
   * Portions Copyright 2004 eBay, Inc.
   */
  package com.ebay.carad.os.vitalsigns.dao;
  
  import java.text.Format;
  import java.text.MessageFormat;
  import java.util.List;
  import java.util.Map;
  
  import org.apache.log4j.Logger;
  
  import com.ebay.carad.os.vitalsigns.DataPoint;
  import com.ebay.carad.os.vitalsigns.IDashboardReport;
  import com.ebay.carad.os.vitalsigns.IReportingListenerContainer;
  import com.ebay.carad.os.vitalsigns.ReportingException;
  
  /***
   * <p>An IDataDAO implementation that stores its data in a SQL DB.  Default
   * queries are provided in the form of a <tt>Format</tt>, but can be substituted
   * for a particular SQL-syntax for other types of databases.</p>
   * 
   * <p>Uses a <tt>ISqlDao</tt> to perform its' queries.</p>
   * 
   * <p>TODO : add various SQL syntaxes to SqlDataDAO that allow a string like "MySQL.dialect" or "MSSQL.dialect" to determine what default queries to use.</p>
   * 
   * @see #setInsertQuery(String)
   * @see #setSelectQuery(String)
   * 
   * @author Jeremy Thomerson
   * @version $Id$
   */
  public class SqlDataDAO implements IDataDAO {
  
      private static final Logger LOGGER = Logger.getLogger(IDataDAO.class);
      private ISqlDAO mSqlDAO;
      private Format mInsertQuery = new MessageFormat("INSERT INTO ReportData (logtime, reportid, data) VALUES ({0}, {1}, {2})");
      private Format mSelectQuery = new MessageFormat("SELECT data, logtime FROM ReportData WHERE reportid = {0} ORDER BY logtime DESC");
  
      public SqlDataDAO() {
          super();
      }
  
      public void storeReportData(float data, IReportingListenerContainer agent, IDashboardReport report) throws ReportingException {
      	LOGGER.info("storing data [" + data + "] for report: " + report.getID() + " [" + report.getTitle() + "]");
          Object[] params = new Object[] { 
                  Long.toString(System.currentTimeMillis()), 
                  Integer.toString(report.getID()), 
                  report.getThisRunData() == null ? null : Float.toString(report.getThisRunData().floatValue()) 
                  };
          String qry = mInsertQuery.format(params);
          LOGGER.debug("query: " + qry);
          mSqlDAO.updateWithSQL(qry);
      }
  
      public DataPoint[] getData(IDashboardReport report) {
      	LOGGER.info("retrieving data for report: " + report.getID() + " [" + report.getTitle() + "]");
          Object[] params = new Object[] { Integer.toString(report.getID()) };
          String qry = mSelectQuery.format(params);
          LOGGER.debug("query: " + qry);
          List list = mSqlDAO.findBySqlQuery(qry);
          DataPoint[] points = new DataPoint[list.size()];
          for (int i = 0; i < points.length; i++) {
              Map cols = (Map) list.get(i);
              points[i] = new DataPoint();
              points[i].setData(cols.get("data") == null ? 0 : Float.parseFloat(cols.get("data").toString()));
              points[i].setLogTime(Long.parseLong(cols.get("logtime").toString()));
          }
          return points;
      }
  
      public void setSqlDAO(ISqlDAO sqlDAO) {
          mSqlDAO = sqlDAO;
      }
  
      public ISqlDAO getSqlDAO() {
          return mSqlDAO;
      }
      
      /***
       * <p>The query to insert a new DataPoint record.  String is formatted with <tt>MessageFormat</tt>, so
       * the rules that apply to <tt>MessageFormat</tt> apply to this String.  The parameters given to
      * the format are: 
      * <tt>new Object[] { new Long(System.currentTimeMillis()), new Integer(report.getID()), new Float(report.getThisRunData()) }</tt>.
      * </p>
      * 
      * @param query the query to insert a new DataPoint record
      * @see MessageFormat
      */
     public void setInsertQuery(String query) {
         mInsertQuery = new MessageFormat(query);
     }
     
     /***
      * <p>The query to select all DataPoint records for a given report.  
      * String is formatted with <tt>MessageFormat</tt>, so the rules that apply to 
      * <tt>MessageFormat</tt> apply to this String.  The parameters given to
      * the format are: 
      * <tt>new Object[] { new Integer(report.getID()) }</tt>.</p>
      * 
      * <p>
      * Note that the following column names must be returned by this query:
      * <ul>
      *  <li>logtime - the moment in time that this DataPoint refers to</li>
      *  <li>data - the float data that was stored for the moment in time for this report</li>
      * </p>
      * 
      * @param query the query to select a set of DataPoint records based on report ID 
      * @see MessageFormat
      */
     public void setSelectQuery(String query) {
         mSelectQuery = new MessageFormat(query);
     }
     
 }