added lombok, refactoring to english language

demo-spring-batch/.factorypath

@@ -0,0 +1,35 @@
+<factorypath>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/boot/spring-boot-starter-batch/2.1.3.RELEASE/spring-boot-starter-batch-2.1.3.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/boot/spring-boot-starter/2.1.3.RELEASE/spring-boot-starter-2.1.3.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/boot/spring-boot/2.1.3.RELEASE/spring-boot-2.1.3.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/boot/spring-boot-autoconfigure/2.1.3.RELEASE/spring-boot-autoconfigure-2.1.3.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/boot/spring-boot-starter-logging/2.1.3.RELEASE/spring-boot-starter-logging-2.1.3.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/ch/qos/logback/logback-classic/1.2.3/logback-classic-1.2.3.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/ch/qos/logback/logback-core/1.2.3/logback-core-1.2.3.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/apache/logging/log4j/log4j-to-slf4j/2.11.2/log4j-to-slf4j-2.11.2.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/apache/logging/log4j/log4j-api/2.11.2/log4j-api-2.11.2.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/slf4j/jul-to-slf4j/1.7.25/jul-to-slf4j-1.7.25.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/javax/annotation/javax.annotation-api/1.3.2/javax.annotation-api-1.3.2.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/yaml/snakeyaml/1.23/snakeyaml-1.23.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/boot/spring-boot-starter-jdbc/2.1.3.RELEASE/spring-boot-starter-jdbc-2.1.3.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/com/zaxxer/HikariCP/3.2.0/HikariCP-3.2.0.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/batch/spring-batch-core/4.1.1.RELEASE/spring-batch-core-4.1.1.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/com/fasterxml/jackson/core/jackson-databind/2.9.8/jackson-databind-2.9.8.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/com/fasterxml/jackson/core/jackson-annotations/2.9.0/jackson-annotations-2.9.0.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/com/fasterxml/jackson/core/jackson-core/2.9.8/jackson-core-2.9.8.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/javax/batch/javax.batch-api/1.0/javax.batch-api-1.0.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/codehaus/jettison/jettison/1.2/jettison-1.2.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/batch/spring-batch-infrastructure/4.1.1.RELEASE/spring-batch-infrastructure-4.1.1.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/retry/spring-retry/1.2.4.RELEASE/spring-retry-1.2.4.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/spring-aop/5.1.5.RELEASE/spring-aop-5.1.5.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/spring-beans/5.1.5.RELEASE/spring-beans-5.1.5.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/spring-context/5.1.5.RELEASE/spring-context-5.1.5.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/spring-expression/5.1.5.RELEASE/spring-expression-5.1.5.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/spring-tx/5.1.5.RELEASE/spring-tx-5.1.5.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/hsqldb/hsqldb/2.4.1/hsqldb-2.4.1.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/slf4j/slf4j-api/1.7.25/slf4j-api-1.7.25.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/spring-core/5.1.5.RELEASE/spring-core-5.1.5.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/spring-jcl/5.1.5.RELEASE/spring-jcl-5.1.5.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/springframework/spring-jdbc/5.1.5.RELEASE/spring-jdbc-5.1.5.RELEASE.jar" enabled="true" runInBatchMode="false"/>
+    <factorypathentry kind="VARJAR" id="M2_REPO/org/projectlombok/lombok/1.18.6/lombok-1.18.6.jar" enabled="true" runInBatchMode="false"/>
+</factorypath>

demo-spring-batch/pom.xml

@@ -1,12 +1,13 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 	<modelVersion>4.0.0</modelVersion>
 	<parent>
 		<groupId>org.springframework.boot</groupId>
 		<artifactId>spring-boot-starter-parent</artifactId>
 		<version>2.1.3.RELEASE</version>
-		<relativePath/> <!-- lookup parent from repository -->
+		<relativePath /> <!-- lookup parent from repository -->
 	</parent>
 	<groupId>com.example</groupId>
 	<artifactId>demo-spring-batch</artifactId>
@@ -39,6 +40,14 @@
 			<artifactId>spring-batch-test</artifactId>
 			<scope>test</scope>
 		</dependency>
+
+		<!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
+		<dependency>
+			<groupId>org.projectlombok</groupId>
+			<artifactId>lombok</artifactId>
+			<scope>provided</scope>
+		</dependency>
+
 	</dependencies>
 
 	<build>

demo-spring-batch/src/main/java/com/example/demospringbatch/BatchConfiguration.java

@@ -20,63 +20,59 @@
 import org.springframework.core.io.ClassPathResource;
 
 import com.example.demospringbatch.listener.JobListener;
-import com.example.demospringbatch.model.Persona;
-import com.example.demospringbatch.processor.PersonaItemProcessor;
+import com.example.demospringbatch.model.Person;
+import com.example.demospringbatch.processor.PersonItemProcessor;
 
 @Configuration
 @EnableBatchProcessing
 public class BatchConfiguration {
-	
+
 	@Autowired
 	public JobBuilderFactory jobBuilderFactory;
-	
+
 	@Autowired
 	public StepBuilderFactory stepBuilderFactory;
-	
+
 	@Bean
-	public FlatFileItemReader<Persona> reader(){
-		return new FlatFileItemReaderBuilder<Persona>()
-			   .name("personaItemReader")
-			   .resource(new ClassPathResource("sample-data.csv"))
-			   .delimited()
-			   .names(new String[] {"primerNombre", "segundoNombre", "telefono"})
-			   .fieldSetMapper(new BeanWrapperFieldSetMapper<Persona>() {{
-				   setTargetType(Persona.class);
-			   }})
-			   .build();
+	public FlatFileItemReader<Person> reader() {
+		return new FlatFileItemReaderBuilder<Person>().name("personItemReader")
+				.resource(new ClassPathResource("sample-data.csv")).delimited()
+				.names(new String[] { "firstName", "secondName", "phone" })
+				.fieldSetMapper(new BeanWrapperFieldSetMapper<Person>() {
+					{
+						setTargetType(Person.class);
+					}
+				}).build();
 	}
-	
+
 	@Bean
-	public PersonaItemProcessor processor() {
-		return new PersonaItemProcessor();
+	public PersonItemProcessor processor() {
+		return new PersonItemProcessor();
 	}
-	
+
 	@Bean
-	public JdbcBatchItemWriter<Persona> writer(DataSource dataSource){
-		return new JdbcBatchItemWriterBuilder<Persona>()
+	public JdbcBatchItemWriter<Person> writer(DataSource dataSource) {
+		return new JdbcBatchItemWriterBuilder<Person>()
 				.itemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<>())
-				.sql("INSERT INTO persona (primer_nombre, segundo_nombre, telefono) VALUES (:primerNombre, :segundoNombre, :telefono)")
-				.dataSource(dataSource)
-				.build();
+				.sql("INSERT INTO person (first_name, second_name, phone) VALUES (:firstName, :secondName, :phone)")
+				.dataSource(dataSource).build();
 	}
-	
+
 	@Bean
 	public Job importPersonaJob(JobListener listener, Step step1) {
-		return jobBuilderFactory.get("importPersonaJob")
+		return jobBuilderFactory.get("importPersonJob")
 				.incrementer(new RunIdIncrementer())
 				.listener(listener)
-				.flow(step1)
-				.end()
-				.build();
+				.flow(step1).end().build();
 	}
-	
+
 	@Bean
-	public Step step1(JdbcBatchItemWriter<Persona> writer) {
+	public Step step1(JdbcBatchItemWriter<Person> writer) {
 		return stepBuilderFactory.get("step1")
-				.<Persona, Persona> chunk(10)
+				.<Person, Person>chunk(10)
 				.reader(reader())
-				.writer(writer)
-				.build();
+				.processor(processor())
+				.writer(writer).build();
 	}
 
 }

demo-spring-batch/src/main/java/com/example/demospringbatch/listener/JobListener.java

@@ -1,20 +1,20 @@
 package com.example.demospringbatch.listener;
 
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import org.springframework.batch.core.BatchStatus;
 import org.springframework.batch.core.JobExecution;
 import org.springframework.batch.core.listener.JobExecutionListenerSupport;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Component;
 
-import com.example.demospringbatch.model.Persona;
+import com.example.demospringbatch.model.Person;
 
+import lombok.extern.log4j.Log4j2;
+
+@Log4j2
 @Component
 public class JobListener extends JobExecutionListenerSupport {
 
-	private static final Logger LOG = LoggerFactory.getLogger(JobListener.class);
 
 	private JdbcTemplate jdbcTemplate;
 
@@ -27,12 +27,14 @@ public JobListener(JdbcTemplate jdbcTemplate) {
 	@Override
 	public void afterJob(JobExecution jobExecution) {
 		if (jobExecution.getStatus() == BatchStatus.COMPLETED) {
-			LOG.info("FINALIZÓ EL JOB!! Verifica los resultados:");
+			log.info("===========================================================\n");
+			log.info("The Job is over!! Check the results converted to uppercase:\n");
+			log.info("===========================================================\n");
 
 			jdbcTemplate
-					.query("SELECT primer_nombre, segundo_nombre, telefono FROM persona",
-							(rs, row) -> new Persona(rs.getString(1), rs.getString(2), rs.getString(3)))
-					.forEach(persona -> LOG.info("Registro < " + persona + " >"));
+					.query("SELECT first_name, second_name, phone FROM person",
+							(rs, row) -> new Person(rs.getString(1), rs.getString(2), rs.getString(3)))
+					.forEach(person -> log.info("Record < " + person + " >"));
 		}
 	}
 

demo-spring-batch/src/main/java/com/example/demospringbatch/model/Person.java

@@ -0,0 +1,16 @@
+package com.example.demospringbatch.model;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class Person {
+
+	private String firstName;
+	private String secondName;
+	private String phone;
+
+}

demo-spring-batch/src/main/java/com/example/demospringbatch/processor/PersonItemProcessor.java

@@ -0,0 +1,25 @@
+package com.example.demospringbatch.processor;
+
+import org.springframework.batch.item.ItemProcessor;
+
+import com.example.demospringbatch.model.Person;
+
+import lombok.extern.log4j.Log4j2;
+
+@Log4j2
+public class PersonItemProcessor implements ItemProcessor<Person, Person> {
+
+	@Override
+	public Person process(Person item) throws Exception {
+		String firstName = item.getFirstName().toUpperCase();
+		String secondName = item.getSecondName().toUpperCase();
+		String phone = item.getPhone();
+
+		Person person = new Person(firstName, secondName, phone);
+
+		log.info("Changing ("+item+") a ("+person+")");
+
+		return person;
+	}
+
+}

demo-spring-batch/src/main/resources/schema-all.sql

@@ -1,8 +1,8 @@
-DROP TABLE persona IF EXISTS;
+DROP TABLE person IF EXISTS;
 
-CREATE TABLE persona(
+CREATE TABLE person(
   id BIGINT IDENTITY NOT NULL PRIMARY KEY,
-  primer_nombre VARCHAR(20),
-  segundo_nombre VARCHAR(20),
-  telefono VARCHAR(10)
+  first_name VARCHAR(20),
+  second_name VARCHAR(20),
+  phone VARCHAR(10)
 );