org.waarp.common.database

Class DbSession

java.lang.Object

org.waarp.common.database.DbSession

public class DbSession
extends Object

Class to handle session with the SGBD

Constructor Summary

Constructors

Constructor and Description
DbSession(DbAdmin admin, boolean isReadOnly) Create a session and connect the current object to the server using the DbAdmin object.
DbSession(DbAdmin admin, boolean isReadOnly, boolean autoCommit) Create a session and connect the current object to the server using the DbAdmin object.

Method Summary

Modifier and Type	Method and Description
void	addLongTermPreparedStatement(DbPreparedStatement longterm) Add a Long Term PreparedStatement
void	checkConnection() Check the connection to the Database and try to reopen it if possible
boolean	checkConnectionNoException()
void	commit() Commit everything
void	disconnect() Close the connection
void	endUseConnection() To be called when a client will stop to use this DbSession (once by client)
void	enUseConnectionNoDisconnect() To be called when a client will stop to use this DbSession (once by client).
boolean	equals(Object o)
void	forceDisconnect() Force the close of the connection
DbAdmin	getAdmin()
Connection	getConn()
GUID	getInternalId()
int	hashCode()
boolean	isAutoCommit()
boolean	isDisActive()
boolean	isReadOnly()
void	recreateLongTermPreparedStatements() Due to a reconnection, recreate all associated long term PreparedStatements
void	releaseSavepoint(Savepoint savepoint) Release the savepoint
void	removeLongTermPreparedStatements() Remove all Long Term PreparedStatements (closing connection)
void	removeLongTermPreparedStatements(DbPreparedStatement longterm) Remove one Long Term PreparedStatement
void	rollback(Savepoint savepoint) Rollback from the savepoint or the last set if null
Savepoint	savepoint() Make a savepoint
protected void	setAdmin(DbAdmin admin)
void	setAutoCommit(boolean autoCommit) Change the autocommit feature
void	setConn(Connection conn)
void	setDisActive(boolean isDisActive)
void	setReadOnly(boolean isReadOnly)
void	useConnection() To be called when a client will start to use this DbSession (once by client)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DbSession

public DbSession(DbAdmin admin,
                 boolean isReadOnly)
          throws WaarpDatabaseNoConnectionException

Create a session and connect the current object to the server using the DbAdmin object. The database access use auto commit.

If the initialize is not call before, call it with the default value.

Parameters:

admin -

isReadOnly -

Throws:

WaarpDatabaseSqlException

WaarpDatabaseNoConnectionException

DbSession

public DbSession(DbAdmin admin,
                 boolean isReadOnly,
                 boolean autoCommit)
          throws WaarpDatabaseNoConnectionException

Create a session and connect the current object to the server using the DbAdmin object.

If the initialize is not call before, call it with the default value.

Parameters:

admin -

isReadOnly -

autoCommit -

Throws:

WaarpDatabaseSqlException

WaarpDatabaseNoConnectionException

Method Detail

setAutoCommit

public final void setAutoCommit(boolean autoCommit)
                         throws WaarpDatabaseNoConnectionException

Change the autocommit feature

Parameters:

autoCommit -

Throws:

WaarpDatabaseNoConnectionException

getAdmin

public final DbAdmin getAdmin()

Returns:

the admin

setAdmin

protected final void setAdmin(DbAdmin admin)

Parameters:

admin - the admin to set

useConnection

public final void useConnection()

To be called when a client will start to use this DbSession (once by client)

endUseConnection

public final void endUseConnection()

To be called when a client will stop to use this DbSession (once by client)

enUseConnectionNoDisconnect

public final void enUseConnectionNoDisconnect()

To be called when a client will stop to use this DbSession (once by client). This version is not blocking.

hashCode

public final int hashCode()

Overrides:

hashCode in class Object

equals

public final boolean equals(Object o)

Overrides:

equals in class Object

forceDisconnect

public final void forceDisconnect()

Force the close of the connection

disconnect

public final void disconnect()

Close the connection

checkConnection

public final void checkConnection()
                           throws WaarpDatabaseNoConnectionException

Check the connection to the Database and try to reopen it if possible

Throws:

WaarpDatabaseNoConnectionException

checkConnectionNoException

public final boolean checkConnectionNoException()

Returns:

True if the connection was successfully reconnected

addLongTermPreparedStatement

public final void addLongTermPreparedStatement(DbPreparedStatement longterm)

Add a Long Term PreparedStatement

Parameters:

longterm -

recreateLongTermPreparedStatements

public final void recreateLongTermPreparedStatements()
                                              throws WaarpDatabaseNoConnectionException,
                                                     WaarpDatabaseSqlException

Due to a reconnection, recreate all associated long term PreparedStatements

Throws:

WaarpDatabaseNoConnectionException

WaarpDatabaseSqlException

removeLongTermPreparedStatements

public final void removeLongTermPreparedStatements()

Remove all Long Term PreparedStatements (closing connection)

removeLongTermPreparedStatements

public final void removeLongTermPreparedStatements(DbPreparedStatement longterm)

Remove one Long Term PreparedStatement

Parameters:

longterm -

commit

public final void commit()
                  throws WaarpDatabaseSqlException,
                         WaarpDatabaseNoConnectionException

Commit everything

Throws:

WaarpDatabaseSqlException

WaarpDatabaseNoConnectionException

rollback

public final void rollback(Savepoint savepoint)
                    throws WaarpDatabaseNoConnectionException,
                           WaarpDatabaseSqlException

Rollback from the savepoint or the last set if null

Parameters:

savepoint -

Throws:

WaarpDatabaseNoConnectionException

WaarpDatabaseSqlException

savepoint

public final Savepoint savepoint()
                          throws WaarpDatabaseNoConnectionException,
                                 WaarpDatabaseSqlException

Make a savepoint

Returns:

the new savepoint

Throws:

WaarpDatabaseNoConnectionException

WaarpDatabaseSqlException

releaseSavepoint

public final void releaseSavepoint(Savepoint savepoint)
                            throws WaarpDatabaseNoConnectionException,
                                   WaarpDatabaseSqlException

Release the savepoint

Parameters:

savepoint -

Throws:

WaarpDatabaseNoConnectionException

WaarpDatabaseSqlException

isReadOnly

public final boolean isReadOnly()

Returns:

the isReadOnly

setReadOnly

public final void setReadOnly(boolean isReadOnly)

Parameters:

isReadOnly - the isReadOnly to set

isAutoCommit

public final boolean isAutoCommit()

Returns:

the autoCommit

getConn

public final Connection getConn()

Returns:

the conn

setConn

public final void setConn(Connection conn)

Parameters:

conn - the conn to set

getInternalId

public final GUID getInternalId()

Returns:

the internalId

isDisActive

public final boolean isDisActive()

Returns:

the isDisActive

setDisActive

public final void setDisActive(boolean isDisActive)

Parameters:

isDisActive - the isDisActive to set