org.mule.extension.db.internal.operation

Class BulkOperations

java.lang.Object

org.mule.extension.db.internal.operation.BulkOperations

public class BulkOperations
extends Object

Contains a set of operations for performing bulk DML operations from a single statement.

Since:

4.0

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	DEFAULT_FETCH_SIZE
protected static String	QUERY_GROUP
protected static String	QUERY_SETTINGS
protected QueryResolver<ParameterizedStatementDefinition>	queryResolver

Constructor Summary

Constructors

Constructor and Description
BulkOperations()

Method Summary

Modifier and Type	Method and Description
int[]	bulkDelete(List<Map<String,Object>> parameterValues, BulkQueryDefinition query, DbConnector connector, DbConnection connection) Allows executing one delete statement various times using different parameter bindings.
int[]	bulkInsert(List<Map<String,Object>> parameterValues, BulkQueryDefinition query, DbConnector connector, DbConnection connection) Allows executing one insert statement various times using different parameter bindings.
int[]	bulkUpdate(List<Map<String,Object>> parameterValues, BulkQueryDefinition query, DbConnector connector, DbConnection connection) Allows executing one update statement various times using different parameter bindings.
int[]	executeScript(BulkScript script, QuerySettings settings, DbConnection connection) Executes a SQL script in one single Database statement.
protected StatementResult	executeUpdate(QueryDefinition query, AutoGenerateKeysAttributes autoGenerateKeysAttributes, DbConnection connection, Query resolvedQuery)
protected AutoGenerateKeysStrategy	getAutoGeneratedKeysStrategy(AutoGenerateKeysAttributes keyAttributes)
protected QueryStatementFactory	getStatementFactory(boolean streaming, QuerySettings settings)
protected Query	resolveQuery(QueryDefinition query, DbConnector connector, DbConnection connection, QueryType... validTypes)
protected void	validateNoParameterTypeIsUnused(Query query, List<ParameterType> parameterTypes)
protected void	validateQueryType(QueryTemplate queryTemplate, List<QueryType> validTypes)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_FETCH_SIZE

protected static final int DEFAULT_FETCH_SIZE

See Also:

Constant Field Values

QUERY_GROUP

protected static final String QUERY_GROUP

See Also:

Constant Field Values

QUERY_SETTINGS

protected static final String QUERY_SETTINGS

See Also:

Constant Field Values

queryResolver

protected final QueryResolver<ParameterizedStatementDefinition> queryResolver

Constructor Detail

BulkOperations

public BulkOperations()

Method Detail

bulkInsert

public int[] bulkInsert(@Content @Placement(order=1) @TypeResolver(value=DbBulkInputMetadataResolver.class)
                        List<Map<String,Object>> parameterValues,
                        @ParameterGroup(name="Query")
                        BulkQueryDefinition query,
                        @UseConfig
                        DbConnector connector,
                        @Connection
                        DbConnection connection)
                 throws SQLException

Allows executing one insert statement various times using different parameter bindings. This happens using one single Database statement, which has performance advantages compared to executing one single update operation various times.

Parameters:

query - a BulkQueryDefinition as a parameter group

parameterValues - A List of Maps in which every list item represents a row to be inserted, and the map contains the parameter names as keys and the value the parameter is bound to.

connector - the acting connector

connection - the acting connection

Returns:

an array of update counts containing one element for each executed command. The elements of the array are ordered according to the order in which commands were added to the batch.

Throws:

SQLException - if an error is produced

bulkUpdate

public int[] bulkUpdate(@Content @Placement(order=1) @TypeResolver(value=DbBulkInputMetadataResolver.class)
                        List<Map<String,Object>> parameterValues,
                        @ParameterGroup(name="Query")
                        BulkQueryDefinition query,
                        @UseConfig
                        DbConnector connector,
                        @Connection
                        DbConnection connection)
                 throws SQLException

Allows executing one update statement various times using different parameter bindings. This happens using one single Database statement, which has performance advantages compared to executing one single update operation various times.

Parameters:

query - a BulkQueryDefinition as a parameter group

parameterValues - A List of Maps in which every list item represents a row to be inserted, and the map contains the parameter names as keys and the value the parameter is bound to.

connector - the acting connector

connection - the acting connection

Returns:

an array of update counts containing one element for each executed command. The elements of the array are ordered according to the order in which commands were added to the batch.

Throws:

SQLException - if an error is produced

bulkDelete

public int[] bulkDelete(@Content @Placement(order=1) @TypeResolver(value=DbBulkInputMetadataResolver.class)
                        List<Map<String,Object>> parameterValues,
                        @ParameterGroup(name="Query")
                        BulkQueryDefinition query,
                        @UseConfig
                        DbConnector connector,
                        @Connection
                        DbConnection connection)
                 throws SQLException

Allows executing one delete statement various times using different parameter bindings. This happens using one single Database statement, which has performance advantages compared to executing one single delete operation various times.

Parameters:

query - a BulkQueryDefinition as a parameter group

parameterValues - A List of Maps in which every list item represents a row to be inserted, and the map contains the parameter names as keys and the value the parameter is bound to.

connector - the acting connector

connection - the acting connection

Returns:

an array of update counts containing one element for each executed command. The elements of the array are ordered according to the order in which commands were added to the batch.

Throws:

SQLException - if an error is produced

executeScript

public int[] executeScript(@ParameterGroup(name="Query")
                           BulkScript script,
                           @ParameterGroup(name="Query Settings")
                           QuerySettings settings,
                           @Connection
                           DbConnection connection)
                    throws SQLException

Executes a SQL script in one single Database statement. The script is executed as provided by the user, without any parameter binding.

Parameters:

script - a BulkScript as a parameter group

settings - a QuerySettings as a parameter group

connection - the acting connection

Returns:

an array of update counts containing one element for each executed command. The elements of the array are ordered according to the order in which commands were added to the batch.

Throws:

SQLException - if an error is produced

getStatementFactory

protected QueryStatementFactory getStatementFactory(boolean streaming,
                                                    QuerySettings settings)

executeUpdate

protected StatementResult executeUpdate(QueryDefinition query,
                                        AutoGenerateKeysAttributes autoGenerateKeysAttributes,
                                        DbConnection connection,
                                        Query resolvedQuery)
                                 throws SQLException

Throws:

SQLException

resolveQuery

protected Query resolveQuery(QueryDefinition query,
                             DbConnector connector,
                             DbConnection connection,
                             QueryType... validTypes)

validateQueryType

protected void validateQueryType(QueryTemplate queryTemplate,
                                 List<QueryType> validTypes)

validateNoParameterTypeIsUnused

protected void validateNoParameterTypeIsUnused(Query query,
                                               List<ParameterType> parameterTypes)

getAutoGeneratedKeysStrategy

protected AutoGenerateKeysStrategy getAutoGeneratedKeysStrategy(AutoGenerateKeysAttributes keyAttributes)