package com.atlassian.sal.core.rdbms;
   
   import com.google.common.annotations.VisibleForTesting;
   
   import javax.annotation.Nonnull;
   import javax.annotation.concurrent.NotThreadSafe;
   import java.sql.Array;
   import java.sql.Blob;
   import java.sql.CallableStatement;
  import java.sql.Clob;
  import java.sql.Connection;
  import java.sql.DatabaseMetaData;
  import java.sql.NClob;
  import java.sql.PreparedStatement;
  import java.sql.SQLClientInfoException;
  import java.sql.SQLException;
  import java.sql.SQLWarning;
  import java.sql.SQLXML;
  import java.sql.Savepoint;
  import java.sql.Statement;
  import java.sql.Struct;
  import java.util.Map;
  import java.util.Properties;
  import java.util.concurrent.Executor;
  
  /**
   * {@link java.sql.Connection} proxy, which throws {@link java.lang.UnsupportedOperationException} on invocation of:
   * <ul>
   * <li>{@link java.sql.Connection#setAutoCommit(boolean)}</li>
   * <li>{@link java.sql.Connection#commit()}</li>
   * <li>{@link java.sql.Connection#close()}</li>
   * <li>{@link java.sql.Connection#rollback()}</li>
   * <li>{@link java.sql.Connection#setReadOnly(boolean)}</li>
   * <li>{@link java.sql.Connection#setReadOnly(boolean)}</li>
   * <li>{@link java.sql.Connection#abort(java.util.concurrent.Executor)}</li>
   * <li>{@link java.sql.Connection#setCatalog(String)}</li>
   * <li>{@link java.sql.Connection#setSchema(String)}</li>
   * <li>{@link java.sql.Connection#setTransactionIsolation(int)}</li>
   * <li>{@link java.sql.Connection#setNetworkTimeout(java.util.concurrent.Executor, int)}</li>
   * </ul>
   * <p/>
   * {@link #expire()} should be called after use, to prevent users from retaining and abusing the {@link
   * java.sql.Connection}.
   *
   * @since 3.0
   */
  @NotThreadSafe
  class WrappedConnection implements Connection {
      @VisibleForTesting
      Connection connection;
  
      public WrappedConnection(@Nonnull final Connection connection) {
          this.connection = connection;
      }
  
      void expire() {
          connection = null;
      }
  
      private Connection connection() {
          if (connection == null) {
              throw new IllegalStateException("Connection accessed outside the scope of a callback passed to com.atlassian.sal.api.rdbms.TransactionalExecutor");
          } else {
              return connection;
          }
      }
  
      /*
       * Banned methods
       */
      @Override
      public void setAutoCommit(final boolean autoCommit) throws SQLException {
          connection();
          throw new UnsupportedOperationException("java.sql.Connection#setAutoCommit(boolean) called from a connection provided by com.atlassian.sal.api.rdbms.TransactionalExecutor");
      }
  
      @Override
      public void commit() throws SQLException {
          connection();
          throw new UnsupportedOperationException("java.sql.Connection#commit() called from a connection provided by com.atlassian.sal.api.rdbms.TransactionalExecutor");
      }
  
      @Override
      public void close() {
          connection();
          expire();
      }
  
      @Override
      public void rollback() throws SQLException {
          connection();
          throw new UnsupportedOperationException("java.sql.Connection#rollback() called from a connection provided by com.atlassian.sal.api.rdbms.TransactionalExecutor");
      }
  
      @Override
      public void setReadOnly(final boolean readOnly) throws SQLException {
          connection();
          throw new UnsupportedOperationException("java.sql.Connection#setReadOnly(boolean) called from a connection provided by com.atlassian.sal.api.rdbms.TransactionalExecutor");
      }
 
     @Override
     public void abort(final Executor executor) throws SQLException {
         connection();
         throw new UnsupportedOperationException("java.sql.Connection#abort(java.util.concurrent.Executor)} called from a connection provided by com.atlassian.sal.api.rdbms.TransactionalExecutor");
     }
 
     @Override
     public void setCatalog(final String catalog) throws SQLException {
         connection();
         throw new UnsupportedOperationException("java.sql.Connection#setCatalog(String) called from a connection provided by com.atlassian.sal.api.rdbms.TransactionalExecutor");
     }
 
     @Override
     public void setSchema(final String schema) throws SQLException {
         connection();
         throw new UnsupportedOperationException("java.sql.Connection#setSchema(String) called from a connection provided by com.atlassian.sal.api.rdbms.TransactionalExecutor");
     }
 
     @Override
     public void setTransactionIsolation(final int level) throws SQLException {
         connection();
         throw new UnsupportedOperationException("java.sql.Connection#setTransactionIsolation(int) called from a connection provided by com.atlassian.sal.api.rdbms.TransactionalExecutor");
     }
 
     @Override
     public void setNetworkTimeout(final Executor executor, final int milliseconds) throws SQLException {
         connection();
         throw new UnsupportedOperationException("java.sql.Connection#setNetworkTimeout(java.util.concurrent.Executor, int)} called from a connection provided by com.atlassian.sal.api.rdbms.TransactionalExecutor");
     }
 
     @Override
     public Savepoint setSavepoint() throws SQLException {
         connection();
         throw new UnsupportedOperationException("java.sql.Connection#setSavepoint() called from a connection provided by com.atlassian.sal.api.rdbms.TransactionalExecutor");
     }
 
     @Override
     public Savepoint setSavepoint(final String name) throws SQLException {
         connection();
         throw new UnsupportedOperationException("java.sql.Connection#setSavepoint(String) called from a connection provided by com.atlassian.sal.api.rdbms.TransactionalExecutor");
     }
 
     @Override
     public void rollback(final Savepoint savepoint) throws SQLException {
         connection();
         throw new UnsupportedOperationException("java.sql.Connection#setSavepoint(java.sql.Savepoint) called from a connection provided by com.atlassian.sal.api.rdbms.TransactionalExecutor");
     }
 
     @Override
     public void releaseSavepoint(final Savepoint savepoint) throws SQLException {
         connection();
         throw new UnsupportedOperationException("java.sql.Connection#releaseSavepoint(java.sql.Savepoint) called from a connection provided by com.atlassian.sal.api.rdbms.TransactionalExecutor");
     }
 
     /*
      * Delegating methods
      */
     @Override
     public boolean isWrapperFor(final Class<?> iface) throws SQLException {
         return connection().isWrapperFor(iface);
     }
 
     @Override
     public Statement createStatement() throws SQLException {
         return connection().createStatement();
     }
 
     @Override
     public PreparedStatement prepareStatement(final String sql) throws SQLException {
         return connection().prepareStatement(sql);
     }
 
     @Override
     public CallableStatement prepareCall(final String sql) throws SQLException {
         return connection().prepareCall(sql);
     }
 
     @Override
     public String nativeSQL(final String sql) throws SQLException {
         return connection().nativeSQL(sql);
     }
 
     @Override
     public boolean getAutoCommit() throws SQLException {
         return connection().getAutoCommit();
     }
 
     @Override
     public boolean isClosed() throws SQLException {
         return connection().isClosed();
     }
 
     @Override
     public DatabaseMetaData getMetaData() throws SQLException {
         return connection().getMetaData();
     }
 
     @Override
     public boolean isReadOnly() throws SQLException {
         return connection().isReadOnly();
     }
 
     @Override
     public String getCatalog() throws SQLException {
         return connection().getCatalog();
     }
 
     @Override
     public int getTransactionIsolation() throws SQLException {
         return connection().getTransactionIsolation();
     }
 
     @Override
     public SQLWarning getWarnings() throws SQLException {
         return connection().getWarnings();
     }
 
     @Override
     public void clearWarnings() throws SQLException {
         connection().clearWarnings();
     }
 
     @Override
     public Statement createStatement(final int resultSetType, final int resultSetConcurrency) throws SQLException {
         return connection().createStatement(resultSetType, resultSetConcurrency);
     }
 
     @Override
     public PreparedStatement prepareStatement(final String sql, final int resultSetType, final int resultSetConcurrency)
             throws SQLException {
         return connection().prepareStatement(sql, resultSetType, resultSetConcurrency);
     }
 
     @Override
     public CallableStatement prepareCall(final String sql, final int resultSetType, final int resultSetConcurrency)
             throws SQLException {
         return connection().prepareCall(sql, resultSetType, resultSetConcurrency);
     }
 
     @Override
     public Map<String, Class<?>> getTypeMap() throws SQLException {
         return connection().getTypeMap();
     }
 
     @Override
     public void setTypeMap(final Map<String, Class<?>> map) throws SQLException {
         connection().setTypeMap(map);
     }
 
     @Override
     public void setHoldability(final int holdability) throws SQLException {
         connection().setHoldability(holdability);
     }
 
     @Override
     public int getHoldability() throws SQLException {
         return connection().getHoldability();
     }
 
     @Override
     public Statement createStatement(final int resultSetType, final int resultSetConcurrency, final int resultSetHoldability)
             throws SQLException {
         return connection().createStatement(resultSetType, resultSetConcurrency, resultSetHoldability);
     }
 
     @Override
     public PreparedStatement prepareStatement(final String sql, final int resultSetType, final int resultSetConcurrency, final int resultSetHoldability)
             throws SQLException {
         return connection().prepareStatement(sql, resultSetType, resultSetConcurrency, resultSetHoldability);
     }
 
     @Override
     public CallableStatement prepareCall(final String sql, final int resultSetType, final int resultSetConcurrency, final int resultSetHoldability)
             throws SQLException {
         return connection().prepareCall(sql, resultSetType, resultSetConcurrency, resultSetHoldability);
     }
 
     @Override
     public PreparedStatement prepareStatement(final String sql, final int autoGeneratedKeys) throws SQLException {
         return connection().prepareStatement(sql, autoGeneratedKeys);
     }
 
     @Override
     public PreparedStatement prepareStatement(final String sql, final int[] columnIndexes) throws SQLException {
         return connection().prepareStatement(sql, columnIndexes);
     }
 
     @Override
     public PreparedStatement prepareStatement(final String sql, final String[] columnNames) throws SQLException {
         return connection().prepareStatement(sql, columnNames);
     }
 
     @Override
     public Clob createClob() throws SQLException {
         return connection().createClob();
     }
 
     @Override
     public Blob createBlob() throws SQLException {
         return connection().createBlob();
     }
 
     @Override
     public NClob createNClob() throws SQLException {
         return connection().createNClob();
     }
 
     @Override
     public SQLXML createSQLXML() throws SQLException {
         return connection().createSQLXML();
     }
 
     @Override
     public boolean isValid(final int timeout) throws SQLException {
         return connection().isValid(timeout);
     }
 
     @Override
     public void setClientInfo(final String name, final String value) throws SQLClientInfoException {
         connection().setClientInfo(name, value);
     }
 
     @Override
     public void setClientInfo(final Properties properties) throws SQLClientInfoException {
         connection().setClientInfo(properties);
     }
 
     @Override
     public String getClientInfo(final String name) throws SQLException {
         return connection().getClientInfo(name);
     }
 
     @Override
     public Properties getClientInfo() throws SQLException {
         return connection().getClientInfo();
     }
 
     @Override
     public Array createArrayOf(final String typeName, final Object[] elements) throws SQLException {
         return connection().createArrayOf(typeName, elements);
     }
 
     @Override
     public Struct createStruct(final String typeName, final Object[] attributes) throws SQLException {
         return connection().createStruct(typeName, attributes);
     }
 
     @Override
     public String getSchema() throws SQLException {
         return connection().getSchema();
     }
 
     @Override
     public int getNetworkTimeout() throws SQLException {
         return connection().getNetworkTimeout();
     }
 
     @Override
     public <T> T unwrap(final Class<T> iface) throws SQLException {
         return connection().unwrap(iface);
     }
 }