package fr.ifremer.quadrige3.synchro.intercept.administration;
   
   /*-
    * #%L
    * Quadrige3 Core :: Quadrige3 Synchro Core
    * $Id:$
    * $HeadURL:$
    * %%
    * Copyright (C) 2017 Ifremer
   * %%
   * This program is free software: you can redistribute it and/or modify
   * it under the terms of the GNU Affero General Public License as published by
   * the Free Software Foundation, either version 3 of the License, or
   * (at your option) any later version.
   * 
   * This program is distributed in the hope that it will be useful,
   * but WITHOUT ANY WARRANTY; without even the implied warranty of
   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   * GNU General Public License for more details.
   * 
   * You should have received a copy of the GNU Affero General Public License
   * along with this program.  If not, see <http://www.gnu.org/licenses/>.
   * #L%
   */
  
  import com.google.common.eventbus.Subscribe;
  import fr.ifremer.common.synchro.dao.Daos;
  import fr.ifremer.common.synchro.dao.SynchroBaseDao;
  import fr.ifremer.common.synchro.dao.SynchroTableDao;
  import fr.ifremer.common.synchro.intercept.SynchroOperationRepository;
  import fr.ifremer.common.synchro.meta.SynchroTableMetadata;
  import fr.ifremer.common.synchro.meta.event.CreateQueryEvent;
  import fr.ifremer.common.synchro.query.SynchroQueryBuilder;
  import fr.ifremer.common.synchro.query.SynchroQueryName;
  import fr.ifremer.quadrige3.synchro.meta.DatabaseColumns;
  import fr.ifremer.quadrige3.synchro.meta.administration.ProgramStrategySynchroTables;
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  
  import java.io.IOException;
  import java.sql.PreparedStatement;
  import java.sql.SQLException;
  import java.util.List;
  
  /**
   * Manage table PMFM_STRATEGY :
   * <ul>
   * <li>Limit to program list (if specified in configuration)
   * <li>Delete PMFM_APPLIED_STRATEGY before deleting PMFM_STRATEGY
   * </ul>
   * 
   * @author Benoit Lavenier <benoit.lavenier@e-is.pro>
   * @since 1.0
   */
  public class PmfmStrategyInterceptor extends AbstractProgramStrategyInterceptor {
  
  	private static final Log log = LogFactory.getLog(PmfmStrategyInterceptor.class);
  
  	private PreparedStatement deletePmfmAppliedStrategyStatement = null;
  
  	/**
  	 * <p>
  	 * Constructor for PmfmStrategyInterceptor.
  	 * </p>
  	 */
  	public PmfmStrategyInterceptor() {
  		super(ProgramStrategySynchroTables.PMFM_STRATEGY.name());
  		setEnableOnWrite(true);
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	protected void doClose() throws IOException {
  		super.doClose();
  
  		Daos.closeSilently(deletePmfmAppliedStrategyStatement);
  		deletePmfmAppliedStrategyStatement = null;
  	}
  
  	/**
  	 * <p>
  	 * handleQuery.
  	 * </p>
  	 * 
  	 * @param e
  	 *            a {@link fr.ifremer.common.synchro.meta.event.CreateQueryEvent} object.
  	 */
  	@Subscribe
  	public void handleQuery(CreateQueryEvent e) {
  
  		switch (e.queryName) {
  		case count:
  		case countFromUpdateDate:
  		case select:
  		case selectFromUpdateDate:
  		case selectMaxUpdateDate:
  			// Add restriction
  			e.sql = addRestriction(e.source, e.queryName, e.sql);
  
 		default:
 			break;
 		}
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	protected void doOnDelete(List<Object> pk, SynchroTableDao sourceDao, SynchroTableDao targetDao, SynchroOperationRepository buffer)
 			throws SQLException {
 		// Getting the pmfmStratId
 		Integer pmfmStratId = Integer.parseInt(pk.get(0).toString());
 
 		// If need, delete referenced PMFM_APPLIED_STRATEGY
 		if (getConfig().isIntegrityConstraintEnable()) {
 			deletePmfmAppliedStrategyByPmfmStratId(targetDao, pmfmStratId);
 		}
 	}
 
 	/* -- Internal methods -- */
 
 	/**
 	 * <p>
 	 * addRestriction.
 	 * </p>
 	 * 
 	 * @param table
 	 *            a {@link fr.ifremer.common.synchro.meta.SynchroTableMetadata} object.
 	 * @param queryName
 	 *            a {@link fr.ifremer.common.synchro.query.SynchroQueryName} object.
 	 * @param sql
 	 *            a {@link java.lang.String} object.
 	 * @return a {@link java.lang.String} object.
 	 */
 	protected String addRestriction(SynchroTableMetadata table, SynchroQueryName queryName, String sql) {
 		SynchroQueryBuilder queryBuilder = SynchroQueryBuilder.newBuilder(sql);
 
 		// join: filter on program
 		String programFilterJoin = createProgramWhereClauseOrNull(getConfig(), "INNER JOIN STRATEGY s ON s.strat_id=t.strat_id AND s.prog_cd IN (%s)");
 		if (programFilterJoin != null) {
 			queryBuilder.addJoin(programFilterJoin);
 		}
 
 		return queryBuilder.build();
 	}
 
 	/**
 	 * <p>
 	 * createDeletePmfmAppliedStrategyByPmfmStratIdSql.
 	 * </p>
 	 * 
 	 * @return a {@link java.lang.String} object.
 	 */
 	protected String createDeletePmfmAppliedStrategyByPmfmStratIdSql() {
 		return String.format("DELETE FROM %s where %s=?",
 				ProgramStrategySynchroTables.PMFM_APPLIED_STRATEGY.name(),
 				DatabaseColumns.PMFM_STRAT_ID);
 	}
 
 	/**
 	 * <p>
 	 * deletePmfmAppliedStrategyByPmfmStratId.
 	 * </p>
 	 * 
 	 * @param targetDao
 	 *            a {@link fr.ifremer.common.synchro.dao.SynchroBaseDao} object.
 	 * @param pmfmStratId
 	 *            a int.
 	 * @throws java.sql.SQLException
 	 *             if any.
 	 */
 	protected void deletePmfmAppliedStrategyByPmfmStratId(SynchroBaseDao targetDao, int pmfmStratId) throws SQLException {
 
 		// Init the statement (if need)
 		if (deletePmfmAppliedStrategyStatement == null || deletePmfmAppliedStrategyStatement.isClosed()) {
 			deletePmfmAppliedStrategyStatement = targetDao.getPreparedStatement(createDeletePmfmAppliedStrategyByPmfmStratIdSql());
 		}
 
 		// Execute the DELETE sql command
 		deletePmfmAppliedStrategyStatement.setInt(1, pmfmStratId);
 		deletePmfmAppliedStrategyStatement.executeUpdate();
 	}
 
 	/* -- Internal methods -- */
 
 }