java读取cvs文件并导入数据库

敬爱的读者，首先感谢您对 Java 编程的热爱。关于如何从CSV文件中读取数据并将其导入数据库，本文将提供一个完整的攻略，详细介绍每个步骤。在本文中，我们将使用Java编写代码来实现该功能。

1. 准备CSV文件

首先，需要准备好包含数据的 CSV 文件。CSV 文件是一种纯文本格式，用于存储和交换以逗号、制表符、分号等分隔符隔开的数据。你可以使用 Microsoft Excel 或 Google Sheets 等电子表格应用程序创建一个CSV文件。

请确保 CSV 文件的列与数据库表的列名一致，并且每一行的数据类型与数据库表列的数据类型相匹配。否则，你需要在代码中进行数据类型转换。

2. 导入依赖

接下来，需要将以下依赖项导入到你的代码中，以便从 CSV 文件读取和解析数据：

<!-- CSV 解析器 -->
<dependency>
    <groupId>com.opencsv</groupId>
    <artifactId>opencsv</artifactId>
    <version>5.5.2</version>
</dependency>

<!-- JDBC 驱动程序 -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.26</version>
</dependency>

3. 代码实现

3.1 连接数据库

在开始处理CSV文件之前，我们需要先连接到数据库。请在代码中添加以下代码：

String url = "jdbc:mysql://localhost/mydatabase";
String username = "root";
String password = "password";
Connection connection = DriverManager.getConnection(url, username, password);

请将mydatabase替换为你要连接的数据库名称，并将root和password替换为你的数据库用户名和密码。你需要替换的部分用你真实的用户名和密码。

3.2 读取CSV文件

接下来，我们需要读取 CSV 文件数据。请在代码中添加以下代码：

CSVReader reader = new CSVReader(new FileReader("data.csv"));
List<String[]> data = reader.readAll();

请将"data.csv"替换为你创建的CSV文件的名称或路径。解析完数据后将其存储在 List<String[]>类型的对象中。

3.3 插入数据到数据库

接下来，我们需要将数据插入到数据库中。请在代码中添加以下代码：

PreparedStatement ps = null;
String query = "INSERT INTO table_name (column1, column2, ...) VALUES (?, ?, ...)";
for (String[] row : data) {
    ps = connection.prepareStatement(query);
    ps.setString(1, row[0]);
    ps.setInt(2, Integer.parseInt(row[1])); // 如果你的数据类型不是字符串，请进行相应的数据类型转换
    // 将其他列进行数据类型转换后，添加到 PreparedStatement 中
    ps.executeUpdate();
}

请将 table_name 替换为你要插入数据的表名。在 PreparedStatement 中指定列名和值。请注意，需要将CSV文件中的字符串转换为适当的数据类型（如整数，浮点数，日期等）。

4. 示例

接下来，我们将展示两个使用此攻略导入 CSV 数据的示例。

示例1：将 CSV 数据插入到MySQL数据库中

import java.io.FileReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.List;
import com.opencsv.CSVReader;
import com.opencsv.exceptions.CsvValidationException;

public class CsvToDatabase {
  public static void main(String[] args) throws ClassNotFoundException, SQLException, CsvValidationException {
    String url = "jdbc:mysql://localhost/mydatabase";
    String username = "root";
    String password = "password";
    Connection connection = DriverManager.getConnection(url, username, password);
    CSVReader reader = new CSVReader(new FileReader("data.csv"));
    List<String[]> data = reader.readAll();
    PreparedStatement ps = null;
    String query = "INSERT INTO employee (name, age, salary) VALUES (?, ?, ?)";
    for (String[] row : data) {
      ps = connection.prepareStatement(query);
      ps.setString(1, row[0]);
      ps.setInt(2, Integer.parseInt(row[1]));
      ps.setDouble(3, Double.parseDouble(row[2]));
      ps.executeUpdate();
    }
    System.out.println("CSV data inserted into the database successfully"); // 提示插入成功
    connection.close();
  }
}

示例2：将 CSV 数据插入到PostgreSQL数据库中

import java.io.FileReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.List;
import com.opencsv.CSVReader;
import com.opencsv.exceptions.CsvValidationException;

public class CsvToDatabase {
  public static void main(String[] args) throws ClassNotFoundException, SQLException, CsvValidationException {
    String url = "jdbc:postgresql://localhost/mydatabase";
    String username = "postgres";
    String password = "password";
    Connection connection = DriverManager.getConnection(url, username, password);
    CSVReader reader = new CSVReader(new FileReader("data.csv"));
    List<String[]> data = reader.readAll();
    PreparedStatement ps = null;
    String query = "INSERT INTO employee (name, age, salary) VALUES (?, ?, ?)";
    for (String[] row : data) {
      ps = connection.prepareStatement(query);
      ps.setString(1, row[0]);
      ps.setInt(2, Integer.parseInt(row[1]));
      ps.setDouble(3, Double.parseDouble(row[2]));
      ps.executeUpdate();
    }
    System.out.println("CSV data inserted into the database successfully"); // 提示插入成功
    connection.close();
  }
}

这是完整的代码示例。你可以根据自己的需求进行更改和修改。

我们希望以上攻略能够帮助你成功地将 CSV 数据导入到数据库中。如果你遇到任何问题，请随时在评论中发表评论回复。