JTA/JTS代码实例

以下是一个使用JTA和JTS的简单代码实例：

import javax.transaction.UserTransaction;
import javax.transaction.TransactionManager;
import javax.transaction.Transaction;
import javax.naming.InitialContext;
import javax.sql.DataSource;
import java.sql.*;

public class JtaJtsExample {

    public void doTransaction() throws Exception {
        // 获取UserTransaction和TransactionManager
        UserTransaction tx = (UserTransaction) new InitialContext().lookup("java:comp/UserTransaction");
        TransactionManager tm = (TransactionManager) new InitialContext().lookup("java:appserver/TransactionManager");

        // 开始事务
        tx.begin();
        try {
            // 获取数据源
            DataSource ds = (DataSource) new InitialContext().lookup("java:app/jdbc/mydatasource");

            // 获取数据库连接，并设置自动提交为false
            Connection conn = ds.getConnection();
            conn.setAutoCommit(false);

            // 执行SQL语句
            PreparedStatement pstmt = conn.prepareStatement("INSERT INTO mytable VALUES (?, ?)");
            pstmt.setInt(1, 1);
            pstmt.setString(2, "test");
            pstmt.executeUpdate();

            // 提交事务
            conn.commit();
            tx.commit();
        } catch (Exception e) {
            // 回滚事务
            tx.rollback();
            throw e;
        }
    }
}

在上面的代码中，我们使用了UserTransaction和TransactionManager来管理事务。我们首先获取了UserTransaction和TransactionManager的实例，然后开始事务并获取数据源。在执行SQL语句之前，我们将数据库连接的自动提交设置为false，以便我们可以在事务中控制提交和回滚。当我们执行完SQL语句后，我们提交事务并关闭数据库连接。如果出现任何异常，我们将回滚事务并抛出异常。