ref #8385: adapt local and db preference pages

[taxeditor.git] / eu.etaxonomy.taxeditor.store / src / main / java / eu / etaxonomy / taxeditor / io / ExportManager.java

diff --git a/eu.etaxonomy.taxeditor.store/src/main/java/eu/etaxonomy/taxeditor/io/ExportManager.java b/eu.etaxonomy.taxeditor.store/src/main/java/eu/etaxonomy/taxeditor/io/ExportManager.java
index d256407643de5697c6ed43924cd57962fafbf6a1..854ea00994fea65fa61c2d053cf3219d3eb5fb89 100644 (file)
--- a/eu.etaxonomy.taxeditor.store/src/main/java/eu/etaxonomy/taxeditor/io/ExportManager.java
+++ b/eu.etaxonomy.taxeditor.store/src/main/java/eu/etaxonomy/taxeditor/io/ExportManager.java
@@ -10,10 +10,8 @@
 package eu.etaxonomy.taxeditor.io;
 
 import java.io.BufferedWriter;
 package eu.etaxonomy.taxeditor.io;
 
 import java.io.BufferedWriter;

-import java.io.ByteArrayOutputStream;

 import java.io.File;
 import java.io.FileOutputStream;
 import java.io.File;
 import java.io.FileOutputStream;

-import java.io.IOException;

 import java.io.OutputStreamWriter;
 import java.io.Writer;
 import java.text.SimpleDateFormat;
 import java.io.OutputStreamWriter;
 import java.io.Writer;
 import java.text.SimpleDateFormat;


@@ -31,37 +29,32 @@ import org.eclipse.core.runtime.Assert;
 import org.eclipse.core.runtime.IProgressMonitor;
 import org.eclipse.core.runtime.IStatus;
 import org.eclipse.core.runtime.Status;
 import org.eclipse.core.runtime.IProgressMonitor;
 import org.eclipse.core.runtime.IStatus;
 import org.eclipse.core.runtime.Status;

+import org.eclipse.core.runtime.SubMonitor;

 import org.eclipse.core.runtime.jobs.Job;
 import org.eclipse.swt.widgets.Display;
 import org.eclipse.core.runtime.jobs.Job;
 import org.eclipse.swt.widgets.Display;

-import org.eclipse.ui.IWorkbenchPart;
-import org.eclipse.ui.PlatformUI;

 
 import eu.etaxonomy.cdm.api.application.CdmApplicationState;
 import eu.etaxonomy.cdm.api.application.ICdmRepository;
 import eu.etaxonomy.cdm.api.conversation.IConversationEnabled;
 import eu.etaxonomy.cdm.common.monitor.IRemotingProgressMonitor;
 
 import eu.etaxonomy.cdm.api.application.CdmApplicationState;
 import eu.etaxonomy.cdm.api.application.ICdmRepository;
 import eu.etaxonomy.cdm.api.conversation.IConversationEnabled;
 import eu.etaxonomy.cdm.common.monitor.IRemotingProgressMonitor;

+import eu.etaxonomy.cdm.io.cdmLight.CdmLightExportConfigurator;

 import eu.etaxonomy.cdm.io.common.CdmDefaultExport;
 import eu.etaxonomy.cdm.io.common.ExportDataWrapper;
 import eu.etaxonomy.cdm.io.common.ExportResult;
 import eu.etaxonomy.cdm.io.common.ExportResultType;
 import eu.etaxonomy.cdm.io.common.IExportConfigurator;
 import eu.etaxonomy.cdm.io.common.CdmDefaultExport;
 import eu.etaxonomy.cdm.io.common.ExportDataWrapper;
 import eu.etaxonomy.cdm.io.common.ExportResult;
 import eu.etaxonomy.cdm.io.common.ExportResultType;
 import eu.etaxonomy.cdm.io.common.IExportConfigurator;

-import eu.etaxonomy.cdm.io.common.IImportConfigurator;

 import eu.etaxonomy.cdm.io.common.IIoConfigurator;
 import eu.etaxonomy.cdm.io.common.IIoConfigurator;

-import eu.etaxonomy.cdm.io.common.IImportConfigurator.SOURCE_TYPE;

 import eu.etaxonomy.cdm.io.dwca.out.DwcaTaxExportConfigurator;
 import eu.etaxonomy.cdm.io.jaxb.JaxbExportConfigurator;
 import eu.etaxonomy.cdm.io.dwca.out.DwcaTaxExportConfigurator;
 import eu.etaxonomy.cdm.io.jaxb.JaxbExportConfigurator;

-import eu.etaxonomy.cdm.io.cdmLight.CdmLightExportConfigurator;

 import eu.etaxonomy.cdm.io.sdd.out.SDDExportConfigurator;
 import eu.etaxonomy.cdm.io.service.IIOService;
 import eu.etaxonomy.cdm.io.sdd.out.SDDExportConfigurator;
 import eu.etaxonomy.cdm.io.service.IIOService;

+import eu.etaxonomy.taxeditor.event.EventUtility;

 import eu.etaxonomy.taxeditor.model.AbstractUtility;
 import eu.etaxonomy.taxeditor.model.CdmProgressMonitorAdapter;
 import eu.etaxonomy.taxeditor.model.MessagingUtils;
 import eu.etaxonomy.taxeditor.model.AbstractUtility;
 import eu.etaxonomy.taxeditor.model.CdmProgressMonitorAdapter;
 import eu.etaxonomy.taxeditor.model.MessagingUtils;

-
-import eu.etaxonomy.taxeditor.operation.FeedbackGenerator;

 import eu.etaxonomy.taxeditor.operation.IFeedbackGenerator;
 import eu.etaxonomy.taxeditor.operation.IPostMoniteredOperationEnabled;
 import eu.etaxonomy.taxeditor.store.CdmStore;
 import eu.etaxonomy.taxeditor.operation.IFeedbackGenerator;
 import eu.etaxonomy.taxeditor.operation.IPostMoniteredOperationEnabled;
 import eu.etaxonomy.taxeditor.store.CdmStore;

-import eu.etaxonomy.taxeditor.store.StoreUtil;

 import eu.etaxonomy.taxeditor.store.internal.TaxeditorStorePlugin;
 
 /**
 import eu.etaxonomy.taxeditor.store.internal.TaxeditorStorePlugin;
 
 /**


@@ -74,8 +67,8 @@ import eu.etaxonomy.taxeditor.store.internal.TaxeditorStorePlugin;
  * @version 1.0
  */
 public class ExportManager extends AbstractIOManager<IExportConfigurator> implements IPostMoniteredOperationEnabled {
  * @version 1.0
  */
 public class ExportManager extends AbstractIOManager<IExportConfigurator> implements IPostMoniteredOperationEnabled {

-       
-       private final String successMessage = "The export was successfull";
+
+       private final String successMessage = "The export was successful";

 
     private static final Logger logger = Logger.getLogger(ExportManager.class);
     /** Constant <code>DATE_FORMAT_NOW="yyyyMMddHHmm"</code> */
 
     private static final Logger logger = Logger.getLogger(ExportManager.class);
     /** Constant <code>DATE_FORMAT_NOW="yyyyMMddHHmm"</code> */


@@ -154,7 +147,7 @@ public class ExportManager extends AbstractIOManager<IExportConfigurator> implem
                                        monitor.worked(60);
                                } catch (RuntimeException e) {
                                        MessagingUtils.messageDialog("Error exporting data", this,
                                        monitor.worked(60);
                                } catch (RuntimeException e) {
                                        MessagingUtils.messageDialog("Error exporting data", this,

-                                                       "An error occured while"
+                                                       "An error occurred while"

                                                                        + "exporting to destination '"
                                                                        + configurator.getDestinationNameString()
                                                                        + "'.\n"
                                                                        + "exporting to destination '"
                                                                        + configurator.getDestinationNameString()
                                                                        + "'.\n"


@@ -165,8 +158,7 @@ public class ExportManager extends AbstractIOManager<IExportConfigurator> implem
 
                                        @Override
                                        public void run() {
 
                                        @Override
                                        public void run() {

-                                               IWorkbenchPart activePart = StoreUtil.getActivePage()
-                                                               .getActivePart();
+                                               Object activePart = EventUtility.getActivePart();

                                                if (activePart instanceof IConversationEnabled) {
                                                        // terminate any open transactions
                                                        IConversationEnabled conversationEnabled = (IConversationEnabled) activePart;
                                                if (activePart instanceof IConversationEnabled) {
                                                        // terminate any open transactions
                                                        IConversationEnabled conversationEnabled = (IConversationEnabled) activePart;


@@ -192,6 +184,8 @@ public class ExportManager extends AbstractIOManager<IExportConfigurator> implem
 
                                return Status.OK_STATUS;
                        }
 
                                return Status.OK_STATUS;
                        }

+
+

                };
 
                return job;
                };
 
                return job;


@@ -205,7 +199,8 @@ public class ExportManager extends AbstractIOManager<IExportConfigurator> implem
            Job job = new Job("Export: " + configurator.getClass().getSimpleName()) { //$NON-NLS-1$
                @Override
                protected IStatus run(IProgressMonitor monitor) {
            Job job = new Job("Export: " + configurator.getClass().getSimpleName()) { //$NON-NLS-1$
                @Override
                protected IStatus run(IProgressMonitor monitor) {

-                   monitor.beginTask("Exporting database. This will take some time.", IProgressMonitor.UNKNOWN);
+                   SubMonitor subMonitor = SubMonitor.convert(monitor, 100);
+                   subMonitor.beginTask("Exporting database. This will take some time.", IProgressMonitor.UNKNOWN);

                    try {
                        IIOService ioService = CdmApplicationState.getIOService();
                        UUID uuid = ioService.monitExportData(configurator);
                    try {
                        IIOService ioService = CdmApplicationState.getIOService();
                        UUID uuid = ioService.monitExportData(configurator);


@@ -217,22 +212,41 @@ public class ExportManager extends AbstractIOManager<IExportConfigurator> implem
                                 1000,
                                 ExportManager.this,
                                 feedBackGeneratorList,
                                 1000,
                                 ExportManager.this,
                                 feedBackGeneratorList,

-                                monitor);
-                       
+                                subMonitor);
+

                     } catch (Exception ex) {
                         return new Status(Status.ERROR, TaxeditorStorePlugin.PLUGIN_ID, "Operation Interrupted", ex);
                     }
                     } catch (Exception ex) {
                         return new Status(Status.ERROR, TaxeditorStorePlugin.PLUGIN_ID, "Operation Interrupted", ex);
                     }

-                       
+

                        ExportResult result = (ExportResult)remotingMonitor.getResult();
                        ExportDataWrapper data = result.getExportData();
                        try{
                        ExportResult result = (ExportResult)remotingMonitor.getResult();
                        ExportDataWrapper data = result.getExportData();
                        try{

-                       if (result.getExportData().getType().equals(ExportResultType.BYTE_ARRAY)){
-                           byte[] exportData = (byte[])data.getExportData();
-                               if(exportData != null){
-                                   FileOutputStream stream = new FileOutputStream(exportFile);
-                                stream.write(exportData);
-                                stream.close();
-                               } 
+                       if (result.getExportData().getType().equals(ExportResultType.BYTE_ARRAY) || result.getExportData().getType().equals(ExportResultType.LIST_BYTE_ARRAY)){
+                           if (data.getExportData() instanceof byte[]){
+                               byte[] exportData = (byte[])data.getExportData();
+                               if(exportData != null){
+                                    FileOutputStream stream = new FileOutputStream(exportFile);
+                                    Writer out = new BufferedWriter(new OutputStreamWriter(
+                                           stream, "UTF8"));
+
+                                    stream.write(exportData);
+                                    out.flush();
+                                    stream.close();
+                                }
+                           }else if (data.getExportData() instanceof List<?>){
+                                //TODO:This needs to be improved
+                               List<byte[]> exportData = (List<byte[]>)data.getExportData();
+                                    if(exportData != null){
+                                        FileOutputStream stream = new FileOutputStream(exportFile);
+                                        Writer out = new BufferedWriter(new OutputStreamWriter(
+                                               stream, "UTF8"));
+
+                                        stream.write(exportData.get(0));
+                                        out.flush();
+                                        stream.close();
+                                }
+                           }
+

                        } else if (result.getExportData().getType().equals(ExportResultType.MAP_BYTE_ARRAY)){
                             Map<String, byte[]> resultMap = (Map<String, byte[]>)data.getExportData();
                             Set<String> keySet = resultMap.keySet();
                        } else if (result.getExportData().getType().equals(ExportResultType.MAP_BYTE_ARRAY)){
                             Map<String, byte[]> resultMap = (Map<String, byte[]>)data.getExportData();
                             Set<String> keySet = resultMap.keySet();


@@ -241,13 +255,13 @@ public class ExportManager extends AbstractIOManager<IExportConfigurator> implem
                             String fileEnding = ".zip";
                             if (configurator instanceof DwcaTaxExportConfigurator){
                                DwcaTaxExportConfigurator dwcaConfig = (DwcaTaxExportConfigurator)configurator;
                             String fileEnding = ".zip";
                             if (configurator instanceof DwcaTaxExportConfigurator){
                                DwcaTaxExportConfigurator dwcaConfig = (DwcaTaxExportConfigurator)configurator;

-                            
-                               File file = new File(dwcaConfig.getDestination().toURI());                              
+
+                               File file = new File(dwcaConfig.getDestination().toURI());

                                 FileOutputStream stream = new FileOutputStream(file);
                                 ZipOutputStream zos = new ZipOutputStream(stream);
                                 for (String key: keySet){
                                        byte[] fileData = resultMap.get(key);
                                 FileOutputStream stream = new FileOutputStream(file);
                                 ZipOutputStream zos = new ZipOutputStream(stream);
                                 for (String key: keySet){
                                        byte[] fileData = resultMap.get(key);

-                                       ZipEntry entry = new ZipEntry( key + fileEnding); 
+                                       ZipEntry entry = new ZipEntry( key + fileEnding);

                                                                        zos.putNextEntry(entry);
                                                                        zos.write(fileData);
                                                                        zos.closeEntry();
                                                                        zos.putNextEntry(entry);
                                                                        zos.write(fileData);
                                                                        zos.closeEntry();


@@ -257,12 +271,12 @@ public class ExportManager extends AbstractIOManager<IExportConfigurator> implem
                                 } else{
                            logger.error("This kind of result data is not supported yet." + result.getExportData().getType().toString());
                        }
                                 } else{
                            logger.error("This kind of result data is not supported yet." + result.getExportData().getType().toString());
                        }

-                               
+

                        } catch(Exception e){
                            logger.error(e.getStackTrace());
                        }
 
                        } catch(Exception e){
                            logger.error(e.getStackTrace());
                        }
 

-                       showResult(configurator.getClass().getSimpleName(), display, result, successMessage); 
+                       showResult(configurator.getClass().getSimpleName(), display, result, successMessage);

 
 
                    } catch (Exception e) {
 
 
                    } catch (Exception e) {


@@ -327,18 +341,22 @@ public class ExportManager extends AbstractIOManager<IExportConfigurator> implem
     public Job createIOServiceJob(CdmLightExportConfigurator configurator, String urlString) {
         Assert.isNotNull(configurator, "Configuration may not be null");
         final Display display = Display.getDefault();
     public Job createIOServiceJob(CdmLightExportConfigurator configurator, String urlString) {
         Assert.isNotNull(configurator, "Configuration may not be null");
         final Display display = Display.getDefault();

-        
+

          Job job = new Job("Export: " + configurator.getClass().getSimpleName()) { //$NON-NLS-1$
              @Override
              protected IStatus run(IProgressMonitor monitor) {
                  monitor.beginTask("Exporting database. This will take some time.", IProgressMonitor.UNKNOWN);
                  try {
                      IIOService ioService = CdmApplicationState.getIOService();
          Job job = new Job("Export: " + configurator.getClass().getSimpleName()) { //$NON-NLS-1$
              @Override
              protected IStatus run(IProgressMonitor monitor) {
                  monitor.beginTask("Exporting database. This will take some time.", IProgressMonitor.UNKNOWN);
                  try {
                      IIOService ioService = CdmApplicationState.getIOService();

-
+                     monitor.beginTask(
+                             "Exporting database. This will take some time.", 100);
+                     monitor.worked(10);
+                     configurator.setProgressMonitor(CdmProgressMonitorAdapter
+                             .CreateSubMonitor(monitor, 80));

                      ExportResult result = ioService.export(configurator);
                      ExportDataWrapper data = result.getExportData();
                      try{
                      ExportResult result = ioService.export(configurator);
                      ExportDataWrapper data = result.getExportData();
                      try{

-                         if (result.getExportData().getType().equals(ExportResultType.BYTE_ARRAY)){
+                         if (result.getExportData().getType().equals(ExportResultType.BYTE_ARRAY) || result.getExportData().getType().equals(ExportResultType.LIST_BYTE_ARRAY)){

                              byte[] exportData = (byte[])data.getExportData();
                              if(exportData != null){
                                  File file = new File(urlString);
                              byte[] exportData = (byte[])data.getExportData();
                              if(exportData != null){
                                  File file = new File(urlString);


@@ -356,14 +374,14 @@ public class ExportManager extends AbstractIOManager<IExportConfigurator> implem
                              SimpleDateFormat sdf = new SimpleDateFormat(DATE_FORMAT_NOW);
                              Calendar cal = Calendar.getInstance();
                              String fileEnding = ".csv";
                              SimpleDateFormat sdf = new SimpleDateFormat(DATE_FORMAT_NOW);
                              Calendar cal = Calendar.getInstance();
                              String fileEnding = ".csv";

-                             
-                             if (configurator.isCreateZipFile()){      
-                                        File file = new File(urlString+File.separator + "csv_light_" + sdf.format(cal.getTime())+ ".zip");                              
+
+                             if (configurator.isCreateZipFile()){
+                                        File file = new File(urlString+File.separator + "csv_light_" + sdf.format(cal.getTime())+ ".zip");

                                  FileOutputStream stream = new FileOutputStream(file);
                                  ZipOutputStream zos = new ZipOutputStream(stream);
                                  for (String key: keySet){
                                        byte[] fileData = resultMap.get(key);
                                  FileOutputStream stream = new FileOutputStream(file);
                                  ZipOutputStream zos = new ZipOutputStream(stream);
                                  for (String key: keySet){
                                        byte[] fileData = resultMap.get(key);

-                                       ZipEntry entry = new ZipEntry( key + fileEnding); 
+                                       ZipEntry entry = new ZipEntry( key + fileEnding);

                                                                zos.putNextEntry(entry);
                                                                zos.write(fileData);
                                                                zos.closeEntry();
                                                                zos.putNextEntry(entry);
                                                                zos.write(fileData);
                                                                zos.closeEntry();


@@ -407,7 +425,7 @@ public class ExportManager extends AbstractIOManager<IExportConfigurator> implem
     public void runMoniteredOperation(final IExportConfigurator configurator, String urlString) {
         IIOService ioService = CdmApplicationState.getIOService();
         final UUID uuid = ioService.monitExportData(configurator);
     public void runMoniteredOperation(final IExportConfigurator configurator, String urlString) {
         IIOService ioService = CdmApplicationState.getIOService();
         final UUID uuid = ioService.monitExportData(configurator);

-        
+

         Display.getDefault().asyncExec(new Runnable() {
             @Override
             public void run() {
         Display.getDefault().asyncExec(new Runnable() {
             @Override
             public void run() {


@@ -415,7 +433,7 @@ public class ExportManager extends AbstractIOManager<IExportConfigurator> implem
                if (configurator instanceof CdmLightExportConfigurator){
                        isZip = ((CdmLightExportConfigurator)configurator).isCreateZipFile();
                 }
                if (configurator instanceof CdmLightExportConfigurator){
                        isZip = ((CdmLightExportConfigurator)configurator).isCreateZipFile();
                 }

-                AbstractUtility.executeMoniteredExport("Export: " + configurator.getClass().getSimpleName(),
+                AbstractUtility.executeMoniteredExport(configurator.getUserFriendlyIOName(),

                         uuid,
                         1000,
                         true,
                         uuid,
                         1000,
                         true,


@@ -423,6 +441,7 @@ public class ExportManager extends AbstractIOManager<IExportConfigurator> implem
                         null,
                         urlString,
                         isZip);
                         null,
                         urlString,
                         isZip);

+

             }
         });
 
             }
         });
 


@@ -437,7 +456,7 @@ public class ExportManager extends AbstractIOManager<IExportConfigurator> implem
                        CdmStore.getContextManager().notifyContextRefresh();
                    }
                });
                        CdmStore.getContextManager().notifyContextRefresh();
                    }
                });

-               
+

        }
 
 }
        }
 
 }