Application: gvSIG desktop

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2013 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 3 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.exportto.swing.prov.jdbc;

import java.util.Map;

import org.apache.commons.lang3.StringUtils;

import org.cresques.cts.ICoordTrans;

import org.cresques.cts.IProjection;

import org.gvsig.exportto.ExporttoService;

import org.gvsig.exportto.ExporttoServiceException;

import org.gvsig.exportto.ExporttoServiceFinishAction;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

import org.gvsig.fmap.dal.DataTypes;

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

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

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

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

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

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

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

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

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

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

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

import org.gvsig.fmap.geom.Geometry;

import org.gvsig.tools.dispose.DisposableIterator;

import org.gvsig.tools.task.AbstractMonitorableTask;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 * @author gvSIG Team

 * @version $Id$

 *

 */

public class ExporrtoJDBCService extends AbstractMonitorableTask implements

        ExporttoService {

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

    public static final int CHECK_NONE = 0;

    public static final int CHECK_IF_CORRUPT = 1;

    public static final int CHECK_IF_VALID = 2;

    public static final int ACTION_SET_GEOMETRY_TO_NULL = 0;

    public static final int ACTION_SKIP_FEATURE = 1;

    public static final int ACTION_ABORT = 2;

    private ExporttoServiceFinishAction exporttoServiceFinishAction = null;

    private ExporttoJDBCOptions options;

//    private Map<String,String> translationIds;

    public ExporrtoJDBCService(ExporttoJDBCOptions options) {

        this.options = options;

    }

    protected String getTranslatedIdentifier(String identifier) {

        String s = identifier;

        if( this.options.getTranslateIdentifiersToLowerCase() ) {

            s = s.toLowerCase();

        }

        if( this.options.getRemoveSpacesInIdentifiers() ) {

            s = StringUtils.normalizeSpace(s).replace(" ", "_");

        }

        return s;

    }

    protected void createTable(JDBCServerExplorer explorer) throws Exception {

        FeatureType targetFeatureType;

        EditableFeatureType targetEditableFeatureType;

        targetFeatureType = options.getSource().getDefaultFeatureType().getCopy();

        targetEditableFeatureType = targetFeatureType.getEditable();

        if( this.options.getTranslateIdentifiersToLowerCase() 

                || this.options.getRemoveSpacesInIdentifiers() ) {

            for( int i=0; i<targetEditableFeatureType.size(); i++ ) {

                EditableFeatureAttributeDescriptor x = (EditableFeatureAttributeDescriptor)targetEditableFeatureType.get(i);

                x.setName(getTranslatedIdentifier(x.getName()));

            }

        }

        if (this.options.getPrimaryKey() != null) {

            EditableFeatureAttributeDescriptor pk = (EditableFeatureAttributeDescriptor) targetEditableFeatureType.get(getTranslatedIdentifier(options.getPrimaryKey()));

            if (pk == null) {

                pk = targetEditableFeatureType.add(

                        getTranslatedIdentifier(this.options.getPrimaryKey()), 

                        DataTypes.LONG

                );

                pk.setIsPrimaryKey(true);

                pk.setIsAutomatic(true);

            } else {

                pk.setIsPrimaryKey(true);

            }

        }

        if( this.options.getCreateIndexInGeometryRow() ) {

            EditableFeatureAttributeDescriptor x = (EditableFeatureAttributeDescriptor)targetEditableFeatureType.getDefaultGeometryAttribute();

            x.setIsIndexed(true);

        }

        // ======================================================

        // Reprojection: set SRS of geometry field to target SRS

        EditableFeatureAttributeDescriptor attrdescriptor

                = (EditableFeatureAttributeDescriptor) targetEditableFeatureType.getDefaultGeometryAttribute();

        if (attrdescriptor != null) {

            attrdescriptor.setSRS(this.options.getTargetProjection());

        }

        // ======================================

        JDBCNewStoreParameters createTableParams = (JDBCNewStoreParameters) explorer.getAddParameters();

        createTableParams.setDefaultFeatureType(targetEditableFeatureType);

        createTableParams.setTable(this.options.getTableName()); 

        explorer.add(explorer.getStoreName(), createTableParams, true);

    }

    private static class InvalidGeometryException extends ExporttoServiceException {

        public InvalidGeometryException(Feature feature, String checkMessage) {

            super(checkMessage, null, checkMessage, 0);

            this.feature = feature;

        }

    }

    public void export(FeatureSet featureSet) throws ExporttoServiceException {

        Geometry.ValidationStatus geometryCheck;

        DisposableIterator it = null;

        EditableFeature targetFeature = null;

        FeatureStore target = null;

        try {

            // ======================================

            // Reprojection 

            FeatureAttributeDescriptor geo_att = this.options.getSource().getDefaultFeatureType().getDefaultGeometryAttribute();

            IProjection sourceProjection = null;

            ICoordTrans coord_trans = null;

            Geometry reproj_geom = null;

            if (geo_att != null) {

                sourceProjection = geo_att.getSRS();

                // this comparison is perhaps too preventive

                // we could  have two instances of same projection

                // so we would do more computations than needed

                if (sourceProjection != this.options.getTargetProjection()) {

                    coord_trans = sourceProjection.getCT(this.options.getTargetProjection());

                }

            }

            // ============================================

            DataManager dataManager = DALLocator.getDataManager();

            JDBCServerExplorer explorer = (JDBCServerExplorer) dataManager.openServerExplorer(

                    this.options.getExplorerParameters().getExplorerName(),

                    this.options.getExplorerParameters()

            );

            if (this.options.canCreatetable() ) {

                this.createTable(explorer);

            }

            JDBCStoreParameters openParams = (JDBCStoreParameters) explorer.getOpenParameters();

            openParams.setTable(this.options.getTableName());

            openParams.setCRS(this.options.getTargetProjection());

            openParams.setDefaultGeometryField(

                    this.options.getSource().getDefaultFeatureType().getDefaultGeometryAttributeName()

            );

            target = (FeatureStore) explorer.open(openParams);

            FeatureType targetFeatureType = target.getDefaultFeatureType();

            FeatureType sourceFeatureType = featureSet.getDefaultFeatureType();

            target.edit(FeatureStore.MODE_APPEND);

            int featureCount = 1;

            taskStatus.setRangeOfValues(0, featureSet.getSize());

            it = featureSet.fastIterator();

            while (it.hasNext()) {

                Feature feature = (Feature) it.next();

                targetFeature = target.createNewFeature(targetFeatureType, feature);

                for( int i=0; i<sourceFeatureType.size(); i++ ) {

                    FeatureAttributeDescriptor x = sourceFeatureType.getAttributeDescriptor(i);

                    targetFeature.set(getTranslatedIdentifier(x.getName()), feature.get(x.getName()));

                }

                Geometry geometry = targetFeature.getDefaultGeometry();

                if (geometry != null) {

                    switch (this.options.getGeometryChecks()) {

                        case CHECK_IF_CORRUPT:

                            geometryCheck = geometry.getValidationStatus();

                            if (geometryCheck.getStatusCode() == Geometry.ValidationStatus.CURRUPTED) {

                                switch (this.options.getGeometryChecksAction()) {

                                    case ACTION_SET_GEOMETRY_TO_NULL:

                                        targetFeature.setDefaultGeometry(null);

                                        break;

                                    case ACTION_SKIP_FEATURE:

                                        continue;

                                    case ACTION_ABORT:

                                    default:

                                        throw new InvalidGeometryException(targetFeature, geometryCheck.getMessage());

                                }

                            }

                            break;

                        case CHECK_IF_VALID:

                            geometryCheck = geometry.getValidationStatus();

                            if (!geometryCheck.isValid()) {

                                Geometry g = null;

                                if (this.options.getTryToFixGeometry() ) {

                                    g = geometry.makeValid();

                                    if (g != null) {

                                        targetFeature.setDefaultGeometry(g);

                                    }

                                }

                                if (g == null) {

                                    switch (this.options.getGeometryChecksAction()) {

                                        case ACTION_SET_GEOMETRY_TO_NULL:

                                            targetFeature.setDefaultGeometry(null);

                                            break;

                                        case ACTION_SKIP_FEATURE:

                                            continue;

                                        case ACTION_ABORT:

                                        default:

                                            throw new InvalidGeometryException(targetFeature, geometryCheck.getMessage());

                                    }

                                }

                            }

                            break;

                        case CHECK_NONE:

                        default:

                            break;

                    }

                    // ================================================

                    // Reprojection 

                    if (geo_att != null && coord_trans != null) {

                        reproj_geom = targetFeature.getDefaultGeometry();

                        reproj_geom = reproj_geom.cloneGeometry();

                        reproj_geom.reProject(coord_trans);

                        targetFeature.setDefaultGeometry(reproj_geom);

                    }

                    // ================================================

                }

                target.insert(targetFeature);

                this.taskStatus.setCurValue(featureCount);

                if (this.taskStatus.isCancellationRequested()) {

                    return;

                }

                featureCount++;

            }

            targetFeature = null;

            target.finishEditing();

            if( this.options.getUpdateTableStatistics() ) {

                explorer.updateTableStatistics(openParams.tableID());

            }

            if (exporttoServiceFinishAction != null) {

                exporttoServiceFinishAction.finished(

                        this.options.getTableName() + " (" + explorer.getStoreName() + ")",

                        openParams);

            }

        } catch (Exception e) {

            logger.warn("Can't export data.", e);

            taskStatus.message(e.getMessage());

            throw new ExporttoServiceException(e, targetFeature);

        } finally {

            if (it != null) {

                it.dispose();

            }

            featureSet.dispose();

            if (target != null) {

                target.dispose();

            }

            this.taskStatus.terminate();

            this.taskStatus.remove();

        }

    }

    public void setFinishAction(

            ExporttoServiceFinishAction exporttoServiceFinishAction) {

        this.exporttoServiceFinishAction = exporttoServiceFinishAction;

    }

}