org.waarp.common.database

Class DbAdmin

java.lang.Object

org.waarp.common.database.DbAdmin

public class DbAdmin
extends Object

Class for access to Database

Author:

Frederic Bregier

Field Summary

Fields

Modifier and Type	Field and Description
protected static io.netty.util.Timer	dbSessionTimer
static int	RETRYNB
protected DbType	typeDriver Database type
static long	WAITFORNETOP

Constructor Summary

Constructors

Constructor and Description
DbAdmin() Empty constructor for no Database support (very thin client)
DbAdmin(DbModel model, String server, String user, String passwd) Use a default server for basic connection.
DbAdmin(DbModel model, String server, String user, String passwd, boolean write) Use a default server for basic connection.

Method Summary

Methods

Modifier and Type	Method and Description
static void	addConnection(UUID id, DbSession session) Add a Connection into the list
static void	checkAllConnections() Check all database connections and try to reopen them if disActive
void	close() Close the underlying session.
static void	closeAllConnection() Close all database connections
void	commit() Commit on connection (since in autocommit, should not be used)
static void	decHttpSession() Decrement nb of Http Connection
DbModel	getDbModel()
static int	getHttpSession()
static int	getNbConnection()
String	getPasswd()
String	getServer()
DbSession	getSession()
DbType	getTypeDriver()
String	getUser()
static void	incHttpSession() Increment nb of Http Connection
boolean	isActive()
boolean	isCompatibleWithThreadSharedConnexion()
boolean	isReadOnly()
static void	removeConnection(UUID id) Remove a Connection from the list
void	setActive(boolean isActive)
void	setSession(DbSession session)
String	toString()
void	validConnection() Validate connection

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

RETRYNB

public static int RETRYNB

WAITFORNETOP

public static long WAITFORNETOP

typeDriver

protected final DbType typeDriver

Database type

dbSessionTimer

protected static final io.netty.util.Timer dbSessionTimer

Constructor Detail

DbAdmin

public DbAdmin(DbModel model,
       String server,
       String user,
       String passwd)
        throws WaarpDatabaseNoConnectionException

Use a default server for basic connection. Later on, specific connection to database for the scheme that provides access to the table R66DbIndex for one specific Legacy could be done. A this time, only one driver is possible! If a new driver is needed, then we need to create a new DbSession object. Be aware that DbSession.initialize should be call only once for each driver, whatever the number of DbSession objects that could be created (=> need a hashtable for specific driver when created). Also, don't know if two drivers at the same time (two different DbSession) is allowed by JDBC.

Parameters:

model -

server -

user -

passwd -

Throws:

WaarpDatabaseNoConnectionException

DbAdmin

public DbAdmin(DbModel model,
       String server,
       String user,
       String passwd,
       boolean write)
        throws WaarpDatabaseNoConnectionException

Use a default server for basic connection. Later on, specific connection to database for the scheme that provides access to the table R66DbIndex for one specific Legacy could be done. A this time, only one driver is possible! If a new driver is needed, then we need to create a new DbSession object. Be aware that DbSession.initialize should be call only once for each driver, whatever the number of DbSession objects that could be created (=> need a hashtable for specific driver when created). Also, don't know if two drivers at the same time (two different DbSession) is allowed by JDBC.

Parameters:

model -

server -

user -

passwd -

write -

Throws:

WaarpDatabaseSqlException

WaarpDatabaseNoConnectionException

DbAdmin

public DbAdmin()

Empty constructor for no Database support (very thin client)

Method Detail

getSession

public DbSession getSession()

Returns:

the session

setSession

public void setSession(DbSession session)

Parameters:

session - the session to set

isReadOnly

public boolean isReadOnly()

Returns:

True if the connection is ReadOnly

isActive

public boolean isActive()

Returns:

the isActive

setActive

public void setActive(boolean isActive)

Parameters:

isActive - the isActive to set

validConnection

public void validConnection()
                     throws WaarpDatabaseNoConnectionException

Validate connection

Throws:

WaarpDatabaseNoConnectionException

close

public void close()

Close the underlying session. Can be call even for connection given from the constructor DbAdmin(Connection, boolean).

commit

public void commit()
            throws WaarpDatabaseSqlException,
                   WaarpDatabaseNoConnectionException

Commit on connection (since in autocommit, should not be used)

Throws:

WaarpDatabaseNoConnectionException

WaarpDatabaseSqlException

getServer

public String getServer()

Returns:

the server

getUser

public String getUser()

Returns:

the user

getPasswd

public String getPasswd()

Returns:

the passwd

getDbModel

public DbModel getDbModel()

Returns:

the associated dbModel

getTypeDriver

public DbType getTypeDriver()

Returns:

the typeDriver

toString

public String toString()

Overrides:

toString in class Object

incHttpSession

public static void incHttpSession()

Increment nb of Http Connection

decHttpSession

public static void decHttpSession()

Decrement nb of Http Connection

getHttpSession

public static int getHttpSession()

Returns:

the nb of Http Connection

addConnection

public static void addConnection(UUID id,
                 DbSession session)

Add a Connection into the list

Parameters:

id -

session -

removeConnection

public static void removeConnection(UUID id)

Remove a Connection from the list

Parameters:

id - Id of the connection

getNbConnection

public static int getNbConnection()

Returns:

the number of connection (so number of network channels)

closeAllConnection

public static void closeAllConnection()

Close all database connections

checkAllConnections

public static void checkAllConnections()

Check all database connections and try to reopen them if disActive

isCompatibleWithThreadSharedConnexion

public boolean isCompatibleWithThreadSharedConnexion()

Returns:

True if this driver allows Thread Shared Connexion (concurrency usage)