Application: gvSIG desktop

package org.gvsig.fmap.dal.store.jdbc2.spi.operations;

import java.sql.Connection;

import java.sql.SQLException;

import java.util.logging.Level;

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

import org.gvsig.fmap.dal.resource.ResourceAction;

import org.gvsig.fmap.dal.resource.spi.ResourceProvider;

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

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

import org.gvsig.fmap.dal.store.jdbc2.spi.JDBCSQLBuilderBase;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public abstract class AbstractConnectionOperation implements ConnectionOperation {

    final static protected Logger logger = LoggerFactory.getLogger(AbstractConnectionOperation.class);

    final protected JDBCHelper helper;

    private Connection conn = null;

    public AbstractConnectionOperation(JDBCHelper helper) {

        this.helper = helper;

    }

    @Override

    public boolean continueTransactionAllowed() {

        return false;

    }

    @Override

    public boolean needTransaction() {

        return true;

    }

    protected JDBCSQLBuilderBase createSQLBuilder() {

        return this.helper.createSQLBuilder();

    }

    @Override

    public Object perform()  {

        try {

            return this.perform_operation();

        } catch (RuntimeException ex) {

            throw ex;

        } catch (Exception ex) {

            throw new RuntimeException("Can't perform operation '"+this.getClass().getSimpleName()+"'.",ex);

        }

    }

    protected Connection getConnection() {

        return this.conn;

    }

    public Object perform_operation() throws Exception {

            Object result = null;

        try {

            logger.debug("preparing execution of "+this.getClass().getSimpleName()+".");

            conn = helper.getConnection();

            // XXX OJO esta condicion NO ES FIABLE

            if (!conn.getAutoCommit()) {

                if (!continueTransactionAllowed()) {

                    throw new SQLException("nested operations not allowed.");

                }

            }

            conn.setAutoCommit(false);

            try {

                logger.debug("Excuting operation {}.", this.getClass().getSimpleName());

                result = perform(conn);

            } catch (Exception ex) {

                try {

                    conn.rollback();

                } catch (Exception e1) {

                    throw new JDBCTransactionRollbackException(e1, ex);

                }

                throw new RuntimeException("Can't perform operation '"+this.getClass().getSimpleName()+"'.",ex);

            }

            conn.commit();

            return result;

        } finally {

            helper.closeConnection(conn);

            conn = null;

        }

    }

//

//    public Object perform2() {

//        ResourceProvider resource = this.helper.getResource();

//        Object r = resource.execute(new ResourceAction() {

//

//            @Override

//            public Object run() throws Exception {

//                return perform_operation();

//            }

//        });

//        return r;

//    }

}