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

    /**
     * 解析CSV输入流，自动检测分隔符（分号或逗号）。
     *
     * @param inputStream CSV文件的输入流。
     * @param type 目标Java对象的Class类型。
     * @param columns 用于映射CSV列到Java对象属性的列名数组。
     * @param <T> 目标Java对象的泛型类型。
     * @return 转换后的Java对象列表。
     * @throws IOException IO操作异常。
     * @throws CsvException OpenCSV解析异常。
     */
    public static <T> List<T> parseFromCsvWithSeparatorDetection(
            InputStream inputStream, Class<T> type, String[] columns)
            throws IOException, CsvException {

        // 步骤1：将整个InputStream读取到内存中的String，以便进行分隔符检测。
        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：使用检测到的分隔符重新构建Reader并进行解析。
        try (Reader reader = new StringReader(csvContent)) {
            // 配置列位置映射策略，适用于没有标题行的CSV文件。
            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 User {
    private String id;
    private String name;

    // 必须有无参构造函数
    public User() {
    }

    // Getter和Setter方法
    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    @Override
    public String toString() {
        return "User{id='" + id + "', name='" + name + "'}";
    }
}

import java.io.ByteArrayInputStream;
import java.io.InputStream;
import java.util.List;

public class Demo {
    public static void main(String[] args) {
        // 示例CSV数据1：使用分号作为分隔符
        String csvDataSemicolon = "user1;Alice\nuser2;Bob";
        // 示例CSV数据2：使用逗号作为分隔符
        String csvDataComma = "user3,Charlie\nuser4,David";

        // 定义列映射，对应User类的id和name属性
        String[] columns = new String[]{"id", "name"};

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

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

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

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