MySQL是一种流行的关系型数据库，广泛应用于各种应用程序中。在Java应用程序中，MySQL也是常用的数据库之一。本教程将详细介绍如何使用Java连接MySQL数据库，提供多个方面的阐述，包括MySQL数据库的连接、CRUD操作、事务处理等内容。
一、MySQL数据库的连接
在Java应用程序中连接MySQL数据库，需要先获取数据库连接。获取数据库连接的方式有多种，其中使用MySQL官方提供的JDBC驱动程序是较为常用的方式。以下是获取MySQL数据库连接的示例代码：
try {
// 加载MySQL JDBC驱动程序
Class.forName("com.mysql.cj.jdbc.Driver");
// 创建连接
String url = "jdbc:mysql://localhost:3306/mydb?useSSL=false&serverTimezone=UTC";
String user = "root";
String password = "123456";
Connection connection = DriverManager.getConnection(url, user, password);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
以上代码中，首先使用Class.forName()方法加载MySQL JDBC驱动程序。接着创建连接时，需要指定MySQL服务器地址、端口号、数据库名、用户名和密码。在创建连接时可以通过修改URL的参数来控制连接的一些属性，如是否使用SSL、时区等。
二、CRUD操作
1. 查询操作
查询操作是数据库中最常用的操作之一。以下是查询操作的示例代码：
try {
String sql = "SELECT * FROM users";
PreparedStatement statement = connection.prepareStatement(sql);
ResultSet resultSet = statement.executeQuery();
while (resultSet.next()) {
int id = resultSet.getInt("id");
String name = resultSet.getString("name");
int age = resultSet.getInt("age");
System.out.println("id:" + id + ", name:" + name + ", age:" + age);
}
resultSet.close();
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
以上代码中，使用PreparedStatement对象创建查询SQL语句，并调用executeQuery()方法执行查询操作。查询结果保存在ResultSet对象中，通过调用ResultSet中的next()方法以逐行解析结果集。
2. 插入操作
插入操作是往数据库中添加数据的操作。以下是插入操作的示例代码：
try {
String sql = "INSERT INTO users (name, age) VALUES (?, ?)";
PreparedStatement statement = connection.prepareStatement(sql);
statement.setString(1, "Tom");
statement.setInt(2, 20);
int count = statement.executeUpdate();
if (count >= 1) {
System.out.println("Insert successfully!");
}
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
以上代码中，使用PreparedStatement对象创建插入SQL语句，并调用executeUpdate()方法执行插入操作。插入操作执行成功后，会返回受影响的行数。
3. 更新操作
更新操作是修改数据库中已有数据的操作。以下是更新操作的示例代码：
try {
String sql = "UPDATE users SET age = ? WHERE id = ?";
PreparedStatement statement = connection.prepareStatement(sql);
statement.setInt(1, 25);
statement.setInt(2, 1);
int count = statement.executeUpdate();
if (count >= 1) {
System.out.println("Update successfully!");
}
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
以上代码中，使用PreparedStatement对象创建更新SQL语句，并调用executeUpdate()方法执行更新操作。更新操作执行成功后，同样会返回受影响的行数。
4. 删除操作
删除操作是从数据库中删除数据的操作。以下是删除操作的示例代码：
try {
String sql = "DELETE FROM users WHERE id = ?";
PreparedStatement statement = connection.prepareStatement(sql);
statement.setInt(1, 1);
int count = statement.executeUpdate();
if (count >= 1) {
System.out.println("Delete successfully!");
}
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
以上代码中，使用PreparedStatement对象创建删除SQL语句，并调用executeUpdate()方法执行删除操作。删除操作执行成功后，同样会返回受影响的行数。
三、事务处理
MySQL数据库支持事务处理，可以保证多个操作作为一个整体完成或者失败。Java程序中可以通过在Connection对象上设置事务隔离级别和提交或回滚事务来实现事务处理。以下是事务处理的示例代码：
try {
connection.setAutoCommit(false);
String sql1 = "UPDATE users SET age = ? WHERE id = ?";
PreparedStatement statement1 = connection.prepareStatement(sql1);
statement1.setInt(1, 20);
statement1.setInt(2, 1);
statement1.executeUpdate();
String sql2 = "UPDATE users SET age = ? WHERE id = ?";
PreparedStatement statement2 = connection.prepareStatement(sql2);
statement2.setInt(1, 30);
statement2.setInt(2, 2);
statement2.executeUpdate();
connection.commit();
connection.setAutoCommit(true);
System.out.println("Transaction successfully!");
} catch (SQLException e) {
connection.rollback();
connection.setAutoCommit(true);
e.printStackTrace();
}
以上代码中，通过调用Connection对象的setAutoCommit(false)方法将自动提交事务的功能关闭。然后可以执行多个SQL语句，这些SQL语句将被作为一个事务提交到数据库中。如果事务执行失败，可以通过调用Connection对象的rollback()方法回滚事务。如果执行成功，最后再调用Connection对象的commit()方法提交事务。
