ra.db.connection

Class ConcurrentConnection

java.lang.Object

ra.db.connection.ConcurrentConnection

All Implemented Interfaces:

java.lang.AutoCloseable, DatabaseConnection, KeepAlive, KeepAvailable

public class ConcurrentConnection
extends java.lang.Object
implements KeepAvailable

Provide execute SQL statement using a keep database connection, and the connection is thread safe.

Author:

Ray Li

Nested Class Summary

Nested classes/interfaces inherited from interface ra.db.DatabaseConnection

DatabaseConnection.ConnectionFunction

Constructor Summary

Constructors

Constructor and Description
ConcurrentConnection(DatabaseParameters param) Initialize.

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	connect() Connect to database.
java.sql.Connection	getConnection() Get current database connection.
int	getConnection(DatabaseConnection.ConnectionFunction consumer) Get current database connection.
DatabaseParameters	getParam() Returns database properties settings.
boolean	isLive() Returns database state whether available.
void	keep() Trigger keep-alive event.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface ra.db.KeepAvailable

interval

Methods inherited from interface ra.db.DatabaseConnection

connectIf, createStatementExecutor, loadDriveInstance, tryGetConnection

Constructor Detail

ConcurrentConnection

public ConcurrentConnection(DatabaseParameters param)

Initialize.

Parameters:

param - database connection settings.

Method Detail

getParam

public DatabaseParameters getParam()

Description copied from interface: DatabaseConnection

Returns database properties settings.

Specified by:

getParam in interface DatabaseConnection

Returns:

DatabaseParameters

getConnection

public java.sql.Connection getConnection()

Description copied from interface: DatabaseConnection

Get current database connection.

Specified by:

getConnection in interface DatabaseConnection

Returns:

Database original connection.

getConnection

public int getConnection(DatabaseConnection.ConnectionFunction consumer)
                  throws RaSqlException,
                         RaConnectException

Description copied from interface: DatabaseConnection

Get current database connection.

Specified by:

getConnection in interface DatabaseConnection

Parameters:

consumer - consumer

Returns:

Database original connection.

Throws:

RaSqlException - RaSqlException

RaConnectException - if can't to connect database.

connect

public boolean connect()

Connect to database.

Specified by:

connect in interface DatabaseConnection

Returns:

If connect successful return true.

isLive

public boolean isLive()

Description copied from interface: DatabaseConnection

Returns database state whether available.

Specified by:

isLive in interface DatabaseConnection

Returns:

database state

keep

public void keep()

Description copied from interface: KeepAlive

Trigger keep-alive event.

Specified by:

keep in interface KeepAlive

close

public void close()
           throws RaSqlException

Specified by:

close in interface java.lang.AutoCloseable

Throws:

RaSqlException