ConnectPool (root 0.2-SNAPSHOT API)

java.lang.Object
- xyz.cofe.sql.ConnectPool

```
public class ConnectPool
extends Object
```
Пул соединений c СУБД.
Задачи
- Создание и регистрация соединений с СУБД
- Создание proxy для соединений и запросов
- Отслеживание активности соединений и запросов
- Закрытие объектов по истичении времени при остутсвии активности
Author:

Kamnev Georgiy (nt.gocha@gmail.com)

Field Summary

Fields
Modifier and Type	Field and Description
`protected LinkedBlockingQueue<DataEvent>`	`eventQueue`
`protected DataEventSupport`	`eventSupport`
`protected WeakHashMap<DataSource,ConnectOptions>`	`options`
`protected EventList<ConnectionPoolService>`	`services`
`protected WeakHashMap<Statement,Long>`	`statementCreateTime`
`protected WeakHashMap<Statement,Connection>`	`statements`

Constructor Summary

Constructors
Constructor and Description

ConnectPool()

ConnectPool(ConnectionPoolService... services)

Constructors
Constructor and Description
`ConnectPool()`
`ConnectPool(ConnectionPoolService... services)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`InvokeActivityStat`	`activityStatOf(CallableStatement stmt)`
`InvokeActivityStat`	`activityStatOf(Connection conn)`
`InvokeActivityStat`	`activityStatOf(PreparedStatement stmt)`
`InvokeActivityStat`	`activityStatOf(Statement stmt)`
`void`	`addDataEvent(DataEvent ev)`
`Closeable`	`addDataEventListener(DataEventListener ls)`
`Closeable`	`addDataEventListener(DataEventListener ls, boolean weak)`
`void`	`closeAll()` Закрывает все объекты: statements, connections.
`void`	`closeAllConnections(boolean addEvents)` Закрытие всех соединений с СУБД
`void`	`closeAllStatements(boolean addEvents)` Закрытие всех запросов.
`Connection`	`connect(String source)`
`Connection`	`connect(String source, String username, String password)`
`long`	`createTimeOf(Connection conn)`
`protected void`	`finalize()`
`void`	`fireDataEvent(DataEvent event)`
`void`	`fireEventQueue()`
`Set<Connection>`	`getConnections()` Возвращает соединения с СУБД.
`Set<Connection>`	`getConnections(boolean autoCreateProxy)` Возвращает соединения с СУБД
`Map<DataSource,Set<Connection>>`	`getConnectionsMap()` Возвращает карту источников данныи и их соединений.
`Map<DataSource,Set<Connection>>`	`getConnectionsMap(boolean autoCreateProxy)` Возвращает карту источников данныи и их соединений
`DataEventListener[]`	`getDataEventListeners()`
`ConnectOptions`	`getDefaultOptions()`
`int`	`getId()`
`WeakHashMap<Object,InvokeActivityStat>`	`getInvokeStats()`
`Set<Connection>`	`getOpenConnections(boolean autoCreateProxy)` Возвращает открытиые соединения с СУБД
`int`	`getOpenConnectionsCount()` Возвращает кол-во открытых соединений
`EventList<ConnectionPoolService>`	`getServices()` Возвращает список сервисов (расширений) пула
`Set<Connection>`	`getSourceConnections()` Возвращает соединения с СУБД.
`Map<DataSource,Set<Connection>>`	`getSourceConnectionsMap()` Возвращает карту источников данныи и их соединений.
`EventMap<String,DataSource>`	`getSources()` Возвращает карту именнованных источников данных
`Set<Statement>`	`getStatements(boolean autoCreateProxy)`
`Map<Connection,Set<Statement>>`	`getStatementsMap(boolean autoCreateProxy)`
`Timer`	`getTimer()` Возвращает таймер обслуживающий задачи утилизации
`int`	`getTotalConnectionsCount()` Возвращает общее кол-во соединений с СУБД
`boolean`	`hasDataEventListener(DataEventListener ls)`
`boolean`	`isProxy(Object conn)`
`boolean`	`isSkipRegistered()`
`String`	`nameOf(Connection conn)` Возвращает имя под которым зарегистрированно соединение с СУБД
`String`	`nameOf(DataSource ds)` Возвращает имя под которым зарегистрированн источник данных
`Set<String>`	`namesOf(Connection conn)` Возвращает имя под которым зарегистрированно соединение с СУБД
`Set<String>`	`namesOf(DataSource ds)` Возвращает имя под которым зарегистрированн источник данных
`ConnectOptions`	`optionsOf(Connection conn)`
`ConnectOptions`	`optionsOf(DataSource ds)`
`ConnectOptions`	`optionsOf(Statement st)`
`CallableStatement`	`proxy(Connection conn, CallableStatement st)`
`Connection`	`proxy(Connection conn, ConnectOptions copts)`
`PreparedStatement`	`proxy(Connection conn, PreparedStatement st)`
`Statement`	`proxy(Connection conn, Statement st)`
`Statement`	`proxy(Connection conn, Statement st, ConnectOptions copts)`
`Statement`	`proxy(Method meth, Connection conn, Statement st)`
`GenericProxy.Builder`	`proxyBuilder(Method meth, Statement st)`
`GenericProxy.Builder`	`proxyBuilder(Statement st)`
`void`	`registerSource(String name, DataSource ds)` Регистрирует источник данных
`void`	`registerSource(String name, DataSource ds, ConnectOptions copt)` Регистрирует источник данных.
`void`	`registerStatement(Connection conn, Statement st)`
`void`	`removeClosedConnections()`
`void`	`removeClosedConnections(boolean addEvents)`
`void`	`removeClosedStatements()`
`void`	`removeClosedStatements(boolean addEvents)`
`void`	`removeDataEventListener(DataEventListener ls)`
`void`	`setSkipRegistered(boolean skipRegistered)`
`void`	`shutdown()`
`void`	`shutdown(boolean addEvents)` Закрытие всех запросов, соединений и остановка фоновых заданий.
`CallableStatement`	`sourceOf(CallableStatement conn)`
`<T> T`	`sourceOf(Class<? extends T> cls, T obj)`
`Connection`	`sourceOf(Connection conn)`
`PreparedStatement`	`sourceOf(PreparedStatement conn)`
`Statement`	`sourceOf(Statement conn)`

Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - eventSupport
```
protected final transient DataEventSupport eventSupport
```
  - eventQueue
```
protected final transient LinkedBlockingQueue<DataEvent> eventQueue
```
  - services
```
protected final EventList<ConnectionPoolService> services
```
  - statements
```
protected final WeakHashMap<Statement,Connection> statements
```
  - statementCreateTime
```
protected final WeakHashMap<Statement,Long> statementCreateTime
```
  - options
```
protected WeakHashMap<DataSource,ConnectOptions> options
```
- Constructor Detail
  - ConnectPool
```
public ConnectPool()
```
  - ConnectPool
```
public ConnectPool(ConnectionPoolService... services)
```
- Method Detail
  - addDataEventListener
```
public Closeable addDataEventListener(DataEventListener ls,
                                      boolean weak)
```
  - addDataEventListener
```
public Closeable addDataEventListener(DataEventListener ls)
```
  - removeDataEventListener
```
public void removeDataEventListener(DataEventListener ls)
```
  - hasDataEventListener
```
public boolean hasDataEventListener(DataEventListener ls)
```
  - getDataEventListeners
```
public DataEventListener[] getDataEventListeners()
```
  - fireDataEvent
```
public void fireDataEvent(DataEvent event)
```
  - addDataEvent
```
public void addDataEvent(DataEvent ev)
```
  - fireEventQueue
```
public void fireEventQueue()
```
  - getId
```
public int getId()
```
  - getServices
```
public EventList<ConnectionPoolService> getServices()
```
    Возвращает список сервисов (расширений) пула
    
    Returns:
    
    список сервисов
  - getTimer
```
public Timer getTimer()
```
    Возвращает таймер обслуживающий задачи утилизации
    
    Returns:
    
    таймер
  - finalize
```
protected void finalize()
                 throws Throwable
```
    Overrides:
    
    finalize in class Object
    
    Throws:
    
    Throwable
  - closeAll
```
public void closeAll()
```
    Закрывает все объекты: statements, connections. Генерирует соответ сообщения.
  - closeAllStatements
```
public void closeAllStatements(boolean addEvents)
```
    Закрытие всех запросов.
    
    Parameters:
    
    addEvents - true - Добавить сообщения в очередь.
  - closeAllConnections
```
public void closeAllConnections(boolean addEvents)
```
    Закрытие всех соединений с СУБД
    
    Parameters:
    
    addEvents - true - Добавить сообщения в очередь.
  - shutdown
```
public void shutdown()
```
  - shutdown
```
public void shutdown(boolean addEvents)
```
    Закрытие всех запросов, соединений и остановка фоновых заданий.
    
    Parameters:
    
    addEvents - true - Добавить сообщения в очередь.
  - getSources
```
public EventMap<String,DataSource> getSources()
```
    Возвращает карту именнованных источников данных
    
    Returns:
    
    источники данных
  - isSkipRegistered
```
public boolean isSkipRegistered()
```
  - setSkipRegistered
```
public void setSkipRegistered(boolean skipRegistered)
```
  - registerSource
```
public void registerSource(String name,
                           DataSource ds)
```
    Регистрирует источник данных
    
    Parameters:
    
    name - Имя истоничка
    
    ds - Источник данных
    
    See Also:
    
    registerSource(java.lang.String, javax.sql.DataSource, xyz.cofe.sql.ConnectOptions)
  - registerSource
```
public void registerSource(String name,
                           DataSource ds,
                           ConnectOptions copt)
```
    Регистрирует источник данных.
    Если источник уже зарегистрирован и свойство skipRegistered = true, то новых источник не регистрируется.
    Если skipRegistered = false, то источник данных регистриуется (перетерая ранее зарегистрированный одноименный, если есть)
    
    Parameters:
    
    name - Имя истоничка
    
    ds - Источник данных
    
    copt - Опции соединения или null
  - namesOf
```
public Set<String> namesOf(DataSource ds)
```
    Возвращает имя под которым зарегистрированн источник данных
    
    Parameters:
    
    ds - источник данных
    
    Returns:
    
    имена под которым зарегистрирован источник данных
  - nameOf
```
public String nameOf(DataSource ds)
```
    Возвращает имя под которым зарегистрированн источник данных
    
    Parameters:
    
    ds - источник данных
    
    Returns:
    
    имя или null
  - namesOf
```
public Set<String> namesOf(Connection conn)
```
    Возвращает имя под которым зарегистрированно соединение с СУБД
    
    Parameters:
    
    conn - соединение с СУБД
    
    Returns:
    
    Имена под каторым зарегистрировано соединение
  - nameOf
```
public String nameOf(Connection conn)
```
    Возвращает имя под которым зарегистрированно соединение с СУБД
    
    Parameters:
    
    conn - соединение с СУБД
    
    Returns:
    
    Имя соединения или null
  - getConnections
```
public Set<Connection> getConnections(boolean autoCreateProxy)
```
    Возвращает соединения с СУБД
    
    Parameters:
    
    autoCreateProxy - true - Автоматически создавать PROXY объект
    
    Returns:
    
    Соединения с СУБД
  - getSourceConnections
```
public Set<Connection> getSourceConnections()
```
    Возвращает соединения с СУБД.
    Аналогично: getConnections(false)
    
    Returns:
    
    соединения с СУБД
  - getConnections
```
public Set<Connection> getConnections()
```
    Возвращает соединения с СУБД.
    Аналогично: getConnections(true)
    
    Returns:
    
    соединения с СУБД
  - getConnectionsMap
```
public Map<DataSource,Set<Connection>> getConnectionsMap(boolean autoCreateProxy)
```
    Возвращает карту источников данныи и их соединений
    
    Parameters:
    
    autoCreateProxy - true - Автоматически создавать PROXY для соединений
    
    Returns:
    
    Карта Источник данных => Соединения созданные этим источником данных
  - getSourceConnectionsMap
```
public Map<DataSource,Set<Connection>> getSourceConnectionsMap()
```
    Возвращает карту источников данныи и их соединений.
    Аналогично: getConnectionsMap(false)
    
    Returns:
    
    Карта Источник данных => Соединения созданные этим источником данных
  - getConnectionsMap
```
public Map<DataSource,Set<Connection>> getConnectionsMap()
```
    Возвращает карту источников данныи и их соединений.
    Аналогично: getConnectionsMap(true)
    
    Returns:
    
    Карта Источник данных => Соединения созданные этим источником данных
  - getTotalConnectionsCount
```
public int getTotalConnectionsCount()
```
    Возвращает общее кол-во соединений с СУБД
    
    Returns:
    
    Кол-во соединений с СУБД
  - getOpenConnections
```
public Set<Connection> getOpenConnections(boolean autoCreateProxy)
```
    Возвращает открытиые соединения с СУБД
    
    Parameters:
    
    autoCreateProxy - true - автоматически создавать PROXY
    
    Returns:
    
    Открытые соединения с СУБД
  - getOpenConnectionsCount
```
public int getOpenConnectionsCount()
```
    Возвращает кол-во открытых соединений
    
    Returns:
    
    кол-во открытых соединений
  - proxyBuilder
```
public GenericProxy.Builder proxyBuilder(Method meth,
                                         Statement st)
```
  - proxyBuilder
```
public GenericProxy.Builder proxyBuilder(Statement st)
```
  - proxy
```
public Statement proxy(Method meth,
                       Connection conn,
                       Statement st)
```
  - proxy
```
public Statement proxy(Connection conn,
                       Statement st)
```
  - proxy
```
public PreparedStatement proxy(Connection conn,
                               PreparedStatement st)
```
  - proxy
```
public CallableStatement proxy(Connection conn,
                               CallableStatement st)
```
  - getStatements
```
public Set<Statement> getStatements(boolean autoCreateProxy)
```
  - getStatementsMap
```
public Map<Connection,Set<Statement>> getStatementsMap(boolean autoCreateProxy)
```
  - registerStatement
```
public void registerStatement(Connection conn,
                              Statement st)
```
  - createTimeOf
```
public long createTimeOf(Connection conn)
```
  - getDefaultOptions
```
public ConnectOptions getDefaultOptions()
```
  - getInvokeStats
```
public WeakHashMap<Object,InvokeActivityStat> getInvokeStats()
```
  - activityStatOf
```
public InvokeActivityStat activityStatOf(Connection conn)
```
  - activityStatOf
```
public InvokeActivityStat activityStatOf(Statement stmt)
```
  - activityStatOf
```
public InvokeActivityStat activityStatOf(PreparedStatement stmt)
```
  - activityStatOf
```
public InvokeActivityStat activityStatOf(CallableStatement stmt)
```
  - optionsOf
```
public ConnectOptions optionsOf(DataSource ds)
```
  - optionsOf
```
public ConnectOptions optionsOf(Connection conn)
```
  - optionsOf
```
public ConnectOptions optionsOf(Statement st)
```
  - sourceOf
```
public Connection sourceOf(Connection conn)
```
  - sourceOf
```
public CallableStatement sourceOf(CallableStatement conn)
```
  - sourceOf
```
public Statement sourceOf(Statement conn)
```
  - sourceOf
```
public PreparedStatement sourceOf(PreparedStatement conn)
```
  - sourceOf
```
public <T> T sourceOf(Class<? extends T> cls,
                      T obj)
```
  - isProxy
```
public boolean isProxy(Object conn)
```
  - proxy
```
public Statement proxy(Connection conn,
                       Statement st,
                       ConnectOptions copts)
```
  - proxy
```
public Connection proxy(Connection conn,
                        ConnectOptions copts)
```
  - connect
```
public Connection connect(String source)
                   throws SQLException
```
    Throws:
    
    SQLException
  - connect
```
public Connection connect(String source,
                          String username,
                          String password)
                   throws SQLException
```
    Throws:
    
    SQLException
  - removeClosedConnections
```
public void removeClosedConnections()
```
  - removeClosedConnections
```
public void removeClosedConnections(boolean addEvents)
```
  - removeClosedStatements
```
public void removeClosedStatements()
```
  - removeClosedStatements
```
public void removeClosedStatements(boolean addEvents)
```

Class ConnectPool

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

eventSupport

eventQueue

services

statements

statementCreateTime

options

Constructor Detail

ConnectPool

ConnectPool

Method Detail

addDataEventListener

addDataEventListener

removeDataEventListener

hasDataEventListener

getDataEventListeners

fireDataEvent

addDataEvent

fireEventQueue

getId

getServices

getTimer

finalize

closeAll

closeAllStatements

closeAllConnections

shutdown

shutdown

getSources

isSkipRegistered

setSkipRegistered

registerSource

registerSource

namesOf

nameOf

namesOf

nameOf

getConnections

getSourceConnections

getConnections

getConnectionsMap

getSourceConnectionsMap

getConnectionsMap

getTotalConnectionsCount

getOpenConnections

getOpenConnectionsCount

proxyBuilder

proxyBuilder

proxy

proxy

proxy

proxy

getStatements

getStatementsMap

registerStatement

createTimeOf

getDefaultOptions

getInvokeStats

activityStatOf

activityStatOf

activityStatOf

activityStatOf

optionsOf

optionsOf

optionsOf

sourceOf

sourceOf

sourceOf

sourceOf

sourceOf

isProxy

proxy

proxy

connect

connect