/cdmlib-io/src/main/java/eu/etaxonomy/cdm/io/pesi/out/PesiOccurrenceExport.java - Diff - EDIT - EDIT Project Management

« Previous | Next »

Revision 892efc69

Added by Andreas Kohlbecker almost 14 years ago

ID 892efc6951acfa51b009e26798a12033d2a6335b
Parent e0a7671f
Child 667ac7fc, 9e9de24f

merging /branches/cdmlib/SPRINT-Chichorieae1/ to trunk

     import java.sql.Connection;
     import java.sql.PreparedStatement;
     import java.sql.ResultSet;
     import java.sql.SQLException;
     import java.util.HashMap;
     import java.util.List;
-...
     import eu.etaxonomy.cdm.model.description.Distribution;
     import eu.etaxonomy.cdm.model.description.TaxonDescription;
     import eu.etaxonomy.cdm.model.location.NamedArea;
     import eu.etaxonomy.cdm.model.name.TaxonNameBase;
     import eu.etaxonomy.cdm.model.reference.ReferenceBase;
     import eu.etaxonomy.cdm.model.taxon.Taxon;
     import eu.etaxonomy.cdm.model.taxon.TaxonBase;
-...
     					if (taxonBase.isInstanceOf(Taxon.class)) {
     						// Set the current Taxon
     						setTaxon(CdmBase.deproxy(taxonBase, Taxon.class));
     						taxon = CdmBase.deproxy(taxonBase, Taxon.class);
     						// Determine the TaxonDescriptions
     						Set<TaxonDescription> taxonDescriptions = getTaxon().getDescriptions();
     						Set<TaxonDescription> taxonDescriptions = taxon.getDescriptions();
     						// Determine the DescriptionElements (Citations) for the current Taxon
     						for (TaxonDescription taxonDescription : taxonDescriptions) {
     							Set<DescriptionElementBase> descriptionElements = taxonDescription.getElements();
     							for (DescriptionElementBase descriptionElement : descriptionElements) {
     								Set<DescriptionElementSource> elementSources = descriptionElement.getSources();
     								if (descriptionElement.isInstanceOf(Distribution.class)) {
     //									logger.error("Distribution instance found.");
     									Distribution distribution = CdmBase.deproxy(descriptionElement, Distribution.class);
     									setNamedArea(distribution.getArea());
     									setDistribution(distribution);
     									Set<DescriptionElementSource> elementSources = distribution.getSources();
     									// Differentiate between descriptionElements with and without sources.
     									if (! hasCitations(elementSources)) {
     //										logger.error("Distribution has no sources. Exporting ...");
     									if (elementSources.size() == 0 && state.getDbId(descriptionElement) != null) {
     										doCount(count++, modCount, pluralString);
     										success &= mapping.invoke(distribution);
     										success &= mapping.invoke(descriptionElement);
     									} else {
     //										logger.error("Distribution has " + elementSources.size() + " sources. Exporting ...");
     										for (DescriptionElementSource elementSource : elementSources) {
     											ReferenceBase reference = elementSource.getCitation();
     											// Citations can be empty (null): Is it wrong data or just a normal case?
     											if (reference != null) {
     //												logger.error("Exporting Reference " + reference.getTitleCache() + " ...");
     											if (reference != null && state.getDbId(reference) != null) {
     												doCount(count++, modCount, pluralString);
     												success &= mapping.invoke(reference);
     											} else {
     												// This should never be the case. Testing purpose only.
     //												logger.error("Citation of ElementSource is NULL. Nothing to export for ElementSource: " + elementSource.getUuid());
+    											}
+    										}
-...
     				// Start transaction
     				txStatus = startTransaction(true);
     				logger.error("Started new transaction. Fetching some " + parentPluralString + " first (max: " + limit + ") ...");
     				logger.error("Started new transaction. Fetching some " + pluralString + " first (max: " + limit + ") ...");
+    			}
     			if (list.size() == 0) {
     				logger.error("No " + pluralString + " left to fetch.");
-...
+    	}
     	/**
     	 * Returns whether the given Set of DescriptionElementSources have a citation or not.
     	 * @param elementSources
     	 * Returns the identifier of the last occurrence committed to the database.
     	 * @param state
     	 * @return
     	 */
     	public static boolean hasCitations(Set<DescriptionElementSource> elementSources) {
     		boolean notFound = true;
     		if (elementSources.size() == 0) {
     			return false;
     		} else {
     			for (DescriptionElementSource elementSource : elementSources) {
     				notFound &= elementSource.getCitation() == null;
     	private static Integer getLastOccurrenceId(PesiExportState state) {
     		// Retrieve the identifier of the last stored record
     		// Retrieve database identifier of the last created occurrence record.
     		String lastRecordSql = "Select @@Identity From OccurrenceSource";
     		Connection con = state.getConfig().getDestination().getConnection();
     		PreparedStatement stmt = null;
     		Integer occurrenceId = 0;
     		try {
     			stmt = con.prepareStatement(lastRecordSql);
     	//		stmt.setString(1, dbTableName);
     			ResultSet resultSet = stmt.executeQuery();
     			while (resultSet.next()) {
     				// Count of this resultset should be 1
     				occurrenceId = resultSet.getInt(1);
+    			}
     			if (occurrenceId == 0) {
     				throw new RuntimeException();
+    			}
     		} catch (SQLException e) {
     			logger.error("SQLException during getOccurrenceId invoke.");
     			e.printStackTrace();
+    		}
     		if (notFound) {
     			return false;
     		} else {
     			return true;
+    		}
+    	}
     	/**
     	 * @return the taxon
     	 */
     	public static Taxon getTaxon() {
     		return taxon;
     		return occurrenceId;
+    	}
     	/**
     	 * @param taxon the taxon to set
     	 */
     	public static void setTaxon(Taxon taxon) {
     		PesiOccurrenceExport.taxon = taxon;
+    	}
     	/**
     	 * Creates the entries for the database table 'OccurrenceSource'.
-...
     				stmt.executeUpdate();
     				return true;
     			} catch (SQLException e) {
     				logger.error("SQLException during update into " + dbTableName + ". Entity: " + entity.getUuid());
     				logger.error("SQLException during getOccurrenceId invoke...");
     				e.printStackTrace();
     				return false;
+    			}
-...
     	/**
     	 * Returns the <code>TaxonFk</code> attribute.
     	 * @param entity
     	 * @param state The {@link DbExportStateBase DbExportState}.
     	 * @return The <code>TaxonFk</code> attribute.
     	 * @see MethodMapper
-...
     		// since it awaits two parameters if one of them is of instance DbExportStateBase.
     		Integer result = null;
     		if (state != null && taxon != null) {
     			result = state.getDbId(taxon);
     			result = state.getDbId(taxon.getName());
+    		}
     		return result;
+    	}
-...
     	@SuppressWarnings("unused")
     	private static String getTaxonFullNameCache(AnnotatableEntity entity) {
     		String result = null;
     		if (getTaxon() != null) {
     			TaxonNameBase taxonName = getTaxon().getName();
     			if (taxonName != null) {
     				result = taxonName.getTitleCache();
+    			}
+    		}
     		result = taxon.getName().getTitleCache();
     		return result;
+    	}
-...
     		if (getNamedArea() != null) {
     			result = PesiTransformer.area2AreaId(namedArea);
     		} else {
     			logger.warn("A NamedArea could not be found for entity: " + entity.getUuid());
     			logger.warn("This should never happen, but a NamedArea could not be found for entity: " + entity.getUuid());
+    		}
     		return result;
+    	}
-...
     		if (getNamedArea() != null) {
     			result = PesiTransformer.area2AreaCache(namedArea);
     		} else {
     			logger.warn("A NamedArea could not be found for entity: " + entity.getUuid());
     			logger.warn("This should never happen, but a NamedArea could not be found for entity: " + entity.getUuid());
+    		}
     		return result;
+    	}
-...
     		Integer result = null;
     		if (state != null && entity != null && entity.isInstanceOf(ReferenceBase.class)) {
     			ReferenceBase reference = CdmBase.deproxy(entity, ReferenceBase.class);
     			if (reference != null) {
     				result = state.getDbId(reference);
+    			}
     			result = state.getDbId(reference);
+    		}
     		return result;
+    	}
-...
     		String result = null;
     		if (entity != null && entity.isInstanceOf(ReferenceBase.class)) {
     			ReferenceBase reference = CdmBase.deproxy(entity, ReferenceBase.class);
     			if (reference != null) {
     				result = reference.getTitle();
+    			}
     			result = reference.getTitle();
+    		}
     		return result;
+    	}

Also available in: Unified diff

Project

General

Profile

EDIT

Revision 892efc69

Added by Andreas Kohlbecker almost 14 years ago