OpenCSV动态分隔符检测与处理教程

import com.opencsv.bean.ColumnPositionMappingStrategy;
import com.opencsv.bean.CsvToBean;
import com.opencsv.bean.CsvToBeanBuilder;
import com.opencsv.exceptions.CsvException;

import java.io.*;
import java.nio.charset.StandardCharsets;
import java.util.List;

public class CsvSeparatorDetector {

    /**
     * 解析CSV输入流，动态检测并使用逗号或分号作为分隔符。
     *
     * @param inputStream CSV文件的输入流。
     * @param type 目标Java对象的Class类型。
     * @param columns 映射到CSV列的Java对象属性名称数组。
     * @param <T> 泛型类型参数。
     * @return 转换后的Java对象列表。
     * @throws IOException 如果读取输入流时发生I/O错误。
     * @throws CsvException 如果CSV解析过程中发生错误。
     */
    public static <T> List<T> parseFromCsvWithSeparatorDetection(
            InputStream inputStream, Class<T> type, String[] columns)
            throws IOException, CsvException {

        // 步骤1: 读取整个输入流内容到内存中，以便进行分隔符检测
        final StringBuilder textBuilder = new StringBuilder();
        try (Reader reader = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8))) {
            int c;
            while ((c = reader.read()) != -1) {
                textBuilder.append((char) c);
            }
        }
        final String csvContent = textBuilder.toString();

        // 步骤2: 根据内容检测分隔符
        final char detectedSeparator;
        if (csvContent.contains(";")) {
            detectedSeparator = ';'; // 如果包含分号，则认为是分号分隔
        } else {
            detectedSeparator = ','; // 否则，默认为逗号分隔
        }

        // 步骤3: 使用检测到的分隔符重新解析CSV内容
        try (Reader reader = new StringReader(csvContent)) {
            // 配置列位置映射策略
            ColumnPositionMappingStrategy<T> strategy = new ColumnPositionMappingStrategy<>();
            strategy.setColumnMapping(columns);
            strategy.setType(type);

            // 构建CsvToBean解析器
            CsvToBean<T> csvToBean = new CsvToBeanBuilder<T>(reader)
                    .withMappingStrategy(strategy)
                    .withSeparator(detectedSeparator) // 应用检测到的分隔符
                    .withIgnoreLeadingWhiteSpace(true) // 忽略前导空格
                    .build();

            return csvToBean.parse();
        }
    }
}

public class Bean {
    private String a;
    private String b;

    public Bean() {
    }

    public String getA() {
        return a;
    }

    public void setA(String a) {
        this.a = a;
    }

    public String getB() {
        return b;
    }

    public void setB(String b) {
        this.b = b;
    }

    @Override
    public String toString() {
        return "Bean{" +
               "a='" + a + '\'' +
               ", b='" + b + '\'' +
               '}';
    }
}

import java.io.ByteArrayInputStream;
import java.io.InputStream;
import java.nio.charset.StandardCharsets;
import java.util.List;

public class UsageExample {
    public static void main(String[] args) {
        String[] columns = new String[]{"a", "b"};

        // 示例1: 使用分号分隔的CSV数据
        String csvDataSemicolon = "A1;B1\nA2;B2";
        InputStream inSemicolon = new ByteArrayInputStream(csvDataSemicolon.getBytes(StandardCharsets.UTF_8));

        System.out.println("--- 解析分号分隔的CSV ---");
        try {
            List<Bean> objects = CsvSeparatorDetector.parseFromCsvWithSeparatorDetection(inSemicolon, Bean.class, columns);
            objects.forEach(System.out::println);
        } catch (IOException | CsvException e) {
            e.printStackTrace();
        }

        System.out.println("\n--- 解析逗号分隔的CSV ---");
        // 示例2: 使用逗号分隔的CSV数据
        String csvDataComma = "A3,B3\nA4,B4";
        InputStream inComma = new ByteArrayInputStream(csvDataComma.getBytes(StandardCharsets.UTF_8));

        try {
            List<Bean> objects = CsvSeparatorDetector.parseFromCsvWithSeparatorDetection(inComma, Bean.class, columns);
            objects.forEach(System.out::println);
        } catch (IOException | CsvException e) {
            e.printStackTrace();
        }
    }
}