Spring批处理通配符ItemWriter

Question

我有一个假问题。为了解释我的用例，我有不同类型的DAO；比如说啤酒。。。等等，我想用一个通用的ItemWriter来处理所有的问题。我创建了一个CommonComponentConfiguration，在这里我定义了；

@Bean
@Qualifier(WRITER_INSERT_TO_DATABASE_BEAN)
public ItemWriter<?> insertDbItemWriter(@Qualifier(DATA_SOURCE) DataSource dataSource,
                                        @Qualifier("insertSql") String insertSql) {
         return new MyItemWriter<>(dataSource, insertSql);
     }

作家班是这样的；

@Slf4j
public class MyItemWriter<T> extends JdbcBatchItemWriter<T> {

    public MyItemWriter(DataSource dataSource, String sql) {
        this.setDataSource(dataSource);
        this.setSql(sql);
        this.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<>());
        this.setAssertUpdates(false);
    }

    @Override
    public void write(List<? extends T> items) {
        try {
            super.write(items);
        } catch (Exception e) {
            log.error("Could not write the items " + items);
            log.error(e.getMessage());
        }
    }
}

到目前为止一切都还好。事情变得复杂的地方是，我为每个存储库定义了单独的配置类，其中定义了存储库特定的项。例如，为用户插入数据库的步骤。

@Bean
@Qualifier(STEP_INSERT_TO_DB_BEAN)
public Step insertToDbStep(@Qualifier(READER_LOADED_INPUT_DATA_BEAN) ListItemReader<User> sourceItemReader, UserInsertProcessor userInsertProcessor, @Qualifier(WRITER_INSERT_TO_DATABASE_BEAN)
        ItemWriter<User> dbItemWriter) {
    return stepBuilderFactory.get("processInsertStep").<User, User>chunk(100)
            .reader(sourceItemReader)
            .processor(userInsertProcessor)
            .writer(dbItemWriter)
            .build();
}

当我用IJ编写这段代码时，我抱怨无法自动连线。合格bean必须是“ItemWriter”

你可能会说，如果有用的话，不要碰它。不过我真的很想知道幕后发生了什么。

此外，如果你发现设计中的缺陷（例如试图使用一个共同的东西来做所有的事情），你的建议是非常受欢迎的。

提前谢谢你。

PS：看到下面这条线，看起来非常相似——如果不是相同的话——情况。然而，我想知道这里是否与泛型有关。IntelliJ IDEA在使用Spring的@Autowired注释时显示错误




Answer 1

不过我真的很想知道幕后发生了什么。

对于这个IntelliJ IDEA警告，您是对的，它与IntelliJ IDEA中讨论的问题相同，在使用Spring的@Autowmed注释时显示错误（尤金在评论中也解释了这一点）

此外，如果你发现设计中的缺陷（例如试图使用一个共同的东西来做所有的事情），你的建议是非常受欢迎的。

如果当前的方法适合你，你可以使用它。然而，我建议你做一件事，做一件事，并把它做好。在您的情况下，这将为每种域类型使用一个条目编写器，并将这些编写器包装在ClassifierCompositeItemWriter中。复合编写器使用分类器对项目进行分类，并相应地调用相应的编写器。