java 怎么导入数据库

前置条件与核心组件

✅ 必要元素清单

🔧 典型场景分类

标准实现流程（以MySQL为例）

📌 Step 1: 添加依赖库

<!-Maven坐标 -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.33</version>
</dependency>

⚠️ 注意：若使用旧版驱动可能出现时区问题，建议升级至8.x系列并添加以下启动参数：
jdbc:mysql://localhost:3306/mydb?serverTimezone=UTC

📌 Step 2: 建立数据库连接

// 传统DAO模式写法
public class DBUtil {
    private static final String URL = "jdbc:mysql://localhost:3306/testdb";
    private static final String USER = "root";
    private static final String PASSWORD = "your_password";
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(URL, USER, PASSWORD);
    }
}

💡 优化建议：采用连接池替代直接获取物理连接

// HikariCP连接池配置示例
HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:mysql://localhost:3306/testdb");
config.setUsername("root");
config.setPassword("your_password");
config.addDataSourceProperty("cachePrepStmts", "true");
config.addDataSourceProperty("prepStmtCacheSize", "250");
HikariDataSource ds = new HikariDataSource(config);

📌 Step 3: 执行SQL语句

Statement对象（适用于无参查询）

try (Connection conn = DBUtil.getConnection();
     Statement stmt = conn.createStatement()) {
    ResultSet rs = stmt.executeQuery("SELECT  FROM employees");
    while (rs.next()) {
        System.out.println(rs.getString("name"));
    }
} catch (SQLException e) {
    e.printStackTrace();
}

PreparedStatement（推荐，防SQL注入）

String sql = "INSERT INTO products(name, price) VALUES(?, ?)";
try (Connection conn = DBUtil.getConnection();
     PreparedStatement pstmt = conn.prepareStatement(sql)) {
    pstmt.setString(1, "Laptop");
    pstmt.setDouble(2, 999.99);
    int affectedRows = pstmt.executeUpdate();
} catch (SQLException e) {
    e.printStackTrace();
}

📌 Step 4: 结果集处理

关键问题解决方案

🔥 高频异常排查表

⚡️ 性能优化技巧

1. 批处理机制：将多次单条插入改为批量提交

   String sql = "INSERT INTO logs(message) VALUES(?)";
   try (Connection conn = ds.getConnection();
     PreparedStatement pstmt = conn.prepareStatement(sql)) {
    for (String msg : messages) {
        pstmt.setString(1, msg);
        pstmt.addBatch(); // 累积到批处理队列
    }
    pstmt.executeBatch(); // 一次性发送所有指令
   }

2. 流式读取：处理大数据量时启用流模式

   Statement stmt = conn.createStatement();
   stmt.setFetchSize(Integer.MIN_VALUE); // 启用流式读取
   ResultSet rs = stmt.executeQuery("SELECT  FROM huge_table");
   while (rs.next()) { / 逐行处理 / }

3. 连接复用：通过连接池减少TCP握手开销
   • HikariCP默认最大连接数=10，可根据CPU核心数调整
   • 空闲超时时间建议设置为30分钟

现代框架集成方案

相关问答FAQs

Q1: 为什么会出现”com.mysql.cj.jdbc.exceptions.CommunicationsException”?

A: 这是典型的网络层故障，常见原因包括：① 数据库服务未启动；② 防火墙阻止了3306端口；③ 连接字符串中的IP地址错误，排查步骤：

1. 执行telnet localhost 3306验证端口可达性
2. 检查my.cnf配置文件中的bind-address是否允许远程连接
3. 确认使用的是正确的数据库名称而非实例名

Q2: 如何实现Excel文件批量导入数据库？

A: 推荐使用Apache POI解析Excel，结合批处理实现高效导入：

// 伪代码示例
Workbook workbook = WorkbookFactory.create(new FileInputStream("data.xlsx"));
Sheet sheet = workbook.getSheetAt(0);
List<Object[]> batchData = new ArrayList<>();
for (Row row : sheet) {
    Object[] values = Arrays.stream(row.getCells())
                            .map(cell -> cell.toString())
                            .toArray();
    batchData.add(values);
}
try (Connection conn = ds.getConnection();
     PreparedStatement pstmt = conn.prepareStatement(
         "INSERT INTO table_name VALUES(?, ?, ...)")) {
    for (Object[] data : batchData) {
        for (int i = 0; i < data.length; i++) {
            pstmt.setObject(i+1, data[i]);
        }
        pstmt.addBatch();
    }
    pstmt.executeBatch(); // 单次网络往返完成全部插入
}