跨数据库事物

import java.sql.*;

public class CrossDatabaseTransaction {
    public static void main(String[] args) {
        String url1 = "jdbc:mysql://localhost:3306/db1";
        String url2 = "jdbc:mysql://localhost:3306/db2";
        String user = "user";
        String password = "password";

        Connection conn1 = null;
        Connection conn2 = null;
        try {
            // 连接数据库1
            conn1 = DriverManager.getConnection(url1, user, password);
            // 连接数据库2
            conn2 = DriverManager.getConnection(url2, user, password);

            // 开启事务
            conn1.setAutoCommit(false);
            conn2.setAutoCommit(false);

            // 执行数据库1的操作
            Statement stmt1 = conn1.createStatement();
            stmt1.executeUpdate("UPDATE table1 SET column1 = 'value1' WHERE id = 1");

            // 执行数据库2的操作
            Statement stmt2 = conn2.createStatement();
            stmt2.executeUpdate("UPDATE table2 SET column2 = 'value2' WHERE id = 1");

            // 提交事务
            conn1.commit();
            conn2.commit();

        } catch (SQLException e) {
            try {
                if (conn1 != null) conn1.rollback();
                if (conn2 != null) conn2.rollback();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
            e.printStackTrace();
        } finally {
            try {
                if (conn1 != null) conn1.close();
                if (conn2 != null) conn2.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}