\n
\n
\n
\n
\n
\nChunk Oriented Processing Feature has come with Spring Batch v2.0. It refers to reading the data one at a time, and creating \u2018chunks\u2019 that will be written out, within a transaction boundary. One item is read from an ItemReader<\/strong>, handed to an ItemProcessor<\/strong>, and written. Once the number of items read equals the commit interval, the entire chunk is written out via the ItemWriter<\/strong>, and then the transaction is committed.<\/p>\n
Basically, this feature should be used if at least one data item\u2019 s reading and writing is required. Otherwise, TaskletStep Oriented processing can be used if the data item\u2019 s only reading or writing is required.<\/p>\n
Chunk Oriented Processing model exposes three important interface as ItemReader<\/strong>, ItemProcessor<\/strong> and ItemWriter<\/strong> via org.springframework.batch.item<\/strong> package.<\/p>\n Let us take a look how to develop Chunk Oriented Processing Model.<\/p>\n Used Technologies :<\/strong><\/p>\n A maven project is created as below. (It can be created by using Maven or IDE Plug-in).<\/p>\n A new USER Table is created by executing below script:<\/p>\n Firstly, dependencies are added to Maven\u2019 s pom.xml.<\/p>\n maven-compiler-plugin<\/strong>(Maven Plugin) is used to compile the project with JDK 1.7<\/p>\n The following Maven plugin can be used to create runnable-jar<\/strong>,<\/p>\n STEP 4 : CREATE User ENTITY<\/strong><\/p>\n User<\/strong> Entity is created. This entity will be stored after processing.<\/p>\n IUserDAO<\/strong> Interface is created to expose data access functionality.<\/p>\n UserDAO<\/strong> Class is created by implementing IUserDAO<\/strong> Interface.<\/p>\n STEP 7 : CREATE IUserService INTERFACE<\/strong><\/p>\n IUserService<\/strong> Interface is created for service layer.<\/p>\n UserService<\/strong> Class is created by implementing IUserService<\/strong> Interface.<\/p>\n TestReader<\/strong> Class is created by implementing ItemReader<\/strong> Interface. This class is called in order to read items. When read method returns null, reading operation is completed. The following steps explains with details how to be executed firstJob. The commit-interval value of firstjob is 2 and the following steps are executed :<\/p>\n 1) firstTestReader is called to read first item(firstname_0, firstsurname_0) firstStep is completed with COMPLETED status and secondStep is started. secondJob and thirdJob are executed in the same way.<\/p>\n FailedCaseTestReader<\/strong> Class is created in order to simulate the failed job status. In this sample application, when thirdJob is processed at fifthStep, failedCaseTestReader is called and exception is thrown so its status will be FAILED.<\/p>\n TestProcessor<\/strong> Class is created by implementing ItemProcessor<\/strong> Interface. This class is called to process items. User item is received from TestReader, processed and returned to TestWriter.<\/p>\n TestWriter<\/strong> Class is created by implementing ItemWriter<\/strong> Interface. This class is called to write items to DB, memory etc\u2026<\/p>\n FailedStepTasklet<\/strong> is created by implementing Tasklet Interface. It illustrates business logic in failed step.<\/p>\n BatchProcessStarter<\/strong> Class is created to launch the jobs. Also, it logs their execution results.<\/p>\n jdbc.properties<\/strong>, is created. It defines data-source informations and is read via dataContext.xml<\/strong><\/p>\n Spring Configuration file, dataContext.xml<\/strong>, is created. It covers dataSource, sessionFactory and transactionManager definitions.<\/p>\n Spring Configuration file, jobContext.xml<\/strong>, is created. It covers jobRepository, jobLauncher, item reader, item processor, item writer, tasklet and job definitions.<\/p>\n Spring Configuration file, applicationContext.xml<\/strong>, is created. It covers bean definitions.<\/p>\n Application Class is created to run the application.<\/p>\n After OTV_SpringBatch_Chunk_Oriented_Processing<\/strong> Project is built, OTV_SpringBatch_Chunk_Oriented_Processing-0.0.1-SNAPSHOT.jar<\/strong> will be created.<\/p>\n After created OTV_SpringBatch_Chunk_Oriented_Processing-0.0.1-SNAPSHOT.jar<\/strong> file is run, the following database and console output logs will be shown :<\/p>\n Database screenshot :<\/strong><\/p>\n First Job\u2019 s console output :<\/strong><\/p>\n Second Job\u2019 s console output :<\/strong><\/p>\n Third Job\u2019 s console output :<\/strong><\/p>\n STEP 22 : DOWNLOAD<\/strong> Chunk Oriented Processing in Spring Batch<\/a><\/strong> Reference: <\/em><\/strong>Chunk Oriented Processing in Spring Batch<\/a> from our JCG partner<\/a> Eren Avsarogullari at the Online Technology Vision<\/a> blog.<\/p>\n","protected":false},"excerpt":{"rendered":" Big Data Sets\u2019 Processing is one of the most important problem in the software world. Spring Batch is a lightweight and robust batch framework to process the data sets. Spring Batch Framework offers \u2018TaskletStep Oriented\u2019 and \u2018Chunk Oriented\u2019 processing style. In this article, Chunk Oriented Processing Model is explained. Also, TaskletStep Oriented Processing in Spring …<\/p>\n","protected":false},"author":158,"featured_media":240,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[8],"tags":[30,691],"class_list":["post-6014","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-enterprise-java","tag-spring","tag-spring-batch"],"yoast_head":"\n\n
\n
STEP 1 : CREATE MAVEN PROJECT<\/h2>\n
![\"\"](\"http:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2012\/12\/Spring-Batch-Chunk-Oriented-Processing2.png\" "\\"Spring")
<\/a><\/p>\nSTEP 2 : LIBRARIES<\/h2>\n
CREATE TABLE ONLINETECHVISION.USER (\r\n id int(11) NOT NULL AUTO_INCREMENT,\r\n name varchar(45) NOT NULL,\r\n surname varchar(45) NOT NULL,\r\n PRIMARY KEY (`id`)\r\n);<\/pre>\n
STEP 3 : LIBRARIES<\/h2>\n
<properties>\r\n <spring.version>3.1.3.RELEASE<\/spring.version>\r\n <spring-batch.version>2.1.9.RELEASE<\/spring-batch.version>\r\n <\/properties>\r\n\r\n <dependencies>\r\n\r\n <dependency>\r\n <groupId>org.springframework<\/groupId>\r\n <artifactId>spring-core<\/artifactId>\r\n <version>${spring.version}<\/version>\r\n <\/dependency>\r\n\r\n <dependency>\r\n <groupId>org.springframework<\/groupId>\r\n <artifactId>spring-context<\/artifactId>\r\n <version>${spring.version}<\/version>\r\n <\/dependency> \r\n\r\n\t <dependency>\r\n\t\t<groupId>org.springframework<\/groupId>\r\n\t\t<artifactId>spring-tx<\/artifactId>\r\n\t\t<version>${spring.version}<\/version>\r\n\t <\/dependency>\r\n\r\n\t <dependency>\r\n\t\t<groupId>org.springframework<\/groupId>\r\n\t\t<artifactId>spring-orm<\/artifactId>\r\n\t\t<version>${spring.version}<\/version>\r\n\t <\/dependency>\r\n\r\n\t <dependency>\r\n\t\t<groupId>org.springframework.batch<\/groupId>\r\n\t\t<artifactId>spring-batch-core<\/artifactId>\r\n\t\t<version>${spring-batch.version}<\/version>\r\n\t <\/dependency>\r\n\r\n\t <!-- Hibernate dependencies -->\r\n <dependency>\r\n <groupId>org.hibernate<\/groupId>\r\n <artifactId>hibernate-core<\/artifactId>\r\n <version>4.1.8.Final<\/version>\r\n <\/dependency>\r\n\r\n\t <!-- Tomcat DBCP -->\r\n\t <dependency>\r\n\t\t<groupId>org.apache.tomcat<\/groupId>\r\n\t\t<artifactId>tomcat-jdbc<\/artifactId>\r\n\t\t<version>7.0.27<\/version>\r\n\t <\/dependency>\r\n\r\n\t <!-- MySQL Java Connector library -->\r\n\t <dependency>\r\n\t\t<groupId>mysql<\/groupId>\r\n\t\t<artifactId>mysql-connector-java<\/artifactId>\r\n\t\t<version>5.1.17<\/version>\r\n\t <\/dependency>\r\n\r\n\t <!-- Log4j library -->\r\n\t <dependency>\r\n\t\t<groupId>log4j<\/groupId>\r\n\t\t<artifactId>log4j<\/artifactId>\r\n\t\t<version>1.2.16<\/version>\r\n\t <\/dependency>\r\n\r\n <\/dependencies><\/pre>\n\t<plugin>\r\n\t\t<groupId>org.apache.maven.plugins<\/groupId>\r\n\t\t<artifactId>maven-compiler-plugin<\/artifactId>\r\n\t\t<version>3.0<\/version>\r\n\t\t<configuration>\r\n\t\t <source>1.7<\/source>\r\n\t\t <target>1.7<\/target>\r\n\t\t<\/configuration>\r\n\t<\/plugin><\/pre>\n
\t<plugin>\r\n\t\t<groupId>org.apache.maven.plugins<\/groupId>\r\n\t\t<artifactId>maven-shade-plugin<\/artifactId>\r\n\t\t<version>2.0<\/version>\r\n\r\n\t\t<executions>\r\n\t\t\t<execution>\r\n\t\t\t\t<phase>package<\/phase>\r\n\t\t\t\t<goals>\r\n\t\t\t\t\t<goal>shade<\/goal>\r\n\t\t\t\t<\/goals>\r\n\t\t\t\t<configuration>\r\n\t\t\t\t\t<configuration>\r\n\t\t\t <source>1.7<\/source>\r\n\t\t\t <target>1.7<\/target>\r\n\t\t\t <\/configuration>\r\n\t\t\t\t\t<transformers>\r\n\t\t\t\t\t\t<transformer\r\n\t\t\t\t\t\t\timplementation='org.apache.maven.plugins.shade.resource.\r\nManifestResourceTransformer'>\r\n\t\t\t\t\t\t\t<mainClass>com.onlinetechvision.exe.Application<\/mainClass>\r\n\t\t\t\t\t\t<\/transformer>\r\n\t\t\t\t\t\t<transformer\r\n\t\t\t\t\t\t\timplementation='org.apache.maven.plugins.shade.resource.\r\nAppendingTransformer'>\r\n\t\t\t\t\t\t\t<resource>META-INF\/spring.handlers<\/resource>\r\n\t\t\t\t\t\t<\/transformer>\r\n\t\t\t\t\t\t<transformer\r\n\t\t\t\t\t\t\timplementation='org.apache.maven.plugins.shade.resource.\r\nAppendingTransformer'>\r\n\t\t\t\t\t\t\t<resource>META-INF\/spring.schemas<\/resource>\r\n\t\t\t\t\t\t<\/transformer>\r\n\t\t\t\t\t<\/transformers>\r\n\t\t\t\t<\/configuration>\r\n\t\t\t<\/execution>\r\n\t\t<\/executions>\r\n\t<\/plugin><\/pre>\n
package com.onlinetechvision.user;\r\n\r\nimport javax.persistence.Column;\r\nimport javax.persistence.Entity;\r\nimport javax.persistence.GeneratedValue;\r\nimport javax.persistence.GenerationType;\r\nimport javax.persistence.Id;\r\nimport javax.persistence.Table;\r\n\r\n\/**\r\n * User Entity\r\n *\r\n * @author onlinetechvision.com\r\n * @since 10 Dec 2012\r\n * @version 1.0.0\r\n *\r\n *\/\r\n@Entity\r\n@Table(name='USER')\r\npublic class User {\r\n\r\n private int id;\r\n private String name;\r\n private String surname;\r\n\r\n @Id\r\n @GeneratedValue(strategy=GenerationType.AUTO)\r\n @Column(name='ID', unique = true, nullable = false)\r\n public int getId() {\r\n return id;\r\n }\r\n\r\n public void setId(int id) {\r\n this.id = id;\r\n }\r\n\r\n @Column(name='NAME', unique = true, nullable = false)\r\n public String getName() {\r\n return name;\r\n }\r\n\r\n public void setName(String name) {\r\n this.name = name;\r\n }\r\n\r\n @Column(name='SURNAME', unique = true, nullable = false)\r\n public String getSurname() {\r\n return surname;\r\n }\r\n\r\n public void setSurname(String surname) {\r\n this.surname = surname;\r\n } \r\n\r\n @Override\r\n public String toString() {\r\n StringBuffer strBuff = new StringBuffer();\r\n strBuff.append('id : ').append(getId());\r\n strBuff.append(', name : ').append(getName());\r\n strBuff.append(', surname : ').append(getSurname());\r\n return strBuff.toString();\r\n }\r\n}<\/pre>\nSTEP 5 : CREATE IUserDAO INTERFACE<\/h2>\n
package com.onlinetechvision.user.dao;\r\n\r\nimport java.util.List;\r\n\r\nimport com.onlinetechvision.user.User;\r\n\r\n\/**\r\n * User DAO Interface\r\n *\r\n * @author onlinetechvision.com\r\n * @since 10 Dec 2012\r\n * @version 1.0.0\r\n *\r\n *\/\r\npublic interface IUserDAO {\r\n\r\n \/**\r\n * Adds User\r\n *\r\n * @param User user\r\n *\/\r\n void addUser(User user);\r\n\r\n \/**\r\n * Gets User List\r\n *\r\n *\/\r\n List<User> getUsers();\r\n}<\/pre>\nSTEP 6 : CREATE UserDAO IMPL<\/h2>\n
package com.onlinetechvision.user.dao;\r\n\r\nimport java.util.List;\r\n\r\nimport org.hibernate.SessionFactory;\r\n\r\nimport com.onlinetechvision.user.User;\r\n\r\n\/**\r\n * User DAO\r\n *\r\n * @author onlinetechvision.com\r\n * @since 10 Dec 2012\r\n * @version 1.0.0\r\n *\r\n *\/\r\npublic class UserDAO implements IUserDAO {\r\n\r\n private SessionFactory sessionFactory;\r\n\r\n \/**\r\n * Gets Hibernate Session Factory\r\n *\r\n * @return SessionFactory - Hibernate Session Factory\r\n *\/\r\n public SessionFactory getSessionFactory() {\r\n return sessionFactory;\r\n }\r\n\r\n \/**\r\n * Sets Hibernate Session Factory\r\n *\r\n * @param SessionFactory - Hibernate Session Factory\r\n *\/\r\n public void setSessionFactory(SessionFactory sessionFactory) {\r\n this.sessionFactory = sessionFactory;\r\n }\r\n\r\n \/**\r\n * Adds User\r\n *\r\n * @param User user\r\n *\/\r\n @Override\r\n public void addUser(User user) {\r\n getSessionFactory().getCurrentSession().save(user);\r\n }\r\n\r\n \/**\r\n * Gets User List\r\n *\r\n * @return List - User list\r\n *\/\r\n @SuppressWarnings({ 'unchecked' })\r\n\t@Override\r\n public List<User> getUsers() {\r\n List<User> list = getSessionFactory().getCurrentSession().createQuery('from User').list();\r\n return list;\r\n }\r\n\r\n}<\/pre>\npackage com.onlinetechvision.user.service;\r\n\r\nimport java.util.List;\r\n\r\nimport com.onlinetechvision.user.User;\r\n\r\n\/**\r\n *\r\n * User Service Interface\r\n *\r\n * @author onlinetechvision.com\r\n * @since 10 Dec 2012\r\n * @version 1.0.0\r\n *\r\n *\/\r\npublic interface IUserService {\r\n\r\n \/**\r\n * Adds User\r\n *\r\n * @param User user\r\n *\/\r\n void addUser(User user);\r\n\r\n \/**\r\n * Gets User List\r\n *\r\n * @return List - User list\r\n *\/\r\n List<User> getUsers();\r\n}<\/pre>\nSTEP 8 : CREATE UserService IMPL<\/h2>\n
package com.onlinetechvision.user.service;\r\n\r\nimport java.util.List;\r\n\r\nimport org.springframework.transaction.annotation.Transactional;\r\n\r\nimport com.onlinetechvision.user.User;\r\nimport com.onlinetechvision.user.dao.IUserDAO;\r\n\r\n\/**\r\n *\r\n * User Service\r\n *\r\n * @author onlinetechvision.com\r\n * @since 10 Dec 2012\r\n * @version 1.0.0\r\n *\r\n *\/\r\n@Transactional(readOnly = true)\r\npublic class UserService implements IUserService {\r\n\r\n IUserDAO userDAO;\r\n\r\n \/**\r\n * Adds User\r\n *\r\n * @param User user\r\n *\/\r\n @Transactional(readOnly = false)\r\n @Override\r\n public void addUser(User user) {\r\n getUserDAO().addUser(user);\r\n }\r\n\r\n \/**\r\n * Gets User List\r\n *\r\n *\/\r\n @Override\r\n public List<User> getUsers() {\r\n return getUserDAO().getUsers();\r\n }\r\n\r\n public IUserDAO getUserDAO() {\r\n return userDAO;\r\n }\r\n\r\n public void setUserDAO(IUserDAO userDAO) {\r\n this.userDAO = userDAO;\r\n }\r\n}<\/pre>\nSTEP 9 : CREATE TestReader IMPL<\/h2>\n
\n2) firstTestReader is called again to read second item(firstname_1, firstsurname_1)
\n3) testProcessor is called to process first item(FIRSTNAME_0, FIRSTSURNAME_0)
\n4) testProcessor is called to process second item(FIRSTNAME_1, FIRSTSURNAME_1)
\n5) testWriter is called to write first item(FIRSTNAME_0, FIRSTSURNAME_0) to database
\n6) testWriter is called to write second item(FIRSTNAME_1, FIRSTSURNAME_1) to database
\n7) first and second items are committed and the transaction is closed.
\nfirstTestReader is called to read third item(firstname_2, firstsurname_2)
\n9) maxIndex value of firstTestReader is 3. read method returns null and item reading operation is completed.
\n10) testProcessor is called to process third item(FIRSTNAME_2, FIRSTSURNAME_2)
\n11) testWriter is called to write first item(FIRSTNAME_2, FIRSTSURNAME_2) to database
\n12) third item is committed and the transaction is closed.<\/p>\npackage com.onlinetechvision.item;\r\n\r\nimport org.springframework.batch.item.ItemReader;\r\nimport org.springframework.batch.item.NonTransientResourceException;\r\nimport org.springframework.batch.item.ParseException;\r\nimport org.springframework.batch.item.UnexpectedInputException;\r\n\r\nimport com.onlinetechvision.user.User;\r\n\r\n\/**\r\n * TestReader Class is created to read items which will be processed\r\n *\r\n * @author onlinetechvision.com\r\n * @since 10 Dec 2012\r\n * @version 1.0.0\r\n *\r\n *\/\r\npublic class TestReader implements ItemReader<User> {\r\n\tprivate int index;\r\n\tprivate int maxIndex;\r\n\tprivate String namePrefix;\r\n\tprivate String surnamePrefix;\r\n\r\n\t\/**\r\n * Reads items one by one\r\n *\r\n * @return User\r\n *\r\n * @throws Exception\r\n * @throws UnexpectedInputException\r\n * @throws ParseException\r\n * @throws NonTransientResourceException\r\n *\r\n *\/\r\n\t@Override\r\n\tpublic User read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException {\r\n\t\tUser user = new User();\r\n\t\tuser.setName(getNamePrefix() + '_' + index);\r\n\t\tuser.setSurname(getSurnamePrefix() + '_' + index);\r\n\r\n\t\tif(index > getMaxIndex()) {\r\n\t\t\treturn null;\r\n\t\t}\r\n\r\n\t\tincrementIndex();\r\n\r\n\t\treturn user;\r\n\t}\r\n\r\n\t\/**\r\n * Increments index which defines read-count\r\n *\r\n * @return int\r\n *\r\n *\/\r\n\tprivate int incrementIndex() {\r\n\t\treturn index++;\r\n\t}\r\n\r\n\tpublic int getMaxIndex() {\r\n\t\treturn maxIndex;\r\n\t}\r\n\r\n\tpublic void setMaxIndex(int maxIndex) {\r\n\t\tthis.maxIndex = maxIndex;\r\n\t}\r\n\r\n\tpublic String getNamePrefix() {\r\n\t\treturn namePrefix;\r\n\t}\r\n\r\n\tpublic void setNamePrefix(String namePrefix) {\r\n\t\tthis.namePrefix = namePrefix;\r\n\t}\r\n\r\n\tpublic String getSurnamePrefix() {\r\n\t\treturn surnamePrefix;\r\n\t}\r\n\r\n\tpublic void setSurnamePrefix(String surnamePrefix) {\r\n\t\tthis.surnamePrefix = surnamePrefix;\r\n\t}\r\n\r\n}<\/pre>\nSTEP 10 : CREATE FailedCaseTestReader IMPL<\/h2>\n
package com.onlinetechvision.item;\r\n\r\nimport org.springframework.batch.item.ItemReader;\r\nimport org.springframework.batch.item.NonTransientResourceException;\r\nimport org.springframework.batch.item.ParseException;\r\nimport org.springframework.batch.item.UnexpectedInputException;\r\n\r\nimport com.onlinetechvision.user.User;\r\n\r\n\/**\r\n * FailedCaseTestReader Class is created in order to simulate the failed job status.\r\n *\r\n * @author onlinetechvision.com\r\n * @since 10 Dec 2012\r\n * @version 1.0.0\r\n *\r\n *\/\r\npublic class FailedCaseTestReader implements ItemReader<User> {\r\n\tprivate int index;\r\n\tprivate int maxIndex;\r\n\tprivate String namePrefix;\r\n\tprivate String surnamePrefix;\r\n\r\n\t\/**\r\n * Reads items one by one\r\n *\r\n * @return User\r\n *\r\n * @throws Exception\r\n * @throws UnexpectedInputException\r\n * @throws ParseException\r\n * @throws NonTransientResourceException\r\n *\r\n *\/\r\n\t@Override\r\n\tpublic User read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException {\r\n\t\tUser user = new User();\r\n\t\tuser.setName(getNamePrefix() + '_' + index);\r\n\t\tuser.setSurname(getSurnamePrefix() + '_' + index);\r\n\r\n\t\tif(index >= getMaxIndex()) {\r\n\t\t\tthrow new Exception('Unexpected Error!');\r\n\t\t}\r\n\r\n\t\tincrementIndex();\r\n\r\n\t\treturn user;\r\n\t}\r\n\r\n\t\/**\r\n * Increments index which defines read-count\r\n *\r\n * @return int\r\n *\r\n *\/\r\n\tprivate int incrementIndex() {\r\n\t\treturn index++;\r\n\t}\r\n\r\n\tpublic int getMaxIndex() {\r\n\t\treturn maxIndex;\r\n\t}\r\n\r\n\tpublic void setMaxIndex(int maxIndex) {\r\n\t\tthis.maxIndex = maxIndex;\r\n\t}\r\n\r\n\tpublic String getNamePrefix() {\r\n\t\treturn namePrefix;\r\n\t}\r\n\r\n\tpublic void setNamePrefix(String namePrefix) {\r\n\t\tthis.namePrefix = namePrefix;\r\n\t}\r\n\r\n\tpublic String getSurnamePrefix() {\r\n\t\treturn surnamePrefix;\r\n\t}\r\n\r\n\tpublic void setSurnamePrefix(String surnamePrefix) {\r\n\t\tthis.surnamePrefix = surnamePrefix;\r\n\t}\r\n\r\n}<\/pre>\nSTEP 11 : CREATE TestProcessor IMPL<\/h2>\n
package com.onlinetechvision.item;\r\n\r\nimport java.util.Locale;\r\n\r\nimport org.springframework.batch.item.ItemProcessor;\r\n\r\nimport com.onlinetechvision.user.User;\r\n\r\n\/**\r\n * TestProcessor Class is created to process items.\r\n *\r\n * @author onlinetechvision.com\r\n * @since 10 Dec 2012\r\n * @version 1.0.0\r\n *\r\n *\/\r\npublic class TestProcessor implements ItemProcessor<User, User> {\r\n\r\n\t\/**\r\n * Processes items one by one\r\n *\r\n * @param User user\r\n * @return User\r\n * @throws Exception\r\n *\r\n *\/\r\n\t@Override\r\n\tpublic User process(User user) throws Exception {\r\n\t\tuser.setName(user.getName().toUpperCase(Locale.ENGLISH));\r\n\t\tuser.setSurname(user.getSurname().toUpperCase(Locale.ENGLISH));\r\n\t\treturn user;\r\n\t}\r\n\r\n}<\/pre>\nSTEP 12 : CREATE TestWriter IMPL<\/h2>\n
package com.onlinetechvision.item;\r\n\r\nimport java.util.List;\r\n\r\nimport org.springframework.batch.item.ItemWriter;\r\n\r\nimport com.onlinetechvision.user.User;\r\nimport com.onlinetechvision.user.service.IUserService;\r\n\r\n\/**\r\n * TestWriter Class is created to write items to DB, memory etc...\r\n *\r\n * @author onlinetechvision.com\r\n * @since 10 Dec 2012\r\n * @version 1.0.0\r\n *\r\n *\/\r\npublic class TestWriter implements ItemWriter<User> {\r\n\r\n\tprivate IUserService userService;\r\n\r\n\t\/**\r\n * Writes items via list\r\n *\r\n * @throws Exception\r\n *\r\n *\/\r\n\t@Override\r\n\tpublic void write(List<? extends User> userList) throws Exception {\r\n\t\tfor(User user : userList) {\r\n\t\t\tgetUserService().addUser(user);\r\n\t\t}\r\n\t\tSystem.out.println('User List : ' + getUserService().getUsers());\r\n\t}\r\n\r\n\tpublic IUserService getUserService() {\r\n\t\treturn userService;\r\n\t}\r\n\r\n\tpublic void setUserService(IUserService userService) {\r\n\t\tthis.userService = userService;\r\n\t}\r\n\r\n}<\/pre>\nSTEP 13 : CREATE FailedStepTasklet CLASS<\/h2>\n
package com.onlinetechvision.tasklet;\r\n\r\nimport org.apache.log4j.Logger;\r\nimport org.springframework.batch.core.StepContribution;\r\nimport org.springframework.batch.core.scope.context.ChunkContext;\r\nimport org.springframework.batch.core.step.tasklet.Tasklet;\r\nimport org.springframework.batch.repeat.RepeatStatus;\r\n\r\n\/**\r\n * FailedStepTasklet Class illustrates a failed job.\r\n *\r\n * @author onlinetechvision.com\r\n * @since 10 Dec 2012\r\n * @version 1.0.0\r\n *\r\n *\/\r\npublic class FailedStepTasklet implements Tasklet {\r\n\r\n\tprivate static final Logger logger = Logger.getLogger(FailedStepTasklet.class);\r\n\r\n private String taskResult;\r\n\r\n \/**\r\n * Executes FailedStepTasklet\r\n *\r\n * @param StepContribution stepContribution\r\n * @param ChunkContext chunkContext\r\n * @return RepeatStatus\r\n * @throws Exception\r\n *\r\n *\/\r\n public RepeatStatus execute(StepContribution stepContribution, ChunkContext chunkContext) throws Exception {\r\n \tlogger.debug('Task Result : ' + getTaskResult());\r\n \tthrow new Exception('Error occurred!');\r\n\t}\r\n\r\n\tpublic String getTaskResult() {\r\n\t\treturn taskResult;\r\n\t}\r\n\r\n\tpublic void setTaskResult(String taskResult) {\r\n\t\tthis.taskResult = taskResult;\r\n\t} \r\n\r\n}<\/pre>\nSTEP 14 : CREATE BatchProcessStarter CLASS<\/h2>\n
package com.onlinetechvision.spring.batch;\r\n\r\nimport org.apache.log4j.Logger;\r\nimport org.springframework.batch.core.Job;\r\nimport org.springframework.batch.core.JobExecution;\r\nimport org.springframework.batch.core.JobParametersBuilder;\r\nimport org.springframework.batch.core.JobParametersInvalidException;\r\nimport org.springframework.batch.core.launch.JobLauncher;\r\nimport org.springframework.batch.core.repository.JobExecutionAlreadyRunningException;\r\nimport org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException;\r\nimport org.springframework.batch.core.repository.JobRepository;\r\nimport org.springframework.batch.core.repository.JobRestartException;\r\n\r\n\/**\r\n * BatchProcessStarter Class launches the jobs and logs their execution results.\r\n *\r\n * @author onlinetechvision.com\r\n * @since 10 Dec 2012\r\n * @version 1.0.0\r\n *\r\n *\/\r\npublic class BatchProcessStarter {\r\n\r\n\tprivate static final Logger logger = Logger.getLogger(BatchProcessStarter.class);\r\n\r\n\tprivate Job firstJob;\r\n\tprivate Job secondJob;\r\n\tprivate Job thirdJob;\r\n\tprivate JobLauncher jobLauncher;\r\n\tprivate JobRepository jobRepository;\r\n\r\n\t\/**\r\n * Starts the jobs and logs their execution results.\r\n *\r\n *\/\r\n\tpublic void start() {\r\n\t\tJobExecution jobExecution = null;\r\n\t\tJobParametersBuilder builder = new JobParametersBuilder();\r\n\r\n\t\ttry {\r\n\t\t\tgetJobLauncher().run(getFirstJob(), builder.toJobParameters());\r\n\t\t\tjobExecution = getJobRepository().getLastJobExecution(getFirstJob().getName(), builder.toJobParameters());\r\n\t\t\tlogger.debug(jobExecution.toString());\t\t\t\r\n\r\n\t\t\tgetJobLauncher().run(getSecondJob(), builder.toJobParameters());\r\n\t\t\tjobExecution = getJobRepository().getLastJobExecution(getSecondJob().getName(), builder.toJobParameters());\r\n\t\t\tlogger.debug(jobExecution.toString());\r\n\r\n\t\t\tgetJobLauncher().run(getThirdJob(), builder.toJobParameters());\r\n\t\t\tjobExecution = getJobRepository().getLastJobExecution(getThirdJob().getName(), builder.toJobParameters());\r\n\t\t\tlogger.debug(jobExecution.toString());\r\n\r\n\t\t} catch (JobExecutionAlreadyRunningException\r\n\t\t\t\t\t| JobRestartException\r\n\t\t\t\t\t| JobInstanceAlreadyCompleteException\r\n\t\t\t\t\t| JobParametersInvalidException e) {\r\n\t\t\tlogger.error(e);\r\n\t\t}\r\n\r\n\t}\t\r\n\r\n\tpublic Job getFirstJob() {\r\n\t\treturn firstJob;\r\n\t}\r\n\r\n\tpublic void setFirstJob(Job firstJob) {\r\n\t\tthis.firstJob = firstJob;\r\n\t}\r\n\r\n\tpublic Job getSecondJob() {\r\n\t\treturn secondJob;\r\n\t}\r\n\r\n\tpublic void setSecondJob(Job secondJob) {\r\n\t\tthis.secondJob = secondJob;\r\n\t}\t\r\n\r\n\tpublic Job getThirdJob() {\r\n\t\treturn thirdJob;\r\n\t}\r\n\r\n\tpublic void setThirdJob(Job thirdJob) {\r\n\t\tthis.thirdJob = thirdJob;\r\n\t}\r\n\r\n\tpublic JobLauncher getJobLauncher() {\r\n\t\treturn jobLauncher;\r\n\t}\r\n\r\n\tpublic void setJobLauncher(JobLauncher jobLauncher) {\r\n\t\tthis.jobLauncher = jobLauncher;\r\n\t}\r\n\r\n\tpublic JobRepository getJobRepository() {\r\n\t\treturn jobRepository;\r\n\t}\r\n\r\n\tpublic void setJobRepository(JobRepository jobRepository) {\r\n\t\tthis.jobRepository = jobRepository;\r\n\t}\t\r\n\r\n}<\/pre>\nSTEP 15 : CREATE dataContext.xml <\/h2>\n
jdbc.db.driverClassName=com.mysql.jdbc.Driver\r\njdbc.db.url=jdbc:mysql:\/\/localhost:3306\/onlinetechvision\r\njdbc.db.username=root\r\njdbc.db.password=root\r\njdbc.db.initialSize=10\r\njdbc.db.minIdle=3\r\njdbc.db.maxIdle=10\r\njdbc.db.maxActive=10\r\njdbc.db.testWhileIdle=true\r\njdbc.db.testOnBorrow=true\r\njdbc.db.testOnReturn=true\r\njdbc.db.initSQL=SELECT 1 FROM DUAL\r\njdbc.db.validationQuery=SELECT 1 FROM DUAL\r\njdbc.db.timeBetweenEvictionRunsMillis=30000<\/pre>\n
STEP 16 : CREATE dataContext.xml <\/h2>\n
<?xml version='1.0' encoding='UTF-8'?>\r\n<beans xmlns='http:\/\/www.springframework.org\/schema\/beans'\r\n\t xmlns:xsi='http:\/\/www.w3.org\/2001\/XMLSchema-instance'\r\n\t xmlns:context='http:\/\/www.springframework.org\/schema\/context'\r\n\t xmlns:p='http:\/\/www.springframework.org\/schema\/p'\r\n\t xmlns:batch='http:\/\/www.springframework.org\/schema\/batch'\r\n\t xmlns:tx='http:\/\/www.springframework.org\/schema\/tx'\r\n\t xsi:schemaLocation='http:\/\/www.springframework.org\/schema\/beans \r\n\r\nhttp:\/\/www.springframework.org\/schema\/beans\/spring-beans-3.0.xsd\r\n\r\nhttp:\/\/www.springframework.org\/schema\/context\r\n\r\nhttp:\/\/www.springframework.org\/schema\/context\/spring-context-3.0.xsd\r\n\r\nhttp:\/\/www.springframework.org\/schema\/batch\r\n\r\nhttp:\/\/www.springframework.org\/schema\/batch\/spring-batch-2.1.xsd\r\n\r\nhttp:\/\/www.springframework.org\/schema\/tx\r\n\r\nhttp:\/\/www.springframework.org\/schema\/tx\/spring-tx-3.0.xsd'>\r\n\r\n <context:property-placeholder location='classpath:jdbc.properties'\/>\r\n\r\n <!-- Enable the configuration of transactional behavior based on annotations -->\r\n <tx:annotation-driven transaction-manager='transactionManager'\/>\r\n\r\n <!-- Data Source Declaration -->\r\n\t<bean id='dataSource' class='org.apache.tomcat.jdbc.pool.DataSource' destroy-method='close'\r\n\t\t\t p:driverClassName='${jdbc.db.driverClassName}'\r\n\t\t\t p:url='${jdbc.db.url}'\r\n\t\t\t p:username='${jdbc.db.username}'\r\n\t\t\t p:password='${jdbc.db.password}'\r\n\t\t\t p:initialSize='${jdbc.db.initialSize}'\r\n\t\t\t p:minIdle='${jdbc.db.minIdle}'\r\n\t\t\t p:maxIdle='${jdbc.db.maxIdle}'\r\n\t\t\t p:maxActive='${jdbc.db.maxActive}'\r\n\t\t\t p:testWhileIdle='${jdbc.db.testWhileIdle}'\r\n\t\t\t p:testOnBorrow='${jdbc.db.testOnBorrow}'\r\n\t\t\t p:testOnReturn='${jdbc.db.testOnReturn}'\r\n\t\t\t p:initSQL='${jdbc.db.initSQL}'\r\n\t\t\t p:validationQuery='${jdbc.db.validationQuery}'\r\n\t\t\t p:timeBetweenEvictionRunsMillis='${jdbc.db.timeBetweenEvictionRunsMillis}'\/>\t\r\n\r\n <!-- Session Factory Declaration -->\r\n\t<bean id='sessionFactory' class='org.springframework.orm.hibernate4.LocalSessionFactoryBean'>\r\n\t\t<property name='dataSource' ref='dataSource' \/>\r\n\t\t<property name='annotatedClasses'>\r\n\t\t\t<list>\r\n\t\t\t\t<value>com.onlinetechvision.user.User<\/value>\r\n\t\t\t<\/list>\r\n\t\t<\/property>\r\n\t\t<property name='hibernateProperties'>\r\n\t\t\t<props>\r\n\t\t\t\t<prop key='hibernate.dialect'>org.hibernate.dialect.MySQLDialect<\/prop>\r\n\t\t\t\t<prop key='hibernate.show_sql'>true<\/prop>\r\n\t\t\t<\/props>\r\n\t\t<\/property>\r\n\t<\/bean>\r\n\r\n\t<!-- Transaction Manager Declaration -->\r\n <bean id='transactionManager' class='org.springframework.orm.hibernate4.HibernateTransactionManager'>\r\n <property name='sessionFactory' ref='sessionFactory'\/>\r\n <\/bean>\r\n\r\n<\/beans><\/pre>\nSTEP 17 : CREATE jobContext.xml <\/h2>\n
<?xml version='1.0' encoding='UTF-8'?>\r\n<beans xmlns='http:\/\/www.springframework.org\/schema\/beans'\r\n\txmlns:xsi='http:\/\/www.w3.org\/2001\/XMLSchema-instance'\r\n\txmlns:batch='http:\/\/www.springframework.org\/schema\/batch'\r\n\txsi:schemaLocation='http:\/\/www.springframework.org\/schema\/beans \r\n\r\nhttp:\/\/www.springframework.org\/schema\/beans\/spring-beans-3.0.xsd\r\n\r\nhttp:\/\/www.springframework.org\/schema\/batch\r\n\r\nhttp:\/\/www.springframework.org\/schema\/batch\/spring-batch-2.1.xsd'>\r\n\r\n <import resource='dataContext.xml'\/>\r\n\r\n <!-- jobRepository Declaration -->\r\n <bean id='jobRepository' class='org.springframework.batch.core.repository.support.MapJobRepositoryFactoryBean'>\r\n\t\t<property name='transactionManager' ref='transactionManager' \/>\r\n <\/bean>\r\n\r\n <!-- jobLauncher Declaration -->\r\n <bean id='jobLauncher' class='org.springframework.batch.core.launch.support.SimpleJobLauncher' >\r\n <property name='jobRepository' ref='jobRepository'\/>\r\n <\/bean>\r\n\r\n <!-- Reader Bean Declarations -->\r\n <bean id='firstTestReader' class='com.onlinetechvision.item.TestReader'>\r\n \t<property name='maxIndex' value='2'\/>\r\n\t <property name='namePrefix' value='firstname'\/>\r\n\t <property name='surnamePrefix' value='firstsurname'\/>\r\n <\/bean>\r\n\r\n <bean id='secondTestReader' class='com.onlinetechvision.item.TestReader'>\r\n <property name='maxIndex' value='2'\/>\r\n\t <property name='namePrefix' value='secondname'\/>\r\n\t <property name='surnamePrefix' value='secondsurname'\/>\r\n <\/bean>\r\n\r\n <bean id='thirdTestReader' class='com.onlinetechvision.item.TestReader'>\r\n <property name='maxIndex' value='3'\/>\r\n\t <property name='namePrefix' value='thirdname'\/>\r\n\t <property name='surnamePrefix' value='thirdsurname'\/>\r\n <\/bean>\r\n\r\n <bean id='fourthTestReader' class='com.onlinetechvision.item.TestReader'>\r\n <property name='maxIndex' value='3'\/>\r\n\t <property name='namePrefix' value='fourthname'\/>\r\n\t <property name='surnamePrefix' value='fourthsurname'\/>\r\n <\/bean>\r\n\r\n <bean id='fifthTestReader' class='com.onlinetechvision.item.TestReader'>\r\n <property name='maxIndex' value='3'\/>\r\n\t <property name='namePrefix' value='fifthname'\/>\r\n\t <property name='surnamePrefix' value='fifthsurname'\/>\r\n <\/bean>\r\n\r\n <bean id='failedCaseTestReader' class='com.onlinetechvision.item.FailedCaseTestReader'>\r\n <property name='maxIndex' value='1'\/>\r\n\t <property name='namePrefix' value='failedcasename'\/>\r\n\t <property name='surnamePrefix' value='failedcasesurname'\/>\r\n <\/bean>\r\n\r\n <!-- Processor Bean Declaration -->\r\n <bean id='testProcessor' class='com.onlinetechvision.item.TestProcessor' \/>\r\n\r\n <!-- Writer Bean Declaration -->\r\n <bean id='testWriter' class='com.onlinetechvision.item.TestWriter' >\r\n \t<property name='userService' ref='userService'\/>\r\n <\/bean>\r\n\r\n <!-- Failed Step Tasklet Declaration -->\r\n <bean id='failedStepTasklet' class='com.onlinetechvision.tasklet.FailedStepTasklet'>\r\n <property name='taskResult' value='Error occurred!' \/>\r\n <\/bean> \r\n\r\n <!-- Batch Job Declarations -->\r\n <batch:job id='firstJob'>\r\n\t\t<batch:step id='firstStep' next='secondStep'>\r\n\t\t\t<batch:tasklet>\r\n\t\t\t\t<batch:chunk reader='firstTestReader' processor='testProcessor' writer='testWriter' commit-interval='2'\/>\r\n\t\t\t<\/batch:tasklet>\r\n\t\t<\/batch:step>\r\n\t\t<batch:step id='secondStep'>\r\n\t\t\t<batch:tasklet>\r\n\t\t\t\t<batch:chunk reader='secondTestReader' processor='testProcessor' writer='testWriter' commit-interval='2'\/>\r\n\t\t\t<\/batch:tasklet>\r\n\t\t<\/batch:step>\r\n\t<\/batch:job>\r\n\r\n\t<batch:job id='secondJob'>\r\n\t\t<batch:step id='thirdStep'>\r\n\t\t\t<batch:tasklet>\r\n\t\t\t\t<batch:chunk reader='thirdTestReader' processor='testProcessor' writer='testWriter' commit-interval='2'\/>\r\n\t\t\t<\/batch:tasklet>\r\n\t\t\t<batch:next on='*' to='fourthStep' \/>\r\n\t <batch:next on='FAILED' to='firstFailedStep' \/>\r\n\t <\/batch:step>\r\n\t <batch:step id='fourthStep'>\r\n\t\t\t<batch:tasklet>\r\n\t\t\t\t<batch:chunk reader='fourthTestReader' processor='testProcessor' writer='testWriter' commit-interval='2'\/>\r\n\t\t\t<\/batch:tasklet>\r\n\t\t<\/batch:step>\r\n\t\t<batch:step id='firstFailedStep'>\r\n <batch:tasklet ref='failedStepTasklet' \/>\r\n <\/batch:step>\r\n\t<\/batch:job>\r\n\r\n\t<batch:job id='thirdJob'>\r\n\t\t<batch:step id='fifthStep'>\r\n\t\t\t<batch:tasklet>\r\n\t\t\t\t<batch:chunk reader='failedCaseTestReader' processor='testProcessor' writer='testWriter' commit-interval='2'\/>\r\n\t\t\t<\/batch:tasklet>\r\n\t\t\t<batch:next on='*' to='sixthStep' \/>\r\n\t <batch:next on='FAILED' to='secondFailedStep' \/>\r\n\t <\/batch:step>\r\n\t <batch:step id='sixthStep'>\r\n\t\t\t<batch:tasklet>\r\n\t\t\t\t<batch:chunk reader='fifthTestReader' processor='testProcessor' writer='testWriter' commit-interval='2'\/>\r\n\t\t\t<\/batch:tasklet>\r\n\t\t<\/batch:step>\r\n\t\t<batch:step id='secondFailedStep'>\r\n <batch:tasklet ref='failedStepTasklet' \/>\r\n <\/batch:step>\r\n\t<\/batch:job>\r\n\r\n<\/beans><\/pre>\n
STEP 18 : CREATE applicationContext.xml <\/h2>\n
<?xml version='1.0' encoding='UTF-8'?>\r\n<beans xmlns='http:\/\/www.springframework.org\/schema\/beans'\r\n\txmlns:xsi='http:\/\/www.w3.org\/2001\/XMLSchema-instance'\r\n\txmlns:batch='http:\/\/www.springframework.org\/schema\/batch'\r\n\txsi:schemaLocation='http:\/\/www.springframework.org\/schema\/beans \r\n\r\nhttp:\/\/www.springframework.org\/schema\/beans\/spring-beans-3.0.xsd\r\n\r\nhttp:\/\/www.springframework.org\/schema\/batch\r\n\r\nhttp:\/\/www.springframework.org\/schema\/batch\/spring-batch-2.1.xsd'>\r\n\r\n\t<import resource='jobContext.xml'\/>\r\n\r\n <!-- User DAO Declaration -->\r\n\t<bean id='userDAO' class='com.onlinetechvision.user.dao.UserDAO'>\r\n\t\t<property name='sessionFactory' ref='sessionFactory' \/>\r\n\t<\/bean>\r\n\r\n\t<!-- User Service Declaration -->\r\n\t<bean id='userService' class='com.onlinetechvision.user.service.UserService'>\r\n\t\t<property name='userDAO' ref='userDAO' \/>\r\n\t<\/bean>\t\r\n\r\n\t<!-- BatchProcessStarter Declaration -->\r\n\t<bean id='batchProcessStarter' class='com.onlinetechvision.spring.batch.BatchProcessStarter'>\r\n\t\t<property name='jobLauncher' ref='jobLauncher'\/>\r\n\t\t<property name='jobRepository' ref='jobRepository'\/>\r\n\t\t<property name='firstJob' ref='firstJob'\/>\r\n\t\t<property name='secondJob' ref='secondJob'\/>\r\n\t\t<property name='thirdJob' ref='thirdJob'\/>\r\n <\/bean> \r\n\r\n<\/beans><\/pre>\n
STEP 19 : CREATE Application CLASS<\/h2>\n
package com.onlinetechvision.exe;\r\n\r\nimport org.springframework.context.ApplicationContext;\r\nimport org.springframework.context.support.ClassPathXmlApplicationContext;\r\n\r\nimport com.onlinetechvision.spring.batch.BatchProcessStarter;\r\n\r\n\/**\r\n * Application Class starts the application.\r\n *\r\n * @author onlinetechvision.com\r\n * @since 10 Dec 2012\r\n * @version 1.0.0\r\n *\r\n *\/\r\npublic class Application {\r\n\r\n\t\/**\r\n * Starts the application\r\n *\r\n * @param String[] args\r\n *\r\n *\/\r\n\tpublic static void main(String[] args) {\r\n\t\tApplicationContext appContext = new ClassPathXmlApplicationContext('applicationContext.xml');\r\n\t\tBatchProcessStarter batchProcessStarter = (BatchProcessStarter)appContext.getBean('batchProcessStarter');\r\n\t\tbatchProcessStarter.start();\r\n\t}\r\n\r\n}<\/pre>\nSTEP 20 : BUILD PROJECT<\/h2>\n
STEP 21 : RUN PROJECT<\/h2>\n
![\"\"](\"http:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2012\/12\/Result_Table2.png\" "\\"Result_Table\\"")
<\/a><\/p>\n16.12.2012 19:30:41 INFO (SimpleJobLauncher.java:118) - Job: [FlowJob: [name=firstJob]] launched with the following parameters: [{}]\r\n\r\n16.12.2012 19:30:41 DEBUG (AbstractJob.java:278) - Job execution starting: JobExecution: id=0, version=0, startTime=null, endTime=null, lastUpdated=Sun Dec 16 19:30:41 GMT 2012, status=STARTING, exitStatus=exitCode=UNKNOWN;exitDescription=, job=[JobInstance: id=0, version=0, JobParameters=[{}], Job=[firstJob]]\r\n\r\nUser List : [id : 181, name : FIRSTNAME_0, surname : FIRSTSURNAME_0, id : 182, name : FIRSTNAME_1, surname : FIRSTSURNAME_1, id : 183, name : FIRSTNAME_2, surname : FIRSTSURNAME_2, id : 184, name : SECONDNAME_0, surname : SECONDSURNAME_0, id : 185, name : SECONDNAME_1, surname : SECONDSURNAME_1, id : 186, name : SECONDNAME_2, surname : SECONDSURNAME_2]\r\n\r\n16.12.2012 19:30:42 DEBUG (BatchProcessStarter.java:43) - JobExecution: id=0, version=2, startTime=Sun Dec 16 19:30:41 GMT 2012, endTime=Sun Dec 16 19:30:42 GMT 2012, lastUpdated=Sun Dec 16 19:30:42 GMT 2012, status=COMPLETED, exitStatus=exitCode=COMPLETED;exitDescription=, job=[JobInstance: id=0, version=0, JobParameters=[{}], Job=[firstJob]]<\/pre>\n16.12.2012 19:30:42 INFO (SimpleJobLauncher.java:118) - Job: [FlowJob: [name=secondJob]] launched with the following parameters: [{}]\r\n\r\n16.12.2012 19:30:42 DEBUG (AbstractJob.java:278) - Job execution starting: JobExecution: id=1, version=0, startTime=null, endTime=null, lastUpdated=Sun Dec 16 19:30:42 GMT 2012, status=STARTING, exitStatus=exitCode=UNKNOWN;exitDescription=, job=[JobInstance: id=1, version=0, JobParameters=[{}], Job=[secondJob]]\r\n\r\nUser List : [id : 181, name : FIRSTNAME_0, surname : FIRSTSURNAME_0, id : 182, name : FIRSTNAME_1, surname : FIRSTSURNAME_1, id : 183, name : FIRSTNAME_2, surname : FIRSTSURNAME_2, id : 184, name : SECONDNAME_0, surname : SECONDSURNAME_0, id : 185, name : SECONDNAME_1, surname : SECONDSURNAME_1, id : 186, name : SECONDNAME_2, surname : SECONDSURNAME_2, id : 187, name : THIRDNAME_0, surname : THIRDSURNAME_0, id : 188, name : THIRDNAME_1, surname : THIRDSURNAME_1, id : 189, name : THIRDNAME_2, surname : THIRDSURNAME_2, id : 190, name : THIRDNAME_3, surname : THIRDSURNAME_3, id : 191, name : FOURTHNAME_0, surname : FOURTHSURNAME_0, id : 192, name : FOURTHNAME_1, surname : FOURTHSURNAME_1, id : 193, name : FOURTHNAME_2, surname : FOURTHSURNAME_2, id : 194, name : FOURTHNAME_3, surname : FOURTHSURNAME_3]\r\n\r\n16.12.2012 19:30:42 DEBUG (BatchProcessStarter.java:47) - JobExecution: id=1, version=2, startTime=Sun Dec 16 19:30:42 GMT 2012, endTime=Sun Dec 16 19:30:42 GMT 2012, lastUpdated=Sun Dec 16 19:30:42 GMT 2012, status=COMPLETED, exitStatus=exitCode=COMPLETED;exitDescription=, job=[JobInstance: id=1, version=0, JobParameters=[{}], Job=[secondJob]]<\/pre>\n16.12.2012 19:30:42 INFO (SimpleJobLauncher.java:118) - Job: [FlowJob: [name=thirdJob]] launched with the following parameters: [{}]\r\n\r\n16.12.2012 19:30:42 DEBUG (AbstractJob.java:278) - Job execution starting: JobExecution: id=2, version=0, startTime=null, endTime=null, lastUpdated=Sun Dec 16 19:30:42 GMT 2012, status=STARTING, exitStatus=exitCode=UNKNOWN;exitDescription=, job=[JobInstance: id=2, version=0, JobParameters=[{}], Job=[thirdJob]]\r\n\r\n16.12.2012 19:30:42 DEBUG (TransactionTemplate.java:159) - Initiating transaction rollback on application exception\r\norg.springframework.batch.repeat.RepeatException: Exception in batch process; nested exception is java.lang.Exception: Unexpected Error!\r\n...\r\n\r\n16.12.2012 19:30:43 DEBUG (BatchProcessStarter.java:51) - JobExecution: id=2, version=2, startTime=Sun Dec 16 19:30:42 GMT 2012, endTime=Sun Dec 16 19:30:43 GMT 2012, lastUpdated=Sun Dec 16 19:30:43 GMT 2012, status=FAILED, exitStatus=exitCode=FAILED;exitDescription=, job=[JobInstance: id=2, version=0, JobParameters=[{}], Job=[thirdJob]]<\/pre>\n
\nhttps:\/\/github.com\/erenavsarogullari\/OTV_SpringBatch_Chunk_Oriented_Processing<\/a><\/strong><\/p>\nResources:<\/h4>\n
\n <\/p>\n