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.datastores.vectorial.ISelectiveWriter;

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.exception.OpenException;

import org.gvsig.data.exception.ReadException;

import org.gvsig.data.exception.WriteException;

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) {

                this.store = (JDBCStore)store;

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

        }

        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);

                }

        }

}