Application: gvSIG desktop

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

import java.sql.Connection;

import java.sql.SQLException;

import java.sql.Statement;

import org.gvsig.data.CloseException;

import org.gvsig.data.DataException;

import org.gvsig.data.OpenException;

import org.gvsig.data.ReadException;

import org.gvsig.data.WriteException;

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

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

import org.gvsig.data.datastores.vectorial.db.DBFeatureType;

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

import org.gvsig.data.datastores.vectorial.db.jdbc.postgresql.PostgresqlStore;

import org.gvsig.data.vectorial.IFeatureStore;

public abstract class JDBCFeaturesWriter implements ISelectiveWriter{

        protected Connection conex;

        protected JDBCStore store;

        protected boolean previousAutocommit;

        public void init(IFeatureStore store) throws InitializeWriterException{

                this.store = (JDBCStore)store;

                try {

                        this.conex = this.store.getWriterConnection();

                } catch (ReadException e) {

                        throw new InitializeWriterException(this.store.getName(),e);

                }

        }

        /* (non-Javadoc)

         * @see org.gvsig.data.datastores.vectorial.IFeaturesWriter#dispose()

         */

        public void dispose() throws DataException {

                try {

                        this.conex.close();

                } catch (SQLException e) {

                        throw new CloseException(this.store.getName(),e);

                }

                this.conex = null;

        }

        public void preProcess() throws WriteException, ReadException {

                try {

                        previousAutocommit = conex.getAutoCommit();

                        conex.setAutoCommit(false);

                } catch (SQLException e) {

                        throw new WriteException(this.store.getName(),e);

                }

        }

        public void postProcess() throws OpenException, WriteException {

                try {

                        conex.commit();

                        if (previousAutocommit){

                                conex.setAutoCommit(true);

                        }

                } catch (SQLException e) {

                        throw new WriteException(this.store.getName(),e);

                }

        }

        public void cancelProcess() throws WriteException {

                try {

                        conex.rollback();

                        if (previousAutocommit){

                                conex.setAutoCommit(true);

                        }

                } catch (SQLException e) {

                        throw new WriteException(this.store.getName(),e);

                }

        }

}