EDIT

/**

* Copyright (C) 2007 EDIT

* 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.

*/

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

	public static final String NAMESPACE = "Fact";

	public static final String SEQUENCE_PREFIX = "ORDER: ";

	private int modCount = 10000;

	private static final String pluralString = "facts";

	private static final String dbTableName = "Fact";

	//FIXME don't use as class variable

	private Map<Integer, Feature> featureMap;

	public BerlinModelFactsImport(){

		super(dbTableName, pluralString);

	}

			return featureVocabulary;

		} catch (UnknownCdmTypeException e) {

			logger.error("Feature vocabulary not available. New vocabulary created");

		}

	}

	private Map<Integer, Feature>  invokeFactCategories(BerlinModelImportState state){

		Map<Integer, Feature>  result = state.getConfig().getFeatureMap();

		Source source = state.getConfig().getSource();

		try {

			//get data from database

					" FROM FactCategory "+

                    " WHERE (1=1)";

			ResultSet rs = source.getResultSet(strQuery) ;

			TermVocabulary<Feature> featureVocabulary = getFeatureVocabulary();

			int i = 0;

			//for each reference

			while (rs.next()){

				if ((i++ % modCount) == 0 && i!= 1 ){ logger.info("FactCategories handled: " + (i-1));}

				int factCategoryId = rs.getInt("factCategoryId");

				String factCategory = rs.getString("factCategory");

				Feature feature;

				try {

					feature = BerlinModelTransformer.factCategory2Feature(factCategoryId);

//					locExtensionFormName	nvarchar(80)	Checked

//					RankRestrictionFk	int	Checked

				}

				result.put(factCategoryId, feature);

			}

			return result;

		super.doInvoke(state);

		return;

	}

	@Override

	protected String getIdQuery(BerlinModelImportState state) {

	@Override

	protected String getRecordQuery(BerlinModelImportConfigurator config) {

					" FROM Fact " +

                      	" INNER JOIN PTaxon ON Fact.PTNameFk = PTaxon.PTNameFk AND Fact.PTRefFk = PTaxon.PTRefFk " +

                      	" LEFT OUTER JOIN RefDetail ON Fact.FactRefDetailFk = RefDetail.RefDetailId AND Fact.FactRefFk = RefDetail.RefFk " +

              	" WHERE (FactId IN (" + ID_LIST_TOKEN + "))";

			    strQuery += getOrderBy(config);

		return strQuery;

	}

		}

		return result;

	}

	@Override

	public boolean doPartition(ResultSetPartitioner partitioner, BerlinModelImportState state) {

		boolean success = true ;

		BerlinModelImportConfigurator config = state.getConfig();

		Set<TaxonBase> taxaToSave = new HashSet<TaxonBase>();

		ResultSet rs = partitioner.getResultSet();

		try{

			int i = 0;

			//for each fact

			while (rs.next()){

				try{

					if ((i++ % modCount) == 0){ logger.info("Facts handled: " + (i-1));}

					int factId = rs.getInt("factId");

					Integer taxonId = nullSafeInt(rs, "taxonId");

					Integer factRefFkInt = nullSafeInt(rs, "factRefFk");

					String fact = CdmUtils.Nz(rs.getString("Fact"));

					String notes = CdmUtils.Nz(rs.getString("notes"));

					Boolean doubtfulFlag = rs.getBoolean("DoubtfulFlag");

					TaxonBase<?> taxonBase = getTaxon(taxonMap, taxonId, taxonId);

					Feature feature = getFeature(featureMap, categoryFkInt) ;

					if (taxonBase == null){

						logger.warn("Taxon for Fact " + factId + " does not exist in store");

						success = false;

							success = false;

							continue;

						}

						//textData

						TextData textData = null;

						boolean newTextData = true;

						// description element append the fact text to the existing TextData

						if(categoryFkInt.equals(31)) {

							Set<DescriptionElementBase> descriptionElements = taxonDescription.getElements();

								}

							}

						}

						}

						//for diptera database

						if (categoryFkInt.equals(99) && notes.contains("<OriginalName>")){

//							notes = notes.replaceAll("<OriginalName>", "");

							//example <a href="http://euromed.luomus.fi/euromed_map.php?taxon=280629&size=medium">distribution</a>

							fact = fact.replace("<a href=\"", "").replace("\">distribution</a>", "");

						}

						//TODO textData.putText(fact, bmiConfig.getFactLanguage());  //doesn't work because  bmiConfig.getFactLanguage() is not not a persistent Language Object

						//throws  in thread "main" org.springframework.dao.InvalidDataAccessApiUsageException: object references an unsaved transient instance - save the transient instance before flushing: eu.etaxonomy.cdm.model.common.Language; nested exception is org.hibernate.TransientObjectException: object references an unsaved transient instance - save the transient instance before flushing: eu.etaxonomy.cdm.model.common.Language

						if (! taxonDescription.isImageGallery()){

							textData.putText(Language.DEFAULT(), fact);

							textData.setFeature(feature);

						}

						//reference

						String factRefFk = String.valueOf(factRefFkInt);

						if (factRefFkInt != null){

						}

						if (citation == null && (factRefFkInt != null)){

							logger.warn("Citation not found in referenceMap: " + factRefFk);

							Boolean publishFlag = rs.getBoolean(strPublishFlag);

							textData.addMarker(Marker.NewInstance(MarkerType.PUBLISH(), publishFlag));

						}

						//Sequence

						Integer sequence = rs.getInt("Sequence");

						if (sequence != null && sequence != 999){

							Annotation annotation = Annotation.NewInstance(strSequence, Language.DEFAULT());

							textData.addAnnotation(annotation);

						}

						//						if (categoryFkObj == FACT_DESCRIPTION){

	//						//;

	//					}else if (categoryFkObj == FACT_OBSERVATION){

	//						//TODO

	//						//logger.warn("FactCategory " + categoryFk + " not yet implemented");

	//					}

						//notes

						doCreatedUpdatedNotes(state, textData, rs);

						doId(state, textData, factId, "Fact");

						//TODO

						//Designation References -> unclear how to map to CDM

						//sequence -> textData is not an identifiable entity therefore extensions are not possible

						//fact category better

						taxaToSave.add(taxonBase);

					}

				} catch (Exception re){

			}

			logger.info("Facts handled: " + (i-1));

			logger.info("Taxa to save: " + taxaToSave.size());

		}catch(SQLException e){

			throw new RuntimeException(e);

		}

		return success;

	}

		Taxon taxon = null;

		if ( taxonBase instanceof Taxon ) {

			taxon = (Taxon) taxonBase;

			logger.warn("TaxonBase " + (taxonId==null?"(null)":taxonId) + " for Fact " + factId + " was not of type Taxon but: " + taxonBase.getClass().getSimpleName());

			return null;

		}

		TaxonDescription taxonDescription = null;

		Set<TaxonDescription> descriptionSet= taxon.getDescriptions();

		boolean isImage = false;

		Media media = null;

		//for diptera images

			isImage = true;

			media = Media.NewInstance();

			taxonDescription = makeImage(state, fact, media, descriptionSet, taxon);

			if (taxonDescription == null){

				return null;

			}

			TextData textData = null;

			for (DescriptionElementBase el:  taxonDescription.getElements()){

				if (el.isInstanceOf(TextData.class)){

			textData.addMedia(media);

		}

		//all others (no image) -> getDescription

			for (TaxonDescription desc: descriptionSet){

				if (! desc.isImageGallery()){

					taxonDescription = desc;

		Class<?> cdmClass;

		Set<String> idSet;

		Map<Object, Map<String, ? extends CdmBase>> result = new HashMap<Object, Map<String, ? extends CdmBase>>();

		try{

			Set<String> taxonIdSet = new HashSet<String>();

			Set<String> referenceIdSet = new HashSet<String>();

				handleForeignKey(rs, refDetailIdSet, "FactRefDetailFk");

				handleForeignKey(rs, refDetailIdSet, "PTDesignationRefDetailFk");

		}

			//taxon map

			nameSpace = BerlinModelTaxonImport.NAMESPACE;

			cdmClass = TaxonBase.class;

			idSet = referenceIdSet;

			Map<String, Reference> referenceMap = (Map<String, Reference>)getCommonService().getSourcedObjectsByIdInSource(cdmClass, idSet, nameSpace);

			result.put(nameSpace, referenceMap);

			//refDetail map

			nameSpace = BerlinModelRefDetailImport.REFDETAIL_NAMESPACE;

			cdmClass = Reference.class;

			idSet = refDetailIdSet;

			Map<String, Reference> refDetailMap= (Map<String, Reference>)getCommonService().getSourcedObjectsByIdInSource(cdmClass, idSet, nameSpace);

			result.put(nameSpace, refDetailMap);

		} catch (SQLException e) {

			throw new RuntimeException(e);

	}

		return result;

	}

	/**

	 */

	private TaxonDescription makeImage(BerlinModelImportState state, String fact, Media media, Set<TaxonDescription> descriptionSet, Taxon taxon) {

		TaxonDescription taxonDescription = null;

		ImageInfo imageInfo = null;

		URI uri;

		try {

		media.addRepresentation(mediaRepresentation);

		ImageFile image = ImageFile.NewInstance(uri, size, imageInfo);

		mediaRepresentation.addRepresentationPart(image);

		taxonDescription = taxon.getOrCreateImageGallery(sourceRef == null ? null :sourceRef.getTitleCache());

		return taxonDescription;

	}

		}else{

			return null;

		}

	}

	private Feature getFeature(Map<Integer, Feature>  featureMap, Integer categoryFkInt){

		if (categoryFkInt != null){

		}else{

			return null;

		}

	}

	@Override

	protected boolean doCheck(BerlinModelImportState state){

		IOValidator<BerlinModelImportState> validator = new BerlinModelFactsImportValidator();

		return validator.validate(state);

	}

	@Override

	protected boolean isIgnore(BerlinModelImportState state){

		return ! state.getConfig().isDoFacts();