Application: gvSIG desktop

package org.gvsig.geodb.databaseworkspace;

import javax.swing.JComponent;

import javax.swing.JOptionPane;

import javax.swing.event.ChangeEvent;

import javax.swing.event.ChangeListener;

import org.apache.commons.lang.StringUtils;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.DatabaseWorkspaceManager;

import static org.gvsig.fmap.dal.DatabaseWorkspaceManager.CONFIG_NAME_STORESREPOSITORYID;

import static org.gvsig.fmap.dal.DatabaseWorkspaceManager.CONFIG_NAME_STORESREPOSITORYLABEL;

import org.gvsig.fmap.dal.StoresRepository;

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

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

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

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.i18n.I18nManager;

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

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

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

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

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;

/**

 *

 * @author jjdelcerro

 */

public class ConnectToDatabaseWorkspacePanel 

        extends ConnectToDatabaseWorkspacePanelView

        implements Component

    {

    private Dialog dialog;

    private PickerController<JDBCServerExplorerParameters> connectionPicker;

    public ConnectToDatabaseWorkspacePanel() {

        this.initComponents();

    }

    public boolean connect() {

        JDBCServerExplorerParameters conn = getConnection();

        if( conn == null ) {

            return false;

        }

        DataManager dataManager = DALLocator.getDataManager();

        DatabaseWorkspaceManager workspace = dataManager.createDatabaseWorkspaceManager(conn);

        StoresRepository repo = workspace.getStoresRepository();

        if( hasConflictTheRepositoryWithOtherRepositoryAlreadyRegistered(repo) ) {

            ThreadSafeDialogsManager dialogs = ToolsSwingLocator.getThreadSafeDialogsManager();

            I18nManager i18n = ToolsLocator.getI18nManager();

            int n = dialogs.confirmDialog(

                    i18n.getTranslation("_The_name_of_some_tables_of_the_repository_coincide_with_those_of_another_repository_already_registered") + 

                            " ("+repo.getLabel()+")\n" +

                            i18n.getTranslation("_If_you_connect_to_this_repository_and_have_tables_or_layers_loaded_from_the_previous_repository_you_may_notice_inconsistencies_in_the_data") + "\n" +

                            i18n.getTranslation("_Do_you_want_to_connect_with_the_current_repository_anyway"), 

                    i18n.getTranslation("_Connect_to_repository"), 

                    JOptionPane.YES_NO_OPTION, 

                    JOptionPane.QUESTION_MESSAGE

            );

            if( n!=JOptionPane.YES_OPTION ) {

                return false;

            }

        }        

        workspace.connect();

        return true;

    }

    public void disconnect() {

      String id = this.getID();

      DataManager dataManager = DALLocator.getDataManager();

      DatabaseWorkspaceManager workspace = dataManager.getDatabaseWorkspace(id);

      if( workspace!=null ) {

        workspace.disconnect();

      }

    }

    private void initComponents() {

        this.connectionPicker = DALSwingLocator.getSwingManager().createJDBCConnectionPickerController(

                this.cboConnection,

                this.btnConnection

        );

        this.connectionPicker.addChangeListener(new ChangeListener() {

            @Override

            public void stateChanged(ChangeEvent e) {

                doUpdateStoresRepositoryInfo();

            }

        });

        ToolsSwingUtils.ensureRowsCols(this, 7, 110, 10, 160);

        doUpdateStoresRepositoryInfo();

    }

    @Override

    public JComponent asJComponent() {

        return this;

    }

    public JDBCServerExplorerParameters getConnection() {

        JDBCServerExplorerParameters conn = this.connectionPicker.get();

        if (conn == null) {

            return null;

        }

        DataManager dataManager = DALLocator.getDataManager();

        DatabaseWorkspaceManager workspace = dataManager.createDatabaseWorkspaceManager(conn);

        if( !workspace.isValidStoresRepository() ) {

            return null;

        }

        return conn;

    }

    private void doUpdateEnableComponents() {

        DataManager dataManager = DALLocator.getDataManager();

        boolean theEnabled = this.getConnection() != null;

        if( dialog!=null ) {

            this.dialog.setButtonEnabled(

                    WindowManager_v2.BUTTON_OK, 

                    theEnabled

            );

            String id = this.getID();

            this.dialog.setButtonEnabled(

                    WindowManager_v2.BUTTON_APPLY, 

                    dataManager.getDatabaseWorkspace(id)!=null

            );

        }

    }

    private void doUpdateStoresRepositoryInfo() {

        if( this.getConnection()!=null ) {

          DataManager dataManager = DALLocator.getDataManager();

          JDBCServerExplorerParameters conn = getConnection();

          DatabaseWorkspaceManager workspace = dataManager.createDatabaseWorkspaceManager(conn);

          String id = workspace.get(CONFIG_NAME_STORESREPOSITORYID);

          String label = workspace.get(CONFIG_NAME_STORESREPOSITORYLABEL);

          String url = conn.getUrl();

          this.txtID.setText(StringUtils.defaultIfBlank(id, ""));

          this.txtLabel.setText(StringUtils.defaultIfBlank(label, ""));

          this.txtUrl.setText(StringUtils.defaultIfBlank(url, ""));

          this.connectionPicker.set(conn);

        } else {

          this.txtID.setText("");

          this.txtLabel.setText("");

          this.txtUrl.setText("");

          this.connectionPicker.set(null);

        }

        this.doUpdateEnableComponents();

    }

    public String getID() {

      return this.txtID.getText();

    }

    public String getLabel() {

      return this.txtLabel.getText();

    }

    void setDialog(Dialog dialog) {

       this.dialog = dialog;

       this.doUpdateEnableComponents();

    }

    private boolean hasConflictTheRepositoryWithOtherRepositoryAlreadyRegistered(StoresRepository repo) {

        DataManager dataManager = DALLocator.getDataManager();

        StoresRepository globalRepository = dataManager.getStoresRepository();

        for (String name : repo.keySet()) {

            DataStoreParameters params = repo.get(name);

            if( params instanceof JDBCStoreParameters ) {

                DataStoreParameters registeredParams = globalRepository.get(name);

                if( registeredParams instanceof JDBCStoreParameters ) {

                    String url = ((JDBCStoreParameters) params).getUrl();

                    String registeredUrl = ((JDBCStoreParameters) registeredParams).getUrl();

                    if( !StringUtils.equals(url, registeredUrl)) {

                        return true;

                    }

                }

            }

        }

        return false;

    }

}