ref #10183 add BuxalesExportActivator

diff --git a/app-import/src/main/java/eu/etaxonomy/cdm/app/common/CdmDestinations.java b/app-import/src/main/java/eu/etaxonomy/cdm/app/common/CdmDestinations.java
index 39b83aee0740ff41770dbf66e741d197791ed6e6..5eb43b2278c6e3045bb0cbf98b4fbc7f5c12befb 100644 (file)
--- a/app-import/src/main/java/eu/etaxonomy/cdm/app/common/CdmDestinations.java
+++ b/app-import/src/main/java/eu/etaxonomy/cdm/app/common/CdmDestinations.java
@@ -783,6 +783,22 @@ public class CdmDestinations {
                return makeDestination(dbType, cdmServer, cdmDB, -1, cdmUserName, null);
        }
 
+    public static ICdmDataSource cdm_production_cuba(){
+        DatabaseTypeEnum dbType = DatabaseTypeEnum.MySQL;
+        String cdmServer = "160.45.63.171";
+        String cdmDB = "cdm_production_flora_cuba";
+        String cdmUserName = "edit";
+        return makeDestination(dbType, cdmServer, cdmDB, -1, cdmUserName, null);
+    }
+
+    public static ICdmDataSource cdm_production_buxales(){
+        DatabaseTypeEnum dbType = DatabaseTypeEnum.MySQL;
+        String cdmServer = "160.45.63.171";
+        String cdmDB = "cdm_production_buxales";
+        String cdmUserName = "edit";
+        return makeDestination(dbType, cdmServer, cdmDB, -1, cdmUserName, null);
+    }
+
        public static ICdmDataSource cdm_production_palmae(){
                DatabaseTypeEnum dbType = DatabaseTypeEnum.MySQL;
                String cdmServer = "160.45.63.171";

diff --git a/app-import/src/main/java/eu/etaxonomy/cdm/app/cuba/BuxalesExportActivator.java b/app-import/src/main/java/eu/etaxonomy/cdm/app/cuba/BuxalesExportActivator.java
new file mode 100644 (file)
index 0000000..a9dd345
--- /dev/null
+++ b/app-import/src/main/java/eu/etaxonomy/cdm/app/cuba/BuxalesExportActivator.java
@@ -0,0 +1,120 @@
+/**
+* Copyright (C) 2019 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.app.cuba;
+
+import java.util.Calendar;
+import java.util.UUID;
+
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+
+import eu.etaxonomy.cdm.app.common.CdmDestinations;
+import eu.etaxonomy.cdm.common.monitor.IProgressMonitor;
+import eu.etaxonomy.cdm.database.DbSchemaValidation;
+import eu.etaxonomy.cdm.database.ICdmDataSource;
+import eu.etaxonomy.cdm.filter.TaxonNodeFilter.ORDER;
+import eu.etaxonomy.cdm.io.cdm2cdm.Cdm2CdmImportConfigurator;
+import eu.etaxonomy.cdm.io.common.CdmDefaultImport;
+import eu.etaxonomy.cdm.io.common.IImportConfigurator.CHECK;
+import eu.etaxonomy.cdm.io.common.ITaxonNodeOutStreamPartitioner;
+import eu.etaxonomy.cdm.io.common.TaxonNodeOutStreamPartitioner;
+import eu.etaxonomy.cdm.io.common.TaxonNodeOutStreamPartitionerConcurrent;
+import eu.etaxonomy.cdm.model.common.VerbatimTimePeriod;
+import eu.etaxonomy.cdm.model.reference.Reference;
+import eu.etaxonomy.cdm.model.reference.ReferenceFactory;
+
+/**
+ * @author a.mueller
+ * @since 2022-11-08
+ */
+public class BuxalesExportActivator {
+
+    @SuppressWarnings("unused")
+    private static final Logger logger = LogManager.getLogger();
+
+    static final ICdmDataSource cubaSource = CdmDestinations.cdm_production_cuba();
+//    static final ICdmDataSource cdmDestination = CdmDestinations.cdm_local_cdmtest_mysql();
+    static final ICdmDataSource cdmDestination = CdmDestinations.cdm_production_buxales();
+
+    static final String sourceRefTitle = "Flora of Cuba";
+    static final UUID sourceRefUuid = UUID.fromString("85c9bd24-a297-491a-b28a-842030ce0693");
+
+    static final DbSchemaValidation schemaValidation = DbSchemaValidation.VALIDATE;
+
+    //check - import
+    static final CHECK check = CHECK.IMPORT_WITHOUT_CHECK;
+
+    static final int partitionSize = 5000;
+
+    static final boolean doTaxa = true;
+    static final boolean doDescriptions = true;
+    static final boolean doVocabularies = false;
+
+    static final boolean removeImportSources = true;
+
+    static final boolean doConcurrent = false;
+    //auditing
+    static final boolean registerAuditing = true;
+
+// ***************** ALL ************************************************//
+
+    private UUID uuidBuxalesTaxonNodeFilter = UUID.fromString("32d5f482-a82f-4049-8052-032ca6fd1b8a");
+
+    private void doImport(ICdmDataSource source, ICdmDataSource destination, DbSchemaValidation hbm2dll){
+
+        String importFrom = " import from "+ source.getDatabase() + " to "+ destination.getDatabase() + " ...";
+        System.out.println("Start" + importFrom);
+
+        Cdm2CdmImportConfigurator config = Cdm2CdmImportConfigurator.NewInstace(source, destination);
+        config.setConcurrent(doConcurrent);
+        config.setDoTaxa(doTaxa);
+        config.setDoDescriptions(doDescriptions);
+        config.setDoVocabularies(doVocabularies);
+        config.setSourceReference(getSourceRef());
+        config.setRemoveImportSources(removeImportSources);
+
+        IProgressMonitor monitor = config.getProgressMonitor();
+
+        config.setDbSchemaValidation(hbm2dll);
+        config.getTaxonNodeFilter().orSubtree(uuidBuxalesTaxonNodeFilter);
+        config.getTaxonNodeFilter().setOrder(ORDER.TREEINDEX);
+        if (doConcurrent){
+            ITaxonNodeOutStreamPartitioner partitioner = TaxonNodeOutStreamPartitionerConcurrent
+                    .NewInstance(config.getSource(), config.getTaxonNodeFilter(),
+                            8, monitor, 1, TaxonNodeOutStreamPartitioner.fullPropertyPaths);
+            config.setPartitioner(partitioner);
+        }
+
+        config.setCheck(check);
+//        config.setRecordsPerTransaction(partitionSize);
+
+        config.setRegisterAuditing(registerAuditing);
+
+        // invoke import
+        CdmDefaultImport<Cdm2CdmImportConfigurator> myImport = new CdmDefaultImport<>();
+        myImport.invoke(config);
+
+        System.out.println("End" + importFrom);
+    }
+
+    private Reference getSourceRef() {
+        Reference ref = ReferenceFactory.newDatabase();
+        ref.setTitle(sourceRefTitle);
+        ref.setDatePublished(VerbatimTimePeriod.NewVerbatimInstance(Calendar.getInstance()));
+        ref.setUuid(sourceRefUuid);
+        return ref;
+    }
+
+    public static void main(String[] args) {
+        ICdmDataSource cdmDB = CdmDestinations.chooseDestination(args) != null ? CdmDestinations.chooseDestination(args) : cdmDestination;
+        BuxalesExportActivator myImport = new BuxalesExportActivator();
+        myImport.doImport(cubaSource, cdmDB, schemaValidation);
+        System.exit(0);
+    }
+}