java将csv导入mysql

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.26</version>
</dependency>
<dependency>
    <groupId>com.opencsv</groupId>
    <artifactId>opencsv</artifactId>
    <version>5.5.2</version>
</dependency>

import com.opencsv.CSVReader;
import com.opencsv.exceptions.CsvValidationException;

import java.io.FileReader;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class CsvToMysql {
    public static void main(String[] args) {
        String csvFile = "path/to/your/file.csv";
        String jdbcUrl = "jdbc:mysql://localhost:3306/your_database";
        String username = "your_username";
        String password = "your_password";
        String tableName = "your_table";

        try (CSVReader reader = new CSVReader(new FileReader(csvFile));
             Connection conn = DriverManager.getConnection(jdbcUrl, username, password)) {

            String[] header = reader.readNext(); // 读取CSV文件的标题行
            String sql = generateInsertSql(header, tableName);

            while ((String[] row : reader.readAll()) {
                PreparedStatement pstmt = conn.prepareStatement(sql);
                for (int i = 0; i < row.length; i++) {
                    pstmt.setString(i + 1, row[i]);
                }
                pstmt.executeUpdate();
            }
        } catch (IOException | SQLException | CsvValidationException e) {
            e.printStackTrace();
        }
    }

    private static String generateInsertSql(String[] columns, String tableName) {
        StringBuilder columnsStr = new StringBuilder();
        StringBuilder valuesStr = new StringBuilder();
        for (String column : columns) {
            columnsStr.append(column).append(",");
            valuesStr.append("?,");
        }
        columnsStr.deleteCharAt(columnsStr.length() - 1);
        valuesStr.deleteCharAt(valuesStr.length() - 1);
        return "INSERT INTO " + tableName + " (" + columnsStr.toString() + ") VALUES (" + valuesStr.toString() + ")";
    }
}