jdbc怎么连接数据库进行事物处理

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class TransactionExample {
    public static void main(String[] args) {
        Connection connection = null;
        Statement statement = null;
        try {
            // 1. 加载数据库驱动
            Class.forName(“com.mysql.cj.jdbc.Driver”);
            // 2. 建立数据库连接
            String url = “jdbc:mysql://localhost:3306/database_name”;
            String username = “username”;
            String password = “password”;
            connection = DriverManager.getConnection(url, username, password);
            // 3. 开启事务
            connection.setAutoCommit(false);
            // 4. 执行SQL语句
            statement = connection.createStatement();
            String sql1 = “INSERT INTO table_name (column1, column2) VALUES ('value1', 'value2')”;
            String sql2 = “DELETE FROM table_name WHERE id = 1”;
            statement.executeUpdate(sql1);
            statement.executeUpdate(sql2);
            // 5. 提交事务
            connection.commit();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
            // 6. 回滚事务
            try {
                if (connection != null) {
                    connection.rollback();
                }
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        } finally {
            // 7. 关闭数据库连接
            try {
                if (statement != null) {
                    statement.close();
                }
                if (connection != null) {
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}