EDIT

/**

* Copyright (C) 2009 EDIT

* European Distributed Institute of Taxonomy

* http://www.e-taxonomy.eu

*

* The contents of this file are subject to the Mozilla Public License Version 1.1

* See LICENSE.TXT at the top of this package for the full license terms.

*/

package eu.etaxonomy.cdm.database.update;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.List;

import java.util.UUID;

import org.apache.logging.log4j.LogManager;import org.apache.logging.log4j.Logger;

import eu.etaxonomy.cdm.common.monitor.IProgressMonitor;

import eu.etaxonomy.cdm.database.ICdmDataSource;

/**

 * Moves terms from one vocabulary to another.

 * TODO does not yet check all DefinedTermBase_XXX tables except for representations.

 * TODO Does also not handle AUD tables

 * TODO Does not handle orderindex

 *

 * @author a.mueller

 * @since 06.09.2013

 *

 */

public class TermMover extends SchemaUpdaterStepBase{

    private static final Logger logger = LogManager.getLogger(TermMover.class);

	public static final TermMover NewInstance(List<ISchemaUpdaterStep> stepList, String stepName, UUID newVocabulary, String uuidTerm){

		List<String> terms = new ArrayList<>();

		terms.add(uuidTerm);

		return new TermMover(stepList, stepName, newVocabulary, terms);

	}

	public static final TermMover NewInstance(List<ISchemaUpdaterStep> stepList, String stepName, UUID newVocabulary, List<String> terms){

		return new TermMover(stepList, stepName, newVocabulary, terms);

	}

	private String uuidNewVocabulary ;

	private List<String> termUuids = new ArrayList<>();

	private TermMover(List<ISchemaUpdaterStep> stepList, String stepName, UUID newVocabulary, List<String> terms) {

		super(stepList, stepName);

		this.uuidNewVocabulary = newVocabulary.toString();

		this.termUuids = terms;

	}

    @Override

    public void invoke(ICdmDataSource datasource, IProgressMonitor monitor,

            CaseType caseType, SchemaUpdateResult result) throws SQLException {

        //get new vocabulary id

		String sql = " SELECT id FROM %s WHERE uuid = '%s'";

		Integer id = (Integer)datasource.getSingleValue(String.format(sql,

				caseType.transformTo("TermVocabulary") , this.uuidNewVocabulary));

		if (id == null || id == 0){

			String message = "New vocabulary ("+uuidNewVocabulary+") does not exist. Can't move terms";

			monitor.warning(message);

			logger.warn(message);

			result.addError(message, this, "invoke");

			return;

		}

		//check if in use

		for (String uuid : this.termUuids){

			sql = " UPDATE %s SET vocabulary_id = %d WHERE uuid = '%s' ";

			sql = String.format(sql, caseType.transformTo("DefinedTermBase"), id, uuid);

			datasource.executeUpdate(sql);

		}

		return;

	}

	public TermMover addTermUuid(UUID uuid){

		this.termUuids.add(uuid.toString());

		return this;

	}

}