Project

General

Profile

Download (5.52 KB) Statistics
| Branch: | Revision:
1
/**
2
* Copyright (C) 2007 EDIT
3
* European Distributed Institute of Taxonomy
4
* http://www.e-taxonomy.eu
5
*
6
* The contents of this file are subject to the Mozilla Public License Version 1.1
7
* See LICENSE.TXT at the top of this package for the full license terms.
8
*/
9

    
10
package eu.etaxonomy.cdm.app.iapt;
11

    
12
import java.io.File;
13
import java.net.URI;
14
import java.net.URISyntaxException;
15
import java.util.UUID;
16

    
17
import eu.etaxonomy.cdm.common.monitor.DefaultProgressMonitor;
18
import eu.etaxonomy.cdm.database.DatabaseTypeEnum;
19
import eu.etaxonomy.cdm.model.common.TimePeriod;
20
import org.apache.log4j.Logger;
21

    
22
import eu.etaxonomy.cdm.app.common.CdmDestinations;
23
import eu.etaxonomy.cdm.database.DbSchemaValidation;
24
import eu.etaxonomy.cdm.database.ICdmDataSource;
25
import eu.etaxonomy.cdm.io.common.CdmDefaultImport;
26
import eu.etaxonomy.cdm.io.common.IImportConfigurator.CHECK;
27
import eu.etaxonomy.cdm.io.iapt.IAPTImportConfigurator;
28
import eu.etaxonomy.cdm.model.reference.Reference;
29
import eu.etaxonomy.cdm.model.reference.ReferenceFactory;
30

    
31

    
32
/**
33
 * @author a.kohlbecker
34
 * @date Jul 26, 2016
35
 *
36
 */
37
public class IAPTActivator {
38
    private static final Logger logger = Logger.getLogger(IAPTActivator.class);
39

    
40
    public static final String DATA_FILE_FULL = "Registration_DB_from_BGBM17.xls";
41
    public static final String DATA_FILE_0_100 = "iapt-100.xls";
42
    public static final String DATA_ENCODING_PROBLEMS = "encoding-problems.xls";
43
    public static final String DATA_IAPT_TYPES_100 = "iapt-types-100.xls";
44
    public static final String DATA_TYPE_LEG_100 = "iapt-type-leg-100.xls";
45
    public static final String DATA_NAME_TYPES = "iapt-name-types.xls";
46
    public static final String DATA_SINGLE = "single.xls";
47
    public static final String DATA_FILE = DATA_FILE_FULL;
48

    
49
    //database validation status (create, update, validate ...)
50
    static DbSchemaValidation hbm2dll = DbSchemaValidation.CREATE;
51

    
52
    static ICdmDataSource cdmDestination = null;
53
    static {
54
        DatabaseTypeEnum dbType = DatabaseTypeEnum.MySQL;
55
        String cdmServer = "127.0.0.1";
56
        String cdmDB = "cdm_algea_registry";
57
        String cdmUserName = "edit";
58
        cdmDestination =  CdmDestinations.makeDestination(dbType, cdmServer, cdmDB, -1, cdmUserName, null);
59
        // cdmDestination = CdmDestinations.localH2();
60
    }
61

    
62
    static boolean invers = true;
63

    
64
    static boolean include = !invers;
65

    
66
    //classification
67
    static final UUID classificationUuid = UUID.fromString("8c51efb4-3d67-4bea-8f87-4bc1cba1310d");
68
    private static final String classificationName = "IAPT";
69
    static final String sourceReferenceTitle = "IAPT Import";
70

    
71
    //check - import
72
    static final CHECK check = CHECK.IMPORT_WITHOUT_CHECK;
73

    
74

    
75
    private void doImport(ICdmDataSource cdmDestination){
76

    
77
        URI source = fileURI();
78

    
79
        Reference secRef = ReferenceFactory.newDatabase();
80
        secRef.setTitle("IAPT");
81

    
82
        Reference sourceRef = ReferenceFactory.newDatabase();
83
        sourceRef.setTitle("IAPT Registration of Plant Names Database");
84
        sourceRef.setDatePublished(TimePeriod.NewInstance(1998, 2016));
85
        sourceRef.setOrganization("International Association for Plant Taxonomy");
86
        try {
87
            sourceRef.setUri(new URI("http://archive.bgbm.org/scripts/ASP/registration/regSearch.asp"));
88
        } catch (URISyntaxException e) {
89
            e.printStackTrace();
90
        }
91

    
92

    
93
        //make Source
94
        IAPTImportConfigurator config= IAPTImportConfigurator.NewInstance(source, cdmDestination);
95
        config.setClassificationUuid(classificationUuid);
96
        config.setClassificationName(classificationName);
97
        config.setCheck(check);
98
        config.setDbSchemaValidation(hbm2dll);
99
        config.setSourceReference(sourceRef);
100
        config.setSecReference(secRef);
101
        config.setProgressMonitor(DefaultProgressMonitor.NewInstance());
102
        // config.setBatchSize(100); // causes Error during managed flush [Don't change the reference to a collection with delete-orphan enabled : eu.etaxonomy.cdm.model.taxon.TaxonNode.annotations]
103

    
104
        CdmDefaultImport<IAPTImportConfigurator> myImport = new CdmDefaultImport<>();
105

    
106
        doSingleSource(fileURI(), config, myImport);
107

    
108
        System.exit(0);
109

    
110
    }
111

    
112
    /**
113
     * @param source
114
     * @param config
115
     * @param myImport
116
     */
117
    private void doSingleSource(URI source, IAPTImportConfigurator config, CdmDefaultImport<IAPTImportConfigurator> myImport) {
118
        config.setSource(source);
119
        String fileName = source.toString();
120
        fileName = fileName.substring(fileName.lastIndexOf("/") + 1 );
121

    
122
        String message = "Start import from ("+ fileName + ") ...";
123
        System.out.println(message);
124
        logger.warn(message);
125
        config.setSourceReference(getSourceReference(fileName));
126
        myImport.invoke(config);
127

    
128
        System.out.println("End import from ("+ source.toString() + ")...");
129
    }
130

    
131
    private final Reference inRef = ReferenceFactory.newGeneric();
132
    private Reference getSourceReference(String string) {
133
        Reference result = ReferenceFactory.newGeneric();
134
        result.setTitleCache(string, true);
135
        result.setInReference(inRef);
136
        inRef.setTitleCache(sourceReferenceTitle, true);
137
        return result;
138
    }
139

    
140

    
141

    
142
    public static URI fileURI() {
143
        File f = new File(System.getProperty("user.home") + "/data/Projekte/Algea Name Registry/registry/sources/IAPT/" + DATA_FILE);
144
        return f.toURI();
145
    }
146

    
147
    /**
148
     * @param args
149
     */
150
    public static void main(String[] args) {
151
        IAPTActivator me = new IAPTActivator();
152
        me.doImport(cdmDestination);
153
    }
154

    
155
}
    (1-1/1)