Revision 3f87d726
Added by Katja Luther over 4 years ago
| app-import/src/main/java/eu/etaxonomy/cdm/app/wp6/cichorieae/CichorieaeCacheUpdater.java | ||
|---|---|---|
| 11 | 11 |
|
| 12 | 12 |
import java.util.Arrays; |
| 13 | 13 |
import java.util.List; |
| 14 |
import java.util.UUID; |
|
| 14 | 15 |
|
| 15 | 16 |
import org.apache.log4j.Logger; |
| 16 | 17 |
|
| 18 |
import eu.etaxonomy.cdm.api.application.CdmApplicationController; |
|
| 17 | 19 |
import eu.etaxonomy.cdm.api.service.config.CacheUpdaterConfigurator; |
| 18 | 20 |
import eu.etaxonomy.cdm.app.common.CdmDestinations; |
| 21 |
import eu.etaxonomy.cdm.common.monitor.IRemotingProgressMonitor; |
|
| 19 | 22 |
import eu.etaxonomy.cdm.database.DbSchemaValidation; |
| 20 | 23 |
import eu.etaxonomy.cdm.database.ICdmDataSource; |
| 24 |
import eu.etaxonomy.cdm.io.api.application.CdmIoApplicationController; |
|
| 21 | 25 |
import eu.etaxonomy.cdm.io.common.CdmDefaultImport; |
| 22 | 26 |
import eu.etaxonomy.cdm.io.common.ImportResult; |
| 23 | 27 |
import eu.etaxonomy.cdm.model.name.TaxonName; |
| ... | ... | |
| 103 | 107 |
|
| 104 | 108 |
|
| 105 | 109 |
private ImportResult doInvoke(ICdmDataSource destination){
|
| 106 |
ImportResult success; |
|
| 110 |
ImportResult success = null;
|
|
| 107 | 111 |
|
| 108 | 112 |
CacheUpdaterConfigurator config; |
| 109 | 113 |
try {
|
| 110 |
config = CacheUpdaterConfigurator.NewExludedInstance(destination, classListStrings);
|
|
| 114 |
config = CacheUpdaterConfigurator.NewInstance(classListStrings);
|
|
| 111 | 115 |
|
| 112 | 116 |
// invoke import |
| 113 |
CdmDefaultImport<CacheUpdaterConfigurator> myImport = new CdmDefaultImport<>(); |
|
| 114 |
success = myImport.invoke(config); |
|
| 115 |
String successString = success.isSuccess() ? "successful" : " with errors "; |
|
| 117 |
CdmApplicationController appCtrInit = CdmIoApplicationController.NewInstance(destination, DbSchemaValidation.VALIDATE, false); |
|
| 118 |
appCtrInit.authenticate("admin", "kups366+RU");
|
|
| 119 |
UUID monitUuid = appCtrInit.getLongRunningTasksService().monitLongRunningTask(config); |
|
| 120 |
IRemotingProgressMonitor monitor = appCtrInit.getProgressMonitorService().getRemotingMonitor(monitUuid); |
|
| 121 |
while(monitor != null && (!monitor.isCanceled() || !monitor.isDone() || !monitor.isFailed())) {
|
|
| 122 |
try {
|
|
| 123 |
Thread.sleep(10); |
|
| 124 |
} catch (InterruptedException e) {
|
|
| 125 |
// TODO Auto-generated catch block |
|
| 126 |
e.printStackTrace(); |
|
| 127 |
} |
|
| 128 |
logger.info("Waiting for monitered work to start ..");
|
|
| 129 |
monitor = appCtrInit.getProgressMonitorService().getRemotingMonitor(monitUuid); |
|
| 130 |
} |
|
| 131 |
|
|
| 132 |
|
|
| 133 |
String successString = monitor == null || monitor.isDone() ? "successful" : " with errors "; |
|
| 116 | 134 |
System.out.println("End updating caches for "+ destination.getDatabase() + "..." + successString);
|
| 117 | 135 |
return success; |
| 118 | 136 |
} catch (ClassNotFoundException e) {
|
Also available in: Unified diff
fix compile errors in app-import