Application: gvSIG desktop

 * 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.

import java.util.Iterator;

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

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

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

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

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

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

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

import org.gvsig.tools.service.ServiceException;

 * 

    ExporttoService {

    private static final DataManager DATA_MANAGER = DALLocator.getDataManager();

    private String dbName = null;

    private String schema = null;

    private String tableName = null;

    private String pkField = null;

    private String userName = null;

    private String password = null;

    private String host = null;

    private int port = -1;

    private String explorerName = null;

    private String storeName = null;

    private NewFeatureStoreParameters newFeatureStoreParameters;

    private JDBCServerExplorer explorer;

    private FeatureStore featureStore;

    private IProjection targetProjection;

    /**

     * @param taskName

     * @throws ServiceException

     */

    protected ExporrtoJDBCService(FeatureStore featureStore, String dbName,

        String schema, String tableName, String pkField, String userName,

        String password, String host, int port, String explorerName,

        String storeName, IProjection target_projetion) {

        super("Export to JDBC");

        this.featureStore = featureStore;

        this.dbName = dbName;

        this.schema = schema;

        this.tableName = tableName;

        this.pkField = pkField;

        this.userName = userName;

        this.password = password;

        this.host = host;

        this.port = port;

        this.storeName = storeName;

        this.explorerName = explorerName;

        this.targetProjection = target_projetion;

    public void export(FeatureSet featureSet) throws ExporttoServiceException {

        initializeParams(featureSet);

        DisposableIterator it1 = null;

        EditableFeatureType ef_type = null;

        FeatureType f_type = null;

        EditableFeature edit_feat = null;

            f_type = featureStore.getDefaultFeatureType();

            f_type = f_type.getCopy();

            ef_type = f_type.getEditable();

            if (pkField != null) {

                EditableFeatureAttributeDescriptor pk =

                    ef_type.add(pkField, DataTypes.LONG);

                pk.setIsPrimaryKey(true);

                pk.setIsAutomatic(true);

            }

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

            // Reprojection: set SRS of geometry field to

            // target SRS

            EditableFeatureAttributeDescriptor eatt =

                (EditableFeatureAttributeDescriptor)

                ef_type.getDefaultGeometryAttribute();

            if (eatt != null) {

                eatt.setSRS(this.targetProjection);

            }

            newFeatureStoreParameters.setDefaultFeatureType(ef_type);

            explorer.add(storeName, newFeatureStoreParameters, true);

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

            FeatureAttributeDescriptor geo_att = f_type.getDefaultGeometryAttribute();

                if (sourceProjection != this.targetProjection) {

                    coord_trans = sourceProjection.getCT(this.targetProjection); 

            target =

                (FeatureStore) DATA_MANAGER.openStore(

                		storeName,

                		newFeatureStoreParameters);

            FeatureType targetType = target.getDefaultFeatureType();

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

            it1 = featureSet.fastIterator();

            Geometry reproj_geom = null;

            while (it1.hasNext()) {

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

                edit_feat = target.createNewFeature(targetType, feature);

                    reproj_geom = edit_feat.getDefaultGeometry();

                    edit_feat.setDefaultGeometry(reproj_geom);

                target.insert(edit_feat);

            edit_feat = null;

            /*

             * Creating normal parameters (not "new store parameters")

             * to add layer

             */

            String storename = newFeatureStoreParameters.getDataStoreName();

            JDBCStoreParameters params = getParams(explorer, tableName, schema, storename);

            if (geo_att != null) {

                params.setCRS(targetProjection);

                params.setDefaultGeometryField(targetType.getDefaultGeometryAttributeName());

            }

                    tableName + " (" + storename + ")",

                    params);

            throw new ExporttoServiceException(e,edit_feat);

            if (it1 != null) {

                it1.dispose();

    private JDBCStoreParameters getParams(

    		JDBCServerExplorer explo,

    		String tab, String sche, String storename) throws DataException {

    	Iterator iter = explo.list().iterator();

    	JDBCStoreParameters item = null;

    	while (iter.hasNext()) {

    		item = (JDBCStoreParameters) iter.next();

    		if (item.getTable().compareTo(tab) == 0

    				&&

    				(sche == null || item.getSchema().compareTo(sche) == 0)) {

    			return item;

    		}

    	}

    	throw new OpenException(storename, new Exception("Table not found: " + tab));

	}

	private void initializeParams(FeatureSet featureSet)

        throws ExporttoServiceException {

        JDBCServerExplorerParameters explorerParam;

        try {

            explorerParam =

                (JDBCServerExplorerParameters) DATA_MANAGER

                    .createServerExplorerParameters(explorerName);

            explorerParam.setHost(host);

            if (port > -1) {

                explorerParam.setPort(port);

            }

            explorerParam.setDBName(dbName);

            explorerParam.setUser(userName);

            explorerParam.setPassword(password);

            if (schema != null && schema.length() > 0) {

                explorerParam.setSchema(schema);

            }

            explorer =

                (JDBCServerExplorer) DATA_MANAGER.openServerExplorer(

                    explorerName, explorerParam);

            newFeatureStoreParameters =

                (NewFeatureStoreParameters) explorer.getAddParameters();

            ((DBStoreParameters) newFeatureStoreParameters).setTable(tableName);

            ((DBStoreParameters) newFeatureStoreParameters)

                .setDefaultGeometryField(featureSet.getDefaultFeatureType()

                    .getDefaultGeometryAttributeName());

        } catch (InitializeException e) {

            throw new ExporttoServiceException(e);

        } catch (ProviderNotRegisteredException e) {

            throw new ExporttoServiceException(e);

        } catch (ValidateDataParametersException e) {

            throw new ExporttoServiceException(e);

        } catch (DataException e) {

            throw new ExporttoServiceException(e);

        }

    }

        ExporttoServiceFinishAction exporttoServiceFinishAction) {