Application: gvSIG desktop

/*

 * To change this license header, choose License Headers in Project Properties.

 * To change this template file, choose Tools | Templates

 * and open the template in the editor.

 */

package org.gvsig.fmap.mapcontrol.dal.jdbc;

import java.awt.event.ItemEvent;

import java.awt.event.ItemListener;

import java.util.Iterator;

import java.util.List;

import javax.swing.ComboBoxModel;

import javax.swing.JTextField;

import org.apache.commons.lang3.StringUtils;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

import org.gvsig.fmap.dal.DataServerExplorerParameters;

import org.gvsig.fmap.dal.DataServerExplorerPool;

import org.gvsig.fmap.dal.DataServerExplorerPoolEntry;

import org.gvsig.fmap.dal.exception.DataException;

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

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

// org.gvsig.fmap.mapcontrol.dal.jdbc.JDBCConnectionPanel

public class JDBCConnectionPanel extends JDBCConnectionPanelLayout {

    private static final Logger logger = LoggerFactory.getLogger(JDBCConnectionPanel.class);

    private static class ServerExplorerParametersComboItem {

        private JDBCServerExplorerParameters params;

        private String label;

        public ServerExplorerParametersComboItem(String label, JDBCServerExplorerParameters params) {

            this.params = params;

            this.label = label;

        }

        public ServerExplorerParametersComboItem(JDBCServerExplorerParameters params) {

            this(params.getExplorerName(), params);

        }

        public String toString() {

            return this.label;

        }

        public JDBCServerExplorerParameters getParams() {

            return this.params;

        }

        public String getLabel() {

            return this.label;

        }

    }

    public JDBCConnectionPanel() {

        initComponents();

    }

    protected void initComponents() {

        this.cboConnections.setEditable(true);

        this.cboConnections.addItemListener(new ItemListener() {

            public void itemStateChanged(ItemEvent e) {

                onChangeConnection();

            }

        });

        this.cboConnectors.addItemListener(new ItemListener() {

            public void itemStateChanged(ItemEvent e) {

                onChangeConnector();

            }

        });

        try {

            fillConnections();

            fillConnectors();

        } catch(Throwable th) {

            // Ignore it to allow use in GUI builders

        }

    }

    public void setServerExplorerParameters(JDBCServerExplorerParameters parameters) {

        int indexConnector = this.getIndexOfConnector(parameters);

        if ( indexConnector >= 0 && this.cboConnectors.getSelectedIndex()!=indexConnector ) {

            this.cboConnectors.setSelectedIndex(indexConnector);

        }

        this.txtServer.setText(parameters.getHost());

        Integer port = parameters.getPort();

        if ( port == null ) {

            this.txtPort.setText("");

        } else {

            this.txtPort.setText(String.valueOf(port));

        }

        this.txtDataBase.setText(parameters.getDBName());

        this.txtUsername.setText(parameters.getUser());

        this.txtPassword.setText(parameters.getPassword());

    }

    public JDBCServerExplorerParameters getServerExplorerParameters() {

        JDBCServerExplorerParameters connector = this.getConnector();

        JDBCServerExplorerParameters params = (JDBCServerExplorerParameters) connector.getCopy();

        params.setHost(this.getServer());

        params.setPort(this.getPort());

        params.setDBName(this.getDataBaseName());

        params.setUser(this.getUsername());

        params.setPassword(this.getPassword());

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

            DataManager dataManager = DALLocator.getDataManager();

            DataServerExplorerPool pool = dataManager.getDataServerExplorerPool();

            pool.add(this.getConnectionName(), params);

        }

        return params;

    }

    protected void setConnectionName(String connectionName) {

        JTextField txtConnections = (JTextField) this.cboConnections.getEditor().getEditorComponent();

        txtConnections.setText(connectionName);

    }

    public String getConnectionName() {

        JTextField txtConnections = (JTextField) this.cboConnections.getEditor().getEditorComponent();

        String value = txtConnections.getText();

        return StringUtils.defaultIfBlank(value, null);

    }

    protected JDBCServerExplorerParameters getConnector() {

        ServerExplorerParametersComboItem item = (ServerExplorerParametersComboItem) this.cboConnectors.getSelectedItem();

        JDBCServerExplorerParameters value = item.getParams();

        return value;

    }

    protected String getConnectorName() {

        JDBCServerExplorerParameters value = this.getConnector();

        if ( value == null ) {

            return null;

        }

        return StringUtils.defaultIfBlank(value.getExplorerName(), null);

    }

    protected String getServer() {

        return StringUtils.defaultIfBlank(this.txtServer.getText(), null);

    }

    protected int getPort() {

        String svalue = StringUtils.defaultIfBlank(this.txtPort.getText(), null);

        int ivalue = -1;

        try {

            ivalue = Integer.parseInt(svalue);

        } catch (Exception ex) {

            ivalue = -1;

        }

        return ivalue;

    }

    protected String getDataBaseName() {

        return StringUtils.defaultIfBlank(this.txtDataBase.getText(), null);

    }

    protected String getUsername() {

        return StringUtils.defaultIfBlank(this.txtUsername.getText(), null);

    }

    protected String getPassword() {

        return StringUtils.defaultIfBlank(this.txtPassword.getText(), null);

    }

    private void onChangeConnector() {

        ServerExplorerParametersComboItem item = (ServerExplorerParametersComboItem) this.cboConnectors.getSelectedItem();

        if( item==null ) {

            return;

        }

        JDBCServerExplorerParameters connector = item.getParams();

        if ( connector == null ) {

            return;

        }

        this.setServerExplorerParameters(connector);

    }

    private void onChangeConnection() {

        Object item = this.cboConnections.getSelectedItem();

        if ( item instanceof ServerExplorerParametersComboItem ) {

            JDBCServerExplorerParameters connection = ((ServerExplorerParametersComboItem) item).getParams();

            if ( connection == null ) {

                return;

            }

            this.setServerExplorerParameters(connection);

        }

    }

    private int getIndexOfConnector(JDBCServerExplorerParameters explorerParameters) {

        String code = null;

        try {

            code = explorerParameters.toString();

            ComboBoxModel model = this.cboConnectors.getModel();

            for ( int i = 0; i < model.getSize(); i++ ) {

                ServerExplorerParametersComboItem x = (ServerExplorerParametersComboItem) model.getElementAt(i);

                if ( x.getLabel().equalsIgnoreCase(explorerParameters.getExplorerName()) ) {

                    return i;

                }

            }

        } catch (Exception ex) {

            logger.warn("Can't get index of exporer parameter '" + code + "'.", ex);

        }

        return -1;

    }

    private void fillConnectors() {

        DataManager dataManager = DALLocator.getDataManager();

        List<String> explorers = dataManager.getExplorerProviders();

        DataServerExplorerParameters params;

        JDBCServerExplorerParameters last = null;

        Iterator<String> it = explorers.iterator();

        while ( it.hasNext() ) {

            String explorerName = it.next();

            try {

                params = dataManager.createServerExplorerParameters(explorerName);

            } catch (DataException e) {

                continue;

            }

            if ( params instanceof JDBCServerExplorerParameters ) {

                JDBCServerExplorerParameters dbParams = (JDBCServerExplorerParameters) params;

                if( dbParams.getClass().getName().equals(JDBCServerExplorerParameters.class.getName()) ) {

                    last = dbParams;

                } else {

                    this.cboConnectors.addItem(

                            new ServerExplorerParametersComboItem(dbParams)

                    );

                }

            }

        }

        if( last!=null ) {

            this.cboConnectors.addItem(

                    new ServerExplorerParametersComboItem(last)

            );

        }

    }

    private void fillConnections() {

        DataManager dataManager = DALLocator.getDataManager();

        DataServerExplorerPool pool = dataManager.getDataServerExplorerPool();

        DataServerExplorerParameters params;

        Iterator<DataServerExplorerPoolEntry> it = pool.iterator();

        while ( it.hasNext() ) {

            DataServerExplorerPoolEntry entry = it.next();

            if ( entry.getExplorerParameters() instanceof JDBCServerExplorerParameters ) {

                JDBCServerExplorerParameters dbParams = (JDBCServerExplorerParameters) entry.getExplorerParameters();

                this.cboConnections.addItem(

                        new ServerExplorerParametersComboItem(entry.getName(), dbParams)

                );

            }

        }

        this.cboConnections.setSelectedIndex(-1);

    }

    public void delete() {

        String name = this.getConnectionName();

        DataManager dataManager = DALLocator.getDataManager();

        DataServerExplorerPool pool = dataManager.getDataServerExplorerPool();

        pool.remove(name);

    }

    public void clear() {

        this.cboConnections.setSelectedIndex(-1);

        this.cboConnectors.setSelectedIndex(-1);

        this.txtServer.setText("");

        this.txtPort.setText("");

        this.txtDataBase.setText("");

        this.txtUsername.setText("");

        this.txtPassword.setText("");

    }

}