Added test for chunk-csv-database project.

Needs wildfly 8.0.0.CR1, because of https://issues.jboss.org/browse/WFLY-2027.

Author: radcortez

batch/chunk-csv-database/pom.xml

@@ -9,8 +9,13 @@
         <relativePath>../pom.xml</relativePath>
     </parent>
 
-    <groupId>org.javaee7.batch</groupId>
     <artifactId>chunk-csv-database</artifactId>
-    <version>1.0-SNAPSHOT</version>
     <packaging>war</packaging>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.javaee7</groupId>
+            <artifactId>util-samples</artifactId>
+        </dependency>
+    </dependencies>
 </project>

batch/chunk-csv-database/src/main/resources/META-INF/create.sql

@@ -1 +1,2 @@
-CREATE TABLE CHUNK_CSV_DATABASE ("ID" INTEGER not null primary key, "NAME" VARCHAR(50) not null primary key, "HIREDATE" VARCHAR(50) not null)
+CREATE SEQUENCE HIBERNATE_SEQUENCE
+CREATE TABLE CHUNK_CSV_DATABASE ("ID" INTEGER not null primary key, "NAME" VARCHAR(50) not null, "HIREDATE" VARCHAR(50) not null)

batch/chunk-csv-database/src/main/resources/META-INF/drop.sql

@@ -1 +1,2 @@
-DROP TABLE CHUNK_CSV_DATABASE
+DROP TABLE CHUNK_CSV_DATABASE
+DROP SEQUENCE HIBERNATE_SEQUENCE

batch/chunk-csv-database/src/main/resources/META-INF/mydata.csv

@@ -1,5 +1,5 @@
 Penny, 12/1/12
-Leonard Hofstadter, 14/6/08
+Leonard Hofstadter, 12/6/08
 Howard Wolowitz, 8/27/7
 Bernadette Rostenkowski-Wolowitz, 8/14/13
 Sheldon Cooper, 3/18/9

batch/chunk-csv-database/src/test/java/org/javaee7/batch/chunk/csv/database/BatchCSVDatabaseTest.java

@@ -0,0 +1,74 @@
+package org.javaee7.batch.chunk.csv.database;
+
+import org.javaee7.util.BatchTestHelper;
+import org.jboss.arquillian.container.test.api.Deployment;
+import org.jboss.arquillian.junit.Arquillian;
+import org.jboss.shrinkwrap.api.ArchivePaths;
+import org.jboss.shrinkwrap.api.ShrinkWrap;
+import org.jboss.shrinkwrap.api.asset.EmptyAsset;
+import org.jboss.shrinkwrap.api.spec.WebArchive;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+import javax.batch.operations.JobOperator;
+import javax.batch.runtime.*;
+import javax.persistence.EntityManager;
+import javax.persistence.PersistenceContext;
+import javax.persistence.Query;
+import java.util.List;
+import java.util.Map;
+import java.util.Properties;
+
+import static org.junit.Assert.assertEquals;
+
+/**
+ * @author Roberto Cortez
+ */
+@RunWith(Arquillian.class)
+public class BatchCSVDatabaseTest {
+    @PersistenceContext
+    private EntityManager entityManager;
+
+    @Deployment
+    public static WebArchive createDeployment() {
+        WebArchive war = ShrinkWrap.create(WebArchive.class)
+                .addClass(BatchTestHelper.class)
+                .addPackage("org.javaee7.batch.chunk.csv.database")
+                .addAsWebInfResource(EmptyAsset.INSTANCE, ArchivePaths.create("beans.xml"))
+                .addAsResource("META-INF/batch-jobs/myJob.xml")
+                .addAsResource("META-INF/persistence.xml")
+                .addAsResource("META-INF/create.sql")
+                .addAsResource("META-INF/drop.sql")
+                .addAsResource("META-INF/mydata.csv");
+        System.out.println(war.toString(true));
+        return war;
+    }
+
+    @Test
+    public void testBatchCSVDatabase() throws Exception {
+        JobOperator jobOperator = BatchRuntime.getJobOperator();
+        Long executionId = jobOperator.start("myJob", new Properties());
+        JobExecution jobExecution = jobOperator.getJobExecution(executionId);
+
+        BatchTestHelper.keepTestAlive(jobExecution);
+
+        List<StepExecution> stepExecutions = jobOperator.getStepExecutions(executionId);
+        for (StepExecution stepExecution : stepExecutions) {
+            if (stepExecution.getStepName().equals("myStep")) {
+                Map<Metric.MetricType, Long> metricsMap = BatchTestHelper.getMetricsMap(stepExecution.getMetrics());
+                System.out.println(metricsMap);
+
+                assertEquals(7L, (long) metricsMap.get(Metric.MetricType.READ_COUNT));
+                assertEquals(7L, (long) metricsMap.get(Metric.MetricType.WRITE_COUNT));
+                assertEquals(3L, (long) metricsMap.get(Metric.MetricType.COMMIT_COUNT));
+            }
+        }
+
+        Query query = entityManager.createQuery("SELECT p FROM Person p");
+        @SuppressWarnings("unchecked")
+        List<Person> persons = query.getResultList();
+
+        assertEquals(7L, persons.size());
+        assertEquals(jobExecution.getBatchStatus(), BatchStatus.COMPLETED);
+    }
+}