org.mule.module.db.internal.domain.executor

Class BulkUpdateExecutor

java.lang.Object

org.mule.module.db.internal.domain.executor.AbstractExecutor

org.mule.module.db.internal.domain.executor.BulkUpdateExecutor

All Implemented Interfaces:

BulkExecutor

public class BulkUpdateExecutor
extends AbstractExecutor
implements BulkExecutor

Executes bulk queries

Field Summary

Fields inherited from class org.mule.module.db.internal.domain.executor.AbstractExecutor

logger, queryLoggerFactory, statementFactory

Constructor Summary

Constructors

Constructor and Description
BulkUpdateExecutor(StatementFactory statementFactory)

Method Summary

Methods

Modifier and Type	Method and Description
Object	execute(DbConnection connection, BulkQuery bulkQuery) Executes a bulk query
Object	execute(DbConnection connection, Query query, List<List<QueryParamValue>> paramValues) Executes a parameterized query using a bulk of parameter sets

Methods inherited from class org.mule.module.db.internal.domain.executor.AbstractExecutor

doProcessParameters, processInputParam, setQueryLoggerFactory

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkUpdateExecutor

public BulkUpdateExecutor(StatementFactory statementFactory)

Method Detail

execute

public Object execute(DbConnection connection,
             BulkQuery bulkQuery)
               throws SQLException

Description copied from interface: BulkExecutor

Executes a bulk query

Specified by:

execute in interface BulkExecutor

Parameters:

connection - connection to the database where the query will be executed. Non null

bulkQuery - contains a group of non parameterized queries to execute

Returns:

a non null result of the query execution

Throws:

SQLException - if a database access error occurs or this method is called on a closed connection

execute

public Object execute(DbConnection connection,
             Query query,
             List<List<QueryParamValue>> paramValues)
               throws SQLException

Description copied from interface: BulkExecutor

Executes a parameterized query using a bulk of parameter sets

Specified by:

execute in interface BulkExecutor

Parameters:

connection - connection to the database where the query will be executed. Non null

query - parameterized query to executed using the sets of parameters

paramValues - parameters to use to execute the query

Returns:

a non null result of the query execution

Throws:

SQLException - if a database access error occurs or this method is called on a closed connection