ItemWriter

ItemWriter 在功能上类似于 ItemReader,但操作相反。资源仍然需要定位、打开和关闭,但它们的不同之处在于 ItemWriter 是写入而不是读入。对于数据库或队列,这些操作可能是插入、更新或发送。输出序列化的格式特定于每个批处理作业。

ItemReader 一样,ItemWriter 是一个相当通用的接口,如以下接口定义所示

public interface ItemWriter<T> {

    void write(Chunk<? extends T> items) throws Exception;

}

ItemReader 上的 read 一样,write 提供了 ItemWriter 的基本契约。它尝试写入传入的项目列表,只要它处于打开状态。由于通常预期项目会“批量”组合成一个块然后输出,因此接口接受一个项目列表,而不是单个项目。在写入列表之后,在从 write 方法返回之前可以执行任何必要的刷新操作。例如,如果写入 Hibernate DAO,可以进行多次写入调用,每个项目一次。然后 writer 可以在返回之前调用 Hibernate 会话上的 flush

© . This site is unofficial and not affiliated with VMware.