Browse Source
* Auto config in main bootstrap jar * Compiler enhancements in groovy cli * Sample script in cli samples [Fixes #48716881], [Fixes #48788313]pull/1/head
8 changed files with 195 additions and 54 deletions
@ -0,0 +1,48 @@
@@ -0,0 +1,48 @@
|
||||
/* |
||||
* Copyright 2012-2013 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 org.springframework.bootstrap.autoconfigure.batch; |
||||
|
||||
import org.springframework.batch.core.launch.JobLauncher; |
||||
import org.springframework.bootstrap.CommandLineRunner; |
||||
import org.springframework.bootstrap.context.annotation.ConditionalOnClass; |
||||
import org.springframework.bootstrap.context.annotation.ConditionalOnMissingBean; |
||||
import org.springframework.bootstrap.context.annotation.EnableAutoConfiguration; |
||||
import org.springframework.context.annotation.Bean; |
||||
import org.springframework.context.annotation.Configuration; |
||||
|
||||
/** |
||||
* {@link EnableAutoConfiguration Auto-configuration} for Spring Batch. |
||||
* |
||||
* @author Dave Syer |
||||
*/ |
||||
@Configuration |
||||
@ConditionalOnClass({ JobLauncher.class }) |
||||
public class BatchAutoConfiguration { |
||||
|
||||
@Bean |
||||
// Harmless to always include this, but maybe could make it conditional as well
|
||||
public BatchDatabaseInitializer batchDatabaseInitializer() { |
||||
return new BatchDatabaseInitializer(); |
||||
} |
||||
|
||||
@Bean |
||||
@ConditionalOnMissingBean({ CommandLineRunner.class }) |
||||
public JobLauncherCommandLineRunner jobLauncherCommandLineRunner() { |
||||
return new JobLauncherCommandLineRunner(); |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,53 @@
@@ -0,0 +1,53 @@
|
||||
/* |
||||
* Copyright 2012-2013 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 org.springframework.bootstrap.autoconfigure.batch; |
||||
|
||||
import javax.annotation.PostConstruct; |
||||
import javax.sql.DataSource; |
||||
|
||||
import org.springframework.batch.support.DatabaseType; |
||||
import org.springframework.beans.factory.annotation.Autowired; |
||||
import org.springframework.core.io.ResourceLoader; |
||||
import org.springframework.jdbc.datasource.init.DatabasePopulatorUtils; |
||||
import org.springframework.jdbc.datasource.init.ResourceDatabasePopulator; |
||||
import org.springframework.stereotype.Component; |
||||
|
||||
@Component |
||||
public class BatchDatabaseInitializer { |
||||
|
||||
@Autowired |
||||
private DataSource dataSource; |
||||
|
||||
@Autowired |
||||
private ResourceLoader resourceLoader; |
||||
|
||||
@PostConstruct |
||||
protected void initialize() throws Exception { |
||||
String platform = DatabaseType.fromMetaData(this.dataSource).toString() |
||||
.toLowerCase(); |
||||
if ("hsql".equals(platform)) { |
||||
platform = "hsqldb"; |
||||
} |
||||
ResourceDatabasePopulator populator = new ResourceDatabasePopulator(); |
||||
populator |
||||
.addScript(this.resourceLoader |
||||
.getResource("org/springframework/batch/core/schema-" + platform |
||||
+ ".sql")); |
||||
populator.setContinueOnError(true); |
||||
DatabasePopulatorUtils.execute(populator, this.dataSource); |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,62 @@
@@ -0,0 +1,62 @@
|
||||
/* |
||||
* Copyright 2012-2013 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 org.springframework.bootstrap.autoconfigure.batch; |
||||
|
||||
import java.util.Arrays; |
||||
import java.util.Properties; |
||||
|
||||
import org.apache.commons.logging.Log; |
||||
import org.apache.commons.logging.LogFactory; |
||||
import org.springframework.batch.core.Job; |
||||
import org.springframework.batch.core.JobExecutionException; |
||||
import org.springframework.batch.core.converter.DefaultJobParametersConverter; |
||||
import org.springframework.batch.core.converter.JobParametersConverter; |
||||
import org.springframework.batch.core.launch.JobLauncher; |
||||
import org.springframework.beans.factory.annotation.Autowired; |
||||
import org.springframework.bootstrap.CommandLineRunner; |
||||
import org.springframework.stereotype.Component; |
||||
import org.springframework.util.StringUtils; |
||||
|
||||
@Component |
||||
// FIXME: what to do with more than one Job?
|
||||
public class JobLauncherCommandLineRunner implements CommandLineRunner { |
||||
|
||||
private static Log logger = LogFactory.getLog(JobLauncherCommandLineRunner.class); |
||||
|
||||
@Autowired(required = false) |
||||
private JobParametersConverter converter = new DefaultJobParametersConverter(); |
||||
|
||||
@Autowired |
||||
private JobLauncher jobLauncher; |
||||
|
||||
@Autowired |
||||
private Job job; |
||||
|
||||
public void run(String... args) { |
||||
logger.info("Running default command line with: " + Arrays.asList(args)); |
||||
launchJobFromProperties(StringUtils.splitArrayElementsIntoProperties(args, |
||||
"=")); |
||||
} |
||||
|
||||
protected void launchJobFromProperties(Properties properties) { |
||||
try { |
||||
this.jobLauncher.run(this.job, |
||||
this.converter.getJobParameters(properties)); |
||||
} catch (JobExecutionException e) { |
||||
throw new IllegalStateException("Could not run job", e); |
||||
} |
||||
} |
||||
} |
||||
Loading…
Reference in new issue