adding collections to AlgaTerra import

diff --git a/.gitattributes b/.gitattributes
index 0ee9363cf975fde9afc5c9e0cf5a8fefe9e7b93f..db41695d67f7e11b9e80b48d7e6f8f5014b254ac 100644 (file)
--- a/.gitattributes
+++ b/.gitattributes
@@ -105,6 +105,7 @@ app-import/src/main/java/eu/etaxonomy/cdm/io/algaterra/AlgaTerraImportTransforme
 app-import/src/main/java/eu/etaxonomy/cdm/io/algaterra/AlgaTerraSpecimenImport.java -text
 app-import/src/main/java/eu/etaxonomy/cdm/io/algaterra/AlgaTerraSpecimenImportBase.java -text
 app-import/src/main/java/eu/etaxonomy/cdm/io/algaterra/AlgaTerraTypeImport.java -text
+app-import/src/main/java/eu/etaxonomy/cdm/io/algaterra/validation/AlgaTerraCollectionImportValidator.java -text
 app-import/src/main/java/eu/etaxonomy/cdm/io/algaterra/validation/AlgaTerraSpecimenImportValidator.java -text
 app-import/src/main/java/eu/etaxonomy/cdm/io/algaterra/validation/AlgaTerraTypeImportValidator.java -text
 app-import/src/main/java/eu/etaxonomy/cdm/io/cyprus/CyprusDistributionImport.java -text

diff --git a/app-import/src/main/java/eu/etaxonomy/cdm/io/algaterra/validation/AlgaTerraCollectionImportValidator.java b/app-import/src/main/java/eu/etaxonomy/cdm/io/algaterra/validation/AlgaTerraCollectionImportValidator.java
new file mode 100644 (file)
index 0000000..ac6acc7
--- /dev/null
+++ b/app-import/src/main/java/eu/etaxonomy/cdm/io/algaterra/validation/AlgaTerraCollectionImportValidator.java
@@ -0,0 +1,88 @@
+// $Id$\r
+/**\r
+* Copyright (C) 2007 EDIT\r
+* European Distributed Institute of Taxonomy \r
+* http://www.e-taxonomy.eu\r
+* \r
+* The contents of this file are subject to the Mozilla Public License Version 1.1\r
+* See LICENSE.TXT at the top of this package for the full license terms.\r
+*/\r
+\r
+package eu.etaxonomy.cdm.io.algaterra.validation;\r
+\r
+import org.apache.log4j.Logger;\r
+\r
+import eu.etaxonomy.cdm.io.berlinModel.in.BerlinModelImportConfigurator;\r
+import eu.etaxonomy.cdm.io.berlinModel.in.BerlinModelImportState;\r
+import eu.etaxonomy.cdm.io.common.IOValidator;\r
+\r
+/**\r
+ * @author a.mueller\r
+ * @created 17.02.2010\r
+ * @version 1.0\r
+ */\r
+public class AlgaTerraCollectionImportValidator implements IOValidator<BerlinModelImportState> {\r
+       private static final Logger logger = Logger.getLogger(AlgaTerraCollectionImportValidator.class);\r
+\r
+       /* (non-Javadoc)\r
+        * @see eu.etaxonomy.cdm.io.common.IOValidator#validate(eu.etaxonomy.cdm.io.common.IoStateBase)\r
+        */\r
+       public boolean validate(BerlinModelImportState state) {\r
+               boolean result = true;\r
+               BerlinModelImportConfigurator bmiConfig = state.getConfig();\r
+//             result &= checkTaxonIsAccepted(bmiConfig);\r
+               //result &= checkPartOfJournal(bmiConfig);\r
+               System.out.println("Checking for Collections not yet fully implemented");\r
+               return result;\r
+       }\r
+       \r
+       \r
+       //******************************** CHECK *************************************************\r
+               \r
+//             private static boolean checkTaxonIsAccepted(BerlinModelImportConfigurator config){\r
+//                     try {\r
+//                             boolean result = true;\r
+//                             Source source = config.getSource();\r
+//                             String strQuery = "SELECT emOccurrence.OccurrenceId, PTaxon.StatusFk, Name.FullNameCache, Status.Status, PTaxon.PTRefFk, Reference.RefCache " + \r
+//                                                     " FROM emOccurrence INNER JOIN " +\r
+//                                                             " PTaxon ON emOccurrence.PTNameFk = PTaxon.PTNameFk AND emOccurrence.PTRefFk = PTaxon.PTRefFk INNER JOIN " + \r
+//                                             " Name ON PTaxon.PTNameFk = Name.NameId INNER JOIN " +\r
+//                                             " Status ON PTaxon.StatusFk = Status.StatusId LEFT OUTER JOIN " +\r
+//                                             " Reference ON PTaxon.PTRefFk = Reference.RefId " + \r
+//                                                     " WHERE (PTaxon.StatusFk <> 1)  ";\r
+//\r
+//                             if (StringUtils.isNotBlank(config.getOccurrenceFilter())){\r
+//                                     strQuery += String.format(" AND (%s) ", config.getOccurrenceFilter()) ; \r
+//                             }\r
+//\r
+//                             \r
+//                             ResultSet resulSet = source.getResultSet(strQuery);\r
+//                             boolean firstRow = true;\r
+//                             while (resulSet.next()){\r
+//                                     if (firstRow){\r
+//                                             System.out.println("========================================================");\r
+//                                             System.out.println("There are Occurrences for a taxon that is not accepted!");\r
+//                                             System.out.println("========================================================");\r
+//                                     }\r
+//                                     int occurrenceId = resulSet.getInt("OccurrenceId");\r
+////                                   int statusFk = resulSet.getInt("StatusFk");\r
+//                                     String status = resulSet.getString("Status");\r
+//                                     String fullNameCache = resulSet.getString("FullNameCache");\r
+//                                     String ptRefFk = resulSet.getString("PTRefFk");\r
+//                                     String ptRef = resulSet.getString("RefCache");\r
+//                                     \r
+//                                     System.out.println("OccurrenceId:" + occurrenceId + "\n  Status: " + status + \r
+//                                                     "\n  FullNameCache: " + fullNameCache +  "\n  ptRefFk: " + ptRefFk +\r
+//                                                     "\n  sec: " + ptRef );\r
+//                                     \r
+//                                     result = firstRow = false;\r
+//                             }\r
+//                             \r
+//                             return result;\r
+//                     } catch (SQLException e) {\r
+//                             e.printStackTrace();\r
+//                             return false;\r
+//                     }\r
+//             }\r
+\r
+}\r