import org.marc4j.MarcReader; //导入依赖的package包/类
private Sequence readMARCRecords(final MarcReader aReader) throws XPathException {
    final MemTreeBuilder builder = context.getDocumentBuilder();
    final DocumentBuilderReceiver receiver = new DocumentBuilderReceiver(builder);
    final SAXResult saxResult = new SAXResult(receiver);
    final MarcWriter writer = new MarcXmlWriter(saxResult);

    writer.setConverter(new AnselToUnicode());

    while (aReader.hasNext()) {
        final Record record = aReader.next();
        final String recordId = record.getControlNumber();

        if (LOGGER.isDebugEnabled() && recordId != null) {
            LOGGER.debug("Reading MARC record: " + recordId);
        }

        writer.write(record);
    }

    writer.close();

    return (DocumentImpl) receiver.getDocument();
}
 

import org.marc4j.MarcReader; //导入依赖的package包/类
public static List<Record> read(String fileName) throws Exception {
	InputStream in = new FileInputStream(fileName);
	MarcReader reader = new MarcStreamReader(in);

	List<Record> records = new ArrayList<>();
	while (reader.hasNext()) {
		Record marc4jRecord = reader.next();
		records.add(marc4jRecord);
		// System.out.println(record.toString());
	}
	return records;
}
 

import org.marc4j.MarcReader; //导入依赖的package包/类
public static MarcReader getReader(String fileName, boolean isMarcxml, boolean isLineSeaparated) throws Exception {
	MarcReader reader = null;
	if (isLineSeaparated)
		reader = ReadMarc.getLineSeparatedMarcReader(fileName);
	else
		reader = (isMarcxml) ? ReadMarc.getXmlReader(fileName) : ReadMarc.getStreamReader(fileName);

	return reader;
}
 

import org.marc4j.MarcReader; //导入依赖的package包/类
public static void main(String[] args) throws ParseException {

		final Validator validator = new Validator(args);
		ValidatorParameters params = validator.getParameters();
		validator.setDoPrintInProcessRecord(false);

		logger.info("Input file is " + params.getArgs());
		SparkConf conf = new SparkConf().setAppName("MarcCompletenessCount");
		JavaSparkContext context = new JavaSparkContext(conf);

		System.err.println(validator.getParameters().formatParameters());

		JavaRDD<String> inputFile = context.textFile(validator.getParameters().getArgs()[0]);

		JavaRDD<String> baseCountsRDD = inputFile
			.flatMap(content -> {
				MarcReader reader = ReadMarc.getMarcStringReader(content);
				Record marc4jRecord = reader.next();
				MarcRecord marcRecord = MarcFactory.createFromMarc4j(
					marc4jRecord, params.getDefaultRecordType(), params.getMarcVersion(), params.fixAlephseq());
				validator.processRecord(marcRecord, 1);
				return ValidationErrorFormatter
					.formatForSummary(marcRecord.getValidationErrors(), params.getFormat())
					.iterator();
			}
		);
		baseCountsRDD.saveAsTextFile(validator.getParameters().getFileName());
	}
 

import org.marc4j.MarcReader; //导入依赖的package包/类
/** Converts Marc21 to MarcXML */
public static Document toMarcXml(byte[] marc21, String charset) {
    MarcReader reader = new MarcStreamReader(new ByteArrayInputStream(marc21), charset);
    DOMResult result = new DOMResult();
    MarcXmlWriter writer = new MarcXmlWriter(result);
    if (reader.hasNext()) {
        Record record = reader.next();
        writer.write(record);
    }
    writer.close();

    Document retval = (Document) result.getNode();
    return retval;
}
 

import org.marc4j.MarcReader; //导入依赖的package包/类
/**
 * @param inputFile
 * @return converted marc xml File Name
 * @throws java.io.FileNotFoundException This method takes in a raw marc file and converts into a marc xml file.
 */
public String convertRawMarcToXML(File inputFile) throws FileNotFoundException {
    InputStream input = new FileInputStream(inputFile);
    String fileName = inputFile.getName().replace(".mrc", ".xml");
    FileOutputStream fileOutputStream = new FileOutputStream(new File(fileName));
    MarcReader reader = new MarcStreamReader(input);
    MarcWriter writer = new MarcXmlWriter(fileOutputStream, true);

    while (reader.hasNext()) {
        Record record = reader.next();
        writer.write(record);
    }
    writer.close();
    return fileName;
}
 

import org.marc4j.MarcReader; //导入依赖的package包/类
/**
 * @param content
 * @return converted marc xml
 */
public String convert(String content) {
    ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(content.getBytes());
    ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();

    MarcReader reader = new MarcStreamReader(byteArrayInputStream);
    MarcWriter writer = new MarcXmlWriter(byteArrayOutputStream, true);

    while (reader.hasNext()) {
        Record record = reader.next();
        writer.write(record);
    }
    writer.close();
    return new String(byteArrayOutputStream.toByteArray());
}
 

import org.marc4j.MarcReader; //导入依赖的package包/类
@Override
public Record next() {
	InputStream is = new ByteArrayInputStream(line.getBytes());
	MarcReader reader = new MarcStreamReader(is);
	Record marc4jRecord = null;
	if (reader.hasNext()) {
		marc4jRecord = reader.next();
	}
	nextIsConsumed = true;
	return marc4jRecord;
}
 

import org.marc4j.MarcReader; //导入依赖的package包/类
public static MarcReader getStreamReader(String fileName) throws Exception {
	InputStream in = new FileInputStream(fileName);
	MarcReader reader = new MarcStreamReader(in);
	return reader;
}
 

import org.marc4j.MarcReader; //导入依赖的package包/类
public static MarcReader getXmlReader(String fileName) throws Exception {
	InputStream in = new FileInputStream(fileName);
	MarcReader reader = new MarcXmlReader(in);
	return reader;
}
 

import org.marc4j.MarcReader; //导入依赖的package包/类
public static MarcReader getLineSeparatedMarcReader(String fileName) throws Exception {
	MarcReader reader = new LineSeparatedMarcReader(fileName);
	return reader;
}
 

import org.marc4j.MarcReader; //导入依赖的package包/类
public static MarcReader getMarcStringReader(String content) throws Exception {
	InputStream is = new ByteArrayInputStream(content.getBytes());
	MarcReader reader = new MarcStreamReader(is);
	return reader;
}