com.toolsverse.etl.sql.service

Class SqlServiceImpl

Object

com.toolsverse.etl.sql.service.SqlServiceImpl

All Implemented Interfaces:

SqlService, Loggable, Service, Serializable

public class SqlServiceImpl
extends Object
implements SqlService

The default implementation for the SqlService interface.

Since:

1.0

Version:

2.0

See Also:

Serialized Form

Field Summary

Fields inherited from interface com.toolsverse.etl.sql.service.SqlService

DB_LOG_TYPE, DELETE_TYPE, DML_TYPE, EXCEPTION_TYPE, EXECUTE_SCRIPT_TYPE, EXECUTE_TYPE, EXPLAIN_PLAN_TYPE, INSERT_TYPE, MERGE_TYPE, NOTHING_TYPE, OUTPUT_PARAM_TYPE, SELECT_TYPE, UPDATE_TYPE

Constructor Summary

Constructors

Constructor and Description
SqlServiceImpl()

Method Summary

Modifier and Type	Method and Description
void	cancel(SessionConnectionProvider<Alias> provider) Cancels currently executed sql.
void	clear() Sets current statement, external process, and result set to null.
void	commitTransaction(SessionConnectionProvider<Alias> provider, Alias params, boolean closeOnCommit) Commits current transaction.
SqlResult	executeAutotrace(SqlRequest sqlRequest) Executes autotrace
SqlResult	executeExplainPlan(SqlRequest sqlRequest) Executes explain plan if supported by driver passed in the sql request.
SqlResult	executeExternal(SqlRequest sqlRequest) Executes sql using external tool if supported by driver passed in the sql request.
SqlResult	executeScript(SqlRequest sqlRequest) Executes sql script, for example anonymous sql block if supported by driver passed in the sql request.
SqlResult	executeSql(SqlRequest sqlRequest) Executes sql.
LogNode	getLogNode(String m, Object ret, Object[] args, Throwable ex) Gets the log node.
Map<String,FieldDef>	getMetaData(SqlRequest sqlRequest) Gets the meta data for the database object (table, view or synonym).
String	getPropertyName() Get the configuration property name used to enable\disable logging for the service.
boolean	isLogByDefault() Checks if service call should be logged by default.
void	releaseConnection(SessionConnectionProvider<Alias> provider, Alias params) Releases connection.
void	rollbackTransaction(SessionConnectionProvider<Alias> provider, Alias params, boolean closeOnRollback) Rollbacks current transaction.

Methods inherited from class Object

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

Constructor Detail

SqlServiceImpl

public SqlServiceImpl()

Method Detail

cancel

public void cancel(SessionConnectionProvider<Alias> provider)

Description copied from interface: SqlService

Cancels currently executed sql. Must be supported by jdbc driver.

Specified by:

cancel in interface SqlService

Parameters:

provider - the connection provider

clear

public void clear()

Sets current statement, external process, and result set to null.

commitTransaction

public void commitTransaction(SessionConnectionProvider<Alias> provider,
                              Alias params,
                              boolean closeOnCommit)
                       throws Exception

Description copied from interface: SqlService

Commits current transaction.

Specified by:

commitTransaction in interface SqlService

Parameters:

provider - the connection provider

params - the alis

closeOnCommit - the close on commit flag. If set the connection will be released on commit

Throws:

Exception - the exception

executeAutotrace

public SqlResult executeAutotrace(SqlRequest sqlRequest)
                           throws Exception

Description copied from interface: SqlService

Executes autotrace

Specified by:

executeAutotrace in interface SqlService

Parameters:

sqlRequest - the sql request

Returns:

the sql result

Throws:

Exception - in case of any error

executeExplainPlan

public SqlResult executeExplainPlan(SqlRequest sqlRequest)
                             throws Exception

Description copied from interface: SqlService

Executes explain plan if supported by driver passed in the sql request.

Specified by:

executeExplainPlan in interface SqlService

Parameters:

sqlRequest - the sql request

Returns:

the sql result

Throws:

Exception - in case of any error

executeExternal

public SqlResult executeExternal(SqlRequest sqlRequest)
                          throws Exception

Description copied from interface: SqlService

Executes sql using external tool if supported by driver passed in the sql request.

Specified by:

executeExternal in interface SqlService

Parameters:

sqlRequest - the sql request

Returns:

the sql result

Throws:

Exception - in case of any error

executeScript

public SqlResult executeScript(SqlRequest sqlRequest)
                        throws Exception

Description copied from interface: SqlService

Executes sql script, for example anonymous sql block if supported by driver passed in the sql request.

Specified by:

executeScript in interface SqlService

Parameters:

sqlRequest - the sql request

Returns:

the sql result

Throws:

Exception - in case of any error

executeSql

public SqlResult executeSql(SqlRequest sqlRequest)
                     throws Exception

Description copied from interface: SqlService

Executes sql.

Specified by:

executeSql in interface SqlService

Parameters:

sqlRequest - the sql request

Returns:

the sql result

Throws:

Exception - in case of any error

getLogNode

public LogNode getLogNode(String m,
                          Object ret,
                          Object[] args,
                          Throwable ex)

Description copied from interface: Loggable

Gets the log node.

Specified by:

getLogNode in interface Loggable

Parameters:

m - the method

ret - the return value

args - the input argument

ex - the exception

Returns:

the log node

getMetaData

public Map<String,FieldDef> getMetaData(SqlRequest sqlRequest)
                                 throws Exception

Description copied from interface: SqlService

Gets the meta data for the database object (table, view or synonym).

Specified by:

getMetaData in interface SqlService

Parameters:

sqlRequest - the sql request

Returns:

the meta data

Throws:

Exception - the exception

getPropertyName

public String getPropertyName()

Description copied from interface: Loggable

Get the configuration property name used to enable\disable logging for the service.

Specified by:

getPropertyName in interface Loggable

Returns:

the configuration property name

isLogByDefault

public boolean isLogByDefault()

Description copied from interface: Loggable

Checks if service call should be logged by default.

Specified by:

isLogByDefault in interface Loggable

Returns:

true, if service call should be logged by default

releaseConnection

public void releaseConnection(SessionConnectionProvider<Alias> provider,
                              Alias params)
                       throws Exception

Description copied from interface: SqlService

Releases connection.

Specified by:

releaseConnection in interface SqlService

Parameters:

provider - the connection provider

params - the alias

Throws:

Exception - in case of any error

rollbackTransaction

public void rollbackTransaction(SessionConnectionProvider<Alias> provider,
                                Alias params,
                                boolean closeOnRollback)
                         throws Exception

Description copied from interface: SqlService

Rollbacks current transaction.

Specified by:

rollbackTransaction in interface SqlService

Parameters:

provider - the connection provider

params - the alias

closeOnRollback - the close on rollback flag. If set the connection will be closed on rollback

Throws:

Exception - in case of any error