updating spring batch example

Author: paxtonhare

examples/spring-batch/build.gradle

@@ -1,13 +1,12 @@
 plugins {
     id 'java'
-    id 'eclipse'
-    id 'idea'
     id 'application'
     id 'net.saliman.properties' version '1.4.6'
     id 'com.marklogic.ml-data-hub' version '1.1.2'
 }
 
 repositories {
+    mavenLocal()
     jcenter()
     maven {url 'http://developer.marklogic.com/maven2/'}
 }
@@ -21,10 +20,19 @@ dependencies {
     runtime "com.marklogic:marklogic-spring-batch-core:0.7.2"
 }
 
-distributions {
-    main {
-        baseName = 'baseJob'
-    }
-}
-
 mainClassName = "com.marklogic.spring.batch.Main"
+
+task importMonsters(type: JavaExec) {
+    classpath = sourceSets.main.runtimeClasspath
+    main = "com.marklogic.spring.batch.Main"
+    args = [
+            "--config", "example.LoadAndRunFlow",
+            "--project_dir", ".",
+            "--env", "local",
+            "--input_file_path", "./input",
+            "--input_file_pattern", ".*\\.xml",
+            "--entity_name", "Monster",
+            "--flow_name", "ingest-monster",
+            "--chunk", "100"
+    ]
+}

examples/spring-batch/settings.gradle

@@ -21,6 +21,7 @@
 import org.springframework.context.annotation.Import;
 import org.springframework.core.env.Environment;
 import org.springframework.core.io.Resource;
+import com.marklogic.hub.HubConfig;
 
 import java.util.*;
 
@@ -41,13 +42,16 @@ public Job job(JobBuilderFactory jobBuilderFactory, Step step) {
     public Step step(
             StepBuilderFactory stepBuilderFactory,
             DatabaseClientProvider databaseClientProvider,
+            @Value("#{jobParameters['project_dir']}") String projectDir,
             @Value("#{jobParameters['input_file_path']}") String inputFilePath,
             @Value("#{jobParameters['input_file_pattern']}") String inputFilePattern,
             @Value("#{jobParameters['entity_name']}") String entityName,
             @Value("#{jobParameters['flow_name']}") String flowName,
             @Value("#{jobParameters['output_collections']}") String[] collections) {
 
-        GenericDocumentManager docMgr = databaseClientProvider.getDatabaseClient().newDocumentManager();
+        HubConfig hubConfig = HubConfig.hubFromEnvironment(projectDir, "local");
+
+        GenericDocumentManager docMgr = hubConfig.newStagingClient().newDocumentManager();
 
         ItemProcessor<Resource, DocumentWriteOperation> processor = new ResourceToDocumentWriteOperationItemProcessor();
         ItemWriter<DocumentWriteOperation> writer = new ItemWriter<DocumentWriteOperation>() {