pe.pase

Class SessionConnection

java.lang.Object

pe.pase.SessionConnection

All Implemented Interfaces:

java.io.Serializable

public class SessionConnection
extends java.lang.Object
implements java.io.Serializable

Session connection provides objects to access database.

Version:

1.1.5,

Author:

lchuang

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected DBService	dBService
protected java.lang.String	m_ip
protected java.lang.String	m_port
protected int	m_sequence
protected java.lang.String	m_session
protected java.lang.String	sdsName

Constructor Summary

Constructors

Constructor and Description
SessionConnection(DBService service, java.lang.String session, int sequence) Constructor.
SessionConnection(DBService service, java.lang.String session, int sequence, java.lang.String name) Constructor.
SessionConnection(DBService service, java.lang.String ip, java.lang.String port, java.lang.String session, int sequence)
SessionConnection(DBService service, java.lang.String ip, java.lang.String port, java.lang.String session, int sequence, java.lang.String name)

Method Summary

Modifier and Type	Method and Description
void	close() Close the connection
void	commit() Make commit on the connection
java.util.Map	executeStoredProcedure(java.lang.String storedProcedureName, java.util.List<java.util.Map<java.lang.String,java.lang.Object>> params, java.lang.String returnType)
java.util.HashMap	getConfig() Get the configuration of SessionConnection
java.lang.String	getIp()
java.lang.String	getPort()
int	getSequence()
java.lang.String	getSessionId()
java.util.Vector	loadValue(java.lang.String sqlcmd) Invoke the connection to load value.
java.util.Vector	loadValue(java.lang.String sqlcmd, java.lang.Object[] args) Invoke the connection to load value with java.sql.PreparedStatement.
void	rollback() Make rollback on the connection
void	setDBService(DBService dBService)
java.lang.String	toString()
boolean	updateValue(java.lang.String sqlcmd) Invoke the connection to update value.
boolean	updateValue(java.lang.String sqlcmd, java.lang.Object[] args) Invoke the connection to update value with java.sql.PreparedStatement.

Methods inherited from class java.lang.Object

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

Field Detail

dBService

protected transient DBService dBService

m_session

protected java.lang.String m_session

m_sequence

protected int m_sequence

m_ip

protected java.lang.String m_ip

m_port

protected java.lang.String m_port

sdsName

protected java.lang.String sdsName

Constructor Detail

SessionConnection

public SessionConnection(DBService service,
                         java.lang.String session,
                         int sequence)

Constructor. Construct a instance of SessionConnection with the specified parameters.

Parameters:

service - the given remote DBService

session - the given session key

sequence - the given data source sequence

Since:

version 1.1.0

SessionConnection

public SessionConnection(DBService service,
                         java.lang.String ip,
                         java.lang.String port,
                         java.lang.String session,
                         int sequence)

SessionConnection

public SessionConnection(DBService service,
                         java.lang.String session,
                         int sequence,
                         java.lang.String name)

Constructor. Construct a instance of SessionConnection with the specified parameters.

Parameters:

service - the given remote DBService

session - the given session key

sequence - the given data source sequence

name - the given SessionDataSource name

Since:

version 1.1.0

SessionConnection

public SessionConnection(DBService service,
                         java.lang.String ip,
                         java.lang.String port,
                         java.lang.String session,
                         int sequence,
                         java.lang.String name)

Method Detail

close

public void close()
           throws java.lang.Exception

Close the connection

Throws:

java.lang.Exception - exception occurs if server can not close session connection

Since:

version 1.1.0

loadValue

public java.util.Vector loadValue(java.lang.String sqlcmd)
                           throws java.lang.Exception

Invoke the connection to load value.

Notes: In Agentflow 4.0, server.properties add a LoadValueExceptionCauseTaskRollback attribute to control rollback when loadValue has failure. Default value is true. When value is true and loadValue has failure, it would cause a task rollback (ex. fail to start a process), even if the script uses try...catch to deal with this error or add the connection to Transaction Manager, it still follows this rule. When value is false and loadValue has failure, it would not cause a task rollback.

Parameters:

sqlcmd - the given sql command

Returns:

the result (element in the Vector is instance of ResultTable)

Throws:

java.lang.Exception - exception occurs if the server can not load value with session connection

Since:

version 1.1.0

See Also:

ResultTable

loadValue

public java.util.Vector loadValue(java.lang.String sqlcmd,
                                  java.lang.Object[] args)
                           throws java.lang.Exception

Invoke the connection to load value with java.sql.PreparedStatement.

Parameters:

sqlcmd - the given sql command

args - args array with values to pass to the sql

Returns:

the result (element in the Vector is instance of ResultTable)

Throws:

java.lang.Exception - exception occurs if the server can not load value with session connection

Since:

version 4.0

See Also:

ResultTable

updateValue

public boolean updateValue(java.lang.String sqlcmd)
                    throws java.lang.Exception

Invoke the connection to update value.

Notes: In Agentflow 4.0, when updateValue has failure, it would not cause a task rollback.

Parameters:

sqlcmd - the given sql command

Returns:

true if the update is success; false otherwise

Throws:

java.lang.Exception - exception occurs if the server can not update value with session connection

Since:

version 1.1.0

updateValue

public boolean updateValue(java.lang.String sqlcmd,
                           java.lang.Object[] args)
                    throws java.lang.Exception

Invoke the connection to update value with java.sql.PreparedStatement.

Parameters:

sqlcmd - the given sql command

args - args array with values to pass to the sql

Returns:

true if the update is success; false otherwise

Throws:

java.lang.Exception - exception occurs if the server can not update value with session connection

Since:

version 4.0

commit

public void commit()
            throws java.lang.Exception

Make commit on the connection

Throws:

java.lang.Exception

Since:

version 1.1.0

rollback

public void rollback()

Make rollback on the connection

Since:

version 1.1.0

getConfig

public java.util.HashMap getConfig()
                            throws java.lang.Exception

Get the configuration of SessionConnection

Throws:

java.lang.Exception - exception occurs if the server can not get the config of the session connection

Since:

version 1.1.5

getSessionId

public java.lang.String getSessionId()

Returns:

the m_session.

getSequence

public int getSequence()

Returns:

the m_sequence

getIp

public java.lang.String getIp()

getPort

public java.lang.String getPort()

setDBService

public void setDBService(DBService dBService)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

executeStoredProcedure

public java.util.Map executeStoredProcedure(java.lang.String storedProcedureName,
                                            java.util.List<java.util.Map<java.lang.String,java.lang.Object>> params,
                                            java.lang.String returnType)
                                     throws java.lang.Exception

Throws:

java.lang.Exception