Add cli archetype

archetypes/simple-cli/src/main/java/example/ExampleItemReader.java

@@ -0,0 +1,22 @@
+package example;
+
+import org.springframework.batch.item.AbstractItemReader;
+import org.springframework.batch.item.ItemReader;
+
+/**
+ * {@link ItemReader} with hard-coded input data.
+ */
+public class ExampleItemReader extends AbstractItemReader {
+	
+	private String[] input = {"Hello world!", null};
+	
+	private int index = 0;
+	
+	/**
+	 * Reads next record from input
+	 */
+	public Object read() throws Exception {
+		return input[index++];
+	}
+
+}

archetypes/simple-cli/src/main/java/example/ExampleItemWriter.java

@@ -0,0 +1,23 @@
+package example;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.batch.item.AbstractItemWriter;
+import org.springframework.batch.item.ItemWriter;
+
+
+/**
+ * Dummy {@link ItemWriter} which only logs data it receives.
+ */
+public class ExampleItemWriter extends AbstractItemWriter {
+
+	private static final Log log = LogFactory.getLog(ExampleItemWriterTests.class);
+	
+	/**
+	 * @see ItemWriter#write(Object)
+	 */
+	public void write(Object data) throws Exception {
+		log.info(data);
+	}
+
+}

archetypes/simple-cli/src/main/resources/data-source-context.xml

@@ -0,0 +1,64 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xmlns:util="http://www.springframework.org/schema/util"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
+	http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-2.0.xsd">
+
+	<!--  Initialise the database before every test case: -->
+	<import resource="data-source-context-init.xml" />
+	<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
+		<property name="driverClassName" value="${batch.jdbc.driver}" />
+		<property name="url" value="${batch.jdbc.url}" />
+		<property name="username" value="${batch.jdbc.user}" />
+		<property name="password" value="${batch.jdbc.password}" />
+	</bean>
+	<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager" lazy-init="true">
+		<property name="dataSource" ref="dataSource" />
+	</bean>
+	<!-- Set up or detect a System property called "environment" used to construct a properties file on the classpath.  The default is "hsql".  -->
+	<bean id="environment" class="org.springframework.beans.factory.config.MethodInvokingFactoryBean">
+		<property name="targetClass" value="java.lang.System" />
+		<property name="targetMethod" value="setProperty" />
+		<property name="arguments">
+			<list>
+				<value>environment</value>
+				<bean class="java.lang.System" factory-method="getProperty">
+					<constructor-arg>
+						<value>environment</value>
+					</constructor-arg>
+					<!-- The default value of the environment property -->
+					<constructor-arg>
+						<value>hsql</value>
+					</constructor-arg>
+				</bean>
+			</list>
+		</property>
+	</bean>
+
+	<!--  Use this to set additional properties on beans at run time -->
+	<bean id="overrideProperties" class="org.springframework.beans.factory.config.PropertyOverrideConfigurer"
+		depends-on="environment">
+		<property name="location" value="classpath:batch-${environment}.properties" />
+		<!-- Allow system properties (-D) to override those from file -->
+		<property name="localOverride" value="true" />
+		<property name="properties">
+			<bean class="java.lang.System" factory-method="getProperties" />
+		</property>
+		<property name="ignoreInvalidKeys" value="true" />
+		<property name="order" value="2" />
+	</bean>
+	<bean id="placeholderProperties" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"
+		depends-on="environment">
+		<property name="location" value="classpath:batch-${environment}.properties" />
+		<property name="systemPropertiesModeName" value="SYSTEM_PROPERTIES_MODE_OVERRIDE" />
+		<property name="ignoreUnresolvablePlaceholders" value="true" />
+		<property name="order" value="1" />
+	</bean>
+	<bean id="lobHandler" class="${batch.lob.handler.class}" />
+	<bean id="incrementerParent" class="${batch.database.incrementer.class}">
+		<property name="dataSource" ref="dataSource" />
+		<property name="incrementerName" value="ID" />
+	</bean>
+
+	<!--import resource="alt-data-source-context.xml" /-->
+</beans>

archetypes/simple-cli/src/main/resources/example/simpleJob.xml

@@ -0,0 +1,25 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans 
+       	http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
+
+	<description>Example job to get you started. It provides a skeleton for a typical batch application.</description>
+	
+	<import resource="classpath:/simple-job-launcher-context.xml"/>
+
+	<bean id="job1" parent="simpleJob">
+		<property name="steps">
+			<list>
+				<bean id="step1" parent="simpleStep">
+					<property name="itemReader">
+						<bean class="example.ExampleItemReader" />
+					</property>
+					<property name="itemWriter">
+						<bean class="example.ExampleItemWriter" />
+					</property>
+				</bean>
+			</list>
+		</property>
+	</bean>
+
+</beans>

archetypes/simple-cli/src/main/resources/log4j.properties

@@ -0,0 +1,13 @@
+log4j.rootCategory=INFO, stdout
+
+log4j.appender.stdout=org.apache.log4j.ConsoleAppender
+log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
+log4j.appender.stdout.layout.ConversionPattern=%d %p [%c] - <%m>%n
+
+log4j.category.org.apache.activemq=ERROR
+log4j.category.org.springframework.batch=DEBUG
+log4j.category.org.springframework.transaction=INFO
+
+log4j.category.org.hibernate.SQL=DEBUG
+# for debugging datasource initialization
+# log4j.category.test.jdbc=DEBUG

archetypes/simple-cli/src/test/java/test/jdbc/datasource/InitializingDataSourceFactoryBean.java

@@ -0,0 +1,152 @@
+/*
+ * Copyright 2006-2007 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package test.jdbc.datasource;
+
+import java.io.IOException;
+import java.util.Iterator;
+import java.util.List;
+
+import javax.sql.DataSource;
+
+import org.apache.commons.io.IOUtils;
+import org.springframework.beans.factory.BeanInitializationException;
+import org.springframework.beans.factory.config.AbstractFactoryBean;
+import org.springframework.core.io.Resource;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.datasource.DataSourceTransactionManager;
+import org.springframework.transaction.TransactionStatus;
+import org.springframework.transaction.support.TransactionCallback;
+import org.springframework.transaction.support.TransactionTemplate;
+import org.springframework.util.Assert;
+import org.springframework.util.StringUtils;
+
+public class InitializingDataSourceFactoryBean extends AbstractFactoryBean {
+
+	private Resource[] initScripts;
+
+	private Resource destroyScript;
+
+	DataSource dataSource;
+
+	private static boolean initialized = false;
+
+	/**
+	 * @throws Throwable
+	 * @see java.lang.Object#finalize()
+	 */
+	protected void finalize() throws Throwable {
+		super.finalize();
+		initialized = false;
+		logger.debug("finalize called");
+	}
+
+	protected void destroyInstance(Object instance) throws Exception {
+		try {
+			doExecuteScript(destroyScript);
+		}
+		catch (Exception e) {
+			if (logger.isDebugEnabled()) {
+				logger.warn("Could not execute destroy script [" + destroyScript + "]", e);
+			}
+			else {
+				logger.warn("Could not execute destroy script [" + destroyScript + "]");
+			}
+		}
+	}
+
+	public void afterPropertiesSet() throws Exception {
+		Assert.notNull(dataSource);
+		super.afterPropertiesSet();
+	}
+
+	protected Object createInstance() throws Exception {
+		Assert.notNull(dataSource);
+		if (!initialized) {
+			try {
+				doExecuteScript(destroyScript);
+			}
+			catch (Exception e) {
+				logger.debug("Could not execute destroy script [" + destroyScript + "]", e);
+			}
+			if (initScripts != null) {
+				for (int i = 0; i < initScripts.length; i++) {
+					Resource initScript = initScripts[i];
+					doExecuteScript(initScript);
+				}
+			}
+			initialized = true;
+		}
+		return dataSource;
+	}
+
+	private void doExecuteScript(final Resource scriptResource) {
+		if (scriptResource == null || !scriptResource.exists())
+			return;
+		TransactionTemplate transactionTemplate = new TransactionTemplate(new DataSourceTransactionManager(dataSource));
+		transactionTemplate.execute(new TransactionCallback() {
+
+			public Object doInTransaction(TransactionStatus status) {
+				JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
+				String[] scripts;
+				try {
+					scripts = StringUtils.delimitedListToStringArray(stripComments(IOUtils.readLines(scriptResource
+							.getInputStream())), ";");
+				}
+				catch (IOException e) {
+					throw new BeanInitializationException("Cannot load script from [" + scriptResource + "]", e);
+				}
+				for (int i = 0; i < scripts.length; i++) {
+					String script = scripts[i].trim();
+					if (StringUtils.hasText(script)) {
+						jdbcTemplate.execute(scripts[i]);
+					}
+				}
+				return null;
+			}
+
+		});
+
+	}
+
+	private String stripComments(List list) {
+		StringBuffer buffer = new StringBuffer();
+		for (Iterator iter = list.iterator(); iter.hasNext();) {
+			String line = (String) iter.next();
+			if (!line.startsWith("//") && !line.startsWith("--")) {
+				buffer.append(line + "\n");
+			}
+		}
+		return buffer.toString();
+	}
+
+	public Class getObjectType() {
+		return DataSource.class;
+	}
+
+	public void setInitScripts(Resource[] initScripts) {
+		this.initScripts = initScripts;
+	}
+
+	public void setDestroyScript(Resource destroyScript) {
+		this.destroyScript = destroyScript;
+	}
+
+	public void setDataSource(DataSource dataSource) {
+		this.dataSource = dataSource;
+	}
+
+}