import au.com.bytecode.opencsv.bean.ColumnPositionMappingStrategy; //导入依赖的package包/类
public void testParse() {
    String s = "" +
            "kyle,123456,emp123\n" +
            "jimmy,abcnum,cust09878";
    ColumnPositionMappingStrategy strat = new ColumnPositionMappingStrategy();
    strat.setType(TestBean.class);
    String[] columns = new String[] {"name", "orderNumber", "id"};
    strat.setColumnMapping(columns);

    CsvToBean csv = new CsvToBean();
    List list = csv.parse(strat, new StringReader(s));
    assertNotNull(list);
    assertTrue(list.size() == 2);
    TestBean bean = (TestBean)list.get(0);
    assertEquals("kyle", bean.getName());
    assertEquals("123456", bean.getOrderNumber());
    assertEquals("emp123", bean.getId());
}
 

import au.com.bytecode.opencsv.bean.ColumnPositionMappingStrategy; //导入依赖的package包/类
@Test
@SuppressWarnings("unchecked")
public void ヘッダ読込中にIO例外が発生した場合は例外が変換される() throws Exception {
    thrown.expect(InternalException.class);
    thrown.expectMessage("CSVのヘッダ読込中にIO例外が発生しました。");
    File f = file.copy("CSVsTest-dummy.csv", "temp.csv");
    readers = CSVs.readers(f, AnnotationTestBean.class);
    readers.open();
    readers.line = new String[] {
        "test"
    };
    ColumnPositionMappingStrategy<AnnotationTestBean> mockStrategy = Mockito.mock(ColumnPositionMappingStrategy.class);
    CSVToBeanMapping<AnnotationTestBean> parser = new CSVToBeanMapping<AnnotationTestBean>();
    doThrow(new IOException()).when(mockStrategy).captureHeader(readers.csv);
    readers.strategy = mockStrategy;
    readers.parser = parser;
    readers.parse();
}
 

import au.com.bytecode.opencsv.bean.ColumnPositionMappingStrategy; //导入依赖的package包/类
public List<T> parseCsv() throws IOException {
    ClassPathResource classPathResource = new ClassPathResource(getClassPathFilePath(), this.getClass().getClassLoader());
    InputStreamReader ioReader = new InputStreamReader(classPathResource.getInputStream(), "UTF-8");
    CSVReader reader = new CSVReader(ioReader, ';');

    ColumnPositionMappingStrategy<T> strat = new ColumnPositionMappingStrategy<>();
    strat.setType(getDestinationClass());
    strat.setColumnMapping(getColumnMapping());
    CsvToBean<T> csv = getParser();
    return csv.parse(strat, reader);
}
 

import au.com.bytecode.opencsv.bean.ColumnPositionMappingStrategy; //导入依赖的package包/类
public static List<Record> parseCreationFile(String path, char delimiter) throws IOException {
    ColumnPositionMappingStrategy<Record> strategy = new ColumnPositionMappingStrategy<Record>();
    strategy.setType(Record.class);

    String[] columns = new String[] {"category", "name", "template", "url"};
    strategy.setColumnMapping(columns);

    CSVReader reader = new CSVReader(new FileReader(path), delimiter, '\"', 1);
    CsvToBean<Record> csv = new CsvToBean<Record>();
    return csv.parse(strategy, reader);
}
 

import au.com.bytecode.opencsv.bean.ColumnPositionMappingStrategy; //导入依赖的package包/类
/**
 * Parses the payment header information in the file.
 *
 * @param fileLine
 * @param reader
 * @param strat
 * @return
 */
protected PaymentHeader parsePaymentHeader(String[] fileLine, MappingCSVReader reader, ColumnPositionMappingStrategy strat) {
    strat.setType(PaymentHeader.class);
    String[] headerColumns = new String[] { PdpConstants.PaymentHeader.CHART,
            PdpConstants.PaymentHeader.UNIT, PdpConstants.PaymentHeader.SUBUNIT,
            PdpConstants.PaymentHeader.CREATION_DATE, PdpConstants.PaymentHeader.VENDOR_OR_EMPLOYEE,
            PdpConstants.PaymentHeader.SOURCE_DOC_NUMBER, PdpConstants.PaymentHeader.PAYMENT_DATE};
    strat.setColumnMapping(headerColumns);
    String[] newNextLine = Arrays.copyOfRange(fileLine, 1, fileLine.length);
    PaymentHeader ph = (PaymentHeader) reader.processLine(strat, newNextLine);
    return ph;
}
 

import au.com.bytecode.opencsv.bean.ColumnPositionMappingStrategy; //导入依赖的package包/类
/**
 * Parses the accounting line information in the file.
 *
 * @param fileLine
 * @param reader
 * @param strat
 * @return
 */
protected PaymentAccountDetail parseAccountingLine(String[] fileLine, MappingCSVReader reader, ColumnPositionMappingStrategy strat) {
    strat.setType(PaymentAccountDetail.class);
    String[] headerColumns = new String[] { PdpConstants.PaymentAccountDetail.CHART,
            PdpConstants.PaymentAccountDetail.ACCOUNT_NBR,
            PdpConstants.PaymentAccountDetail.SUB_ACCOUNT_NBR, PdpConstants.PaymentAccountDetail.OBJECT_CODE,
            PdpConstants.PaymentAccountDetail.SUB_OBJECT_CODE, PdpConstants.PaymentAccountDetail.PROJECT_CODE,
            PdpConstants.PaymentAccountDetail.ORG_REF_ID };
    strat.setColumnMapping(headerColumns);
    String[] newNextLine = Arrays.copyOfRange(fileLine, 1, fileLine.length);
    PaymentAccountDetail ac = (PaymentAccountDetail)reader.processLine(strat, newNextLine);
    return ac;

}
 

import au.com.bytecode.opencsv.bean.ColumnPositionMappingStrategy; //导入依赖的package包/类
/**
 * Parses the payment detail information in the file.
 *
 * @param fileLine
 * @param reader
 * @param strat
 * @return
 */
protected ResearchParticipantPaymentDetail parsePaymentDetail(String[] fileLine, MappingCSVReader reader, ColumnPositionMappingStrategy strat) {
    strat.setType(ResearchParticipantPaymentDetail.class);
    String[] headerColumns = new String[] { PdpConstants.PaymentDetail.PAYEE_NAME,
            PdpConstants.PaymentDetail.ADDRESS_LINE_1, PdpConstants.PaymentDetail.ADDRESS_LINE_2,
            PdpConstants.PaymentDetail.ADDRESS_LINE_3, PdpConstants.PaymentDetail.CITY,
            PdpConstants.PaymentDetail.STATE, PdpConstants.PaymentDetail.ZIP,
            PdpConstants.PaymentDetail.CHECK_STUB_TEXT, PdpConstants.PaymentDetail.AMOUNT };
    strat.setColumnMapping(headerColumns);
    String[] newNextLine = Arrays.copyOfRange(fileLine, 1, fileLine.length);
    ResearchParticipantPaymentDetail pd = (ResearchParticipantPaymentDetail) reader.processLine(strat, newNextLine);
    return pd;
}
 

import au.com.bytecode.opencsv.bean.ColumnPositionMappingStrategy; //导入依赖的package包/类
/**
 * This approach seems to fail with embedded newlines; that might be a weakness of
 * the mapping strategy support classes.
 *
 * @param originalCommentText
 * @throws FileNotFoundException
 */
protected void testMappingStrategyRead(String originalCommentText)
        throws FileNotFoundException {
    ColumnPositionMappingStrategy mappingStrategy = new ColumnPositionMappingStrategy();
    mappingStrategy.setType(MyBean.class);
    String[] columns = new String[]{"name", "value", "amount1", "currency", "comments"}; // the fields to bind to in your JavaBean
    mappingStrategy.setColumnMapping(columns);

    CsvToBean csv = new CsvToBean();
    CSVReader reader = new CSVReader(new FileReader(filePath), Constants.DEFAULT_SEPARATOR, Constants.DEFAULT_QUOTE_CHARACTER, Constants.DEFAULT_ESCAPE_CHARACTER, 0, false, false);
    List<MyBean> list = csv.parse(mappingStrategy, reader);

    if (list.size() != 3) {
        System.out.println("Error - list size is wrong.");
    }
    MyBean myBean = list.get(2);
    if (!myBean.getName().equals("field1")) {
        System.out.println("MappingStrategy Assert Error: Name is wrong.");
    }
    if (!myBean.getValue().equals("3.0")) {
        System.out.println("MappingStrategy Assert Error: Value is wrong.");
    }
    if (!myBean.getAmount1().equals("3,147.25")) {
        System.out.println("MappingStrategy Assert Error: Amount1 is wrong.");
    }
    if (!myBean.getCurrency().equals("$3,147.26")) {
        System.out.println("MappingStrategy Assert Error: Currency is wrong.");
    }
    printfield("MyBeanComments:         ", myBean.getComments());
    printfield("OriginalCommentText:    ", originalCommentText);
    if (!myBean.getComments().equals(originalCommentText)) {
        System.out.println("MappingStrategy Assert Error: Comment is wrong.");
    }
}
 

import au.com.bytecode.opencsv.bean.ColumnPositionMappingStrategy; //导入依赖的package包/类
private static ColumnPositionMappingStrategy getMappingStrategy(){
	ColumnPositionMappingStrategy strategy = new ColumnPositionMappingStrategy();
	strategy.setType(CobasMiraMappingLabitem.class);
	String[] columns = new String[] {
		"testNameCM", "testNameShort", "TestName", "laborwertID", "refM", "refW", "noDecPlaces"
	};
	strategy.setColumnMapping(columns);
	return strategy;
}
 

import au.com.bytecode.opencsv.bean.ColumnPositionMappingStrategy; //导入依赖的package包/类
@Setup
public void init() throws FileNotFoundException {
	mapper = CsvMapperFactory.newInstance().newBuilder(SmallBenchmarkObject.class)
               .addMapping("id")
			.addMapping("year_started")
               .addMapping("name")
			.addMapping("email")
               .mapper();
       finalMapper = CsvMapperFactory.newInstance().newBuilder(FinalSmallBenchmarkObject.class)
               .addMapping("id")
               .addMapping("year_started")
               .addMapping("name")
               .addMapping("email")
               .mapper();

       noAsmMapper = CsvMapperFactory.newInstance().useAsm(false).newBuilder(SmallBenchmarkObject.class)
               .addMapping("id")
               .addMapping("year_started")
               .addMapping("name")
               .addMapping("email")
               .mapper();
       noAsmFinalMapper = CsvMapperFactory.newInstance().useAsm(false).newBuilder(FinalSmallBenchmarkObject.class)
               .addMapping("id")
               .addMapping("year_started")
               .addMapping("name")
               .addMapping("email")
               .mapper();

	schema = CsvSchema.builder().addColumn("id").addColumn("yearStarted")
			.addColumn("name").addColumn("email").build();

       strategy = new ColumnPositionMappingStrategy<SmallBenchmarkObject>();
       strategy.setType(SmallBenchmarkObject.class);
       strategy.setColumnMapping(new String[] {"id", "yearStarted", "name", "email"});

       StringBuilder os = new StringBuilder();
	for (int i = 0; i < limit; i++) {
		os.append(Integer.toString(i));
		os.append(',');
		os.append(Integer.toString(i + 2000));
		os.append(',');
		os.append(("name " + 1));
		os.append(',');
		os.append(("name" + 1 + "@email.com"));
		os.append('\n');
	}

	try {
		file = File.createTempFile("bench", ".txt");
		FileUtils.write(file, os);
	} catch (Exception e) {
		throw new Error(e);
	}
}
 

import au.com.bytecode.opencsv.bean.ColumnPositionMappingStrategy; //导入依赖的package包/类
@Setup
public void init() throws Exception {

       targetClass = Class.forName("org.sfm.beans."+ classType + objectSize);

	schema = newSchema(objectSize, CsvSchema.builder());

       oreader =  new com.fasterxml.jackson.dataformat.csv.CsvMapper()
               .reader(targetClass);

       strategy = new ColumnPositionMappingStrategy();
       strategy.setType(targetClass);

       mapper = newMapper(objectSize, targetClass);

       String[] columns = new String[objectSize];
       for(int i = 0; i <columns.length; i++) {
           columns[i] = "val" + i;
       }
       strategy.setColumnMapping(columns);

       file = File.createTempFile("bench", ".txt");

       writeCsv(limit, file);

   }
 

import au.com.bytecode.opencsv.bean.ColumnPositionMappingStrategy; //导入依赖的package包/类
/**
 * Override the superclass method to parse the incoming spreadsheet
 * file and convert into PaymentFileLoad, then return it to the invoker.
 *
 * @see org.kuali.kfs.sys.batch.BatchInputFileType#parse(byte[])
 */
@Override
public Object parse(byte[] fileByteContent) throws ParseException {

    List<CollectorBatch> batchList = new ArrayList<CollectorBatch>();
    ResearchParticipantUpload uploadFile = new ResearchParticipantUpload();

    try {

        InputStreamReader inputStreamReader = new InputStreamReader(new ByteArrayInputStream(fileByteContent));
        MappingCSVReader reader = new MappingCSVReader(inputStreamReader);

        String[] fileLine = null;

        while ((fileLine = reader.readNext()) != null) {

            ColumnPositionMappingStrategy strat = new ColumnPositionMappingStrategy();
            if (fileLine[0].equalsIgnoreCase(PAYMENT_HEADER)) {
                //If there's already a payment header on the uploadFile,
                //we'll give error message to the user that something's wrong
                //with the file format because the file can only have 1 payment
                //header.
                if (uploadFile.getPaymentHeader() != null) {
                    GlobalVariables.getMessageMap().putError("uploadFile", PdpKeyConstants.ERROR_BATCH_UPLOAD_BAD_FORMAT, PdpConstants.MULTIPLE_PAYMENT_HEADERS);
                    return null;
                }
                PaymentHeader ph = parsePaymentHeader(fileLine, reader, strat);
                uploadFile.setPaymentHeader(ph);
            }
            else if (fileLine[0].equalsIgnoreCase(ACCOUNTING_LINE)) {
                //If there's already an accounting line on the uploadFile,
                //we'll give error message to the user that something's wrong
                //with the file format because the file can only have 1
                //accountingLine
                if (uploadFile.getPaymentAccountDetail() != null) {
                    GlobalVariables.getMessageMap().putError("uploadFile", PdpKeyConstants.ERROR_BATCH_UPLOAD_BAD_FORMAT, PdpConstants.MULTIPLE_ACCOUNTS);
                    return null;
                }
                PaymentAccountDetail ac = parseAccountingLine(fileLine, reader, strat);
                uploadFile.setPaymentAccountDetail(ac);
            }
            else if (fileLine[0].equalsIgnoreCase(PAYMENT_DETAIL)) {
                ResearchParticipantPaymentDetail pd = parsePaymentDetail(fileLine, reader, strat);
                uploadFile.addPaymentDetail(pd);
            }
            else if (fileLine[0].equalsIgnoreCase(GL_DESCRIPTION)) {
                uploadFile.setGenericDescription(fileLine[1]);
            }
        }
    }
    catch (IOException ioe) {
        LOG.error("Error encountered reading from file content", ioe);
        throw new ParseException("Error encountered reading from file content", ioe);
    }

    if ((uploadFile.getPaymentDetails().size() < 1) || uploadFile.getPaymentHeader() == null || uploadFile.getPaymentAccountDetail() == null) {
        GlobalVariables.getMessageMap().putError("uploadFile", PdpKeyConstants.ERROR_BATCH_UPLOAD_BAD_FORMAT, KFSConstants.EMPTY_STRING);
        return null;
    }
    PaymentFileLoad paymentFileLoad = convertToPaymentFileLoad(uploadFile);

    return paymentFileLoad;
}
 

import au.com.bytecode.opencsv.bean.ColumnPositionMappingStrategy; //导入依赖的package包/类
private void create() {
    this.strategy = new ColumnPositionMappingStrategy<T>();
    this.strategy.setType(type);
    this.strategy.setColumnMapping(mapping);
    this.parser = new CSVToBeanMapping<T>();
}