gvSIG projects pool

package org.gvsig.online.app.mainplugin.addlayer;

import java.util.ArrayList;

import java.util.List;

import javax.swing.JOptionPane;

import org.gvsig.app.ApplicationLocator;

import org.gvsig.app.ApplicationManager;

import org.gvsig.app.project.documents.table.TableDocument;

import org.gvsig.app.project.documents.table.TableManager;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

import org.gvsig.fmap.dal.StoresRepository;

import org.gvsig.fmap.dal.feature.FeatureStore;

import org.gvsig.fmap.dal.store.db.DBStoreParameters;

import org.gvsig.geodb.TableInfo;

import org.gvsig.online.lib.api.workingcopy.OnlineEntity;

import org.gvsig.online.lib.api.workingcopy.OnlineWorkingcopy;

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.dispose.DisposeUtils;

import org.gvsig.tools.i18n.I18nManager;

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

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

/**

 *

 * @author jjdelcerro

 */

public class WizardOnlineTabular extends AbstractWizardOnline {

    public WizardOnlineTabular() {

        super();

    }

    @Override

    protected boolean requireGeometry() {

        return false;

    }

    @Override

    public Object executeWizard() {

        DataManager man = DALLocator.getDataManager();

        ApplicationManager application = ApplicationLocator.getManager();

        OnlineWorkingcopy workspace = this.getWorkspace();

        for (TableInfo tableInfo : getTablesInformation()) {

            if (!tableInfo.isSelected()) {

                continue;

            }

            if( ((OnlineTableInfo)tableInfo).needConnectToModel() ) {

                I18nManager i18n = ToolsLocator.getI18nManager();

                ThreadSafeDialogsManager dialogs = ToolsSwingLocator.getThreadSafeDialogsManager();

                int n = dialogs.confirmDialog(

                        i18n.getTranslation("_Some_of_the_selected_tables_require_connection_to_a_data_model") + 

                                "\n" +

                                i18n.getTranslation("_It_is_recommended_that_you_connect_to_the_data_model_before_loading_the_tables") +

                                "\n" +

                                i18n.getTranslation("_Do_you_want_to_add_the_selected_tables_anyway"), 

                        i18n.getTranslation("_AddTable"), 

                        JOptionPane.YES_NO_OPTION, 

                        JOptionPane.QUESTION_MESSAGE, 

                        "_Some_of_the_selected_tables_require_connection_to_a_data_model"

                );

                if( n != JOptionPane.YES_OPTION ) {

                    return null;

                }

            }

        }

        List<TableDocument> tabledocs = new ArrayList<>();

        List<OnlineTableInfo> tablesInformation = new ArrayList<>();

        for (TableInfo tableInfo : getTablesInformation()) {

            if (!tableInfo.isSelected()) {

                continue;

            }

            tablesInformation.add((OnlineTableInfo) tableInfo);

        }

        List<String> dataModels = new ArrayList<>();

        for (OnlineTableInfo tableInfo : tablesInformation) {

            OnlineEntity entity = tableInfo.getEntity();

            List<String> entityModels = entity.getDataModelsAsList();

            if( entityModels!=null ) {

                for (String entityModel : entityModels) {

                    dataModels.add(entityModel);

                }

            }

        }

        if( !dataModels.isEmpty() ) {

            for (StoresRepository storesRepository : man.getStoresRepository().getSubrepositories() ) {

                dataModels.remove(storesRepository.getID());

            }

            for (String dataModel : dataModels) {

                registerDataModelRepository(workspace, dataModel);

            }

        }

        for (OnlineTableInfo tableInfo : tablesInformation) {

            DBStoreParameters storeParams = tableInfo.getParameters();

            FeatureStore store = null;

            try {

                try {

                    store = (FeatureStore) man.openStore(

                            storeParams.getDataStoreName(),

                            storeParams

                    );

                } catch (Exception e) {

                    LOGGER.warn("Can't open store ", e);

                    return null;

                }

                TableDocument document = (TableDocument) application.getProjectManager().createDocument(

                        TableManager.TYPENAME,

                        tableInfo.getDocumentName()

                );

                document.setStore(store);

                tabledocs.add(document);

            } finally {

                DisposeUtils.disposeQuietly(store);

            }

        }

        return tabledocs;

    }

}