OpenCSV动态分隔符检测与解析：灵活处理多源CSV文件

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 CsvParserUtil {

    /**
     * 解析CSV文件，动态检测分隔符（支持分号和逗号）。
     *
     * @param inputStream CSV文件的输入流。
     * @param type 目标Java对象的Class类型。
     * @param columns 用于映射CSV列到Java对象属性的列名数组（按位置）。
     * @param <T> 目标Java对象的类型。
     * @return 转换后的Java对象列表。
     * @throws IOException 读取输入流时可能发生的异常。
     * @throws CsvException OpenCSV解析时可能发生的异常。
     */
    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. 使用检测到的分隔符进行解析
        try (Reader reader = new StringReader(csvContent)) {
            // 配置列位置映射策略
            ColumnPositionMappingStrategy<T> strategy = new ColumnPositionMappingStrategy<>();
            strategy.setColumnMapping(columns); // 设置列名映射
            strategy.setType(type); // 设置目标类型

            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;

    // 无参构造函数 (OpenCSV需要)
    public Bean() {}

    // Getter 和 Setter 方法
    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 Demo {
    public static void main(String[] args) {
        // 示例 CSV 数据 1: 使用分号分隔
        String csvDataSemicolon = "A1;B1\nA2;B2";
        // 示例 CSV 数据 2: 使用逗号分隔
        String csvDataComma = "X1,Y1\nX2,Y2";

        String[] columns = new String[]{"a", "b"}; // 对应Bean的属性名

        try {
            // 解析分号分隔的CSV
            InputStream inSemicolon = new ByteArrayInputStream(csvDataSemicolon.getBytes(StandardCharsets.UTF_8));
            List<Bean> objectsSemicolon = CsvParserUtil.parseFromCsvWithSeparatorDetection(inSemicolon, Bean.class, columns);
            System.out.println("解析分号分隔的CSV结果:");
            objectsSemicolon.forEach(System.out::println);

            System.out.println("\n--------------------\n");

            // 解析逗号分隔的CSV
            InputStream inComma = new ByteArrayInputStream(csvDataComma.getBytes(StandardCharsets.UTF_8));
            List<Bean> objectsComma = CsvParserUtil.parseFromCsvWithSeparatorDetection(inComma, Bean.class, columns);
            System.out.println("解析逗号分隔的CSV结果:");
            objectsComma.forEach(System.out::println);

        } catch (IOException | CsvException e) {
            e.printStackTrace();
        }
    }
}