package fr.ifremer.quadrige3.synchro.intercept.referential;
   
   /*-
    * #%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.collect.ImmutableSet;
  import fr.ifremer.common.synchro.meta.SynchroDatabaseMetadata;
  import fr.ifremer.common.synchro.meta.SynchroMetadataUtils;
  import fr.ifremer.common.synchro.meta.SynchroTableMetadata;
  import fr.ifremer.quadrige3.synchro.intercept.AbstractSynchroInterceptor;
  import fr.ifremer.quadrige3.synchro.service.SynchroDirection;
  import fr.ifremer.quadrige3.synchro.service.referential.ReferentialSynchroDatabaseConfiguration;
  import org.apache.commons.collections4.CollectionUtils;
  import org.hibernate.tool.hbm2ddl.TableMetadata;
  
  import java.util.Collection;
  import java.util.Set;
  
  /**
   * Abstract interceptor, for synchronization on referential tables
   * 
   * @author Benoit Lavenier <benoit.lavenier@e-is.pro>
   * @since 1.0
   */
  public abstract class AbstractReferentialInterceptor extends AbstractSynchroInterceptor<ReferentialSynchroDatabaseConfiguration> {
  
  	/**
  	 * <p>
  	 * Constructor for AbstractReferentialInterceptor.
  	 * </p>
  	 */
  	public AbstractReferentialInterceptor() {
  		super();
  	}
  
  	/**
  	 * <p>
  	 * Constructor for AbstractReferentialInterceptor.
  	 * </p>
  	 * 
  	 * @param directions
  	 *            a {@link fr.ifremer.quadrige3.synchro.service.SynchroDirection} object.
  	 */
  	public AbstractReferentialInterceptor(SynchroDirection... directions) {
  		super(directions);
  	}
  
  	/**
  	 * <p>
  	 * Constructor for AbstractReferentialInterceptor.
  	 * </p>
  	 * 
  	 * @param tables
  	 *            a {@link java.util.Set} object.
  	 * @param directions
  	 *            a {@link fr.ifremer.quadrige3.synchro.service.SynchroDirection} object.
  	 */
  	public AbstractReferentialInterceptor(Set<String> tables, SynchroDirection... directions) {
  		super(tables, directions);
  	}
  
  	/**
  	 * <p>
  	 * Constructor for AbstractReferentialInterceptor.
  	 * </p>
  	 * 
  	 * @param tables
  	 *            a {@link java.util.Set} object.
  	 */
  	public AbstractReferentialInterceptor(Set<String> tables) {
  		super(tables);
  	}
  
  	/**
  	 * <p>
  	 * Constructor for AbstractReferentialInterceptor.
  	 * </p>
  	 * 
  	 * @param tableName
 	 *            a {@link java.lang.String} object.
 	 * @param directions
 	 *            a {@link fr.ifremer.quadrige3.synchro.service.SynchroDirection} object.
 	 */
 	public AbstractReferentialInterceptor(String tableName, SynchroDirection... directions) {
 		this(ImmutableSet.of(tableName), directions);
 	}
 
 	/**
 	 * <p>
 	 * Constructor for AbstractReferentialInterceptor.
 	 * </p>
 	 * 
 	 * @param tableName
 	 *            a {@link java.lang.String} object.
 	 */
 	public AbstractReferentialInterceptor(String tableName) {
 		this(ImmutableSet.of(tableName));
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	protected Class<ReferentialSynchroDatabaseConfiguration> getConfigClass() {
 		return ReferentialSynchroDatabaseConfiguration.class;
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public boolean doApply(SynchroDatabaseMetadata meta, TableMetadata table) {
 		return true;
 	}
 
 	/* -- internal methods -- */
 
 	/**
 	 * <p>
 	 * hasStatusCodesIncludes.
 	 * </p>
 	 * 
 	 * @return a boolean.
 	 */
 	protected boolean hasStatusCodesIncludes() {
 		return CollectionUtils.isNotEmpty(getConfig().getStatusCodeIncludes());
 	}
 
 	/**
 	 * <p>
 	 * createPkFilter.
 	 * </p>
 	 * 
 	 * @param table
 	 *            a {@link fr.ifremer.common.synchro.meta.SynchroTableMetadata} object.
 	 * @return a {@link java.lang.String} object.
 	 */
 	protected String createPkFilter(SynchroTableMetadata table) {
 		if (getConfig().getPkIncludes() == null
 				|| getConfig().getPkIncludes().isEmpty()) {
 			return null;
 		}
 
 		// If more than ONE pk : exit
 		if (table.getPkNames().size() != 1) {
 			return null;
 		}
 
 		String pkName = table.getPkNames().iterator().next();
 
 		Collection<String> pkStrs = getConfig()
 				.getPkIncludes()
 				.get(table.getName().toUpperCase());
 
 		if (org.apache.commons.collections.CollectionUtils.isEmpty(pkStrs)) {
 			// There is filter by PK, but not on this table
 			// so exclude this table
 			return "1=2";
 		}
 
 		boolean isNumericPk = SynchroMetadataUtils.isNumericType(table.getColumnMetadata(pkName));
 
 		StringBuilder inBuilder = new StringBuilder();
 		if (isNumericPk) {
 			for (String pkStr : pkStrs) {
 				inBuilder.append(',').append(pkStr);
 			}
 			return String.format("t.%s IN (%s)",
 					pkName,
 					inBuilder.substring(1)
 					);
 		}
 
 		// Alphanumerical : protect characters
 		else {
 			for (String pkStr : pkStrs) {
 				inBuilder.append("','").append(pkStr);
 			}
 			inBuilder.append("'");// close last string value
 
 			return String.format("t.%s IN (%s)",
 					pkName,
 					inBuilder.substring(2)
 					);
 		}
 	}
 }