| /* | |
| * Licensed to the Apache Software Foundation (ASF) under one or more | |
| * contributor license agreements. See the NOTICE file distributed with | |
| * this work for additional information regarding copyright ownership. | |
| * The ASF licenses this file to You under the Apache License, Version 2.0 | |
| * (the "License"); you may not use this file except in compliance with | |
| * the License. You may obtain a copy of the License at | |
| * | |
| * http://www.apache.org/licenses/LICENSE-2.0 | |
| * | |
| * Unless required by applicable law or agreed to in writing, software | |
| * distributed under the License is distributed on an "AS IS" BASIS, | |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | |
| * See the License for the specific language governing permissions and | |
| * limitations under the License. | |
| */ | |
| package org.apache.commons.dbcp2; | |
| import java.io.InputStream; | |
| import java.io.Reader; | |
| import java.math.BigDecimal; | |
| import java.net.URL; | |
| import java.sql.Array; | |
| import java.sql.Blob; | |
| import java.sql.Clob; | |
| import java.sql.Connection; | |
| import java.sql.DatabaseMetaData; | |
| import java.sql.Date; | |
| import java.sql.Ref; | |
| import java.sql.ResultSet; | |
| import java.sql.RowId; | |
| import java.sql.SQLException; | |
| import java.sql.SQLFeatureNotSupportedException; | |
| import java.sql.SQLXML; | |
| import java.sql.Statement; | |
| import java.sql.Time; | |
| import java.sql.Timestamp; | |
| import java.util.concurrent.Executor; | |
| import java.util.logging.Logger; | |
| import javax.sql.CommonDataSource; | |
| /** | |
| * Defines bridge methods to JDBC 4.1 (Java 7 or above) methods to allow call sites to operate safely (without | |
| * {@link AbstractMethodError}) when using a JDBC driver written for JDBC 4.0 (Java 6 or above). | |
| * <p> | |
| * There should be no need to this kind of code for JDBC 4.2 in Java 8 due to JDBC's use of default methods. | |
| * </p> | |
| * <p> | |
| * This should probably be moved or at least copied in some form to Apache Commons DbUtils. | |
| * </p> | |
| * | |
| * @since 2.6.0 | |
| */ | |
| public class Jdbc41Bridge { | |
| /** | |
| * Delegates to {@link Connection#abort(Executor)} without throwing an {@link AbstractMethodError}. | |
| * <p> | |
| * If the JDBC driver does not implement {@link Connection#abort(Executor)}, then call {@link Connection#close()}. | |
| * </p> | |
| * | |
| * @param connection | |
| * the receiver | |
| * @param executor | |
| * See {@link Connection#abort(Executor)}. | |
| * @throws SQLException | |
| * See {@link Connection#abort(Executor)}. | |
| * @see Connection#abort(Executor) | |
| */ | |
| public static void abort(final Connection connection, final Executor executor) throws SQLException { | |
| try { | |
| connection.abort(executor); | |
| } catch (final AbstractMethodError e) { | |
| connection.close(); | |
| } | |
| } | |
| /** | |
| * Delegates to {@link Statement#closeOnCompletion()} without throwing an {@link AbstractMethodError}. | |
| * <p> | |
| * If the JDBC driver does not implement {@link Statement#closeOnCompletion()}, then just check that the connection | |
| * is closed to then throw an SQLException. | |
| * </p> | |
| * | |
| * @param statement | |
| * See {@link Statement#closeOnCompletion()} | |
| * @throws SQLException | |
| * See {@link Statement#closeOnCompletion()} | |
| * @see Statement#closeOnCompletion() | |
| */ | |
| public static void closeOnCompletion(final Statement statement) throws SQLException { | |
| try { | |
| statement.closeOnCompletion(); | |
| } catch (final AbstractMethodError e) { | |
| if (statement.isClosed()) { | |
| throw new SQLException("Statement closed"); | |
| } | |
| } | |
| } | |
| /** | |
| * Delegates to {@link DatabaseMetaData#generatedKeyAlwaysReturned()} without throwing a | |
| * {@link AbstractMethodError}. | |
| * <p> | |
| * If the JDBC driver does not implement {@link DatabaseMetaData#generatedKeyAlwaysReturned()}, then return false. | |
| * </p> | |
| * | |
| * @param databaseMetaData | |
| * See {@link DatabaseMetaData#generatedKeyAlwaysReturned()} | |
| * @return See {@link DatabaseMetaData#generatedKeyAlwaysReturned()} | |
| * @throws SQLException | |
| * See {@link DatabaseMetaData#generatedKeyAlwaysReturned()} | |
| * @see DatabaseMetaData#generatedKeyAlwaysReturned() | |
| */ | |
| public static boolean generatedKeyAlwaysReturned(final DatabaseMetaData databaseMetaData) throws SQLException { | |
| try { | |
| return databaseMetaData.generatedKeyAlwaysReturned(); | |
| } catch (final AbstractMethodError e) { | |
| // do nothing | |
| return false; | |
| } | |
| } | |
| /** | |
| * Delegates to {@link Connection#getNetworkTimeout()} without throwing an {@link AbstractMethodError}. | |
| * <p> | |
| * If the JDBC driver does not implement {@link Connection#getNetworkTimeout()}, then return 0. | |
| * </p> | |
| * | |
| * @param connection | |
| * the receiver | |
| * @return See {@link Connection#getNetworkTimeout()} | |
| * @throws SQLException | |
| * See {@link Connection#getNetworkTimeout()} | |
| * @see Connection#getNetworkTimeout() | |
| */ | |
| public static int getNetworkTimeout(final Connection connection) throws SQLException { | |
| try { | |
| return connection.getNetworkTimeout(); | |
| } catch (final AbstractMethodError e) { | |
| return 0; | |
| } | |
| } | |
| /** | |
| * Delegates to {@link ResultSet#getObject(int, Class)} without throwing an {@link AbstractMethodError}. | |
| * <p> | |
| * If the JDBC driver does not implement {@link ResultSet#getObject(int, Class)}, then return 0. | |
| * </p> | |
| * | |
| * @param <T> | |
| * See {@link ResultSet#getObject(int, Class)} | |
| * @param resultSet | |
| * See {@link ResultSet#getObject(int, Class)} | |
| * @param columnIndex | |
| * See {@link ResultSet#getObject(int, Class)} | |
| * @param type | |
| * See {@link ResultSet#getObject(int, Class)} | |
| * @return See {@link ResultSet#getObject(int, Class)} | |
| * @throws SQLException | |
| * See {@link ResultSet#getObject(int, Class)} | |
| * @see ResultSet#getObject(int, Class) | |
| */ | |
| @SuppressWarnings("unchecked") | |
| public static <T> T getObject(final ResultSet resultSet, final int columnIndex, final Class<T> type) | |
| throws SQLException { | |
| try { | |
| return resultSet.getObject(columnIndex, type); | |
| } catch (final AbstractMethodError e) { | |
| if (type == String.class) { | |
| return (T) resultSet.getString(columnIndex); | |
| } | |
| // Numbers | |
| if (type == Integer.class) { | |
| return (T) Integer.valueOf(resultSet.getInt(columnIndex)); | |
| } | |
| if (type == Long.class) { | |
| return (T) Long.valueOf(resultSet.getLong(columnIndex)); | |
| } | |
| if (type == Double.class) { | |
| return (T) Double.valueOf(resultSet.getDouble(columnIndex)); | |
| } | |
| if (type == Float.class) { | |
| return (T) Float.valueOf(resultSet.getFloat(columnIndex)); | |
| } | |
| if (type == Short.class) { | |
| return (T) Short.valueOf(resultSet.getShort(columnIndex)); | |
| } | |
| if (type == BigDecimal.class) { | |
| return (T) resultSet.getBigDecimal(columnIndex); | |
| } | |
| if (type == Byte.class) { | |
| return (T) Byte.valueOf(resultSet.getByte(columnIndex)); | |
| } | |
| // Dates | |
| if (type == Date.class) { | |
| return (T) resultSet.getDate(columnIndex); | |
| } | |
| if (type == Time.class) { | |
| return (T) resultSet.getTime(columnIndex); | |
| } | |
| if (type == Timestamp.class) { | |
| return (T) resultSet.getTimestamp(columnIndex); | |
| } | |
| // Streams | |
| if (type == InputStream.class) { | |
| return (T) resultSet.getBinaryStream(columnIndex); | |
| } | |
| if (type == Reader.class) { | |
| return (T) resultSet.getCharacterStream(columnIndex); | |
| } | |
| // Other | |
| if (type == Object.class) { | |
| return (T) resultSet.getObject(columnIndex); | |
| } | |
| if (type == Boolean.class) { | |
| return (T) Boolean.valueOf(resultSet.getBoolean(columnIndex)); | |
| } | |
| if (type == Array.class) { | |
| return (T) resultSet.getArray(columnIndex); | |
| } | |
| if (type == Blob.class) { | |
| return (T) resultSet.getBlob(columnIndex); | |
| } | |
| if (type == Clob.class) { | |
| return (T) resultSet.getClob(columnIndex); | |
| } | |
| if (type == Ref.class) { | |
| return (T) resultSet.getRef(columnIndex); | |
| } | |
| if (type == RowId.class) { | |
| return (T) resultSet.getRowId(columnIndex); | |
| } | |
| if (type == SQLXML.class) { | |
| return (T) resultSet.getSQLXML(columnIndex); | |
| } | |
| if (type == URL.class) { | |
| return (T) resultSet.getURL(columnIndex); | |
| } | |
| throw new SQLFeatureNotSupportedException( | |
| String.format("resultSet=%s, columnIndex=%,d, type=%s", resultSet, columnIndex, type)); | |
| } | |
| } | |
| /** | |
| * Delegates to {@link ResultSet#getObject(String, Class)} without throwing an {@link AbstractMethodError}. | |
| * | |
| * @param <T> | |
| * See {@link ResultSet#getObject(String, Class)} | |
| * @param resultSet | |
| * See {@link ResultSet#getObject(String, Class)} | |
| * @param columnLabel | |
| * See {@link ResultSet#getObject(String, Class)} | |
| * @param type | |
| * See {@link ResultSet#getObject(String, Class)} | |
| * @return See {@link ResultSet#getObject(String, Class)} | |
| * @throws SQLException | |
| * See {@link ResultSet#getObject(String, Class)} | |
| * @see ResultSet#getObject(int, Class) | |
| */ | |
| @SuppressWarnings("unchecked") | |
| public static <T> T getObject(final ResultSet resultSet, final String columnLabel, final Class<T> type) | |
| throws SQLException { | |
| try { | |
| return resultSet.getObject(columnLabel, type); | |
| } catch (final AbstractMethodError e) { | |
| // Numbers | |
| if (type == Integer.class) { | |
| return (T) Integer.valueOf(resultSet.getInt(columnLabel)); | |
| } | |
| if (type == Long.class) { | |
| return (T) Long.valueOf(resultSet.getLong(columnLabel)); | |
| } | |
| if (type == Double.class) { | |
| return (T) Double.valueOf(resultSet.getDouble(columnLabel)); | |
| } | |
| if (type == Float.class) { | |
| return (T) Float.valueOf(resultSet.getFloat(columnLabel)); | |
| } | |
| if (type == Short.class) { | |
| return (T) Short.valueOf(resultSet.getShort(columnLabel)); | |
| } | |
| if (type == BigDecimal.class) { | |
| return (T) resultSet.getBigDecimal(columnLabel); | |
| } | |
| if (type == Byte.class) { | |
| return (T) Byte.valueOf(resultSet.getByte(columnLabel)); | |
| } | |
| // Dates | |
| if (type == Date.class) { | |
| return (T) resultSet.getDate(columnLabel); | |
| } | |
| if (type == Time.class) { | |
| return (T) resultSet.getTime(columnLabel); | |
| } | |
| if (type == Timestamp.class) { | |
| return (T) resultSet.getTimestamp(columnLabel); | |
| } | |
| // Streams | |
| if (type == InputStream.class) { | |
| return (T) resultSet.getBinaryStream(columnLabel); | |
| } | |
| if (type == Reader.class) { | |
| return (T) resultSet.getCharacterStream(columnLabel); | |
| } | |
| // Other | |
| if (type == Object.class) { | |
| return (T) resultSet.getObject(columnLabel); | |
| } | |
| if (type == Boolean.class) { | |
| return (T) Boolean.valueOf(resultSet.getBoolean(columnLabel)); | |
| } | |
| if (type == Array.class) { | |
| return (T) resultSet.getArray(columnLabel); | |
| } | |
| if (type == Blob.class) { | |
| return (T) resultSet.getBlob(columnLabel); | |
| } | |
| if (type == Clob.class) { | |
| return (T) resultSet.getClob(columnLabel); | |
| } | |
| if (type == Ref.class) { | |
| return (T) resultSet.getRef(columnLabel); | |
| } | |
| if (type == RowId.class) { | |
| return (T) resultSet.getRowId(columnLabel); | |
| } | |
| if (type == SQLXML.class) { | |
| return (T) resultSet.getSQLXML(columnLabel); | |
| } | |
| if (type == URL.class) { | |
| return (T) resultSet.getURL(columnLabel); | |
| } | |
| throw new SQLFeatureNotSupportedException( | |
| String.format("resultSet=%s, columnLabel=%s, type=%s", resultSet, columnLabel, type)); | |
| } | |
| } | |
| /** | |
| * Delegates to {@link CommonDataSource#getParentLogger()} without throwing an {@link AbstractMethodError}. | |
| * <p> | |
| * If the JDBC driver does not implement {@link CommonDataSource#getParentLogger()}, then return null. | |
| * </p> | |
| * | |
| * @param commonDataSource | |
| * See {@link CommonDataSource#getParentLogger()} | |
| * @return See {@link CommonDataSource#getParentLogger()} | |
| * @throws SQLFeatureNotSupportedException | |
| * See {@link CommonDataSource#getParentLogger()} | |
| */ | |
| public static Logger getParentLogger(final CommonDataSource commonDataSource) throws SQLFeatureNotSupportedException { | |
| try { | |
| return commonDataSource.getParentLogger(); | |
| } catch (final AbstractMethodError e) { | |
| throw new SQLFeatureNotSupportedException("javax.sql.CommonDataSource#getParentLogger()"); | |
| } | |
| } | |
| /** | |
| * Delegates to {@link DatabaseMetaData#getPseudoColumns(String, String, String, String)} without throwing a | |
| * {@link AbstractMethodError}. | |
| * <p> | |
| * If the JDBC driver does not implement {@link DatabaseMetaData#getPseudoColumns(String, String, String, String)}, | |
| * then return null. | |
| * </p> | |
| * | |
| * @param databaseMetaData | |
| * the receiver | |
| * @param catalog | |
| * See {@link DatabaseMetaData#getPseudoColumns(String, String, String, String)} | |
| * @param schemaPattern | |
| * See {@link DatabaseMetaData#getPseudoColumns(String, String, String, String)} | |
| * @param tableNamePattern | |
| * See {@link DatabaseMetaData#getPseudoColumns(String, String, String, String)} | |
| * @param columnNamePattern | |
| * See {@link DatabaseMetaData#getPseudoColumns(String, String, String, String)} | |
| * @return See {@link DatabaseMetaData#getPseudoColumns(String, String, String, String)} | |
| * @throws SQLException | |
| * See {@link DatabaseMetaData#getPseudoColumns(String, String, String, String)} | |
| * @see DatabaseMetaData#getPseudoColumns(String, String, String, String) | |
| */ | |
| public static ResultSet getPseudoColumns(final DatabaseMetaData databaseMetaData, final String catalog, | |
| final String schemaPattern, final String tableNamePattern, final String columnNamePattern) | |
| throws SQLException { | |
| try { | |
| return databaseMetaData.getPseudoColumns(catalog, schemaPattern, tableNamePattern, columnNamePattern); | |
| } catch (final AbstractMethodError e) { | |
| // do nothing | |
| return null; | |
| } | |
| } | |
| /** | |
| * Delegates to {@link Connection#getSchema()} without throwing an {@link AbstractMethodError}. | |
| * <p> | |
| * If the JDBC driver does not implement {@link Connection#getSchema()}, then return null. | |
| * </p> | |
| * | |
| * @param connection | |
| * the receiver | |
| * @return null for a JDBC 4 driver or a value per {@link Connection#getSchema()}. | |
| * @throws SQLException | |
| * See {@link Connection#getSchema()}. | |
| * @see Connection#getSchema() | |
| */ | |
| public static String getSchema(final Connection connection) throws SQLException { | |
| try { | |
| return connection.getSchema(); | |
| } catch (final AbstractMethodError e) { | |
| // do nothing | |
| return null; | |
| } | |
| } | |
| /** | |
| * Delegates to {@link Statement#isCloseOnCompletion()} without throwing an {@link AbstractMethodError}. | |
| * <p> | |
| * If the JDBC driver does not implement {@link Statement#isCloseOnCompletion()}, then just check that the | |
| * connection is closed to then throw an SQLException. | |
| * </p> | |
| * | |
| * @param statement | |
| * See {@link Statement#isCloseOnCompletion()} | |
| * @return See {@link Statement#isCloseOnCompletion()} | |
| * @throws SQLException | |
| * See {@link Statement#isCloseOnCompletion()} | |
| * @see Statement#closeOnCompletion() | |
| */ | |
| public static boolean isCloseOnCompletion(final Statement statement) throws SQLException { | |
| try { | |
| return statement.isCloseOnCompletion(); | |
| } catch (final AbstractMethodError e) { | |
| if (statement.isClosed()) { | |
| throw new SQLException("Statement closed"); | |
| } | |
| return false; | |
| } | |
| } | |
| /** | |
| * Delegates to {@link Connection#setNetworkTimeout(Executor, int)} without throwing an {@link AbstractMethodError}. | |
| * <p> | |
| * If the JDBC driver does not implement {@link Connection#setNetworkTimeout(Executor, int)}, then do nothing. | |
| * </p> | |
| * | |
| * @param connection | |
| * the receiver | |
| * @param executor | |
| * See {@link Connection#setNetworkTimeout(Executor, int)} | |
| * @param milliseconds | |
| * {@link Connection#setNetworkTimeout(Executor, int)} | |
| * @throws SQLException | |
| * {@link Connection#setNetworkTimeout(Executor, int)} | |
| * @see Connection#setNetworkTimeout(Executor, int) | |
| */ | |
| public static void setNetworkTimeout(final Connection connection, final Executor executor, final int milliseconds) | |
| throws SQLException { | |
| try { | |
| connection.setNetworkTimeout(executor, milliseconds); | |
| } catch (final AbstractMethodError ignored) { | |
| // do nothing | |
| } | |
| } | |
| /** | |
| * Delegates to {@link Connection#setSchema(String)} without throwing an {@link AbstractMethodError}. | |
| * <p> | |
| * If the JDBC driver does not implement {@link Connection#setSchema(String)}, then do nothing. | |
| * </p> | |
| * | |
| * @param connection | |
| * the receiver | |
| * @param schema | |
| * See {@link Connection#setSchema(String)}. | |
| * @throws SQLException | |
| * See {@link Connection#setSchema(String)}. | |
| * @see Connection#setSchema(String) | |
| */ | |
| public static void setSchema(final Connection connection, final String schema) throws SQLException { | |
| try { | |
| connection.setSchema(schema); | |
| } catch (final AbstractMethodError ignored) { | |
| // do nothing | |
| } | |
| } | |
| } |