java使用javacsv读取csv文件 导入Mysql数据库

在Java编程中，将CSV（逗号分隔值）文件的数据导入到MySQL数据库是一项常见的任务。这个过程涉及几个关键步骤，包括读取CSV文件、解析数据、建立与数据库的连接以及执行SQL插入语句。本篇文章将详细讲解如何使用javacsv库来实现这一功能。 `javacsv`是一个轻量级的Java库，专门用于处理CSV文件。它提供了简单易用的API，使我们能够轻松地读取和写入CSV数据。在项目中使用这个库，你需要先将其添加到你的类路径中。如果你使用的是Maven，可以在pom.xml文件中添加以下依赖： ```xml <dependency> <groupId>com.opencsv</groupId> <artifactId>opencsv</artifactId> <version>5.5.2</version> </dependency> ``` 接下来，我们需要编写代码来读取CSV文件。使用`CSVReader`类，可以逐行读取文件并解析每个字段。例如： ```java import com.opencsv.CSVReader; import java.io.FileReader; import java.io.IOException; public class CSVReaderExample { public static void main(String[] args) { try (CSVReader reader = new CSVReader(new FileReader("path_to_your_csv_file.csv"))) { String[] record; while ((record = reader.readNext()) != null) { // 处理每一行记录 processRecord(record); } } catch (IOException e) { e.printStackTrace(); } } private static void processRecord(String[] record) { // 在这里，record数组包含了CSV文件中的一行数据，可以按需处理 } } ``` 在读取CSV数据后，我们需要建立与MySQL数据库的连接。这可以通过JDBC（Java Database Connectivity）实现。确保你的系统已经安装了MySQL驱动，并且添加了对应的JDBC驱动到项目中。如果你使用Maven，添加如下依赖： ```xml <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.27</version> </dependency> ``` 然后，通过`DriverManager.getConnection()`方法创建数据库连接： ```java import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; public class MySQLConnectionExample { public static Connection getConnection() throws SQLException { String url = "jdbc:mysql://localhost:3306/your_database"; String user = "your_username"; String password = "your_password"; return DriverManager.getConnection(url, user, password); } } ``` 当有了数据库连接后，我们可以使用`PreparedStatement`对象来准备和执行SQL插入语句。假设你的CSV文件包含与数据库表相同的列名，你可以这样做： ```java public static void importCSVToDatabase(String[] record, Connection conn) throws SQLException { String sql = "INSERT INTO your_table (column1, column2, ...) VALUES (?, ?, ...)"; try (PreparedStatement pstmt = conn.prepareStatement(sql)) { for (int i = 0; i < record.length; i++) { pstmt.setString(i + 1, record[i]); } pstmt.executeUpdate(); } } ``` 将读取CSV文件和插入数据的过程结合起来，遍历CSV文件中的所有行，对每一行调用`importCSVToDatabase()`函数： ```java public static void main(String[] args) { // ... while ((record = reader.readNext()) != null) { Connection conn = MySQLConnectionExample.getConnection(); importCSVToDatabase(record, conn); conn.close(); } // ... } ``` 以上就是使用javacsv库读取CSV文件并导入到MySQL数据库的基本步骤。在实际应用中，你可能需要处理更复杂的情况，比如错误处理、事务管理、性能优化等。此外，考虑到文件读写和数据库操作的性能，你还可以考虑使用多线程或者批量插入策略来提高效率。记得在完成后关闭所有资源，以防止内存泄漏和资源浪费。