当前位置：首页 > 后端开发 > 正文

如何用Java快速导入Excel数据

admin
后端开发
2025-07-02
3774

在Java中导入数据库表通常有两种方式：使用JDBC直接执行SQL脚本，或通过ORM框架（如Hibernate）的实体类映射，关键步骤包括：建立数据库连接、读取SQL文件内容、执行CREATE TABLE等DDL语句，或配置@Entity注解实现自动建表。

在Java中导入表通常涉及两种场景：导入表结构（创建数据库表） 或 导入表数据（将外部数据写入数据库），以下是详细实现方法,涵盖常见需求：

导入表结构（执行SQL脚本创建表）

通过Java执行SQL脚本文件（如 .sql）,在数据库中创建表结构。

步骤与代码示例

准备SQL脚本文件（如 schema.sql）：

如何用Java快速导入Excel数据第1张

CREATE TABLE users (
  id INT PRIMARY KEY AUTO_INCREMENT,
  name VARCHAR(50) NOT NULL,
  email VARCHAR(100) UNIQUE
);

Java代码执行SQL脚本：

import java.io.BufferedReader;
import java.io.FileReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
public class ImportTableSchema {
    public static void main(String[] args) {
        String jdbcUrl = "jdbc:mysql://localhost:3306/your_database";
        String username = "root";
        String password = "password";
        try (Connection conn = DriverManager.getConnection(jdbcUrl, username, password);
             Statement stmt = conn.createStatement()) {
            // 读取SQL脚本
            BufferedReader reader = new BufferedReader(new FileReader("path/to/schema.sql"));
            String line;
            StringBuilder sql = new StringBuilder();
            while ((line = reader.readLine()) != null) {
                sql.append(line);
            }
            reader.close();
            // 执行SQL（支持多语句）
            stmt.execute(sql.toString());
            System.out.println("表结构导入成功！");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

关键点

依赖库：需JDBC驱动（如MySQL：mysql-connector-java）。
事务处理：建议添加事务回滚（conn.setAutoCommit(false)）。
批量执行：若脚本过大,按分号拆分语句逐条执行。

导入表数据（从文件导入数据库）

将外部数据文件（如CSV、Excel）导入到数据库表中。

场景1：从CSV文件导入

import java.io.BufferedReader;
import java.io.FileReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class ImportCSVToTable {
    public static void main(String[] args) {
        String csvFile = "path/to/data.csv";
        String jdbcUrl = "jdbc:mysql://localhost:3306/your_database";
        String username = "root";
        String password = "password";
        String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
        try (Connection conn = DriverManager.getConnection(jdbcUrl, username, password);
             PreparedStatement pstmt = conn.prepareStatement(sql);
             BufferedReader br = new BufferedReader(new FileReader(csvFile))) {
            String line;
            br.readLine(); // 跳过CSV标题行
            while ((line = br.readLine()) != null) {
                String[] data = line.split(",");
                pstmt.setString(1, data[0]); // name
                pstmt.setString(2, data[1]); // email
                pstmt.addBatch(); // 加入批处理
            }
            pstmt.executeBatch(); // 批量执行
            System.out.println("CSV数据导入成功！");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

场景2：从Excel导入（使用Apache POI）

添加依赖（Maven）：

<dependency>
  <groupId>org.apache.poi</groupId>
  <artifactId>poi</artifactId>
  <version>5.2.3</version>
</dependency>

Java代码：

import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import org.apache.poi.ss.usermodel.*;
public class ImportExcelToTable {
    public static void main(String[] args) {
        String excelFile = "path/to/data.xlsx";
        String jdbcUrl = "jdbc:mysql://localhost:3306/your_database";
        String username = "root";
        String password = "password";
        String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
        try (Connection conn = DriverManager.getConnection(jdbcUrl, username, password);
             PreparedStatement pstmt = conn.prepareStatement(sql);
             FileInputStream fis = new FileInputStream(excelFile);
             Workbook workbook = WorkbookFactory.create(fis)) {
            Sheet sheet = workbook.getSheetAt(0); // 第一个工作表
            for (Row row : sheet) {
                if (row.getRowNum() == 0) continue; // 跳过标题行
                String name = row.getCell(0).getStringCellValue();
                String email = row.getCell(1).getStringCellValue();
                pstmt.setString(1, name);
                pstmt.setString(2, email);
                pstmt.executeUpdate();
            }
            System.out.println("Excel数据导入成功！");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

注意事项

性能优化：
- 批量插入时启用 rewriteBatchedStatements=true（MySQL）。
- 分批次提交（每1000条执行一次 executeBatch()）。
错误处理：
- 捕获 SQLException 并回滚事务。
- 验证文件格式（如CSV分隔符、Excel单元格类型）。
安全风险：
- 防止SQL注入：必须使用 PreparedStatement。
- 文件路径校验：避免任意文件读取破绽。
依赖管理：
- 数据库驱动需与数据库版本匹配。
- 大型文件导入时增加JVM内存（-Xmx1024m）。