Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package com.chrisbeech.batch.step;
- import java.util.ArrayList;
- import java.util.List;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- import org.springframework.batch.item.adapter.ItemReaderAdapter;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.stereotype.Component;
- import com.chrisbeech.batch.mongodb.collections.Client;
- @Component
- public class Reader extends ItemReaderAdapter<Client> {
- private static final Logger log = LoggerFactory.getLogger(Reader.class);
- private int nextClientIndex;
- private List<Client> clients;
- @Autowired
- public Reader(){
- init();
- }
- // populate in memory array
- private void init(){
- clients = new ArrayList<Client>();
- Client beryl = new Client();
- beryl.setFirstName("Beryl");
- beryl.setLastName("A");
- clients.add(beryl);
- Client frank = new Client();
- beryl.setFirstName("Frank");
- beryl.setLastName("A");
- clients.add(frank);
- Client paul = new Client();
- beryl.setFirstName("Paul");
- beryl.setLastName("A");
- clients.add(paul);
- Client judith = new Client();
- beryl.setFirstName("Judith");
- beryl.setLastName("A");
- clients.add(judith);
- Client lizzy = new Client();
- beryl.setFirstName("Lizzy");
- beryl.setLastName("A");
- clients.add(lizzy);
- Client erin = new Client();
- beryl.setFirstName("Erin");
- beryl.setLastName("A");
- clients.add(erin);
- Client norma = new Client();
- beryl.setFirstName("Norma");
- beryl.setLastName("A");
- clients.add(norma);
- Client danko = new Client();
- beryl.setFirstName("Daniel");
- beryl.setLastName("A");
- clients.add(danko);
- Client kyle = new Client();
- beryl.setFirstName("Kyle");
- beryl.setLastName("A");
- clients.add(kyle);
- Client oscar = new Client();
- beryl.setFirstName("Oscar");
- beryl.setLastName("A");
- clients.add(oscar);
- nextClientIndex = 0;
- }
- // read the people
- public Client read() throws Exception {
- Client nextClient = null;
- if(nextClientIndex < clients.size()){
- nextClient = clients.get(nextClientIndex);
- nextClientIndex++;
- log.info("### Reading in " + nextClientIndex + " : " + nextClient);
- }
- return nextClient;
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement