Application: gvSIG desktop

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

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.SQLException;

import java.util.Collections;

import java.util.List;

import org.gvsig.expressionevaluator.GeometryExpressionBuilder;

import org.gvsig.fmap.dal.DataTypes;

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

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

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

import org.gvsig.fmap.dal.feature.exception.AlreadyEditingException;

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

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

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

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

import org.gvsig.fmap.dal.store.jdbc2.OperationsFactory.TableReference;

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

import org.gvsig.tools.dispose.Disposable;

import org.gvsig.tools.dispose.DisposeUtils;

public class AppendOperation {

    protected Connection connection = null;

    protected final JDBCHelper helper;

    protected final TableReference table;

    protected final FeatureType type;

    protected JDBCSQLBuilderBase sqlbuilder = null;

    protected GeometryExpressionBuilder expbuilder;

    protected PreparedStatement preparedStatement;

    protected String insertSQL;

    public AppendOperation(

            JDBCHelper helper, 

            TableReference table, 

            FeatureType type

        ) {

        this.helper = helper;

        this.table = table;

        this.type = type;

    }

    public void begin() throws DataException {

        if (this.sqlbuilder != null) {

            throw new AlreadyEditingException(this.helper.getSourceId());

        }

        try {

            this.connection = this.helper.getConnectionWritable();

            this.sqlbuilder = this.helper.createSQLBuilder();

            this.expbuilder = this.sqlbuilder.expression();

            this.sqlbuilder.insert().table()

                    .database(this.table.getDatabase())

                    .schema(this.table.getSchema())

                    .name(this.table.getTable()

            );

            for (FeatureAttributeDescriptor attr : type) {

                if( attr.isAutomatic() || attr.isComputed() ) {

                    continue;

                }

                if (attr.getType() == DataTypes.GEOMETRY) {

                        this.sqlbuilder.insert().column().name(attr.getName()).with_value( 

                            expbuilder.parameter(attr.getName()).as_geometry_variable().srs( 

                                    expbuilder.parameter().value(attr.getSRS()) 

                            ) 

                        );

                    } else {

                        this.sqlbuilder.insert().column().name(attr.getName()).with_value(

                        expbuilder.parameter(attr.getName()).as_variable()

                    );

                }

            }

            this.insertSQL = this.sqlbuilder.insert().toString();

            if( this.connection != null ) { // Not in test mode ???

              this.preparedStatement = this.connection.prepareStatement(insertSQL);

              this.connection.setAutoCommit(false);

              for (String sql : this.getPreviousSQLs()) {

                JDBCUtils.execute(this.connection, sql);

              }

            }

        } catch (SQLException ex) {

            throw new JDBCPreparingSQLException(this.sqlbuilder.toString(),ex);

        }

    }

    protected void clean() {

        JDBCUtils.closeQuietly(this.preparedStatement);

        this.helper.closeConnection(this.connection);

        this.connection = null;

        this.preparedStatement = null;

        this.sqlbuilder = null;

        this.insertSQL = null;        

    }

    public void end() {

        try {

            if( this.connection == null ) {

              return; // In test mode ???

            }

            this.connection.commit();

            for (String sql : this.getPostSQLs()) {

              JDBCUtils.execute(this.connection, sql);

            }

        } catch (SQLException ex) {

            try {

                this.connection.rollback();

            } catch (SQLException ex1) {

            }

            throw new RuntimeException("Can't commit transaction", ex);

        } finally {

            clean();

        }

    }

    public void abort() {        

        try {

            if( this.connection == null ) {

              return; // In test mode ???

            }

            this.connection.rollback();

            for (String sql : this.getPostSQLs()) {

              JDBCUtils.execute(this.connection, sql);

            }

        } catch (SQLException ex) {

        } finally {

          clean();

        }

    }

    public String getSQL() { // For test

      return this.insertSQL;

    }

    public List<String> getPreviousSQLs() {

      return Collections.EMPTY_LIST;

    }

    public List<String> getPostSQLs() {

      return Collections.EMPTY_LIST;

    }    

    public List<Object> getSQLParameters(FeatureProvider feature) {

      return this.sqlbuilder.getParameters(feature);

    }

    public void append(FeatureProvider feature) throws DataException {

        int n;

        Disposable paramsDisposer = null;

        try {

            paramsDisposer = this.sqlbuilder.setParameters(this.preparedStatement, feature);

            n = JDBCUtils.executeUpdate(this.preparedStatement,this.insertSQL);

        } catch(Exception ex) {

            throw new RuntimeException("Can't insert feature.", ex);

        } finally {

            DisposeUtils.disposeQuietly(paramsDisposer);

        }

        if( n<1 ) {

            throw new RuntimeException("Can't insert feature (n="+n+").");

        }

    }

}