CompositeItemWriter数据持久化异常：多类型Writer使用求助

问题根源 #

你当前的强制类型转换会破坏Spring Batch的类型安全机制，导致Writer处理数据时因类型不匹配静默失败，最终数据无法持久化。普通CompositeItemWriter要求所有委托Writer处理同一种类型的数据，强制混入不同类型的Writer会触发这类问题。

正确整合方案 #

方案1：统一Writer处理类型（推荐） #

如果两个Writer都应该处理同一种数据类型（比如ScheProInfo），直接修改schNamesWriter的泛型定义，使其与另一个Writer保持一致，无需强制转换：

@Bean
public CompositeItemWriter<ScheProInfo> compositeItemWriter() {
    CompositeItemWriter<ScheProInfo> writer = new CompositeItemWriter<>();
    writer.setDelegates(Arrays.asList(
        classifierCompositeItemWriter(null),
        schNamesWriter() // 此时schNamesWriter类型为ItemWriter<ScheProInfo>
    ));
    return writer;
}

// 修改schNamesWriter的泛型定义
@Bean
public ItemWriter<ScheProInfo> schNamesWriter() {
    // 实现逻辑，确保接收并处理ScheProInfo类型数据
    return items -> {
        // 你的数据库持久化逻辑
    };
}

方案2：用Classifier路由不同类型数据 #

如果两个Writer确实需要处理不同类型的数据（比如一个处理ScheProInfo，另一个处理SchName），不要用普通CompositeItemWriter，改用ClassifierCompositeItemWriter实现数据路由：

@Bean
public ClassifierCompositeItemWriter<Object> compositeItemWriter() {
    ClassifierCompositeItemWriter<Object> writer = new ClassifierCompositeItemWriter<>();
    
    // 定义分类逻辑，根据Item类型路由到对应Writer
    writer.setClassifier(item -> {
        if (item instanceof ScheProInfo) {
            return classifierCompositeItemWriter(null);
        } else if (item instanceof SchName) {
            return schNamesWriter();
        }
        throw new IllegalArgumentException("不支持的Item类型: " + item.getClass());
    });
    
    return writer;
}

方案3：适配器包装兼容类型 #

如果必须使用普通CompositeItemWriter，可以用适配器包装不同类型的Writer，统一为ItemWriter<Object>：

@Bean
public CompositeItemWriter<Object> compositeItemWriter() {
    CompositeItemWriter<Object> writer = new CompositeItemWriter<>();
    
    // 包装处理ScheProInfo的Writer
    ItemWriter<Object> scheProAdapter = items -> {
        @SuppressWarnings("unchecked")
        List<ScheProInfo> scheItems = (List<ScheProInfo>) (List<?>) items;
        classifierCompositeItemWriter(null).write(scheItems);
    };
    
    // 包装处理SchName的Writer（假设schNamesWriter处理SchName类型）
    ItemWriter<Object> schNameAdapter = items -> {
        @SuppressWarnings("unchecked")
        List<SchName> schItems = (List<SchName>) (List<?>) items;
        schNamesWriter().write(schItems);
    };
    
    writer.setDelegates(Arrays.asList(scheProAdapter, schNameAdapter));
    return writer;
}

注意：此方案需要确保传入CompositeItemWriter的列表中的数据类型，与对应Writer的处理类型完全匹配，否则会抛出类型转换异常。

内容的提问来源于stack exchange，提问作者ANUPAM