跳到主要内容
版本:6.0.2

ItemWriter

DeepSeek V3 中英对照 ItemWriter ItemWriter

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

ItemReader 类似,ItemWriter 也是一个相当通用的接口,如下面的接口定义所示:

public interface ItemWriter<T> {

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

}

ItemReaderread 方法类似,write 方法定义了 ItemWriter 的基本契约。只要写入器处于开启状态,它就会尝试输出传入的条目列表。由于通常期望将条目"批量"组合成一个数据块后再进行输出,因此该接口接受一个条目列表,而非单个条目。在输出列表后,可以在从 write 方法返回前执行必要的刷新操作。例如,当写入到 Hibernate DAO 时,可以多次调用 write 方法(每次处理一个条目),随后写入器可以在返回前对 Hibernate 会话执行 flush 操作。