OpenCSV动态分隔符检测与解析：构建灵活的CSV处理方案

public static <T> List<T> parseInputStreamFromCsv(InputStream inputStream, Class<T> clazz) {
  try (Reader reader = new BufferedReader(new InputStreamReader(inputStream))) {
    // 这里的 CsvToBeanBuilder 默认使用逗号作为分隔符，或需要通过 .withSeparator() 明确指定
    CsvToBean<T> csvToBean = new CsvToBeanBuilder<T>(reader)
        .withType(clazz) // 假设 clazz 使用注解进行映射
        .withIgnoreLeadingWhiteSpace(true)
        .build();
    return csvToBean.parse();
  } catch (Exception ex) {
    throw new RuntimeException("Error converting CSV", ex); // 统一异常处理
  }
}

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 读取输入流时可能发生的IO异常。
     * @throws CsvException OpenCSV解析CSV时可能发生的异常。
     */
    public static <T> List<T> parseFromCsvWithSeparatorDetection(
            InputStream inputStream, Class<T> type, String[] columns)
            throws IOException, CsvException {

        // 1. 将整个InputStream读取到内存中的字符串，以便进行分隔符检测
        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. 使用检测到的分隔符和 ColumnPositionMappingStrategy 进行解析
        try (Reader reader = new StringReader(csvContent)) { // 使用 StringReader 再次读取内容
            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;

    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 Main {
    public static void main(String[] args) {
        String[] columns = new String[]{"a", "b"}; // 定义CSV列到Bean字段的映射

        // 示例1: 使用分号分隔的CSV数据
        String csvDataSemicolon = "A1;B1\nA2;B2";
        try (InputStream in1 = new ByteArrayInputStream(csvDataSemicolon.getBytes(StandardCharsets.UTF_8))) {
            List<Bean> objects1 = CsvParserUtil.parseFromCsvWithSeparatorDetection(in1, Bean.class, columns);
            System.out.println("解析分号分隔的CSV:");
            objects1.forEach(System.out::println);
        } catch (IOException | CsvException e) {
            e.printStackTrace();
        }

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

        // 示例2: 使用逗号分隔的CSV数据
        String csvDataComma = "X1,Y1\nX2,Y2";
        try (InputStream in2 = new ByteArrayInputStream(csvDataComma.getBytes(StandardCharsets.UTF_8))) {
            List<Bean> objects2 = CsvParserUtil.parseFromCsvWithSeparatorDetection(in2, Bean.class, columns);
            System.out.println("解析逗号分隔的CSV:");
            objects2.forEach(System.out::println);
        } catch (IOException | CsvException e) {
            e.printStackTrace();
        }
    }
}

A1;B1
A2;B2

X1,Y1
X2,Y2