ra.db

Class DatabaseConnections

java.lang.Object

ra.db.DatabaseConnections

public class DatabaseConnections
extends java.lang.Object

Provider multi connections to a single database, which connections are kept connected. Take connection is round-robin.

Author:

Ray Li

Constructor Summary

Constructors

Constructor and Description
DatabaseConnections() Create database connection.
DatabaseConnections(java.lang.String name) Create database connection.

Method Summary

Modifier and Type	Method and Description
void	close() Close all database connection.
void	connect(DatabaseParameters param, int count, java.util.concurrent.Callable<DatabaseConnection> connectionMode) Create Kept connections.
void	connectConcurrentConnection(DatabaseParameters param, int count) Create the Connect Object are kept connected.
void	connectOriginalConnection(DatabaseParameters param, int count) There is non lock when executes SQL, probable return error results when execute insert.
DatabaseConnection	getConnection(int index) Returns database connection.
java.lang.String	getName() Returns connection alias of database.
StatementExecutor	getStatementExecutor(int index) Returns SQL statement executer.
StatementExecutor	next() Take StatementExecutor by round-robin, It's practical when had multi connections.

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabaseConnections

public DatabaseConnections()

Create database connection.

DatabaseConnections

public DatabaseConnections(java.lang.String name)

Create database connection.

Parameters:

name - Connection alias.

Method Detail

getName

public java.lang.String getName()

Returns connection alias of database.

Returns:

name

connectConcurrentConnection

public void connectConcurrentConnection(DatabaseParameters param,
                                        int count)

Create the Connect Object are kept connected. Connect Object are Thread-safe.

Parameters:

param - The parameters of database connect setting.

count - Kept connections count by the same database.

connectOriginalConnection

public void connectOriginalConnection(DatabaseParameters param,
                                      int count)

There is non lock when executes SQL, probable return error results when execute insert.

Parameters:

param - The parameters of database connect setting.

count - Kept connections count by the same database.

connect

public void connect(DatabaseParameters param,
                    int count,
                    java.util.concurrent.Callable<DatabaseConnection> connectionMode)
             throws java.lang.Exception

Create Kept connections.

Parameters:

param - The parameters of database connect setting.

count - Kept connections count by the same database.

connectionMode - Need to be used database connect Object.

Throws:

java.lang.Exception - Throwable any exception, Throw the ConnectException when connect fail.

next

public StatementExecutor next()

Take StatementExecutor by round-robin, It's practical when had multi connections.

Returns:

StatementExecutor

getStatementExecutor

public StatementExecutor getStatementExecutor(int index)

Returns SQL statement executer.

Parameters:

index - index

Returns:

StatementExecutor

getConnection

public DatabaseConnection getConnection(int index)

Returns database connection.

Parameters:

index - index

Returns:

DatabaseConnection

close

public void close()

Close all database connection.