Project

General

Profile

« Previous | Next » 

Revision 3194d52a

Added by Andreas Müller over 2 years ago

update Datasource script

View differences:

cdmlib-services/src/test/java/eu/etaxonomy/cdm/test/function/Datasource.java
26 26
import eu.etaxonomy.cdm.api.application.CdmApplicationUtils;
27 27
import eu.etaxonomy.cdm.api.service.ITaxonNodeService;
28 28
import eu.etaxonomy.cdm.api.service.ITaxonService;
29
import eu.etaxonomy.cdm.api.service.UpdateResult;
29 30
import eu.etaxonomy.cdm.api.service.config.TaxonDeletionConfigurator;
31
import eu.etaxonomy.cdm.api.service.description.AggregationMode;
32
import eu.etaxonomy.cdm.api.service.description.DistributionAggregationConfiguration;
33
import eu.etaxonomy.cdm.api.service.description.StructuredDescriptionAggregationConfiguration;
30 34
import eu.etaxonomy.cdm.api.service.dto.GroupedTaxonDTO;
35
import eu.etaxonomy.cdm.common.monitor.DefaultProgressMonitor;
31 36
import eu.etaxonomy.cdm.config.AccountStore;
32 37
import eu.etaxonomy.cdm.database.CdmDataSource;
33 38
import eu.etaxonomy.cdm.database.CdmPersistentDataSource;
......
35 40
import eu.etaxonomy.cdm.database.DatabaseTypeEnum;
36 41
import eu.etaxonomy.cdm.database.DbSchemaValidation;
37 42
import eu.etaxonomy.cdm.database.ICdmDataSource;
43
import eu.etaxonomy.cdm.filter.TaxonNodeFilter;
38 44
import eu.etaxonomy.cdm.model.agent.Person;
45
import eu.etaxonomy.cdm.model.description.DescriptiveDataSet;
39 46
import eu.etaxonomy.cdm.model.description.Distribution;
40 47
import eu.etaxonomy.cdm.model.description.PresenceAbsenceTerm;
41 48
import eu.etaxonomy.cdm.model.description.TaxonDescription;
......
52 59
import eu.etaxonomy.cdm.model.taxon.Taxon;
53 60
import eu.etaxonomy.cdm.model.taxon.TaxonNode;
54 61
import eu.etaxonomy.cdm.model.term.DefinedTermBase;
62
import eu.etaxonomy.cdm.model.term.TermTree;
55 63
import eu.etaxonomy.cdm.model.term.init.TermNotFoundException;
56 64

  
57 65
public class Datasource {
......
73 81

  
74 82
//		DatabaseTypeEnum dbType = DatabaseTypeEnum.MySQL;
75 83

  
76
		server = "localhost";
77
		database = "cdm_test";
78
//		database = "cdm_production_edaphobase";
79
		username = "edit";
80
		dataSource = CdmDataSource.NewMySqlInstance(server, database, username, AccountStore.readOrStorePassword(server, database, username, null));
84
//		server = "localhost";
85
//		database = "cdm_test";
86
////		database = "cdm_production_edaphobase";
87
//		username = "edit";
88
//		dataSource = CdmDataSource.NewMySqlInstance(server, database, username, AccountStore.readOrStorePassword(server, database, username, null));
81 89

  
82 90
//		server = "160.45.63.171";
83
//		database = "cdm_production_flora_malesiana_prospective";
91
//		database = "xxx";
84 92
//		username = "edit";
85 93
//		dataSource = CdmDataSource.NewMySqlInstance(server, database, username, AccountStore.readOrStorePassword(server, database, username, null));
86 94

  
87 95

  
88
//		server = "test.e-taxonomy.eu";
89
//		database = "cdm_test2";
90
//		username = "edit";
91
//		dataSource = CdmDataSource.NewMySqlInstance(server, database, username, AccountStore.readOrStorePassword(server, database, username, null));
96
		server = "test.e-taxonomy.eu";
97
		database = "cdm_rem_conf_am";
98
		username = "edit";
99
		dataSource = CdmDataSource.NewMySqlInstance(server, database, username, AccountStore.readOrStorePassword(server, database, username, null));
92 100

  
93 101
//		String server = "localhost";
94 102
//		String database = "testCDM";
......
122 130
		CdmApplicationController appCtr;
123 131
		appCtr = CdmApplicationController.NewInstance(dataSource, schema);
124 132

  
125
		appCtr.getOccurrenceService().findRootUnitDTOs(UUID.fromString("2debf5ee-cb57-40bc-af89-173d1d17cefe"));
126

  
133
//		appCtr.getOccurrenceService().findRootUnitDTOs(UUID.fromString("2debf5ee-cb57-40bc-af89-173d1d17cefe"));
134
//		aggregateDDS(appCtr);
135
		aggregateDistribution(appCtr);
127 136

  
128 137
		appCtr.close();
129 138
		System.exit(0);
130 139
	}
131 140

  
141
    private void aggregateDistribution(CdmApplicationController app){
142

  
143
        System.out.println("agg distr");
144
        DefaultProgressMonitor monitor = DefaultProgressMonitor.NewInstance();
145

  
146
        UUID descriptaceaeUuid = UUID.fromString("5a37c47c-347c-49f8-88ba-2720b194dfb9");
147

  
148
        TaxonNodeFilter filter = TaxonNodeFilter.NewSubtreeInstance(descriptaceaeUuid);
149
        filter.setIncludeUnpublished(true);
150
        List<AggregationMode> aggregationModes = AggregationMode.byToParent();
151
        TermTree<PresenceAbsenceTerm> statusOrder = null;
152
        List<UUID> superAreas = new ArrayList<>();
153
        DistributionAggregationConfiguration config = DistributionAggregationConfiguration.NewInstance(aggregationModes, superAreas, filter, statusOrder, monitor);
154
        config.setAdaptBatchSize(false);
155
        UpdateResult result = config.getTaskInstance().invoke(config, app);
156
        System.out.println(result);
157
    }
158

  
159
	private void aggregateDDS(CdmApplicationController app){
160

  
161
	    System.out.println("find dds");
162
	    DescriptiveDataSet dds = app.getDescriptiveDataSetService().find(21);
163
	    UUID facciniaSubtreeUuid = UUID.fromString("cf0bc346-a203-4ad7-ad25-477098361db6");
164
	    UUID arenarioAdamssubtreeUuid = UUID.fromString("0215e668-0a65-42cd-85e0-d97ce78e758b");
165

  
166
	    TaxonNodeFilter filter = TaxonNodeFilter.NewSubtreeInstance(arenarioAdamssubtreeUuid);
167
	    filter.setIncludeUnpublished(true);
168

  
169
	    DefaultProgressMonitor monitor = DefaultProgressMonitor.NewInstance();
170
	    StructuredDescriptionAggregationConfiguration config = StructuredDescriptionAggregationConfiguration.NewInstance(filter, monitor);
171
        config.setDatasetUuid(dds.getUuid());
172
        config.setAggregationMode(AggregationMode.byWithinTaxonAndToParent());
173
        config.setAdaptBatchSize(false);
174
        UpdateResult result = config.getTaskInstance().invoke(config, app);
175
        System.out.println(result);
176

  
177
//	    app.getLongRunningTasksService().invoke(config);
178
	}
179

  
132 180
    private void listClassification(CdmApplicationController appCtr, List<String> propertyPaths) {
133 181
        try {
134 182
            List<Classification> list = appCtr.getClassificationService().list(null, null, null, null, propertyPaths);

Also available in: Unified diff