Application: gvSIG desktop

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2020 gvSIG Association.

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 3

 * of the License, or (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

 * MA  02110-1301, USA.

 *

 * For any additional information, do not hesitate to contact us

 * at info AT gvsig.com, or visit our website www.gvsig.com.

 */

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.Iterator;

import java.util.List;

import java.util.Objects;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

@SuppressWarnings("UseSpecificCatch")

public class JDBCUtils {

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

    private JDBCUtils() {

    }

    private static String getSQLInfo(PreparedStatement st, String sql) {

        try {

            return sql+" [[ "+Objects.toString(st)+" ]]";

        } catch(Throwable th) {

            return sql;

        }

    }

    public static String getConnId(Statement st) {

        if( st==null ) {

            return "null";

        }

        try {

            return getHexId(st.getConnection());

        } catch (SQLException ex) {

            return "null";

        }

    }

    public static String getConnId(ResultSet resulSet) {

        if( resulSet==null ) {

            return "null";

        }

        try {

            return getConnId(resulSet.getStatement());

        } catch (SQLException ex) {

            return "null";

        }

    }

    public static String getConnId(Connection conn) {

        return getHexId(conn);

    }

    public static String getHexId(Object obj) {

        if( obj==null ) {

            return "null";

        }

        return Integer.toHexString(obj.hashCode()).toUpperCase();

    }

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

        if( LOGGER.isDebugEnabled() ) {

            LOGGER.debug("["+getConnId(st)+"] executeQuery(st) SQL= " + sql);

        }

        try {

            @SuppressWarnings("null")

            ResultSet rs = st.executeQuery(sql);

            return rs;

        } catch(Exception ex) {

            LOGGER.warn("execute SQL: " + sql, ex);

            throw ex;

        }

    }

    @SuppressWarnings("null")

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

        if( LOGGER.isDebugEnabled() ) {

            LOGGER.debug("["+getConnId(st)+"] execute(st) SQL: " + sql);

        }

        try {

            st.execute(sql);

        } catch(Exception ex) {

            LOGGER.warn("execute SQL: " + sql, ex);

            throw ex;

        }

    }

    public static void execute(Connection connection, String sql) throws SQLException {

        if( LOGGER.isDebugEnabled() ) {

            LOGGER.debug("["+getConnId(connection)+"] execute(conn) SQL: " + sql);

        }

        try {

            @SuppressWarnings("null")

            Statement st = connection.createStatement();

            st.execute(sql);

        } catch(Exception ex) {

            LOGGER.warn("execute SQL: " + sql, ex);

            throw ex;

        }

    }

    public static void execute(Connection connection, List<String> sqls) throws SQLException {

        Statement st = null;

        String sql = null;

        try {

            st = connection.createStatement();

            Iterator<String> it = sqls.iterator();

            while( it.hasNext() ) {

                sql = it.next();

                if( LOGGER.isDebugEnabled() ) {

                    LOGGER.debug("["+getConnId(connection)+"] execute(conn) SQLs: " + sql);

                }

                st.execute(sql);

            }

        } catch (SQLException ex) {

            LOGGER.warn("execute SQL: " + sql, ex);

            throw ex;

        } finally {

            JDBCUtils.closeQuietly(st);

        }       

    }

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

        if( LOGGER.isDebugEnabled() ) {

            LOGGER.debug("["+getConnId(st)+"] executeQuery(pst) SQL= "+ getSQLInfo(st,sql));

        }

        try {

            @SuppressWarnings("null")

            ResultSet rs = st.executeQuery();

            return rs;

        } catch(Exception ex) {

            LOGGER.warn("execute query SQL: " + getSQLInfo(st,sql), ex);

            throw ex;

        }

    }

    @SuppressWarnings("null")

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

        if( LOGGER.isDebugEnabled() ) {

            LOGGER.debug("["+getConnId(st)+"] execute(pst) SQL= "+ getSQLInfo(st,sql));

        }

        try {

            st.execute();

        } catch(Exception ex) {

            LOGGER.warn("execute SQL: " + getSQLInfo(st,sql), ex);

            throw ex;

        }

    }

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

        if( LOGGER.isDebugEnabled() ) {

            LOGGER.debug("["+getConnId(st)+"] executeUpdate(pst) SQL= "+ getSQLInfo(st,sql));

        }

        try {

            return st.executeUpdate();

        } catch(Exception ex) {

            LOGGER.warn("execute update SQL: " + getSQLInfo(st,sql), ex);

            throw ex;

        }

    }

    public static void closeQuietly(Statement st) {

        if( LOGGER.isDebugEnabled() ) {

            LOGGER.debug("["+getConnId(st)+"] Close statement");

        }

        if (st == null) {

            return;

        }

        try {

            st.close();

        } catch (Exception e) {

            LOGGER.warn("Problems closing " + st.getClass().getSimpleName() + " '" + st.toString() + "'.", e);

        }

    }

    public static void closeQuietly(ResultSet resulSet) {

        if( LOGGER.isDebugEnabled() ) {

            LOGGER.debug("["+getConnId(resulSet)+"] Close ResultSet");

        }

        if (resulSet == null) {

            return;

        }

        try {

            resulSet.close();

        } catch (Exception e) {

            LOGGER.warn("Problems closing " + resulSet.getClass().getSimpleName() + " '" + resulSet.toString() + "'.", e);

        }

    }

    public static void closeQuietly(Connection conn) {

        if( LOGGER.isDebugEnabled() ) {

            LOGGER.debug("["+getConnId(conn)+"] Close conn ("+Objects.toString(conn)+")");

        }

        if (conn == null) {

            return;

        }

        try {

            conn.close();

        } catch (Exception e) {

            LOGGER.warn("Problems closing " + conn.getClass().getSimpleName() + " '" + conn.toString() + "'.", e);

        }

    }

    public static void close(Connection conn) {

        if( LOGGER.isDebugEnabled() ) {

            LOGGER.debug("["+getConnId(conn)+"] Close conn ("+Objects.toString(conn)+")");

        }

        if (conn == null) {

            return;

        }

        try {

            conn.close();

        } catch (Exception e) {

            throw new RuntimeException(e);

        }

    }

    public static void closeQuietly(AutoCloseable obj) {

        if (obj == null) {

            return;

        }

        try {

            if( LOGGER.isDebugEnabled() ) {

                LOGGER.debug("Closing " + obj.getClass().getSimpleName() + " "+ obj.hashCode() + " ("+obj.toString()+")");

            }

            obj.close();

        } catch (Exception e) {

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

        }

    }

}