spring-batch CompositeCustomerUpdateLineTokenizer 源码

spring-batch CompositeCustomerUpdateLineTokenizer 代码

文件路径：/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/trade/CompositeCustomerUpdateLineTokenizer.java

/*
 * Copyright 2006-2021 the original author or authors.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      https://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.springframework.batch.sample.domain.trade;

import org.springframework.batch.core.StepExecution;
import org.springframework.batch.core.StepExecutionListener;
import org.springframework.batch.item.file.transform.FieldSet;
import org.springframework.batch.item.file.transform.LineTokenizer;
import org.springframework.lang.Nullable;

/**
 * Composite {@link LineTokenizer} that delegates the tokenization of a line to one of two
 * potential tokenizers. The file format in this case uses one character, either F, A, U,
 * or D to indicate whether or not the line is an a footer record, or a customer add,
 * update, or delete, and will delegate accordingly.
 *
 * @author Lucas Ward
 * @author Mahmoud Ben Hassine
 * @since 2.0
 */
public class CompositeCustomerUpdateLineTokenizer implements StepExecutionListener, LineTokenizer {

	private LineTokenizer customerTokenizer;

	private LineTokenizer footerTokenizer;

	private StepExecution stepExecution;

	/*
	 * (non-Javadoc)
	 *
	 * @see
	 * org.springframework.batch.item.file.transform.LineTokenizer#tokenize(java.lang.
	 * String)
	 */
	@Override
	public FieldSet tokenize(@Nullable String line) {

		if (line.charAt(0) == 'F') {
			// line starts with F, so the footer tokenizer should tokenize it.
			FieldSet fs = footerTokenizer.tokenize(line);
			long customerUpdateTotal = stepExecution.getReadCount();
			long fileUpdateTotal = fs.readLong(1);
			if (customerUpdateTotal != fileUpdateTotal) {
				throw new IllegalStateException(
						"The total number of customer updates in the file footer does not match the "
								+ "number entered  File footer total: [" + fileUpdateTotal
								+ "] Total encountered during processing: [" + customerUpdateTotal + "]");
			}
			else {
				// return null, because the footer indicates an end of processing.
				return null;
			}
		}
		else if (line.charAt(0) == 'A' || line.charAt(0) == 'U' || line.charAt(0) == 'D') {
			// line starts with A,U, or D, so it must be a customer operation.
			return customerTokenizer.tokenize(line);
		}
		else {
			// If the line doesn't start with any of the characters above, it must
			// obviously be invalid.
			throw new IllegalArgumentException("Invalid line encountered for tokenizing: " + line);
		}
	}

	@Override
	public void beforeStep(StepExecution stepExecution) {
		this.stepExecution = stepExecution;
	}

	/**
	 * Set the {@link LineTokenizer} that will be used to tokenize any lines that begin
	 * with A, U, or D, and are thus a customer operation.
	 * @param customerTokenizer tokenizer to delegate to for customer operation records
	 */
	public void setCustomerTokenizer(LineTokenizer customerTokenizer) {
		this.customerTokenizer = customerTokenizer;
	}

	/**
	 * Set the {@link LineTokenizer} that will be used to tokenize any lines that being
	 * with F and is thus a footer record.
	 * @param footerTokenizer tokenizer to delegate to for footer records
	 */
	public void setFooterTokenizer(LineTokenizer footerTokenizer) {
		this.footerTokenizer = footerTokenizer;
	}

}

相关信息

spring-batch 源码目录

相关文章

spring-batch CustomerCredit 源码

spring-batch CustomerCreditDao 源码

spring-batch CustomerDao 源码

spring-batch CustomerDebit 源码

spring-batch CustomerDebitDao 源码

spring-batch CustomerOperation 源码

spring-batch CustomerUpdate 源码

spring-batch CustomerUpdateFieldSetMapper 源码

spring-batch CustomerUpdateProcessor 源码

spring-batch CustomerUpdateWriter 源码