Application: gvSIG desktop

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

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.List;

import org.gvsig.fmap.dal.ExpressionBuilder.GeometrySupportType;

import static org.gvsig.fmap.dal.ExpressionBuilder.GeometrySupportType.EWKB;

import static org.gvsig.fmap.dal.ExpressionBuilder.GeometrySupportType.WKB;

import static org.gvsig.fmap.dal.ExpressionBuilder.GeometrySupportType.WKT;

import org.gvsig.fmap.geom.Geometry;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class JDBCUtils {

    private static final Logger logger = LoggerFactory.getLogger(JDBCUtils.class);

    private JDBCUtils() {

    }

    public static ResultSet executeQuery(Statement st, String sql) throws SQLException {

        logger.debug("execute query SQL: " + sql);

        ResultSet rs = st.executeQuery(sql);

        return rs;

    }

    public static void execute(Statement st, String sql) throws SQLException {

        logger.debug("execute SQL: " + sql);

        st.execute(sql);

    }

    public static ResultSet executeQuery(PreparedStatement st, String sql) throws SQLException {

        logger.debug("execute query SQL: " + sql);

        ResultSet rs = st.executeQuery();

        return rs;

    }

    public static void execute(PreparedStatement st, String sql) throws SQLException {

        logger.debug("execute SQL: " + sql);

        st.execute();

    }

    public static int executeUpdate(PreparedStatement st, String sql) throws SQLException {

        logger.debug("execute update SQL: "+ sql);

        return st.executeUpdate();

    }

    public static void closeQuietly(Statement obj) {

        if (obj == null) {

            return;

        }

        try {

            obj.close();

        } catch (Exception e) {

            logger.warn("Problems closing " + obj.getClass().getSimpleName() + " '" + obj.toString() + "'.", e);

        }

    }

    public static void closeQuietly(ResultSet obj) {

        if (obj == null) {

            return;

        }

        try {

            obj.close();

        } catch (Exception e) {

            logger.warn("Problems closing " + obj.getClass().getSimpleName() + " '" + obj.toString() + "'.", e);

        }

    }

    public static void closeQuietly(Connection obj) {

        if (obj == null) {

            return;

        }

        try {

            obj.close();

        } catch (Exception e) {

            logger.warn("Problems closing " + obj.getClass().getSimpleName() + " '" + obj.toString() + "'.", e);

        }

    }

    public static void closeQuietly(AutoCloseable obj) {

        if (obj == null) {

            return;

        }

        try {

            obj.close();

        } catch (Exception e) {

            logger.warn("Problems closing " + obj.getClass().getSimpleName() + " '" + obj.toString() + "'.", e);

        }

    }

    public static void setObjects(

        PreparedStatement st, 

        List values, 

        GeometrySupportType geometrySupportType) throws SQLException {

        if (values == null) {

            return;

        }

        try {

            byte[] bytes;

            int columnIndex = 1;

            for (Object value : values) {

                if (value instanceof Geometry) {

                    switch(geometrySupportType) {

                        case WKT:

                            value = ((Geometry) value).convertToWKT();

                            st.setObject(columnIndex, value);

                            break;

                        case WKB: 

                            bytes = ((Geometry) value).convertToWKB();

                            st.setBytes(columnIndex, bytes);

                            break;

                        case EWKB:

                            bytes = ((Geometry) value).convertToEWKB();

                            st.setBytes(columnIndex, bytes);

                            break;

                    }

                } else {

                    st.setObject(columnIndex, value);

                }

                columnIndex++;

            }

        } catch(Exception ex) {

            throw new SQLException("Can't set values for the prepared statement.", ex);

        }

    }

}