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.base.Joiner;
  import com.google.common.collect.*;
  import com.google.common.eventbus.Subscribe;
  import fr.ifremer.common.synchro.intercept.SynchroInterceptorBase;
  import fr.ifremer.common.synchro.meta.SynchroJoinMetadata;
  import fr.ifremer.common.synchro.meta.SynchroMetadataUtils;
  import fr.ifremer.common.synchro.meta.SynchroTableMetadata;
  import fr.ifremer.common.synchro.meta.event.CreateQueryEvent;
  import fr.ifremer.common.synchro.meta.event.LoadJoinEvent;
  import fr.ifremer.common.synchro.meta.event.LoadTableEvent;
  import fr.ifremer.common.synchro.query.SynchroQueryBuilder;
  import fr.ifremer.common.synchro.query.SynchroQueryName;
  import fr.ifremer.common.synchro.query.SynchroQueryOperator;
  import fr.ifremer.quadrige3.core.dao.referential.StatusCode;
  import fr.ifremer.quadrige3.synchro.intercept.referential.internal.ImportFromFileFkInterceptor;
  import fr.ifremer.quadrige3.synchro.intercept.referential.internal.ImportFromFileNumericalPkInterceptor;
  import fr.ifremer.quadrige3.synchro.meta.DatabaseColumns;
  import fr.ifremer.quadrige3.synchro.meta.administration.MetaProgramSynchroTables;
  import fr.ifremer.quadrige3.synchro.meta.referential.ReferentialSynchroTables;
  import fr.ifremer.quadrige3.synchro.meta.system.ContextAndFilterSynchroTables;
  import fr.ifremer.quadrige3.synchro.service.SynchroDirection;
  import fr.ifremer.quadrige3.synchro.service.referential.ReferentialSynchroDatabaseConfiguration;
  import org.apache.commons.collections4.CollectionUtils;
  import org.apache.commons.lang3.StringUtils;
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  
  import java.util.Collection;
  import java.util.Map;
  import java.util.Set;
  
  /**
   * Manage only data table with columns 'update_dt' and/or 'status_cd' and/or 'prog_cd'
   * 
   * @author Benoit Lavenier <benoit.lavenier@e-is.pro>
   * @since 1.0
   */
  public class ReferentialTableInterceptor extends AbstractReferentialInterceptor {
  
  	private static final Log log = LogFactory.getLog(ReferentialTableInterceptor.class);
  
  	/** Constant <code>childJoinIncludes</code> */
  	private static final Multimap<String, String> childJoinIncludes;
  	/** Constant <code>childJoinExcludes</code> */
  	private static final Multimap<String, String> childJoinExcludes;
  	/** Constant <code>naturalIds</code> */
  	private static final Multimap<String, String> naturalIds;
  
  	static {
  		childJoinIncludes = initChildJoinIncludes();
  		childJoinExcludes = initChildJoinExcludes();
  		naturalIds = initNaturalIds();
  	}
  
  	private String statusWhereClauseOrNull;
  	private final Map<String, Map<String, Integer>> recursiveColumnsByTable = Maps.newHashMap();
  
  	/**
  	 * <p>
  	 * Constructor for ReferentialTableInterceptor.
  	 * </p>
  	 */
  	public ReferentialTableInterceptor() {
  		super(ReferentialSynchroTables.getImportTablesIncludes());
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	protected void init(ReferentialSynchroDatabaseConfiguration config) {
  		statusWhereClauseOrNull = createStatusWhereClauseOrNull(config);
  	}
  
  	/** {@inheritDoc} */
  	@Override
 	public SynchroInterceptorBase clone() {
 		ReferentialTableInterceptor result = (ReferentialTableInterceptor) super.clone();
 		result.statusWhereClauseOrNull = this.statusWhereClauseOrNull;
 		return result;
 	}
 
 	/**
 	 * <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;
 		}
 	}
 
 	/**
 	 * <p>
 	 * handleTableLoad.
 	 * </p>
 	 * 
 	 * @param e
 	 *            a {@link fr.ifremer.common.synchro.meta.event.LoadTableEvent} object.
 	 */
 	@Subscribe
 	public void handleTableLoad(LoadTableEvent e) {
 
 		SynchroTableMetadata table = e.table;
 		SynchroDirection direction = getConfig().getDirection();
 
 		boolean hasStatusFilter = statusWhereClauseOrNull != null;
 		boolean hasUpdateDateColumn = hasColumns(table, DatabaseColumns.UPDATE_DT.name());
 		boolean hasStatusCdColumn = hasColumns(table, DatabaseColumns.STATUS_CD.name());
 		boolean isRoot = hasUpdateDateColumn
 				&& (!hasStatusFilter || hasStatusCdColumn);
 
 		// Set isRoot :
 		// - if not already done - e.g. DeletedItemHistoryInterceptor already set as true,
 		// so do not override this to false !
 		// - if has an 'update_dt' column
 		// - if NO status filter, or has 'status_cd' column
 		// - if NO program filter, or is 'PROGRAMME' table
 		if (!table.isRoot() && isRoot) {
 			table.setRoot(true);
 		}
 
 		// Special case for some tables without update_dt
 		/*
 		 * String tableName = table.getName();
 		 * boolean isRootWithoutUpdateDate = !hasUpdateDate
 		 * && ("A_ROOT_TABLE_WITHOUT_UPDATE_DT".equalsIgnoreCase(tableName));
 		 * if (isRootWithoutUpdateDate) {
 		 * table.setRoot(true);
 		 * return;
 		 * }
 		 */
 
 		// File DB -> Local DB
 		if (direction == SynchroDirection.IMPORT_FILE2LOCAL) {
 
 			// Natural Id: add as unique constraints with reject
 			Collection<String> columnNames = naturalIds.get(table.getName());
 			if (CollectionUtils.isNotEmpty(columnNames)) {
 				// Choose the REPLACE_AND_REMAP strategy for forced tables, otherwise REJECT_AND_REMAP
 				SynchroTableMetadata.DuplicateKeyStrategy duplicateKeyStrategy = getConfig().getTableNamesForced().contains(table.getName()) ?
 						SynchroTableMetadata.DuplicateKeyStrategy.REPLACE_AND_REMAP :
 						SynchroTableMetadata.DuplicateKeyStrategy.REJECT_AND_REMAP;
 				table.addUniqueConstraint("NATURAL_ID_UNIQUE_C", ImmutableList.copyOf(columnNames), duplicateKeyStrategy);
 			}
 
 			// Make sure PK are generate for local PK
 			if (table.isSimpleKey()) {
 
 				String pkName = table.getPkNames().iterator().next();
 				boolean isNumericPk = SynchroMetadataUtils.isNumericType(table.getColumnMetadata(pkName));
 
 				if (isNumericPk) {
 					int pkColumnIndex = table.getSelectColumnIndex(pkName);
 
 					// Retrieve recursive columns, filled on method handleJoinLoad()
 					Map<String, Integer> recursiveColumnIndexesByNames = recursiveColumnsByTable.get(table.getName());
 
 					ImportFromFileNumericalPkInterceptor pkInterceptor = new ImportFromFileNumericalPkInterceptor(
 							table.getName(),
 							pkName,
 							pkColumnIndex,
 							recursiveColumnIndexesByNames,
 							getConfig()
 							);
 					table.addInterceptor(pkInterceptor);
 				}
 			}
 		}
 	}
 
 	/**
 	 * <p>
 	 * handleJoinLoad.
 	 * </p>
 	 * 
 	 * @param e
 	 *            a {@link fr.ifremer.common.synchro.meta.event.LoadJoinEvent} object.
 	 */
 	@Subscribe
 	public void handleJoinLoad(LoadJoinEvent e) {
 		SynchroJoinMetadata join = e.join;
 
 		SynchroTableMetadata fkTable = join.getFkTable();
 		String fkTableName = join.getFkTable().getName().toUpperCase();
 		String pkTableName = join.getPkTable().getName().toUpperCase();
 		String fkColumnName = join.getFkColumn().getName().toUpperCase();
 
 		boolean hasStatusFilter = statusWhereClauseOrNull != null;
 		boolean fkTableHasUpdateDateColumn = hasColumns(join.getFkTable(), DatabaseColumns.UPDATE_DT.name());
 		boolean fkTableHasStatusCdColumn = hasColumns(join.getFkTable(), DatabaseColumns.STATUS_CD.name());
 		boolean fkTableIsRoot = fkTableHasUpdateDateColumn
 				&& (!hasStatusFilter || fkTableHasStatusCdColumn);
 		boolean isNumericColumn = SynchroMetadataUtils.isNumericType(fkTable.getColumnMetadata(fkColumnName));
 		SynchroDirection direction = getConfig().getDirection();
 
 		// Disable link to itself
 		if (join.getFkTable() == join.getPkTable()) {
 			if (log.isDebugEnabled()) {
 				log.debug("Disable join: " + join.toString());
 			}
 			join.setIsValid(false);
 
 			// File DB -> Local DB
 			if (direction == SynchroDirection.IMPORT_FILE2LOCAL
 					&& isNumericColumn
 					&& fkTable.isSimpleKey()) {
 
 				// Store this recursive FK column into a map, used in method handleTableLoad()
 				Map<String, Integer> recursiveColumnIndexesByName = recursiveColumnsByTable.computeIfAbsent(pkTableName, k -> Maps.newHashMap());
 				recursiveColumnIndexesByName.put(fkColumnName, fkTable.getSelectColumnIndex(fkColumnName));
 			}
 			return;
 		}
 
 		// Disable all join to a root table
 		if (join.isChild() && fkTableIsRoot) {
 			if (log.isDebugEnabled()) {
 				log.debug("Disable join: " + join.toString());
 			}
 			join.setIsValid(false);
 			return;
 		}
 
 		// Keep child join when status filter is enable (e.g. export to file)
 		else if (join.isChild() && fkTableHasUpdateDateColumn && hasStatusFilter) {
 			// Keep the join
 			return;
 		}
 
 		// Keep a child join if its includes
 		if (join.isChild()) {
 			// Is join explicitly include ?
 			Collection<String> columnIncludes = childJoinIncludes.get(fkTableName);
 			boolean explicitlyInclude = CollectionUtils.isNotEmpty(columnIncludes) && columnIncludes.contains(fkColumnName);
 
 			// Is join explicitly exclude ?
 			Collection<String> columnExcludes = childJoinExcludes.get(fkTableName);
 			boolean explicitlyExclude = CollectionUtils.isNotEmpty(columnExcludes) && columnExcludes.contains(fkColumnName);
 
 			if (!explicitlyInclude || explicitlyExclude) {
 				if (log.isDebugEnabled()) {
 					log.debug("Disable join: " + join.toString());
 				}
 				join.setIsValid(false);
 			}
 		}
 
 		// If the FK table is the current table
 		if (fkTable == e.source) {
 
 			// File DB -> Local DB
 			if (direction == SynchroDirection.IMPORT_FILE2LOCAL
 					&& isNumericColumn
 					&& join.getPkTable().isSimpleKey()) {
 				int fkColumnIndex = fkTable.getSelectColumnIndex(fkColumnName);
 
 				ImportFromFileFkInterceptor fkInterceptor = new ImportFromFileFkInterceptor(
 						pkTableName,
 						fkColumnIndex,
 						getConfig());
 
 				if (!fkTable.containsInterceptor(fkInterceptor)) {
 					fkTable.addInterceptor(fkInterceptor);
 				}
 			}
 		}
 	}
 
 	/* -- Internal methods -- */
 
 	/**
 	 * <p>
 	 * createStatusWhereClauseOrNull.
 	 * </p>
 	 * 
 	 * @param config
 	 *            a {@link fr.ifremer.quadrige3.synchro.service.referential.ReferentialSynchroDatabaseConfiguration}
 	 *            object.
 	 * @return a {@link java.lang.String} object.
 	 */
 	protected String createStatusWhereClauseOrNull(ReferentialSynchroDatabaseConfiguration config) {
 
 		Set<String> statusCodeIncludes = config.getStatusCodeIncludes();
 		if (CollectionUtils.isEmpty(statusCodeIncludes)) {
 			return null;
 		}
 
 		return String.format("t.%s IN ('%s')",
 				DatabaseColumns.STATUS_CD,
 				Joiner.on("','").join(statusCodeIncludes));
 	}
 
 	/**
 	 * <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);
 
 		// where: add status filter
 		if (hasColumns(table, DatabaseColumns.STATUS_CD.name())) {
 			if (statusWhereClauseOrNull != null) {
 				queryBuilder.addWhere(SynchroQueryOperator.AND, statusWhereClauseOrNull);
 			} else
 			// Add specific where clause for selectMaxUpdateDate query
 			if (queryName == SynchroQueryName.selectMaxUpdateDate) {
 				// Only for TEMP to LOCAL, ignore local referential update date
 				if (getConfig().getDirection() == SynchroDirection.IMPORT_TEMP2LOCAL) {
 					queryBuilder.addWhere(
 							SynchroQueryOperator.AND,
 							String.format("t.%s NOT IN ('%s', '%s')", DatabaseColumns.STATUS_CD.name(), StatusCode.LOCAL_ENABLE.getValue(),
 									StatusCode.LOCAL_DISABLE.getValue()));
 				}
 				// Only for FILE to LOCAL, ignore max update
 				else if (getConfig().getDirection() == SynchroDirection.IMPORT_FILE2LOCAL) {
 					queryBuilder.addWhere(SynchroQueryOperator.AND, "1 = 2");
 				}
 			}
 		}
 
 		// where: limit to pks (for import by Pk)
 		String pkFilter = createPkFilter(table);
 		if (StringUtils.isNotBlank(pkFilter)) {
 			// Apply Pk filter, but do not apply date restriction
 			queryBuilder.addWhere(SynchroQueryOperator.AND, pkFilter);
 		}
 
 		return queryBuilder.build();
 	}
 
 	/**
 	 * <p>
 	 * initChildJoinIncludes.
 	 * </p>
 	 * 
 	 * @return a {@link com.google.common.collect.Multimap} object.
 	 */
 	protected static Multimap<String, String> initChildJoinIncludes() {
 		Multimap<String, String> result = ArrayListMultimap.create();
 
 		// Only this child link will be kept (other are invalidate)
 		result.put(ReferentialSynchroTables.CAMPAIGN_AREA.name(), "CAMPAIGN_ID");
 		result.put(ReferentialSynchroTables.CAMPAIGN_LINE.name(), "CAMPAIGN_ID");
 		result.put(ReferentialSynchroTables.CAMPAIGN_POINT.name(), "CAMPAIGN_ID");
 		result.put(ReferentialSynchroTables.CAMPAIGN_PROG.name(), "CAMPAIGN_ID");
 		result.put(ReferentialSynchroTables.DEPARTMENT_PRIVILEGE.name(), "DEP_ID");
 		result.put(ReferentialSynchroTables.EVENT_AREA.name(), "EVENT_ID");
 		result.put(ReferentialSynchroTables.EVENT_LINE.name(), "EVENT_ID");
 		result.put(ReferentialSynchroTables.EVENT_POINT.name(), "EVENT_ID");
 		// FRACTION_MATRIX is child of MATRIX for Q2 (see Mantis #0028388)
 		result.put(ReferentialSynchroTables.FRACTION_MATRIX.name(), "MATRIX_ID");
 		result.put(ReferentialSynchroTables.FRACTION_MATRIX.name(), "FRACTION_ID");
 		result.put(ReferentialSynchroTables.MON_LOC_AREA.name(), "MON_LOC_ID");
 		result.put(ReferentialSynchroTables.MON_LOC_LINE.name(), "MON_LOC_ID");
 		result.put(ReferentialSynchroTables.MON_LOC_ORDER_ITEM.name(), "MON_LOC_ID");
 		result.put(ReferentialSynchroTables.MON_LOC_ORDER_ITEM.name(), "ORDER_ITEM_ID");
 		result.put(MetaProgramSynchroTables.MON_LOC_PMFM_MET.name(), "MON_LOC_MET_ID");
 		result.put(ReferentialSynchroTables.MON_LOC_POINT.name(), "MON_LOC_ID");
 		result.put(ReferentialSynchroTables.MON_LOC_PROG.name(), "PROG_CD");
 		result.put(MetaProgramSynchroTables.MON_LOC_MET.name(), "PROG_CD");
 		result.put(ReferentialSynchroTables.OCCAS_AREA.name(), "OCCAS_ID");
 		result.put(ReferentialSynchroTables.OCCAS_LINE.name(), "OCCAS_ID");
 		result.put(ReferentialSynchroTables.OCCAS_POINT.name(), "OCCAS_ID");
 		result.put(ReferentialSynchroTables.OCCAS_QUSER.name(), "OCCAS_ID");
 		result.put(ReferentialSynchroTables.PROG_DEP_PROG_PRIV.name(), "PROG_CD");
 		result.put(MetaProgramSynchroTables.PMFM_MET.name(), "MET_CD");
 		result.put(ReferentialSynchroTables.PMFM_QUAL_VALUE.name(), "PMFM_ID");
 		result.put(ReferentialSynchroTables.PMFM_STRAT_ACQUIS_LEVEL.name(), "PMFM_STRAT_ID");
 		result.put(ReferentialSynchroTables.PMFM_STRAT_UI_FUNCTION.name(), "PMFM_STRAT_ID");
 		result.put(ReferentialSynchroTables.PMFM_STRAT_PMFM_QUAL_VALUE.name(), "PMFM_STRAT_ID");
 		result.put(ReferentialSynchroTables.PROG_QUSER_PROG_PRIV.name(), "PROG_CD");
 		result.put(ContextAndFilterSynchroTables.PMFM_CONTEXT_ORDER.name(), "CONTEXT_ID");
 		result.put(ReferentialSynchroTables.QUSER_PRIVILEGE.name(), "QUSER_ID");
 		result.put(ReferentialSynchroTables.VIRTUAL_COMPONENT.name(), "REF_TAXON_ID");
 		result.put(ReferentialSynchroTables.TAXON_INFORMATION.name(), "TAXON_NAME_ID");
 		result.put(ReferentialSynchroTables.TAXON_INFORMATION_HISTORY.name(), "TAXON_NAME_HIST_ID");
 		result.put(ReferentialSynchroTables.TAXON_GROUP_INFORMATION.name(), "TAXON_GROUP_ID");
 		result.put(ReferentialSynchroTables.TAXON_GROUP_HISTORICAL_RECORD.name(), "TAXON_GROUP_ID");
 		result.put(ReferentialSynchroTables.TAXON_GROUP_POSITION.name(), "TAXON_GROUP_ID");
 		result.put(ReferentialSynchroTables.PRIVILEGE_TRANSFER.name(), "PRIV_TRANSFER_FROM_DEP_ID");
 		result.put(ReferentialSynchroTables.TAXON_POSITION.name(), "REF_TAXON_ID");
 		result.put(ReferentialSynchroTables.TAXON_POSITION.name(), "MON_LOC_ID");
 		result.put(ReferentialSynchroTables.AUTHOR_REF_DOC.name(), "REF_DOC_ID");
 
 		// Need to allow deletion importation on STRATEGY (mantis #28389)
 		result.put(ReferentialSynchroTables.RESP_QUSER_STRAT.name(), "STRAT_ID");
 		result.put(ReferentialSynchroTables.RESP_DEP_STRAT.name(), "STRAT_ID");
 
 		// Need to allow deletion importation on STRATEGY and children (Fis Mantis #0029640)
 		result.put(ReferentialSynchroTables.STRATEGY.name(), "PROG_CD");
 		result.put(ReferentialSynchroTables.APPLIED_STRATEGY.name(), "STRAT_ID");
 		result.put(ReferentialSynchroTables.APPLIED_PERIOD.name(), "APPLIED_STRAT_ID");
 		result.put(ReferentialSynchroTables.PMFM_APPLIED_STRATEGY.name(), "APPLIED_STRAT_ID");
 		result.put(ReferentialSynchroTables.PMFM_STRATEGY.name(), "STRAT_ID");
 
 		// MORATORIUM
 		result.put(ReferentialSynchroTables.MORATORIUM.name(), "PROG_CD");
 		result.put(ReferentialSynchroTables.MOR_MON_LOC_PROG.name(), "MOR_ID");
 		result.put(ReferentialSynchroTables.MOR_PERIOD.name(), "MOR_ID");
 		result.put(ReferentialSynchroTables.PMFM_MOR.name(), "MOR_ID");
 		result.put(ReferentialSynchroTables.MOR_CAMP.name(), "MOR_ID");
 		result.put(ReferentialSynchroTables.MOR_OCCAS.name(), "MOR_ID");
 
 		return result;
 	}
 
 	/**
 	 * <p>
 	 * initChildJoinExcludes.
 	 * </p>
 	 * 
 	 * @return a {@link com.google.common.collect.Multimap} object.
 	 */
 	protected static Multimap<String, String> initChildJoinExcludes() {
 		Multimap<String, String> result = ArrayListMultimap.create();
 
 		// this child link will be excluded
 		result.put("TAXON_GROUP", "PARENT_TAXON_GROUP_FK");
 		result.put("PMFM_APPLIED_STRATEGY", "PMFM_STRAT_ID");
 
 		return result;
 	}
 
 	/**
 	 * Define all natural Id, by table.
 	 * <p/>
 	 * See specification from file 'Maquette-Référentiels.v2.0.xlsx'
 	 * 
 	 * @return a {@link com.google.common.collect.Multimap} object.
 	 */
 	protected static Multimap<String, String> initNaturalIds() {
 		Multimap<String, String> result = MultimapBuilder.hashKeys().arrayListValues().build();
 		result.put(ReferentialSynchroTables.MONITORING_LOCATION.name(), DatabaseColumns.MON_LOC_NM.name());
 		result.putAll(ReferentialSynchroTables.TAXON_NAME.name(), ImmutableList.of(
 				DatabaseColumns.TAXON_NAME_COMPLETE_NM.name(),
 				DatabaseColumns.CIT_ID.name()));
 		result.put(ReferentialSynchroTables.TAXON_GROUP.name(), DatabaseColumns.TAXON_GROUP_NM.name());
 		result.put(ReferentialSynchroTables.PARAMETER.name(), DatabaseColumns.PAR_CD.name());
 		result.put(ReferentialSynchroTables.MATRIX.name(), DatabaseColumns.MATRIX_NM.name());
 		result.put(ReferentialSynchroTables.FRACTION.name(), DatabaseColumns.FRACTION_NM.name());
 		result.put(ReferentialSynchroTables.METHOD.name(), DatabaseColumns.METHOD_NM.name());
 		result.putAll(ReferentialSynchroTables.QUALITATIVE_VALUE.name(), ImmutableList.of(
 				DatabaseColumns.QUAL_VALUE_NM.name(),
 				DatabaseColumns.PAR_CD.name()));
 
 		// PMFM
 		result.putAll(ReferentialSynchroTables.PMFM.name(), ImmutableList.of(
 				DatabaseColumns.PAR_CD.name(),
 				DatabaseColumns.MATRIX_ID.name(),
 				DatabaseColumns.FRACTION_ID.name(),
 				DatabaseColumns.METHOD_ID.name(),
 				DatabaseColumns.UNIT_ID.name()));
 
 		result.putAll(ReferentialSynchroTables.UNIT.name(), ImmutableList.of(
 				DatabaseColumns.UNIT_NM.name(),
 				DatabaseColumns.UNIT_SYMBOL.name()));
 		result.put(ReferentialSynchroTables.ANALYSIS_INSTRUMENT.name(), DatabaseColumns.ANAL_INST_NM.name());
 		result.put(ReferentialSynchroTables.SAMPLING_EQUIPMENT.name(), DatabaseColumns.SAMPLING_EQUIPMENT_NM.name());
 		result.put(ReferentialSynchroTables.PROGRAMME.name(), DatabaseColumns.PROG_CD.name());
 		result.putAll(ReferentialSynchroTables.STRATEGY.name(), ImmutableList.of(
 				DatabaseColumns.PROG_CD.name(),
 				DatabaseColumns.STRAT_NM.name()));
 		result.put(ReferentialSynchroTables.QUSER.name(), DatabaseColumns.QUSER_INTRANET_LG.name());
 		result.put(ReferentialSynchroTables.DEPARTMENT.name(), DatabaseColumns.DEP_CD.name());
 
 		return result;
 	}
 
 }