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

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

import eu.etaxonomy.cdm.database.ICdmDataSource;

import eu.etaxonomy.cdm.model.common.TermType;

import eu.etaxonomy.cdm.model.description.Feature;

import eu.etaxonomy.cdm.model.name.Rank;

 * Creates a new term if a term with the same given uuid does not exist yet

 * @author a.mueller

 * @since 10.09.2010

 *

public class SingleTermUpdater extends SchemaUpdaterStepBase {

	@SuppressWarnings("unused")

	/**

	public static final SingleTermUpdater NewInstance(String stepName, UUID uuidTerm, String description,  String label, String abbrev, String dtype, UUID uuidVocabulary, UUID uuidLanguage, boolean isOrdered, UUID uuidAfterTerm){

		return new SingleTermUpdater(stepName, null, uuidTerm, null, description, label, abbrev, dtype, uuidVocabulary, uuidLanguage, isOrdered, uuidAfterTerm);

	}

		return new SingleTermUpdater(stepName, termType, uuidTerm, idInVocabulary, description, label, abbrev, dtype, uuidVocabulary, uuidLanguage, isOrdered, uuidAfterTerm);

	}

	private String reverseDescription;

	private RankClass rankClass;

	private final TermType termType;

	private boolean symmetric = false;

	private boolean transitive = false;

	private SingleTermUpdater(String stepName, TermType termType, UUID uuidTerm, String idInVocabulary, String description, String label, String abbrev, String dtype, UUID uuidVocabulary, UUID uuidLanguage, boolean isOrdered, UUID uuidAfterTerm) {

		super(stepName);

		this.termType = termType;

		this.abbrev = abbrev;

		this.isOrdered = isOrdered;

		this.uuidTerm = uuidTerm;

		this.uuidAfterTerm = uuidAfterTerm;

	}

    @Override

 				" FROM " + caseType.transformTo("DefinedTermBase") +

		Long n = (Long)datasource.getSingleValue(sqlCheckTermExists);

		    String message ="Term already exists: " + label + "(" + uuidTerm + ")";

			result.addWarning(message, (String)null, getStepName());

			return;

		}

		//vocabulary id

		String sqlVocId = " SELECT id " +

		ResultSet rs = datasource.executeQuery(sqlVocId);

			String message = "Vocabulary ( "+ uuidVocabulary +" ) for term does not exist!";

		}

		Integer termId;

		String sqlMaxId = " SELECT max(id)+1 as maxId FROM " + caseType.transformTo("DefinedTermBase");

		rs = datasource.executeQuery(sqlMaxId);

			String message = "No defined terms do exist yet. Can't update terms!";

		}

		String id = Integer.toString(termId);

		String created = getNowString();

		String defaultColor = "null";

		String protectedTitleCache = getBoolean(false, datasource);

			orderIndex = getOrderIndex(datasource, vocId, monitor, caseType);

		}else{

		String titleCache = label != null ? label : (abbrev != null ? abbrev : description );

		String idInVocStr = idInVocabulary == null ? "NULL" : "'" + idInVocabulary + "'";

		String sqlInsertTerm = " INSERT INTO @@DefinedTermBase@@ (DTYPE, id, uuid, created, termtype, idInVocabulary, protectedtitlecache, titleCache, orderindex, defaultcolor, vocabulary_id)" +

				"VALUES ('" + dtype + "', " + id + ", '" + uuidTerm + "', '" + created + "', '" + termType.getKey() + "', " + idInVocStr +  ", " + protectedTitleCache + ", '" + titleCache + "', " + orderIndex + ", " + defaultColor + ", " + vocId + ")";

		datasource.executeUpdate(caseType.replaceTableNames(sqlInsertTerm));

		updateFeatureTerms(termId, datasource, monitor, caseType);

//

//		INSERT INTO DefinedTermBase (DTYPE, id, uuid, created, protectedtitlecache, titleCache, orderindex, defaultcolor, vocabulary_id)

//		SELECT 'ReferenceSystem' ,  (@defTermId := max(id)+1)  as maxId , '1bb67042-2814-4b09-9e76-c8c1e68aa281', '2010-06-01 10:15:00', b'0', 'Google Earth', null, null, @refSysVocId

		Integer langId = getLanguageId(uuidLanguage, datasource, monitor, caseType);

		if (langId == null){

			String message = "LangId is null";

			result.addWarning(message);

		    return;

		}

		//representation

		sqlMaxId = " SELECT max(id)+1 as maxId FROM " + caseType.transformTo("Representation");

		rs = datasource.executeQuery(sqlMaxId);

			String message = "No representations do exist yet. Can't update terms!";

		}

		//standard representation

		UUID uuidRepresentation = UUID.randomUUID();

		String sqlInsertRepresentation = " INSERT INTO @@Representation@@ (id, created, uuid, text, label, abbreviatedlabel, language_id) " +

				"VALUES (" + repId + ", '" + created + "', '" + uuidRepresentation + "', " + nullSafeStr(description) +  ", " +nullSafeStr( label) +  ", " + nullSafeStr(abbrev) +  ", " + langId + ")";

		datasource.executeUpdate(caseType.replaceTableNames(sqlInsertRepresentation));

		datasource.executeUpdate(caseType.replaceTableNames(sqlInsertMN));

		//reverse representation

			String sqlInsertReverseRepresentation = " INSERT INTO @@Representation@@ (id, created, uuid, text, label, abbreviatedlabel, language_id) " +

					"VALUES (" + reverseRepId + ", '" + created + "', '" + uuidReverseRepresentation + "', " + nullSafeStr(reverseDescription) +  ", " + nullSafeStr(reverseLabel) +  ",  " + nullSafeStr(reverseAbbrev) +  ", " + langId + ")";

			datasource.executeUpdate(caseType.replaceTableNames(sqlInsertReverseRepresentation));

			datasource.executeUpdate(caseType.replaceTableNames(sqlReverseInsertMN));

		}

		return;

	}

	private String nullSafeStr(String str) {

	private void updateFeatureTerms(Integer termId, ICdmDataSource datasource, IProgressMonitor monitor, CaseType caseType) throws SQLException {

		if (dtype.equals(Feature.class.getSimpleName())){

			String sqlUpdate = "UPDATE  " + caseType.transformTo("DefinedTermBase") +

				" supportsdistribution = " + getBoolean(false, datasource) + ", " +

	private void updateRelationshipTerms(Integer termId, ICdmDataSource datasource, IProgressMonitor monitor, CaseType caseType) throws SQLException {

		if (dtype.contains("Relationship")){

			String sqlUpdate = "UPDATE "  + caseType.transformTo("DefinedTermBase") +

				" WHERE id = " + termId;

	private void updateRanks(Integer termId, ICdmDataSource datasource, IProgressMonitor monitor, CaseType caseType) throws SQLException {

		if (dtype.equals(Rank.class.getSimpleName())){

			String sqlUpdate = "UPDATE " + caseType.transformTo("DefinedTermBase") +

				" WHERE id = " + termId;

	public SingleTermUpdater setRankClass(RankClass rankClass) {

	 * @param caseType

	 * @return

	private String getOrderIndex(ICdmDataSource datasource, int vocId, IProgressMonitor monitor, CaseType caseType) throws SQLException {

		ResultSet rs;

		if (uuidAfterTerm == null){

		String sqlOrderIndex = " SELECT orderindex FROM %s WHERE uuid = '%s' AND vocabulary_id = %d ";

		rs = datasource.executeQuery(sqlOrderIndex);

			String sqlUpdateLowerTerms = "UPDATE %s SET orderindex = orderindex + 1 WHERE vocabulary_id = %d AND orderindex >= %d ";

			sqlUpdateLowerTerms = String.format(sqlUpdateLowerTerms, caseType.transformTo("DefinedTermBase"), vocId, intOrderIndex );

			datasource.executeUpdate(sqlUpdateLowerTerms);

			String sqlMaxOrderIndex = " SELECT max(orderindex) FROM %s WHERE vocabulary_id = %d";

			intOrderIndex = (Integer)datasource.getSingleValue(sqlMaxOrderIndex);

				intOrderIndex =0;

			}

		return intOrderIndex.toString();

	}

	private boolean hasReverseRepresentation() {

	public SingleTermUpdater setSymmetricTransitiv(boolean symmetric, boolean transitive){

		this.symmetric = symmetric;

		this.transitive = transitive;

		return this;

}