Java与MySQL数据库连接实战：JDBC使用教程

在Java开发中，数据库操作是核心功能之一。JDBC（Java Database Connectivity）作为Java标准API，为开发者提供了统一的数据访问接口，使得Java程序能够无缝连接各类关系型数据库。本文ZHANID工具网将以MySQL数据库为例，通过实战案例和代码解析，系统讲解JDBC的核心使用方法，涵盖驱动配置、连接管理、SQL执行及结果处理等关键环节。

一、JDBC核心概念与优势

1.1 JDBC的定位与架构

JDBC是Java语言中用于执行SQL语句的API，其核心架构由以下组件构成：

• DriverManager：驱动管理类，负责加载和注册数据库驱动

• Connection：数据库连接对象，代表与数据库的物理连接

• Statement/PreparedStatement：SQL执行接口，支持静态和预编译SQL

• ResultSet：结果集对象，封装查询返回的数据

1.2 关键优势解析

二、环境准备与驱动配置

2.1 开发环境搭建

• JDK版本：推荐JDK 8或以上版本

• IDE选择：IntelliJ IDEA/Eclipse等主流开发工具

• MySQL版本：MySQL 5.7+或MariaDB 10.0+

2.2 驱动包获取与配置

步骤1：下载官方驱动
访问MySQL官网下载Connector/J驱动包，选择与数据库版本匹配的驱动（如MySQL 8.x对应mysql-connector-java-8.0.xx.jar）。

步骤2：IDE配置方法
以IntelliJ IDEA为例：

1. 创建libs目录存放驱动包

2. 右键项目 → Open Module Settings → Dependencies

3. 点击+ → JARs or Directories → 选择驱动包路径

4. 确认添加后应用配置

步骤3：Maven项目配置
在pom.xml中添加依赖：

<dependency>
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
  <version>8.0.28</version>
</dependency>

三、数据库连接实现方式

3.1 基础连接方式（DriverManager）

代码示例：

import java.sql.*;

public class BasicConnection {
  public static void main(String[] args) {
    // 连接参数配置
    String url = "jdbc:mysql://localhost:3306/test_db?useSSL=false&serverTimezone=UTC";
    String user = "root";
    String password = "123456";

    try (Connection conn = DriverManager.getConnection(url, user, password)) {
      System.out.println("连接成功！数据库版本：" + conn.getMetaData().getDatabaseProductVersion());
    } catch (SQLException e) {
      e.printStackTrace();
    }
  }
}

关键参数说明：

• useSSL=false：禁用SSL加密（开发环境推荐）

• serverTimezone=UTC：解决时区配置问题

• allowPublicKeyRetrieval=true：MySQL 8.x认证插件兼容设置

3.2 高级连接方式（DataSource）

HikariCP连接池配置示例：

import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import java.sql.Connection;

public class DataSourceConnection {
  public static void main(String[] args) {
    HikariConfig config = new HikariConfig();
    config.setJdbcUrl("jdbc:mysql://localhost:3306/test_db");
    config.setUsername("root");
    config.setPassword("123456");
    config.setMaximumPoolSize(10);
    config.setConnectionTimeout(30000);

    try (HikariDataSource ds = new HikariDataSource(config);
       Connection conn = ds.getConnection()) {
      System.out.println("通过连接池获取连接成功！");
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}

性能对比：

四、CRUD操作实战

4.1 数据库表准备

CREATE TABLE users (
  id INT AUTO_INCREMENT PRIMARY KEY,
  username VARCHAR(50) NOT NULL,
  email VARCHAR(100) UNIQUE,
  create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

INSERT INTO users (username, email) VALUES 
('admin', 'admin@example.com'),
('user1', 'user1@test.org');

4.2 查询操作实现

单条查询示例：

public class QueryExample {
  public static void main(String[] args) {
    String sql = "SELECT * FROM users WHERE id = ?";
    
    try (Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
       PreparedStatement pstmt = conn.prepareStatement(sql)) {
      
      pstmt.setInt(1, 1);
      ResultSet rs = pstmt.executeQuery();
      
      while (rs.next()) {
        System.out.printf("ID: %d, 用户名: %s, 邮箱: %s%n",
          rs.getInt("id"),
          rs.getString("username"),
          rs.getString("email"));
      }
    } catch (SQLException e) {
      e.printStackTrace();
    }
  }
}

4.3 增删改操作实现

批量插入示例：

public class BatchInsert {
  public static void main(String[] args) {
    String sql = "INSERT INTO users (username, email) VALUES (?, ?)";
    
    try (Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
       PreparedStatement pstmt = conn.prepareStatement(sql)) {
      
      // 添加批处理参数
      pstmt.setString(1, "user2");
      pstmt.setString(2, "user2@test.com");
      pstmt.addBatch();
      
      pstmt.setString(1, "user3");
      pstmt.setString(2, "user3@test.org");
      pstmt.addBatch();
      
      // 执行批处理
      int[] results = pstmt.executeBatch();
      System.out.println("成功插入 " + results.length + " 条记录");
    } catch (SQLException e) {
      e.printStackTrace();
    }
  }
}

五、事务管理与异常处理

5.1 事务控制示例

public class TransactionExample {
  public static void main(String[] args) {
    Connection conn = null;
    try {
      conn = DriverManager.getConnection(DB_URL, USER, PASS);
      conn.setAutoCommit(false); // 关闭自动提交
      
      // 执行转账操作
      updateBalance(conn, 1, -100); // 账户1扣款
      updateBalance(conn, 2, 100); // 账户2收款
      
      conn.commit(); // 提交事务
      System.out.println("转账成功！");
    } catch (SQLException e) {
      try {
        if (conn != null) conn.rollback(); // 回滚事务
      } catch (SQLException ex) {
        ex.printStackTrace();
      }
      e.printStackTrace();
    } finally {
      try {
        if (conn != null) conn.setAutoCommit(true); // 恢复自动提交
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
  }
  
  private static void updateBalance(Connection conn, int accountId, double amount) throws SQLException {
    String sql = "UPDATE accounts SET balance = balance + ? WHERE id = ?";
    try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
      pstmt.setDouble(1, amount);
      pstmt.setInt(2, accountId);
      pstmt.executeUpdate();
    }
  }
}

5.2 异常处理策略

六、性能优化实践

6.1 连接池配置建议

HikariCP优化参数：

# 最小空闲连接数
minimumIdle=5
# 最大连接数
maximumPoolSize=20
# 连接存活时间（毫秒）
maxLifetime=1800000
# 连接超时时间（毫秒）
connectionTimeout=30000
# 空闲连接检测周期（毫秒）
idleTimeout=600000

6.2 SQL优化技巧

• 索引优化：为高频查询字段创建索引

• 分页查询：使用LIMIT offset, size替代全表扫描

• 批量操作：单次提交100-500条记录为最佳实践

• 结果集处理：及时调用ResultSet.close()释放资源

七、常见问题解决方案

7.1 连接失败排查流程

1. 验证服务状态：systemctl status mysql

2. 检查网络连通性：telnet localhost 3306

3. 验证用户权限：SELECT host, user FROM mysql.user;

4. 查看错误日志：tail -f /var/log/mysql/error.log

7.2 驱动兼容性问题

八、完整示例代码

import java.sql.*;
import java.util.ArrayList;
import java.util.List;

public class JdbcCompleteDemo {
  // 数据库配置
  private static final String DB_URL = "jdbc:mysql://localhost:3306/test_db?useSSL=false&serverTimezone=UTC";
  private static final String USER = "root";
  private static final String PASS = "123456";

  public static void main(String[] args) {
    Connection conn = null;
    try {
      // 1. 加载驱动（JDBC 4.0+可自动加载）
      Class.forName("com.mysql.cj.jdbc.Driver");
      
      // 2. 获取连接
      conn = DriverManager.getConnection(DB_URL, USER, PASS);
      
      // 3. 查询操作
      List<User> users = queryUsers(conn);
      users.forEach(System.out::println);
      
      // 4. 插入操作
      int newId = insertUser(conn, "new_user", "new@test.com");
      System.out.println("新增用户ID: " + newId);
      
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      // 5. 关闭连接
      try {
        if (conn != null) conn.close();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
  }

  // 查询用户方法
  private static List<User> queryUsers(Connection conn) throws SQLException {
    List<User> users = new ArrayList<>();
    String sql = "SELECT * FROM users";
    
    try (Statement stmt = conn.createStatement();
       ResultSet rs = stmt.executeQuery(sql)) {
      
      while (rs.next()) {
        User user = new User();
        user.setId(rs.getInt("id"));
        user.setUsername(rs.getString("username"));
        user.setEmail(rs.getString("email"));
        users.add(user);
      }
    }
    return users;
  }

  // 插入用户方法
  private static int insertUser(Connection conn, String username, String email) throws SQLException {
    String sql = "INSERT INTO users (username, email) VALUES (?, ?)";
    
    try (PreparedStatement pstmt = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS)) {
      pstmt.setString(1, username);
      pstmt.setString(2, email);
      pstmt.executeUpdate();
      
      // 获取自增ID
      try (ResultSet rs = pstmt.getGeneratedKeys()) {
        if (rs.next()) {
          return rs.getInt(1);
        }
      }
    }
    return -1;
  }

  // 用户实体类
  static class User {
    private int id;
    private String username;
    private String email;
    
    // getters & setters & toString...
    @Override
    public String toString() {
      return String.format("User{id=%d, username='%s', email='%s'}", id, username, email);
    }
  }
}

结语

本文通过系统化的知识讲解和实战案例演示，完整呈现了JDBC连接MySQL数据库的全流程。从基础连接配置到高级性能优化，从简单CRUD操作到复杂事务管理，覆盖了实际开发中的核心场景。建议开发者在实践中结合具体业务需求，灵活运用连接池、预编译语句等优化技术，持续提升数据库操作的效率和稳定性。