Examples of org.mule.module.db.internal.domain.executor.BulkExecutor.execute()

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

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

Examples of org.mule.module.db.internal.domain.executor.BulkExecutor.execute()

org.mule.module.db.internal.domain.executor.BulkExecutor.execute()
Executes a bulk query @param connection connection to the database where the query will be executed. Non null @param bulkQuery contains a group of non parameterized queries to execute @return 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

        validateQueryType(query.getQueryTemplate());


        List<List<QueryParamValue>> paramValues = resolveParamSets(muleEvent, query);


        BulkExecutor bulkUpdateExecutor = bulkUpdateExecutorFactory.create();
        return bulkUpdateExecutor.execute(connection, query, paramValues);
    }


    private List<List<QueryParamValue>> resolveParamSets(MuleEvent muleEvent, Query query)
    {
        Object payload;

View Full Code Here

        BulkQuery bulkQuery = bulkQueryResolver.resolve(eventToUse);


        validateQueryTemplates(bulkQuery.getQueryTemplates());


        BulkExecutor bulkUpdateExecutor = bulkUpdateExecutorFactory.create();
        return bulkUpdateExecutor.execute(connection, bulkQuery);
    }


    @Override
    protected List<QueryType> getValidQueryTypes()
    {

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.