Application: gvSIG desktop

package org.gvsig.data.datastores.vectorial.db.jdbc;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.Statement;

import java.util.Iterator;

import org.gvsig.data.commands.implementation.AbstractAttributeCommand;

import org.gvsig.data.commands.implementation.AbstractFeatureCommand;

import org.gvsig.data.commands.implementation.UpdateAttributeCommand;

import org.gvsig.data.commands.implementation.UpdateFeatureCommand;

import org.gvsig.data.datastores.vectorial.ISelectiveWriter;

import org.gvsig.data.datastores.vectorial.db.jdbc.exception.SQLException;

import org.gvsig.data.datastores.vectorial.db.jdbc.h2.H2Utils;

import org.gvsig.data.exception.ReadException;

import org.gvsig.data.exception.WriteException;

import org.gvsig.data.vectorial.AbstractFeatureStore;

import org.gvsig.data.vectorial.CreatedFeature;

import org.gvsig.data.vectorial.IFeature;

import org.gvsig.data.vectorial.IFeatureAttributeDescriptor;

import org.gvsig.data.vectorial.IFeatureType;

public abstract class JDBCStore extends AbstractFeatureStore {

        protected Connection connection = null;

        protected String sqlSelectPart;

        protected String baseWhereClause = null;

        protected String baseOrder = null;

        protected String sqlSource = null;

        protected boolean useSqlSource = false;

        protected abstract Connection getConnection();

        public abstract IFeature getFeatureByID(IFeatureType featureType2, Object[] featureKey) throws ReadException;

        public boolean isEditable() {

                return !this.useSqlSource;

        }

        public String getSqlSelectPart() {

                return sqlSelectPart;

        }

        public String getBaseOrder() {

                return this.baseOrder;

        }

        public String getBaseWhereClause() {

                return baseWhereClause;

        }

        public boolean isUseSqlSource() {

                return this.useSqlSource;

        }

        public String getSqlSource() {

                return this.sqlSource;

        }

        protected abstract JDBCFeaturesWriter getFeaturesWriter();

        protected void doFinishEdition() throws WriteException, ReadException {

                Iterator commandsfeatures = null;

            JDBCFeaturesWriter writer = getFeaturesWriter();

            IFeatureType type = getDefaultFeatureType();

            if (writer instanceof ISelectiveWriter){

                    ISelectiveWriter selectiveWriter=(ISelectiveWriter)writer;

                    selectiveWriter.updateFeatureType(type);

                    selectiveWriter.preProcess();

                commandsfeatures = commands.getCommandsAttributeDeleted().iterator();

                    while( commandsfeatures.hasNext() ) {

                            Object obj=commandsfeatures.next();

                            if (obj instanceof AbstractAttributeCommand){

                                    IFeatureAttributeDescriptor attribute = ((AbstractAttributeCommand)obj).getAttributeDescriptor();

                                    selectiveWriter.deleteAttribute(attribute);

                            }

                    }

                    commandsfeatures = commands.getCommandsAttributeUpdated().iterator();

                    while( commandsfeatures.hasNext() ) {

                            Object obj=commandsfeatures.next();

                            if (obj instanceof AbstractAttributeCommand){

                                    IFeatureAttributeDescriptor oldAttribute = ((UpdateAttributeCommand)obj).getOldAttributeDescriptor();

                                    IFeatureAttributeDescriptor attribute = ((UpdateAttributeCommand)obj).getAttributeDescriptor();

                                    selectiveWriter.updateAttribute(oldAttribute,attribute);

                            }

                    }

                    commandsfeatures = commands.getCommandsAttributeInserted().iterator();

                    while( commandsfeatures.hasNext() ) {

                            Object obj=commandsfeatures.next();

                            if (obj instanceof AbstractAttributeCommand){

                                    IFeatureAttributeDescriptor attribute = ((AbstractAttributeCommand)obj).getAttributeDescriptor();

                                    selectiveWriter.insertAttribute(attribute);

                            }

                    }

                    commandsfeatures = commands.getCommandsFeatureDeleted().iterator();

                    while( commandsfeatures.hasNext() ) {

                            Object obj=commandsfeatures.next();

                            if (obj instanceof AbstractFeatureCommand){

                                    IFeature feature = ((AbstractFeatureCommand)obj).getFeature();

                                    if (feature instanceof CreatedFeature)

                                            continue;

                                    selectiveWriter.deleteFeature(feature);

                            }

                    }

                    commandsfeatures = commands.getCommandsFeatureUpdated().iterator();

                    while( commandsfeatures.hasNext() ) {

                            Object obj=commandsfeatures.next();

                            if (obj instanceof AbstractFeatureCommand){

                                    IFeature oldFeature = ((UpdateFeatureCommand)obj).getOldFeature();

                                    IFeature feature = ((UpdateFeatureCommand)obj).getFeature();

                                    if (featureManager.isDeleted(feature)){

                                            continue;

                                    }

                                    selectiveWriter.updateFeature(oldFeature,feature);

                            }

                    }

                    commandsfeatures = commands.getCommandsFeatureInserted().iterator();

                    while( commandsfeatures.hasNext() ) {

                            Object obj=commandsfeatures.next();

                            if (obj instanceof AbstractFeatureCommand){

                                    IFeature feature = ((AbstractFeatureCommand)obj).getFeature();

                                    if (featureManager.isDeleted(feature)){

                                            continue;

                                    }

                                    selectiveWriter.insertFeature(feature);

                            }

                    }

                    selectiveWriter.postProcess();

            }

        }

}