//

 // Copyright (c) 2004, International Decision Systems

 // all rights reserved

 /*

  * Copyright (c) 2004 International Decision Systems, Inc.  All Rights Reserved.

  *

  * By using this Software, You acknowledge that the Software is a valuable asset

  * and trade secret of either International Decision Systems, Inc. ("IDSI") or a

  * third party supplier of IDSI and constitutes confidential and proprietary

  * information.

  *

  * NEITHER IDSI NOR ANY AGENT OR PERSON ACTING FOR OR WITH IDSI HAS MADE OR DOES

  * MAKE ANY STATEMENTS, AFFIRMATIONS, REPRESENTATIONS OR WARRANTIES WHATSOEVER

  * TO YOU, WHETHER EXPRESS OR IMPLIED, AS TO THE SOFTWARE, THE QUALITY OR

  * CONDITION OF THE SOFTWARE, OR THE OPERATING CHARACTERISTICS OR RELIABILITY OF

  * THE SOFTWARE, OR ITS SUITABILITY FOR ANY GENERAL OR PARTICULAR PURPOSE, OR AS

  * TO ANY OTHER MATTER WHATSOEVER; ANY AND ALL OTHER WARRANTIES INCLUDING

  * WITHOUT LIMITATION ANY WARRANTIES IMPLIED BY LAW, SUCH AS THE IMPLIED

  * WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, AND TITLE,

  * USE AND NON-INFRINGEMENT; ARE HEREBY EXPRESSLY DISCLAIMED AND EXCLUDED.

 */

 package net.sourceforge.addam.ddlrun.custom;

 import java.sql.Connection;

 import java.sql.PreparedStatement;

 import java.sql.SQLException;

 import java.sql.Timestamp;

 import net.sourceforge.addam.ddlrun.utils.RunLogger;

 /**

  * Logs events into a script table and updates the start point based on the group resource in another table.

  * The statements must include

  *

  * @author TIM3

  * @since Mar 6, 2005

  */

 public class IDSRunLogger implements RunLogger {

     public static final String INSERT_SCRIPT_LOG = "INSERT INTO SCRIPT_LOG(SCL_SCRIPT,SCL_RUN_DATE) VALUES(?,?)";

     public static final String UPDATE_VERSION = "UPDATE VERSION SET VRS_VERSION=?, VRS_START_FOLDER=?, VRS_MODIFIED_DATE=? WHERE VRS_TYPE='PF'";

     public static final String UNDEFINE_VERSION = "UPDATE VERSION SET VRS_VERSION='undefined', VRS_MODIFIED_DATE=? WHERE VRS_TYPE='PF'";

     private PreparedStatement undefineVersionStatement;

     private PreparedStatement insertScriptLogStatement;

     private PreparedStatement updateVersionStatement;

     private final Connection connection;

     private final String dbversion;

     /**

      * constructs a IDSRunLogger

      */

     public IDSRunLogger(Connection connection, String version) {

         this.connection = connection;

         this.dbversion = (version != null) ? version : "not provided";

     }

     public void logRunScript(String script, long time) throws SQLException {

         if (insertScriptLogStatement == null) {

             insertScriptLogStatement = connection.prepareStatement(INSERT_SCRIPT_LOG);

         }

         insertScriptLogStatement.setString(1, script);

         insertScriptLogStatement.setTimestamp(2, new Timestamp(System.currentTimeMillis()));

         insertScriptLogStatement.execute();

         if (undefineVersionStatement == null) {

             // only mark the version undefined the first time you record a script run

             // it will later be marked with the correct version when we're done

             undefineVersionStatement = connection.prepareStatement(UNDEFINE_VERSION);

             undefineVersionStatement.setTimestamp(1, new Timestamp(System.currentTimeMillis()));

             undefineVersionStatement.execute();

         }

         this.connection.commit();

     }

     public void logRunComplete(String group, long time) throws Exception {

         if (updateVersionStatement == null) {

             updateVersionStatement = connection.prepareStatement(UPDATE_VERSION);

         }

         updateVersionStatement.setString(1, dbversion);

         updateVersionStatement.setString(2, group);

         updateVersionStatement.setTimestamp(3, new Timestamp(System.currentTimeMillis()));

         updateVersionStatement.execute();

         this.connection.commit();

     }

     public void logRunFailure(String group, String script, Exception e) {

         System.out.println("Execution failed for " + group + "/" + script);

     }

 }