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

BulkUpdateExecutor(StatementFactory statementFactory)

Method Summary

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