Java连接MySQL数据库是Java开发中常见的需求,尤其在企业级应用中,数据库操作是核心功能之一,本文将详细介绍Java连接MySQL数据库的方法、步骤及注意事项,帮助开发者快速掌握这一技能。

准备工作
在开始之前,需要确保已经安装了Java开发环境(JDK)和MySQL数据库,还需要下载MySQL的JDBC驱动程序,JDBC(Java Database Connectivity)是Java提供的用于执行SQL语句的API,通过它可以实现Java与各种数据库的连接,可以从MySQL官网下载最新版本的JDBC驱动,通常是一个.jar文件。
添加JDBC驱动
将下载的MySQL JDBC驱动.jar文件添加到Java项目的类路径中,如果使用Maven或Gradle等构建工具,可以在pom.xml或build.gradle文件中添加依赖,在Maven项目中,添加以下依赖:
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.26</version>
</dependency>
添加依赖后,构建工具会自动下载并配置驱动程序。
加载驱动类
在Java代码中,需要加载MySQL的JDBC驱动类,使用Class.forName()方法可以动态加载驱动类。
Class.forName("com.mysql.cj.jdbc.Driver");
注意:从MySQL 8.0开始,驱动类名已更改为com.mysql.cj.jdbc.Driver,旧版本的驱动类名为com.mysql.jdbc.Driver。
建立数据库连接
加载驱动类后,可以使用DriverManager类的getConnection()方法建立与MySQL数据库的连接,该方法需要三个参数:数据库URL、用户名和密码,数据库URL的格式为:
jdbc:mysql://hostname:port/databaseName
hostname是MySQL服务器的主机名或IP地址,port是端口号(默认为3306),databaseName是要连接的数据库名称。

String url = "jdbc:mysql://localhost:3306/testdb"; String username = "root"; String password = "password"; Connection connection = DriverManager.getConnection(url, username, password);
如果连接的是远程数据库,需要确保防火墙允许相应端口的访问。
执行SQL语句
连接建立后,可以通过Connection对象创建Statement或PreparedStatement对象来执行SQL语句,Statement用于执行静态SQL语句,而PreparedStatement用于执行预编译的SQL语句,可以防止SQL注入攻击。
String sql = "SELECT * FROM users"; Statement statement = connection.createStatement(); ResultSet resultSet = statement.executeQuery(sql);
遍历ResultSet对象可以获取查询结果:
while (resultSet.next()) {
String username = resultSet.getString("username");
int age = resultSet.getInt("age");
System.out.println("Username: " + username + ", Age: " + age);
}
使用PreparedStatement
对于需要参数的SQL语句,建议使用PreparedStatement。
String sql = "INSERT INTO users (username, age) VALUES (?, ?)"; PreparedStatement preparedStatement = connection.prepareStatement(sql); preparedStatement.setString(1, "john_doe"); preparedStatement.setInt(2, 30); preparedStatement.executeUpdate();
PreparedStatement的参数索引从1开始,可以使用setString()、setInt()等方法设置参数类型。
处理结果集
ResultSet对象包含了查询结果,可以使用next()方法移动指针,并通过getXXX()方法获取列值。
while (resultSet.next()) {
int id = resultSet.getInt("id");
String name = resultSet.getString("name");
System.out.println("ID: " + id + ", Name: " + name);
}
注意:在使用完ResultSet后,需要关闭它以释放资源。

事务管理
数据库事务是一组SQL操作,这些操作要么全部执行,要么全部不执行,可以使用Connection对象的方法来管理事务。
connection.setAutoCommit(false); // 开启事务
try {
// 执行多个SQL语句
statement.executeUpdate("UPDATE accounts SET balance = balance - 100 WHERE id = 1");
statement.executeUpdate("UPDATE accounts SET balance = balance + 100 WHERE id = 2");
connection.commit(); // 提交事务
} catch (SQLException e) {
connection.rollback(); // 回滚事务
e.printStackTrace();
} finally {
connection.setAutoCommit(true); // 恢复自动提交模式
}
关闭资源
在完成数据库操作后,需要关闭所有打开的资源,包括ResultSet、Statement和Connection对象,可以使用try-with-resources语句来自动关闭资源,
try (Connection connection = DriverManager.getConnection(url, username, password);
Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery(sql)) {
// 执行SQL语句
} catch (SQLException e) {
e.printStackTrace();
}
try-with-resources语句会自动关闭实现了AutoCloseable接口的资源对象。
常见问题及解决方法
在连接MySQL数据库时,可能会遇到一些常见问题,例如连接超时、驱动版本不兼容等,可以通过检查数据库URL、用户名、密码是否正确,以及确保驱动版本与MySQL版本兼容来解决这些问题。
相关问答FAQs
问题1:Java连接MySQL时出现“Access denied for user 'root'@'localhost'”错误,如何解决?
解答:这个错误通常是由于用户名或密码错误导致的,请检查MySQL数据库中root用户的密码是否正确,或者尝试使用其他具有权限的用户连接,如果密码忘记,可以通过MySQL的安全模式重置密码。
问题2:如何优化Java连接MySQL数据库的性能?
解答:可以通过以下方法优化性能:1. 使用连接池(如HikariCP、DBCP)管理数据库连接,避免频繁创建和销毁连接;2. 使用PreparedStatement预编译SQL语句,减少解析时间;3. 合理设计数据库索引,提高查询效率;4. 避免在循环中执行数据库操作,尽量批量处理数据。