Application: gvSIG desktop » gvSIG data provider for PostgreSQL

package org.gvsig.postgresql.dal.operations;

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

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

import org.gvsig.fmap.dal.feature.spi.FeatureProvider;

import org.gvsig.fmap.dal.store.jdbc.exception.JDBCExecuteSQLException;

import org.gvsig.fmap.dal.store.jdbc.exception.JDBCTransactionRollbackException;

import org.gvsig.fmap.dal.store.jdbc2.JDBCHelper;

import org.gvsig.fmap.dal.store.jdbc2.JDBCUtils;

import org.gvsig.fmap.dal.store.jdbc2.spi.operations.AppendOperation;

import org.gvsig.postgresql.dal.PostgreSQLHelper;

public class PostgreSQLAppendOperation extends AppendOperation {

    public PostgreSQLAppendOperation(

            JDBCHelper helper, 

            String database,

            String schema, 

            String table, 

            FeatureType type

        ) {

        super(helper, database, schema, table, type);

    }

    private PostgreSQLHelper getHelper() {

        return (PostgreSQLHelper) this.helper;

    }

    @Override

    public void append(FeatureProvider feature) throws DataException {

        try {

            this.connection.setAutoCommit(false);

            try {

                getHelper().setPreparedStatementParameters(preparedStatement, sqlbuilder, type, feature);

                int n = JDBCUtils.executeUpdate(this.preparedStatement,this.sql);

                if ( n > 0) {

                    this.connection.commit();

                    return;

                }              

                this.connection.rollback();

            } catch(Exception ex) {

                try {

                    this.connection.rollback();

                } catch (Exception e1) {

                    throw new JDBCTransactionRollbackException(e1, ex);

                }                

                throw new JDBCExecuteSQLException(this.sql,ex);

            } 

            throw new JDBCExecuteSQLException(this.sql,null);

        } catch (JDBCExecuteSQLException ex) {

            throw ex;

        } catch (Exception ex) {

            throw new JDBCExecuteSQLException(this.sql,ex);

        }

    }

}