Application: gvSIG desktop

/* gvSIG. Desktop Geographic Information System.

 *

 * Copyright (c) 2007-2023 gvSIG Association

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 2

 * of the License, or (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

 * MA  02110-1301, USA.

 *

 * For any additional information, do not hesitate to contact us

 * at info AT gvsig.com, or visit our website www.gvsig.com.

 */

package org.gvsig.xml2db.swing.impl.importxml2db;

import java.awt.Color;

import java.io.File;

import java.nio.charset.Charset;

import javax.swing.JComponent;

import javax.swing.JOptionPane;

import javax.swing.SwingUtilities;

import javax.swing.event.ChangeEvent;

import org.apache.commons.lang3.StringUtils;

import org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorerParameters;

import org.gvsig.fmap.dal.swing.DALSwingLocator;

import org.gvsig.fmap.dal.swing.DataSwingManager;

import org.gvsig.tools.ToolsLibrary;

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.i18n.I18nManager;

import org.gvsig.tools.swing.api.ToolsSwingLocator;

import org.gvsig.tools.swing.api.ToolsSwingManager;

import org.gvsig.tools.swing.api.ToolsSwingUtils;

import org.gvsig.tools.swing.api.pickercontroller.CharsetPickerController;

import org.gvsig.tools.swing.api.pickercontroller.FilePickerController;

import org.gvsig.tools.swing.api.pickercontroller.PickerController;

import org.gvsig.tools.swing.api.task.TaskStatusController;

import org.gvsig.tools.swing.api.threadsafedialogs.ThreadSafeDialogsManager;

import org.gvsig.tools.swing.api.windowmanager.Dialog;

import org.gvsig.tools.swing.api.windowmanager.WindowManager_v2;

import org.gvsig.tools.task.SimpleTaskStatus;

import org.gvsig.xml2db.lib.api.Xml2dbLocator;

import org.gvsig.xml2db.lib.api.Xml2dbManager;

import org.gvsig.xml2db.swing.Xml2dbPanel;

import org.gvsig.xml2db.swing.impl.Xml2dbSwingCommons;

import org.gvsig.xml2db.swing.impl.createdbfromxml.CreatedbFromXmlPanel;

import org.gvsig.xml2db.swing.impl.Task;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 *

 * @author jjdelcerro

 */

public class ImportXML2dbPanel 

        extends ImportXML2dbPanelView

        implements Xml2dbPanel

    {

    protected static final Logger LOGGER = LoggerFactory.getLogger(CreatedbFromXmlPanel.class);

    private Dialog dialog;

    private FilePickerController pickerXMLFile;

    private PickerController<JDBCServerExplorerParameters> pickerConnection;

    private TaskStatusController taskStatusController;

    private Task lastTask;

    private CharsetPickerController pickerCharset;

    public ImportXML2dbPanel() {

        this.createComponents();

    }

    private void createComponents() {    

        this.lastTask = Task.FAKE_TASK;

        this.initComponents();

    }

    private void initComponents() {

        ToolsSwingManager toolsSwingManager = ToolsSwingLocator.getToolsSwingManager();

        DataSwingManager dataSwingManager = DALSwingLocator.getDataSwingManager();

        this.taskStatusController = ToolsSwingLocator.getTaskStatusSwingManager().createTaskStatusController(

                lblStatusCaption, 

                lblStatusMsg,

                pbStatus

        );

        this.taskStatusController.setVisible(false);

        this.translate();

        this.pickerXMLFile = toolsSwingManager.createFilePickerController(

                this.txtXMLFile, 

                this.btnXMLFile

        );

        this.pickerXMLFile.addChangeListener((ChangeEvent e) -> {

            updateStateComponents();

        });

        this.pickerCharset = toolsSwingManager.createCharsetPickerController(

                null,

                this.cboCharset

        );

        this.pickerCharset.set(null);        

        this.pickerConnection = dataSwingManager.createJDBCConnectionPickerController(

                this.cboConnection, 

                this.btnConnection

        );

        this.pickerConnection.addChangeListener((ChangeEvent e) -> {

            updateStateComponents();

        });

        this.chkConnectToRepository.setSelected(true);

        ToolsSwingUtils.ensureRowsCols(this, 8, 80, 10, 100);

    }

    private void translate() {

        ToolsSwingManager toolsSwingManager = ToolsSwingLocator.getToolsSwingManager();

        toolsSwingManager.translate(lblDatabase);

        toolsSwingManager.translate(lblFileXML);

        toolsSwingManager.translate(lblCharset);

        toolsSwingManager.translate(lblConnectToRepository);

    }

    private void updateStateComponents() {

        if( !SwingUtilities.isEventDispatchThread() ) {

            SwingUtilities.invokeLater(this::updateStateComponents);

            return;

        }

        message(null);

        if( this.isProcessing() ) {

            this.pickerXMLFile.setEnabled(false);

            this.pickerCharset.setEnabled(false);

            this.pickerConnection.setEnabled(false);

            if( this.dialog!=null ) {

                this.dialog.setButtonEnabled(WindowManager_v2.BUTTON_OK, false);

            }

            return;

        }

        this.pickerXMLFile.setEnabled(true);

        this.pickerCharset.setEnabled(true);

        this.pickerConnection.setEnabled(true);

        File xmlfile = this.pickerXMLFile.get();

        if( xmlfile == null || !xmlfile.exists() ) {

            if( xmlfile==null ) {

                this.message("_XML_file_is_required", JOptionPane.WARNING_MESSAGE);

            } else {

                this.message("_XML_file_not_exists", JOptionPane.WARNING_MESSAGE);

            }

            if( this.dialog!=null ) {

                this.dialog.setButtonEnabled(WindowManager_v2.BUTTON_OK, false);

            }

            return;

        }

        JDBCServerExplorerParameters conn = this.pickerConnection.get();

        if( conn==null ) {

            this.message("_Database_is_required", JOptionPane.WARNING_MESSAGE);

            if( this.dialog!=null ) {

                this.dialog.setButtonEnabled(WindowManager_v2.BUTTON_OK, false);

            }

            return;

        }

        if( this.dialog!=null ) {

            this.dialog.setButtonEnabled(WindowManager_v2.BUTTON_OK, true);        

        }

        this.taskStatusController.setVisible(this.lastTask.needToShowTheStatus());        

    }

    @Override

    public void setDialog(Dialog dialog) {

        this.dialog = dialog;

    }

    @Override

    public JComponent asJComponent() {

        return this;

    }

    @Override

    public void performAction() {

        doImportXML();

    }

    private void doImportXML() {

        Xml2dbManager manager = Xml2dbLocator.getXml2dbManager();

        File xmlfile = this.pickerXMLFile.get();

        if( xmlfile == null || !xmlfile.exists() ) {

            return;

        }

        JDBCServerExplorerParameters dbparams = this.pickerConnection.get();

        if( dbparams==null ) {

            return;

        }

        Charset charset = this.pickerCharset.get();

        boolean connectToRepository = this.chkConnectToRepository.isSelected();

        this.lastTask = new Task(                

                "Xml2db_copyXmml2Db", 

                "Coping XML data", 

                this::updateStateComponents, 

                taskStatusController

            ) {

            @Override

            protected void task(SimpleTaskStatus taskStatus) throws Throwable{

                try {

                    manager.copyXml2Db(xmlfile, charset, dbparams, taskStatus);

                    if( connectToRepository) {

                        DataSwingManager dataSwingManager = DALSwingLocator.getDataSwingManager();

                        dataSwingManager.connectToDatabaseWorkspace(dbparams);                        

                    }

                    taskStatus.terminate();

                } catch(Exception ex) {

                    LOGGER.warn("Can't import xml",ex);

                    I18nManager i18n = ToolsLocator.getI18nManager();

                    ThreadSafeDialogsManager dialogs = ToolsSwingLocator.getThreadSafeDialogsManager();

                    dialogs.messageDialog(

                            i18n.getTranslation("_Problems_processing_XML_file")

                                    +"\n\n"

                                    + ex.getLocalizedMessage(), 

                            i18n.getTranslation("_Xml2db_Import_xml_data_to_a_existing_database"), 

                            JOptionPane.WARNING_MESSAGE

                    );

                    throw ex;

                }

            }

        };

        this.lastTask.start();

    }

    private void message(String msg) {

        message(msg,JOptionPane.INFORMATION_MESSAGE);

    }

    private void message(String msg, int type) {

        if( StringUtils.isBlank(msg) ) {

            this.lblStatusMsg.setText("");

            return;

        }

        if( type == JOptionPane.WARNING_MESSAGE ) {

            msg = Xml2dbSwingCommons.getHTMLColorTag(Color.RED.darker(), msg);

        }        

        this.lblStatusMsg.setText(msg);

        this.lblStatusMsg.setVisible(true);

    }

    private boolean isProcessing() {

        return this.lastTask.isProcessing();

    }

}