langmi

SET HTTP_PROXY=http://%USER%:%PASSWORD%@%SERVER%:%PORT%

langmi

public class AsyncTaskExecutorFactory {
   ...
   public static SimpleAsyncTaskExecutor createInstance() {
       SimpleAsyncTaskExecutor instance = new SimpleAsyncTaskExecutor();

       // set concurrencyLimit according to available processors
       // real simple 1:1 relation
       Runtime runtime = Runtime.getRuntime();
       int nrCpu = runtime.availableProcessors();
       instance.setConcurrencyLimit(nrCpu);

langmi

public class JdbcPagingItemReaderTests {

    private BasicDataSource dataSource;
    
    public void setUp() throws Exception {
        // DataSource Setup, apache commons 
        dataSource = new BasicDataSource();
        dataSource.setDriverClassName("org.hsqldb.jdbcDriver");
        dataSource.setUrl("jdbc:hsqldb:mem:testdb");
        dataSource.setUsername("sa");

langmi

/**
 * CustomSqlParameterSourceProvider, constructs {@link MapSqlParameterSource} with
 * given item.
 *
 * @author Michael R. Lange <michael.r.lange@langmi.de>
 */
public class CustomSqlParameterSourceProvider implements ItemSqlParameterSourceProvider<YourItemObject> {

    @Override
    public SqlParameterSource createSqlParameterSource(final YourItemObject item) {

langmi

/**
 * Implementation for {@link ItemSqlParameterSourceProvider}, 
 * creates {@link MapSqlParameterSource} from {@link FieldSet}.
 *
 * @author Michael R. Lange <michael.r.lange@langmi.de>
 */
public class FieldSetSqlParameterSourceProvider implements ItemSqlParameterSourceProvider<FieldSet> {

    /** {@inheritDoc} */
    @Override

langmi

public class WrappedMrirToGetCurrentResource<T> implements ItemStreamReader<T> {

    private MultiResourceItemReader<T> mrir;

    @Override
    public void open(ExecutionContext executionContext) throws ItemStreamException {
        mrir.open(executionContext);
        // current.resource is only available here if it's a restart
        if (mrir.getCurrentResource() != null && mrir.getCurrentResource().getFilename() != null) {
            System.out.println("open:" + mrir.getCurrentResource().getFilename());

langmi

// from http://www.techper.net/2009/06/05/how-to-acess-target-object-behind-a-spring-proxy/

@SuppressWarnings({"unchecked"})
protected <T> T getTargetObject(Object proxy, Class<T> targetClass) throws Exception {
  if (AopUtils.isJdkDynamicProxy(proxy)) {
    return (T) ((Advised)proxy).getTargetSource().getTarget();
  } else {
    return (T) proxy; // expected to be cglib proxy then, which is simply a specialized class
  }
}

langmi

/**
 * Copyright 2012 Michael R. Lange <michael.r.lange@langmi.de>.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software

langmi

/**
 * Copyright 2012 Michael R. Lange <michael.r.lange@langmi.de>.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software

langmi

import java.util.ArrayList;
import java.util.List;
import org.springframework.batch.item.ExecutionContext;
import org.springframework.batch.item.ItemStream;
import org.springframework.batch.item.ItemStreamException;
import org.springframework.batch.item.ItemStreamReader;
import org.springframework.batch.item.NonTransientResourceException;
import org.springframework.batch.item.ParseException;
import org.springframework.batch.item.UnexpectedInputException;