连接 MySQL 数据库使用 JDBC

连接 MySQL 数据库使用 JDBC（Java Database Connectivity）技术是 Java 开发中常见的任务。以下是连接 MySQL 数据库的基本步骤和示例代码：

步骤：

1. 导入 JDBC 驱动包：
   首先，确保你已经下载并导入了 MySQL 的 JDBC 驱动包。你可以从 MySQL 官方网站下载或者通过 Maven、Gradle 等构建工具引入依赖。

   <!-- Maven 依赖 -->
   <dependency>
       <groupId>mysql</groupId>
       <artifactId>mysql-connector-java</artifactId>
       <version>8.0.28</version> <!-- 这里是版本号，可以根据实际情况调整 -->
   </dependency>
   

2. 加载驱动类：
   在代码中加载 MySQL 的 JDBC 驱动类。这通常在应用程序启动时执行一次即可。

   Class.forName("com.mysql.cj.jdbc.Driver");
   

   注意：在 MySQL Connector/J 8.x 版本后，驱动类名变为 com.mysql.cj.jdbc.Driver。

3. 建立数据库连接：
   使用 DriverManager.getConnection 方法建立与 MySQL 数据库的连接，需要指定数据库 URL、用户名和密码。

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

   • localhost:3306 是 MySQL 服务器的地址和端口号。
   • mydatabase 是数据库的名称。
   • username 和 password 是 MySQL 用户的用户名和密码。

4. 执行 SQL 查询或更新：
   通过 Connection 对象创建 Statement 或 PreparedStatement，然后执行 SQL 查询或更新操作。

   Statement statement = connection.createStatement();
   ResultSet resultSet = statement.executeQuery("SELECT * FROM mytable");
   
   while (resultSet.next()) {
        
       // 处理结果集
       String column1 = resultSet.getString("column1");
       int column2 = resultSet.getInt("column2");
       // 处理其他列...
   }
   
   // 关闭资源
   resultSet.close();
   statement.close();
   

5. 关闭连接：
   在所有操作完成后，务必关闭数据库连接和相关资源，以释放资源并避免内存泄漏。

   connection.close();
   

示例代码：

import java.sql.*;

public class MySQLExample {
   

    public static void main(String[] args) {
   
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String username = "username";
        String password = "password";

        try {
   
            // 加载驱动类
            Class.forName("com.mysql.cj.jdbc.Driver");

            // 建立连接
            Connection connection = DriverManager.getConnection(url, username, password);

            // 执行查询
            Statement statement = connection.createStatement();
            ResultSet resultSet = statement.executeQuery("SELECT * FROM mytable");

            // 处理结果集
            while (resultSet.next()) {
   
                String column1 = resultSet.getString("column1");
                int column2 = resultSet.getInt("column2");
                // 处理其他列...
                System.out.println(column1 + ", " + column2);
            }

            // 关闭资源
            resultSet.close();
            statement.close();
            connection.close();

        } catch (ClassNotFoundException | SQLException e) {
   
            e.printStackTrace();
        }
    }
}

除了基本的连接和执行查询外，还有一些额外的注意事项和技巧可以帮助你更好地使用 JDBC 连接 MySQL 数据库：

1. 异常处理：
   在使用 JDBC 时，经常需要处理各种异常，例如 ClassNotFoundException（找不到驱动类）、SQLException（SQL 异常）等。合理的异常处理可以提高程序的健壮性和可靠性。

   try {
        
       // JDBC 代码
   } catch (ClassNotFoundException e) {
        
       e.printStackTrace(); // 处理驱动类找不到异常
   } catch (SQLException e) {
        
       e.printStackTrace(); // 处理 SQL 异常
   }
   

2. 使用 PreparedStatement：
   PreparedStatement 是 Statement 的子接口，它可以预编译 SQL 语句，执行效率更高，同时能够有效防止 SQL 注入攻击。

   String sql = "SELECT * FROM mytable WHERE column1 = ?";
   PreparedStatement preparedStatement = connection.prepareStatement(sql);
   preparedStatement.setString(1, "some_value");
   ResultSet resultSet = preparedStatement.executeQuery();
   

3. 事务管理：
   如果需要执行一系列相关的 SQL 操作，并确保它们要么全部成功要么全部失败，可以使用事务管理来保证数据的一致性。

   try {
        
       connection.setAutoCommit(false); // 关闭自动提交
       // 执行多条 SQL 语句
       connection.commit(); // 提交事务
   } catch (SQLException e) {
        
       connection.rollback(); // 发生异常时回滚事务
   } finally {
        
       connection.setAutoCommit(true); // 恢复自动提交模式
   }
   

4. 连接池：
   在实际应用中，频繁地创建和关闭数据库连接会带来性能开销。使用连接池可以有效地管理数据库连接，提高性能并减少资源消耗。

   // 使用第三方连接池，如 HikariCP、Apache DBCP 等
   DataSource dataSource = new HikariDataSource(config); // 配置连接池
   Connection connection = dataSource.getConnection();
   

5. 日期和时间处理：
   如果需要处理 MySQL 的日期和时间类型，例如 DATE、TIME、DATETIME，可以使用 JDBC 提供的 java.sql.Date、java.sql.Time 和 java.sql.Timestamp 类。

   PreparedStatement preparedStatement = connection.prepareStatement("INSERT INTO mytable (date_column) VALUES (?)");
   Date date = new Date(System.currentTimeMillis());
   preparedStatement.setDate(1, date);
   

6. 性能优化：
   在编写 SQL 查询时，尽量避免使用 SELECT *，而是明确列出需要查询的字段。另外，可以使用索引来加快查询速度，特别是在处理大量数据时。

7. 资源关闭：
   始终在使用完数据库连接、Statement、ResultSet 等资源后及时关闭它们，以释放资源并避免内存泄漏。