Shulou(Shulou.com)06/02 Report--

< linesToSkip; i++) { String line = readLine(); if (skippedLinesCallback != null) { skippedLinesCallback.handleLine(line); } } noInput = false; } @Override public void afterPropertiesSet() throws Exception { Assert.notNull(lineMapper, "LineMapper is required"); } @Override protected void jumpToItem(int itemIndex) throws Exception { for (int i = 0; i < itemIndex; i++) { readLine(); } } private String applyRecordSeparatorPolicy(String line) throws IOException { String record = line; while (line != null && !recordSeparatorPolicy.isEndOfRecord(record)) { line = this.reader.readLine(); if (line == null) { if (StringUtils.hasText(record)) { // A record was partially complete since it hasn't ended but // the line is null throw new FlatFileParseException("Unexpected end of file before record complete", record, lineCount); } else { // Record has no text but it might still be post processed // to something (skipping preProcess since that was already // done) break; } } else { lineCount++; } record = recordSeparatorPolicy.preProcess(record) + line; } return recordSeparatorPolicy.postProcess(record); }}package l.c.w;import java.io.RandomAccessFile;import java.nio.charset.Charset;import java.util.ArrayList;import java.util.List;import l.c.w.common.contants.JobConstants;import l.c.w.common.utils.StringUtil;import org.springframework.batch.core.StepExecution;import org.springframework.batch.core.annotation.BeforeStep;/** * * footer line skip. * * @author wcl * */public class FileReadFooterHandler { // default encoding for input files public static final String DEFAULT_CHARSET = Charset.defaultCharset().name(); private StepExecution stepExecution; private String charset = DEFAULT_CHARSET; private int lines = 0; @BeforeStep public void beforeStep(StepExecution stepExecution) throws Exception { this.stepExecution = stepExecution; // resource String fileName = this.stepExecution.getJobExecution().getJobParameters(). getString("inFile"); List footers = new ArrayList(); setFooterLines(footers, fileName); this.stepExecution.getExecutionContext().put("footer_line_list", footers); } @SuppressWarnings("unchecked") public List footerLines() { List footers = (List) this.stepExecution.getExecutionContext().get( "footer_line_list"); return footers; } /** * footer line data get. * * @param footers * @throws Exception */ private void setFooterLines(List footers, String fileName) throws Exception { RandomAccessFile raf = null; try { raf = new RandomAccessFile(fileName, "r"); long len = raf.length(); if (len == 0L) { return; } long pos = len - 1; while (pos >

0 & & lines > 0) {pos--; raf.seek (pos); if (raf.read ()) = ='\ n' | | raf.read () = ='\ r') {String line = raf.readLine () If (StringUtil.isNotEmpty (line)) {footers.add (0, new String (line.getBytes ("ISO-8859-1"), charset); lines-- } finally {if (raf! = null) {raf.close ();}} / * Setter for the charset for this input source. Default value is {@ link # DEFAULT_CHARSET}. * * @ param encoding a properties object which possibly contains the encoding for this input file; * / public void setCharset (String charset) {this.charset = charset;} / * * Public setter for footer line. * / public void setLines (int lines) {this.lines = lines }} This is the end of the footer processing of Spring-batch files. I hope the above content can be of some help to you and learn more knowledge. If you think the article is good, you can share it for more people to see.

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.