/*
    * 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.datasources;
  
  import java.io.IOException;
  import java.io.ObjectInputStream;
  import java.sql.Connection;
  import java.sql.SQLException;
  import java.time.Duration;
  import java.util.HashMap;
  import java.util.Map;
  import java.util.NoSuchElementException;
  
  import javax.naming.NamingException;
  import javax.naming.Reference;
  import javax.naming.StringRefAddr;
  import javax.sql.ConnectionPoolDataSource;
  
  import org.apache.commons.dbcp2.SwallowedExceptionLogger;
  import org.apache.commons.dbcp2.Utils;
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  import org.apache.commons.pool2.ObjectPool;
  import org.apache.commons.pool2.impl.GenericObjectPool;
  
  /**
   * <p>
   * A pooling {@code DataSource} appropriate for deployment within J2EE environment. There are many configuration
   * options, most of which are defined in the parent class. This datasource uses individual pools per user, and some
   * properties can be set specifically for a given user, if the deployment environment can support initialization of
   * mapped properties. So for example, a pool of admin or write-access Connections can be guaranteed a certain number of
   * connections, separate from a maximum set for users with read-only connections.
   * </p>
   *
   * <p>
   * User passwords can be changed without re-initializing the datasource. When a
   * {@code getConnection(userName, password)} request is processed with a password that is different from those used
   * to create connections in the pool associated with {@code userName}, an attempt is made to create a new
   * connection using the supplied password and if this succeeds, the existing pool is cleared and a new pool is created
   * for connections using the new password.
   * </p>
   *
   * @since 2.0
   */
  public class PerUserPoolDataSource extends InstanceKeyDataSource {
  
      private static final long serialVersionUID = 7872747993848065028L;
  
      private static final Log log = LogFactory.getLog(PerUserPoolDataSource.class);
  
      private static <K, V> HashMap<K, V> createMap() {
          // Should there be a default size different from what this ctor provides?
          return new HashMap<>();
      }
  
      private Map<String, Boolean> perUserBlockWhenExhausted;
      private Map<String, String> perUserEvictionPolicyClassName;
      private Map<String, Boolean> perUserLifo;
      private Map<String, Integer> perUserMaxIdle;
      private Map<String, Integer> perUserMaxTotal;
      private Map<String, Duration> perUserMaxWaitDuration;
      private Map<String, Duration> perUserMinEvictableIdleDuration;
      private Map<String, Integer> perUserMinIdle;
      private Map<String, Integer> perUserNumTestsPerEvictionRun;
      private Map<String, Duration> perUserSoftMinEvictableIdleDuration;
      private Map<String, Boolean> perUserTestOnCreate;
      private Map<String, Boolean> perUserTestOnBorrow;
      private Map<String, Boolean> perUserTestOnReturn;
      private Map<String, Boolean> perUserTestWhileIdle;
      private Map<String, Duration> perUserDurationBetweenEvictionRuns;
      private Map<String, Boolean> perUserDefaultAutoCommit;
      private Map<String, Integer> perUserDefaultTransactionIsolation;
      private Map<String, Boolean> perUserDefaultReadOnly;
  
      /**
       * Map to keep track of Pools for a given user.
       */
      private transient Map<PoolKey, PooledConnectionManager> managers = createMap();
  
      /**
       * Default no-arg constructor for Serialization.
       */
      public PerUserPoolDataSource() {
      }
  
     /**
      * Clears pool(s) maintained by this data source.
      *
      * @see org.apache.commons.pool2.ObjectPool#clear()
      * @since 2.3.0
      */
     public void clear() {
         managers.values().forEach(manager -> {
             try {
                 getCPDSConnectionFactoryPool(manager).clear();
             } catch (final Exception ignored) {
                 // ignore and try to close others.
             }
         });
         InstanceKeyDataSourceFactory.removeInstance(getInstanceKey());
     }
 
     /**
      * Closes pool(s) maintained by this data source.
      *
      * @see org.apache.commons.pool2.ObjectPool#close()
      */
     @Override
     public void close() {
         managers.values().forEach(manager -> Utils.closeQuietly(getCPDSConnectionFactoryPool(manager)));
         InstanceKeyDataSourceFactory.removeInstance(getInstanceKey());
     }
 
     /**
      * Converts a map with Long milliseconds values to another map with Duration values.
      */
     private Map<String, Duration> convertMap(final Map<String, Duration> currentMap, final Map<String, Long> longMap) {
         final Map<String, Duration> durationMap = createMap();
         longMap.forEach((k, v) -> durationMap.put(k, toDurationOrNull(v)));
         if (currentMap == null) {
             return durationMap;
         }
         currentMap.clear();
         currentMap.putAll(durationMap);
         return currentMap;
 
     }
 
     @Override
     protected PooledConnectionManager getConnectionManager(final UserPassKey upKey) {
         return managers.get(getPoolKey(upKey.getUserName()));
     }
 
     /**
      * Gets the underlying pool but does NOT allocate it.
      *
      * @param manager A CPDSConnectionFactory.
      * @return the underlying pool.
      */
     private ObjectPool<PooledConnectionAndInfo> getCPDSConnectionFactoryPool(final PooledConnectionManager manager) {
         return ((CPDSConnectionFactory) manager).getPool();
     }
 
     /**
      * Gets the number of active connections in the default pool.
      *
      * @return The number of active connections in the default pool.
      */
     public int getNumActive() {
         return getNumActive(null);
     }
 
     /**
      * Gets the number of active connections in the pool for a given user.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     @SuppressWarnings("resource")
     public int getNumActive(final String userName) {
         final ObjectPool<PooledConnectionAndInfo> pool = getPool(getPoolKey(userName));
         return pool == null ? 0 : pool.getNumActive();
     }
 
     /**
      * Gets the number of idle connections in the default pool.
      *
      * @return The number of idle connections in the default pool.
      */
     public int getNumIdle() {
         return getNumIdle(null);
     }
 
     /**
      * Gets the number of idle connections in the pool for a given user.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     @SuppressWarnings("resource")
     public int getNumIdle(final String userName) {
         final ObjectPool<PooledConnectionAndInfo> pool = getPool(getPoolKey(userName));
         return pool == null ? 0 : pool.getNumIdle();
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getBlockWhenExhausted()} for the specified user's pool
      * or the default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     public boolean getPerUserBlockWhenExhausted(final String userName) {
         Boolean value = null;
         if (perUserBlockWhenExhausted != null) {
             value = perUserBlockWhenExhausted.get(userName);
         }
         if (value == null) {
             return getDefaultBlockWhenExhausted();
         }
         return value;
     }
 
     /**
      * Gets the user specific default value for {@link Connection#setAutoCommit(boolean)} for the specified user's pool.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     public Boolean getPerUserDefaultAutoCommit(final String userName) {
         Boolean value = null;
         if (perUserDefaultAutoCommit != null) {
             value = perUserDefaultAutoCommit.get(userName);
         }
         return value;
     }
 
     /**
      * Gets the user specific default value for {@link Connection#setReadOnly(boolean)} for the specified user's pool.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     public Boolean getPerUserDefaultReadOnly(final String userName) {
         Boolean value = null;
         if (perUserDefaultReadOnly != null) {
             value = perUserDefaultReadOnly.get(userName);
         }
         return value;
     }
 
     /**
      * Gets the user specific default value for {@link Connection#setTransactionIsolation(int)} for the specified user's
      * pool.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     public Integer getPerUserDefaultTransactionIsolation(final String userName) {
         Integer value = null;
         if (perUserDefaultTransactionIsolation != null) {
             value = perUserDefaultTransactionIsolation.get(userName);
         }
         return value;
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getDurationBetweenEvictionRuns()} for the specified
      * user's pool or the default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      * @since 2.10.0
      */
     public Duration getPerUserDurationBetweenEvictionRuns(final String userName) {
         Duration value = null;
         if (perUserDurationBetweenEvictionRuns != null) {
             value = perUserDurationBetweenEvictionRuns.get(userName);
         }
         if (value == null) {
             return getDefaultDurationBetweenEvictionRuns();
         }
         return value;
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getEvictionPolicyClassName()} for the specified user's
      * pool or the default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     public String getPerUserEvictionPolicyClassName(final String userName) {
         String value = null;
         if (perUserEvictionPolicyClassName != null) {
             value = perUserEvictionPolicyClassName.get(userName);
         }
         if (value == null) {
             return getDefaultEvictionPolicyClassName();
         }
         return value;
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getLifo()} for the specified user's pool or the default
      * if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     public boolean getPerUserLifo(final String userName) {
         Boolean value = null;
         if (perUserLifo != null) {
             value = perUserLifo.get(userName);
         }
         if (value == null) {
             return getDefaultLifo();
         }
         return value;
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getMaxIdle()} for the specified user's pool or the
      * default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     public int getPerUserMaxIdle(final String userName) {
         Integer value = null;
         if (perUserMaxIdle != null) {
             value = perUserMaxIdle.get(userName);
         }
         if (value == null) {
             return getDefaultMaxIdle();
         }
         return value;
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getMaxTotal()} for the specified user's pool or the
      * default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     public int getPerUserMaxTotal(final String userName) {
         Integer value = null;
         if (perUserMaxTotal != null) {
             value = perUserMaxTotal.get(userName);
         }
         if (value == null) {
             return getDefaultMaxTotal();
         }
         return value;
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getMaxWaitDuration()} for the specified user's pool or
      * the default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      * @since 2.10.0
      */
     public Duration getPerUserMaxWaitDuration(final String userName) {
         Duration value = null;
         if (perUserMaxWaitDuration != null) {
             value = perUserMaxWaitDuration.get(userName);
         }
         if (value == null) {
             return getDefaultMaxWait();
         }
         return value;
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getMaxWaitDuration()} for the specified user's pool or
      * the default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      * @deprecated Use {@link #getPerUserMaxWaitDuration}.
      */
     @Deprecated
     public long getPerUserMaxWaitMillis(final String userName) {
         return getPerUserMaxWaitDuration(userName).toMillis();
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getMinEvictableIdleDuration()} for the specified
      * user's pool or the default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value, never null.
      * @since 2.10.0
      */
     public Duration getPerUserMinEvictableIdleDuration(final String userName) {
         Duration value = null;
         if (perUserMinEvictableIdleDuration != null) {
             value = perUserMinEvictableIdleDuration.get(userName);
         }
         if (value == null) {
             return getDefaultMinEvictableIdleDuration();
         }
         return value;
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getMinEvictableIdleDuration()} for the specified
      * user's pool or the default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      * @deprecated Use {@link #getPerUserMinEvictableIdleDuration(String)}.
      */
     @Deprecated
     public long getPerUserMinEvictableIdleTimeMillis(final String userName) {
         return getPerUserMinEvictableIdleDuration(userName).toMillis();
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getMinIdle()} for the specified user's pool or the
      * default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     public int getPerUserMinIdle(final String userName) {
         Integer value = null;
         if (perUserMinIdle != null) {
             value = perUserMinIdle.get(userName);
         }
         if (value == null) {
             return getDefaultMinIdle();
         }
         return value;
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getNumTestsPerEvictionRun()} for the specified user's
      * pool or the default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     public int getPerUserNumTestsPerEvictionRun(final String userName) {
         Integer value = null;
         if (perUserNumTestsPerEvictionRun != null) {
             value = perUserNumTestsPerEvictionRun.get(userName);
         }
         if (value == null) {
             return getDefaultNumTestsPerEvictionRun();
         }
         return value;
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getSoftMinEvictableIdleDuration()} for the specified
      * user's pool or the default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      * @since 2.10.0
      */
     public Duration getPerUserSoftMinEvictableIdleDuration(final String userName) {
         Duration value = null;
         if (perUserSoftMinEvictableIdleDuration != null) {
             value = perUserSoftMinEvictableIdleDuration.get(userName);
         }
         if (value == null) {
             return getDefaultSoftMinEvictableIdleDuration();
         }
         return value;
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getSoftMinEvictableIdleDuration()} for the specified
      * user's pool or the default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      * @deprecated Use {@link #getPerUserSoftMinEvictableIdleDuration(String)}.
      */
     @Deprecated
     public long getPerUserSoftMinEvictableIdleTimeMillis(final String userName) {
         return getPerUserSoftMinEvictableIdleDuration(userName).toMillis();
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getTestOnBorrow()} for the specified user's pool or the
      * default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     public boolean getPerUserTestOnBorrow(final String userName) {
         Boolean value = null;
         if (perUserTestOnBorrow != null) {
             value = perUserTestOnBorrow.get(userName);
         }
         if (value == null) {
             return getDefaultTestOnBorrow();
         }
         return value;
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getTestOnCreate()} for the specified user's pool or the
      * default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     public boolean getPerUserTestOnCreate(final String userName) {
         Boolean value = null;
         if (perUserTestOnCreate != null) {
             value = perUserTestOnCreate.get(userName);
         }
         if (value == null) {
             return getDefaultTestOnCreate();
         }
         return value;
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getTestOnReturn()} for the specified user's pool or the
      * default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     public boolean getPerUserTestOnReturn(final String userName) {
         Boolean value = null;
         if (perUserTestOnReturn != null) {
             value = perUserTestOnReturn.get(userName);
         }
         if (value == null) {
             return getDefaultTestOnReturn();
         }
         return value;
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getTestWhileIdle()} for the specified user's pool or
      * the default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      */
     public boolean getPerUserTestWhileIdle(final String userName) {
         Boolean value = null;
         if (perUserTestWhileIdle != null) {
             value = perUserTestWhileIdle.get(userName);
         }
         if (value == null) {
             return getDefaultTestWhileIdle();
         }
         return value;
     }
 
     /**
      * Gets the user specific value for {@link GenericObjectPool#getDurationBetweenEvictionRuns()} for the specified
      * user's pool or the default if no user specific value is defined.
      *
      * @param userName
      *            The user name key.
      * @return The user specific value.
      * @deprecated Use {@link #getPerUserDurationBetweenEvictionRuns(String)}.
      */
     @Deprecated
     public long getPerUserTimeBetweenEvictionRunsMillis(final String userName) {
         return getPerUserDurationBetweenEvictionRuns(userName).toMillis();
     }
 
     /**
      * Returns the object pool associated with the given PoolKey.
      *
      * @param poolKey
      *            PoolKey identifying the pool
      * @return the GenericObjectPool pooling connections for the userName and datasource specified by the PoolKey
      */
     private ObjectPool<PooledConnectionAndInfo> getPool(final PoolKey poolKey) {
         final CPDSConnectionFactory mgr = (CPDSConnectionFactory) managers.get(poolKey);
         return mgr == null ? null : mgr.getPool();
     }
 
     @Override
     protected PooledConnectionAndInfo getPooledConnectionAndInfo(final String userName, final String password)
             throws SQLException {
 
         final PoolKey key = getPoolKey(userName);
         ObjectPool<PooledConnectionAndInfo> pool;
         PooledConnectionManager manager;
         synchronized (this) {
             manager = managers.get(key);
             if (manager == null) {
                 try {
                     registerPool(userName, password);
                     manager = managers.get(key);
                 } catch (final NamingException e) {
                     throw new SQLException("RegisterPool failed", e);
                 }
             }
             pool = getCPDSConnectionFactoryPool(manager);
         }
 
         PooledConnectionAndInfo info = null;
         try {
             info = pool.borrowObject();
         } catch (final NoSuchElementException ex) {
             throw new SQLException("Could not retrieve connection info from pool", ex);
         } catch (final Exception e) {
             // See if failure is due to CPDSConnectionFactory authentication failure
             try {
                 testCPDS(userName, password);
             } catch (final Exception ex) {
                 throw new SQLException("Could not retrieve connection info from pool", ex);
             }
             // New password works, so kill the old pool, create a new one, and borrow
             manager.closePool(userName);
             synchronized (this) {
                 managers.remove(key);
             }
             try {
                 registerPool(userName, password);
                 pool = getPool(key);
             } catch (final NamingException ne) {
                 throw new SQLException("RegisterPool failed", ne);
             }
             try {
                 info = pool.borrowObject();
             } catch (final Exception ex) {
                 throw new SQLException("Could not retrieve connection info from pool", ex);
             }
         }
         return info;
     }
 
     /**
      * Creates a pool key from the provided parameters.
      *
      * @param userName
      *            User name
      * @return The pool key
      */
     private PoolKey getPoolKey(final String userName) {
         return new PoolKey(getDataSourceName(), userName);
     }
 
     /**
      * Returns a {@code PerUserPoolDataSource} {@link Reference}.
      */
     @Override
     public Reference getReference() throws NamingException {
         final Reference ref = new Reference(getClass().getName(), PerUserPoolDataSourceFactory.class.getName(), null);
         ref.add(new StringRefAddr("instanceKey", getInstanceKey()));
         return ref;
     }
 
     <K, V> Map<K, V> put(Map<K, V> map, final K key, final V value) {
         if (map == null) {
             map = createMap();
         }
         map.put(key, value);
         return map;
     }
 
     /**
      * Supports Serialization interface.
      *
      * @param in
      *            a {@link java.io.ObjectInputStream} value
      * @throws IOException
      *             if an error occurs
      * @throws ClassNotFoundException
      *             if an error occurs
      */
     private void readObject(final ObjectInputStream in) throws IOException, ClassNotFoundException {
         try {
             in.defaultReadObject();
             final PerUserPoolDataSource oldDS = (PerUserPoolDataSource) new PerUserPoolDataSourceFactory()
                     .getObjectInstance(getReference(), null, null, null);
             this.managers = oldDS.managers;
         } catch (final NamingException e) {
             throw new IOException("NamingException: " + e);
         }
     }
 
     private synchronized void registerPool(final String userName, final String password)
         throws NamingException, SQLException {
 
         final ConnectionPoolDataSource cpds = testCPDS(userName, password);
 
         // Set up the factory we will use (passing the pool associates
         // the factory with the pool, so we do not have to do so
         // explicitly)
         final CPDSConnectionFactory factory = new CPDSConnectionFactory(cpds, getValidationQuery(), getValidationQueryTimeoutDuration(),
             isRollbackAfterValidation(), userName, password);
         factory.setMaxConn(getMaxConnDuration());
 
         // Create an object pool to contain our PooledConnections
         final GenericObjectPool<PooledConnectionAndInfo> pool = new GenericObjectPool<>(factory);
         factory.setPool(pool);
         pool.setBlockWhenExhausted(getPerUserBlockWhenExhausted(userName));
         pool.setEvictionPolicyClassName(getPerUserEvictionPolicyClassName(userName));
         pool.setLifo(getPerUserLifo(userName));
         pool.setMaxIdle(getPerUserMaxIdle(userName));
         pool.setMaxTotal(getPerUserMaxTotal(userName));
         pool.setMaxWait(getPerUserMaxWaitDuration(userName));
         pool.setMinEvictableIdleDuration(getPerUserMinEvictableIdleDuration(userName));
         pool.setMinIdle(getPerUserMinIdle(userName));
         pool.setNumTestsPerEvictionRun(getPerUserNumTestsPerEvictionRun(userName));
         pool.setSoftMinEvictableIdleDuration(getPerUserSoftMinEvictableIdleDuration(userName));
         pool.setTestOnCreate(getPerUserTestOnCreate(userName));
         pool.setTestOnBorrow(getPerUserTestOnBorrow(userName));
         pool.setTestOnReturn(getPerUserTestOnReturn(userName));
         pool.setTestWhileIdle(getPerUserTestWhileIdle(userName));
         pool.setDurationBetweenEvictionRuns(getPerUserDurationBetweenEvictionRuns(userName));
 
         pool.setSwallowedExceptionListener(new SwallowedExceptionLogger(log));
 
         final PooledConnectionManager old = managers.put(getPoolKey(userName), factory);
         if (old != null) {
             throw new IllegalStateException("Pool already contains an entry for this user/password: " + userName);
         }
     }
 
     private <K, V> Map<K, V> replaceAll(final Map<K, V> currentMap, final Map<K, V> newMap) {
         if (currentMap == null) {
             return new HashMap<>(newMap);
         }
         currentMap.clear();
         currentMap.putAll(newMap);
         return currentMap;
     }
 
     void setPerUserBlockWhenExhausted(final Map<String, Boolean> newMap) {
         assertInitializationAllowed();
         perUserBlockWhenExhausted = replaceAll(perUserBlockWhenExhausted, newMap);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getBlockWhenExhausted()} for the specified user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      */
     public void setPerUserBlockWhenExhausted(final String userName, final Boolean value) {
         assertInitializationAllowed();
         perUserBlockWhenExhausted = put(perUserBlockWhenExhausted, userName, value);
     }
 
     void setPerUserDefaultAutoCommit(final Map<String, Boolean> newMap) {
         assertInitializationAllowed();
         perUserDefaultAutoCommit = replaceAll(perUserDefaultAutoCommit, newMap);
     }
 
     /**
      * Sets a user specific default value for {@link Connection#setAutoCommit(boolean)} for the specified user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      */
     public void setPerUserDefaultAutoCommit(final String userName, final Boolean value) {
         assertInitializationAllowed();
         perUserDefaultAutoCommit = put(perUserDefaultAutoCommit, userName, value);
 
     }
 
     void setPerUserDefaultReadOnly(final Map<String, Boolean> newMap) {
         assertInitializationAllowed();
         perUserDefaultReadOnly = replaceAll(perUserDefaultReadOnly, newMap);
     }
 
     /**
      * Sets a user specific default value for {@link Connection#setReadOnly(boolean)} for the specified user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      */
     public void setPerUserDefaultReadOnly(final String userName, final Boolean value) {
         assertInitializationAllowed();
         perUserDefaultReadOnly = put(perUserDefaultReadOnly, userName, value);
 
     }
 
     void setPerUserDefaultTransactionIsolation(final Map<String, Integer> newMap) {
         assertInitializationAllowed();
         perUserDefaultTransactionIsolation = replaceAll(perUserDefaultTransactionIsolation, newMap);
     }
 
     /**
      * Sets a user specific default value for {@link Connection#setTransactionIsolation(int)} for the specified user's
      * pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      */
     public void setPerUserDefaultTransactionIsolation(final String userName, final Integer value) {
         assertInitializationAllowed();
         perUserDefaultTransactionIsolation = put(perUserDefaultTransactionIsolation, userName, value);
 
     }
 
     void setPerUserDurationBetweenEvictionRuns(final Map<String, Duration> newMap) {
         assertInitializationAllowed();
         perUserDurationBetweenEvictionRuns = replaceAll(perUserDurationBetweenEvictionRuns, newMap);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getDurationBetweenEvictionRuns()} for the specified
      * user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      * @since 2.10.0
      */
     public void setPerUserDurationBetweenEvictionRuns(final String userName, final Duration value) {
         assertInitializationAllowed();
         perUserDurationBetweenEvictionRuns = put(perUserDurationBetweenEvictionRuns, userName, value);
 
     }
 
     void setPerUserEvictionPolicyClassName(final Map<String, String> newMap) {
         assertInitializationAllowed();
         perUserEvictionPolicyClassName = replaceAll(perUserEvictionPolicyClassName, newMap);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getEvictionPolicyClassName()} for the specified user's
      * pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      */
     public void setPerUserEvictionPolicyClassName(final String userName, final String value) {
         assertInitializationAllowed();
         perUserEvictionPolicyClassName = put(perUserEvictionPolicyClassName, userName, value);
     }
 
     void setPerUserLifo(final Map<String, Boolean> newMap) {
         assertInitializationAllowed();
         perUserLifo = replaceAll(perUserLifo, newMap);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getLifo()} for the specified user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      */
     public void setPerUserLifo(final String userName, final Boolean value) {
         assertInitializationAllowed();
         perUserLifo = put(perUserLifo, userName, value);
     }
 
     void setPerUserMaxIdle(final Map<String, Integer> newMap) {
         assertInitializationAllowed();
         perUserMaxIdle = replaceAll(perUserMaxIdle, newMap);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getMaxIdle()} for the specified user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      */
     public void setPerUserMaxIdle(final String userName, final Integer value) {
         assertInitializationAllowed();
         perUserMaxIdle = put(perUserMaxIdle, userName, value);
     }
 
     void setPerUserMaxTotal(final Map<String, Integer> newMap) {
         assertInitializationAllowed();
         perUserMaxTotal = replaceAll(perUserMaxTotal, newMap);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getMaxTotal()} for the specified user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      */
     public void setPerUserMaxTotal(final String userName, final Integer value) {
         assertInitializationAllowed();
         perUserMaxTotal = put(perUserMaxTotal, userName, value);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getMaxWaitDuration()} for the specified user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      * @since 2.10.0
      */
     public void setPerUserMaxWait(final String userName, final Duration value) {
         assertInitializationAllowed();
         perUserMaxWaitDuration = put(perUserMaxWaitDuration, userName, value);
     }
 
     void setPerUserMaxWaitDuration(final Map<String, Duration> newMap) {
         assertInitializationAllowed();
         perUserMaxWaitDuration = replaceAll(perUserMaxWaitDuration, newMap);
     }
 
     void setPerUserMaxWaitMillis(final Map<String, Long> newMap) {
         assertInitializationAllowed();
         perUserMaxWaitDuration = convertMap(perUserMaxWaitDuration, newMap);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getMaxWaitDuration()} for the specified user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      * @deprecated Use {@link #setPerUserMaxWait(String, Duration)}.
      */
     @Deprecated
     public void setPerUserMaxWaitMillis(final String userName, final Long value) {
         setPerUserMaxWait(userName, toDurationOrNull(value));
     }
 
     void setPerUserMinEvictableIdle(final Map<String, Duration> newMap) {
         assertInitializationAllowed();
         perUserMinEvictableIdleDuration = replaceAll(perUserMinEvictableIdleDuration, newMap);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getMinEvictableIdleDuration()} for the specified user's
      * pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      * @since 2.10.0
      */
     public void setPerUserMinEvictableIdle(final String userName, final Duration value) {
         assertInitializationAllowed();
         perUserMinEvictableIdleDuration = put(perUserMinEvictableIdleDuration, userName, value);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getMinEvictableIdleDuration()} for the specified user's
      * pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      * @deprecated Use {@link #setPerUserMinEvictableIdle(String, Duration)}.
      */
     @Deprecated
     public void setPerUserMinEvictableIdleTimeMillis(final String userName, final Long value) {
         setPerUserMinEvictableIdle(userName, toDurationOrNull(value));
     }
 
     void setPerUserMinIdle(final Map<String, Integer> newMap) {
         assertInitializationAllowed();
         perUserMinIdle = replaceAll(perUserMinIdle, newMap);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getMinIdle()} for the specified user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      */
     public void setPerUserMinIdle(final String userName, final Integer value) {
         assertInitializationAllowed();
         perUserMinIdle = put(perUserMinIdle, userName, value);
     }
 
     void setPerUserNumTestsPerEvictionRun(final Map<String, Integer> newMap) {
         assertInitializationAllowed();
         perUserNumTestsPerEvictionRun = replaceAll(perUserNumTestsPerEvictionRun, newMap);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getNumTestsPerEvictionRun()} for the specified user's
      * pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      */
     public void setPerUserNumTestsPerEvictionRun(final String userName, final Integer value) {
         assertInitializationAllowed();
         perUserNumTestsPerEvictionRun = put(perUserNumTestsPerEvictionRun, userName, value);
     }
 
     void setPerUserSoftMinEvictableIdle(final Map<String, Duration> newMap) {
         assertInitializationAllowed();
         perUserSoftMinEvictableIdleDuration = replaceAll(perUserSoftMinEvictableIdleDuration, newMap);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getSoftMinEvictableIdleDuration()} for the specified
      * user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      * @since 2.10.0
      */
     public void setPerUserSoftMinEvictableIdle(final String userName, final Duration value) {
         assertInitializationAllowed();
         perUserSoftMinEvictableIdleDuration = put(perUserSoftMinEvictableIdleDuration, userName, value);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getSoftMinEvictableIdleDuration()} for the specified
      * user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      * @deprecated Use {@link #setPerUserSoftMinEvictableIdle(String, Duration)}.
      */
     @Deprecated
     public void setPerUserSoftMinEvictableIdleTimeMillis(final String userName, final Long value) {
         setPerUserSoftMinEvictableIdle(userName, toDurationOrNull(value));
     }
 
     void setPerUserTestOnBorrow(final Map<String, Boolean> newMap) {
         assertInitializationAllowed();
         perUserTestOnBorrow = replaceAll(perUserTestOnBorrow, newMap);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getTestOnBorrow()} for the specified user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      */
     public void setPerUserTestOnBorrow(final String userName, final Boolean value) {
         assertInitializationAllowed();
         perUserTestOnBorrow = put(perUserTestOnBorrow, userName, value);
     }
 
     void setPerUserTestOnCreate(final Map<String, Boolean> newMap) {
         assertInitializationAllowed();
         perUserTestOnCreate = replaceAll(perUserTestOnCreate, newMap);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getTestOnCreate()} for the specified user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      */
     public void setPerUserTestOnCreate(final String userName, final Boolean value) {
         assertInitializationAllowed();
         perUserTestOnCreate = put(perUserTestOnCreate, userName, value);
     }
 
     void setPerUserTestOnReturn(final Map<String, Boolean> newMap) {
         assertInitializationAllowed();
         perUserTestOnReturn = replaceAll(perUserTestOnReturn, newMap);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getTestOnReturn()} for the specified user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      */
     public void setPerUserTestOnReturn(final String userName, final Boolean value) {
         assertInitializationAllowed();
         perUserTestOnReturn = put(perUserTestOnReturn, userName, value);
     }
 
     void setPerUserTestWhileIdle(final Map<String, Boolean> newMap) {
         assertInitializationAllowed();
         perUserTestWhileIdle = replaceAll(perUserTestWhileIdle, newMap);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getTestWhileIdle()} for the specified user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      */
     public void setPerUserTestWhileIdle(final String userName, final Boolean value) {
         assertInitializationAllowed();
         perUserTestWhileIdle = put(perUserTestWhileIdle, userName, value);
     }
 
     /**
      * Sets a user specific value for {@link GenericObjectPool#getDurationBetweenEvictionRuns()} for the specified
      * user's pool.
      *
      * @param userName
      *            The user name key.
      * @param value
      *            The user specific value.
      * @deprecated Use {@link #setPerUserDurationBetweenEvictionRuns(String, Duration)}.
      */
     @Deprecated
     public void setPerUserTimeBetweenEvictionRunsMillis(final String userName, final Long value) {
         setPerUserDurationBetweenEvictionRuns(userName, toDurationOrNull(value));
     }
 
     @Override
     protected void setupDefaults(final Connection con, final String userName) throws SQLException {
         Boolean defaultAutoCommit = isDefaultAutoCommit();
         if (userName != null) {
             final Boolean userMax = getPerUserDefaultAutoCommit(userName);
             if (userMax != null) {
                 defaultAutoCommit = userMax;
             }
         }
 
         Boolean defaultReadOnly = isDefaultReadOnly();
         if (userName != null) {
             final Boolean userMax = getPerUserDefaultReadOnly(userName);
             if (userMax != null) {
                 defaultReadOnly = userMax;
             }
         }
 
         int defaultTransactionIsolation = getDefaultTransactionIsolation();
         if (userName != null) {
             final Integer userMax = getPerUserDefaultTransactionIsolation(userName);
             if (userMax != null) {
                 defaultTransactionIsolation = userMax;
             }
         }
 
         if (defaultAutoCommit != null && con.getAutoCommit() != defaultAutoCommit) {
             con.setAutoCommit(defaultAutoCommit);
         }
 
         if (defaultTransactionIsolation != UNKNOWN_TRANSACTIONISOLATION) {
             con.setTransactionIsolation(defaultTransactionIsolation);
         }
 
         if (defaultReadOnly != null && con.isReadOnly() != defaultReadOnly) {
             con.setReadOnly(defaultReadOnly);
         }
     }
 
     private Duration toDurationOrNull(final Long millis) {
         return millis == null ? null : Duration.ofMillis(millis);
     }
 }