Revision 3194d52a
Added by Andreas Müller over 2 years ago
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
update Datasource script