Package org.mariadb.jdbc.pool

Class Pool

  • All Implemented Interfaces:
    java.lang.AutoCloseable, PoolMBean
    public class Pool
extends java.lang.Object
implements java.lang.AutoCloseable, PoolMBean

    • Field Detail

      • logger

        private static final Logger logger

      • poolState

        private final java.util.concurrent.atomic.AtomicInteger poolState

      • pendingRequestNumber

        private final java.util.concurrent.atomic.AtomicInteger pendingRequestNumber

      • totalConnection

        private final java.util.concurrent.atomic.AtomicInteger totalConnection

      • idleConnections

        private final java.util.concurrent.LinkedBlockingDeque<InternalPoolConnection> idleConnections

      • connectionAppender

        private final java.util.concurrent.ThreadPoolExecutor connectionAppender

      • connectionAppenderQueue

        private final java.util.concurrent.BlockingQueue<java.lang.Runnable> connectionAppenderQueue

      • poolTag

        private final java.lang.String poolTag

      • poolExecutor

        private final java.util.concurrent.ScheduledThreadPoolExecutor poolExecutor

      • scheduledFuture

        private final java.util.concurrent.ScheduledFuture<?> scheduledFuture

    • Constructor Detail

      • Pool

        public Pool​(Configuration conf,
            int poolIndex,
            java.util.concurrent.ScheduledThreadPoolExecutor poolExecutor)
        Create pool from configuration.
        Parameters:
        conf - configuration parser
        poolIndex - pool index to permit distinction of thread name
        poolExecutor - pools common executor

    • Method Detail

      • addConnectionRequest

        private void addConnectionRequest()
        Add new connection if needed. Only one thread create new connection, so new connection request will wait to newly created connection or for a released connection.

      • removeIdleTimeoutConnection

        private void removeIdleTimeoutConnection()
        Removing idle connection. Close them and recreate connection to reach minimal number of connection.

      • addConnection

        private void addConnection()
                    throws java.sql.SQLException
        Create new connection.
        Throws:
        java.sql.SQLException - if connection creation failed

      • getIdleConnection

        private InternalPoolConnection getIdleConnection​(long timeout,
                                                 java.util.concurrent.TimeUnit timeUnit)
                                          throws java.lang.InterruptedException
        Get an existing idle connection in pool.
        Returns:
        an IDLE connection.
        Throws:
        java.lang.InterruptedException

      • silentCloseConnection

        private void silentCloseConnection​(Connection con)

      • silentAbortConnection

        private void silentAbortConnection​(Connection con)

      • getPoolConnection

        public InternalPoolConnection getPoolConnection()
                                         throws java.sql.SQLException
        Retrieve new connection. If possible return idle connection, if not, stack connection query, ask for a connection creation, and loop until a connection become idle / a new connection is created.
        Returns:
        a connection object
        Throws:
        java.sql.SQLException - if no connection is created when reaching timeout (connectTimeout option)

      • getPoolConnection

        public InternalPoolConnection getPoolConnection​(java.lang.String username,
                                                java.lang.String password)
                                         throws java.sql.SQLException
        Get new connection from pool if user and password correspond to pool. If username and password are different from pool, will return a dedicated connection.
        Parameters:
        username - username
        password - password
        Returns:
        connection
        Throws:
        java.sql.SQLException - if any error occur during connection

      • generatePoolTag

        private java.lang.String generatePoolTag​(int poolIndex)

      • close

        public void close()
           throws java.lang.Exception
        Close pool and underlying connections.
        Specified by:
        close in interface java.lang.AutoCloseable
        Throws:
        java.lang.Exception

      • getPoolTag

        public java.lang.String getPoolTag()

      • registerJmx

        private void registerJmx()
                  throws java.lang.Exception
        Throws:
        java.lang.Exception

      • unRegisterJmx

        private void unRegisterJmx()
                    throws java.lang.Exception
        Throws:
        java.lang.Exception

      • testGetConnectionIdleThreadIds

        public java.util.List<java.lang.Long> testGetConnectionIdleThreadIds()
        For testing purpose only.
        Returns:
        current thread id's