java将csv导入mysql

基础概念

CSV（Comma-Separated Values，逗号分隔值）是一种常见的数据交换格式，每一行代表一条记录，每个字段由逗号分隔。MySQL是一种关系型数据库管理系统，用于存储和管理数据。

类型

CSV文件可以是UTF-8编码或其他编码格式，字段分隔符可以是逗号，也可以是其他字符（如制表符）。

应用场景

CSV文件常用于数据备份、数据交换、日志记录等场景。将CSV导入MySQL可以用于数据导入、数据迁移、批量数据更新等。

导入MySQL的步骤

准备CSV文件：确保CSV文件的格式正确，字段顺序与数据库表结构一致。
创建MySQL表：在MySQL中创建与CSV文件字段对应的表。
使用Java代码导入数据：编写Java代码读取CSV文件并将数据插入MySQL表中。

示例代码

以下是一个简单的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>

Java代码

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() + ")";
    }
}