首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >Spring批处理--没有找到产品名称的DatabaseType:[]

问Spring批处理--没有找到产品名称的DatabaseType:[]
EN

Stack Overflow用户
提问于 2016-01-05 23:10:38
回答 1查看 3.7K关注 0票数 2

我想用Spring引导来实现Spring,因为我们使用的是informix数据库,所以当我的spring引导应用程序启动时,我会遇到以下异常。

配置:

代码语言:javascript
复制
@Bean
public DataSource dataSource() throws SQLException {
   BasicDataSource dataSource = new BasicDataSource();
   dataSource.setDriverClassName(dataSourceProperties.getDriverClassName());
    dataSource.setUrl(dataSourceProperties.getDbUrl());
    dataSource.setUsername(dataSourceProperties.getDbUsername());
    dataSource.setPassword(dataSourceProperties.getDbPassword())
    return dataSource;
}


@Bean
public DataSourceTransactionManager dataSourceTransactionManager(DataSource dataSource){

    DataSourceTransactionManager manager=new DataSourceTransactionManager(dataSource);
    return manager;
}

@Bean
public JobRepositoryFactoryBean jobRepositoryFactoryBean( DataSourceTransactionManager txManager,DataSource dataSource ) throws Exception{

    JobRepositoryFactoryBean job=new JobRepositoryFactoryBean();
    job.setDataSource(dataSource);
    job.setDatabaseType("oracle");
    job.setTransactionManager(txManager);
    job.afterPropertiesSet();
    return job;
}


@Bean
public ItemReader<Person> reader() {
    FlatFileItemReader<Person> reader = new FlatFileItemReader<Person>();
    reader.setResource(new ClassPathResource("sample-data.csv"));
    reader.setLineMapper(new DefaultLineMapper<Person>() {{
        setLineTokenizer(new DelimitedLineTokenizer() {{
            setNames(new String[] { "firstName", "lastName" });
        }});
        setFieldSetMapper(new BeanWrapperFieldSetMapper<Person>() {{
            setTargetType(Person.class);
        }});
    }});
    return reader;
}

@Bean
public ItemProcessor<Person, Person> processor() {
    return new PersonItemProcessor();
}

@Bean
public ItemWriter<Person> writer(DataSource dataSource) {
    JdbcBatchItemWriter<Person> writer = new JdbcBatchItemWriter<Person>();
    writer.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<Person>());
    writer.setSql("INSERT INTO people (first_name, last_name) VALUES (:firstName, :lastName)");
    writer.setDataSource(dataSource);
    writer.afterPropertiesSet();
    return writer;
}

@Bean
public Job importUserJob(JobBuilderFactory jobs, Step s1, JobExecutionListener listener,JobRepositoryFactoryBean jobRepositoryFactoryBean) throws Exception {


    return jobs.get("importUserJob")
             .repository(jobRepositoryFactoryBean.getObject())
            .incrementer(new RunIdIncrementer())
            .listener(listener)
            .flow(s1)
            .end()
            .build();
}

@Bean
public Step step1(StepBuilderFactory stepBuilderFactory, ItemReader<Person> reader,
        ItemWriter<Person> writer, ItemProcessor<Person, Person> processor) {
    return stepBuilderFactory.get("step1")
            .<Person, Person> chunk(10)
            .reader(reader)
            .processor(processor)
            .writer(writer)
            .build();
}

异常

产品名称: Informix at org.springframework.batch.support.DatabaseType.fromProductName(DatabaseType.java:79) at org.springframework.batch.support.DatabaseType.fromMetaData(DatabaseType.java:110) at org.springframework.boot.autoconfigure.batch.BatchDatabaseInitializer.getDatabaseType(BatchDatabaseInitializer.java:71) at org.springframework.boot.autoconfigure.batch.BatchDatabaseInitializer.initialize(BatchDatabaseInitializer.java:50) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native方法)在sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:497) at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleElement.invoke(InitDestroyAnnotationBeanPostProcessor.java:349) at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleMetadata.invokeInitMethods(InitDestroyAnnotationBeanPostProcessor.java:300) at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.postProcessBeforeInitialization(InitDestroyAnnotationBeanPostProcessor.java:133)

EN

回答 1

Stack Overflow用户

发布于 2016-01-06 08:28:40

Spring批处理似乎不直接支持Informix。

来自org.springframework.batch.support.DatabaseType:

代码语言:javascript
复制
DERBY("Apache Derby"), 
DB2("DB2"), 
DB2ZOS("DB2ZOS"), 
HSQL("HSQL Database Engine"),
SQLSERVER("Microsoft SQL Server"),
MYSQL("MySQL"),
ORACLE("Oracle"),
POSTGRES("PostgreSQL"),
SYBASE("Sybase"), H2("H2");

但是,正如这里所说的:http://forum.spring.io/forum/spring-projects/batch/61097-why-spring-batch-doesn-t-support-informix-database,您似乎可以将数据库类型设置为Oracle,并且它将支持Informix。

票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/34622928

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档