投稿
  1. 酷盾安全首页
  2. 技术问答
  3. 后端开发

java中怎么写一个事务

酷盾叔 • • 后端开发 • 阅读 0
Java中使用事务，可通过Spring框架的@Transactional注解或手动管理事务（如使用TransactionTemplate），

Java中，事务管理是确保一组数据库操作要么全部成功，要么全部失败的机制，这对于维护数据的一致性和完整性至关重要，Java提供了多种方式来实现事务管理，主要包括使用JDBC、JTA（Java Transaction API）、Spring框架等，下面将详细介绍如何在Java中编写一个事务,涵盖不同的方法和最佳实践。

java中怎么写一个事务

使用JDBC进行事务管理

基本步骤

  1. 获取数据库连接：通过DriverManager或数据源获取连接。
  2. 关闭自动提交：默认情况下，JDBC连接是自动提交的,需要将其关闭以手动管理事务。
  3. 执行SQL操作：在事务中执行多个SQL语句。
  4. 提交或回滚事务：根据操作是否成功,选择提交或回滚事务。
  5. 处理异常：确保在发生异常时能够正确回滚事务,并在最终块中关闭资源。

示例代码

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class JdbcTransactionExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String user = "username";
        String password = "password";
        Connection conn = null;
        try {
            // 1. 获取连接
            conn = DriverManager.getConnection(url, user, password);
            // 2. 关闭自动提交
            conn.setAutoCommit(false);
            // 3. 执行SQL操作
            String sql1 = "UPDATE accounts SET balance = balance ? WHERE id = ?";
            PreparedStatement pstmt1 = conn.prepareStatement(sql1);
            pstmt1.setDouble(1, 100);
            pstmt1.setInt(2, 1);
            pstmt1.executeUpdate();
            String sql2 = "UPDATE accounts SET balance = balance + ? WHERE id = ?";
            PreparedStatement pstmt2 = conn.prepareStatement(sql2);
            pstmt2.setDouble(1, 100);
            pstmt2.setInt(2, 2);
            pstmt2.executeUpdate();
            // 4. 提交事务
            conn.commit();
            System.out.println("事务提交成功！");
        } catch (SQLException e) {
            // 5. 回滚事务
            if (conn != null) {
                try {
                    conn.rollback();
                    System.out.println("事务回滚！");
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
            e.printStackTrace();
        } finally {
            // 6. 关闭连接
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

关键点说明

步骤 描述
获取连接 使用DriverManager.getConnection或数据源获取数据库连接。
关闭自动提交 调用conn.setAutoCommit(false)以手动控制事务。
执行SQL操作 在事务中执行多个SQL语句，如更新、插入等。
提交事务 如果所有操作成功，调用conn.commit()提交事务。
回滚事务 如果发生异常，调用conn.rollback()回滚事务。
关闭连接 在finally块中确保连接被关闭，防止资源泄漏。

使用JTA进行事务管理

JTA（Java Transaction API）是一种更高级的事务管理方式，适用于分布式事务，它允许在多个资源（如多个数据库、消息队列）之间管理事务。

基本步骤

  1. 获取UserTransaction对象：通常通过JNDI查找。
  2. 开始事务：调用userTransaction.begin()。
  3. 执行业务操作：在事务中执行多个资源的操作。
  4. 提交或回滚事务：根据操作结果，调用userTransaction.commit()或userTransaction.rollback()。

示例代码

import javax.naming.InitialContext;
import javax.transaction.UserTransaction;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class JtaTransactionExample {
    public static void main(String[] args) {
        UserTransaction userTransaction = null;
        Connection conn = null;
        try {
            // 1. 获取UserTransaction对象
            InitialContext ctx = new InitialContext();
            userTransaction = (UserTransaction) ctx.lookup("java:comp/UserTransaction");
            // 2. 开始事务
            userTransaction.begin();
            // 3. 获取数据库连接（假设使用JNDI数据源）
            ctx = new InitialContext();
            DataSource ds = (DataSource) ctx.lookup("java:comp/env/jdbc/mydatabase");
            conn = ds.getConnection();
            // 4. 执行SQL操作
            String sql1 = "UPDATE accounts SET balance = balance ? WHERE id = ?";
            PreparedStatement pstmt1 = conn.prepareStatement(sql1);
            pstmt1.setDouble(1, 100);
            pstmt1.setInt(2, 1);
            pstmt1.executeUpdate();
            String sql2 = "UPDATE accounts SET balance = balance + ? WHERE id = ?";
            PreparedStatement pstmt2 = conn.prepareStatement(sql2);
            pstmt2.setDouble(1, 100);
            pstmt2.setInt(2, 2);
            pstmt2.executeUpdate();
            // 5. 提交事务
            userTransaction.commit();
            System.out.println("JTA事务提交成功！");
        } catch (Exception e) {
            // 6. 回滚事务
            if (userTransaction != null) {
                try {
                    userTransaction.rollback();
                    System.out.println("JTA事务回滚！");
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }
            e.printStackTrace();
        } finally {
            // 7. 关闭连接
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

关键点说明

步骤 描述
获取UserTransaction对象 通过JNDI查找UserTransaction实例。
开始事务 调用userTransaction.begin()启动事务。
获取数据库连接 使用JNDI数据源获取连接，确保连接参与事务管理。
执行SQL操作 在事务中执行多个SQL语句。
提交事务 如果所有操作成功，调用userTransaction.commit()提交事务。
回滚事务 如果发生异常，调用userTransaction.rollback()回滚事务。
关闭连接 确保数据库连接被正确关闭。

使用Spring框架进行事务管理

Spring框架提供了强大的事务管理功能，简化了事务的处理过程，通过声明式事务管理，开发者无需在代码中显式处理事务,只需通过配置即可实现。

java中怎么写一个事务

基本步骤

  1. 配置事务管理器：根据使用的数据库和JPA框架,配置相应的事务管理器。
  2. 启用事务注解：使用@EnableTransactionManagement注解启用事务管理。
  3. 标注事务方法：在需要事务管理的方法上使用@Transactional注解。
  4. 处理异常：根据需要配置事务的回滚规则。

示例代码

配置类

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import javax.sql.DataSource;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
@Configuration
@EnableTransactionManagement
public class SpringTransactionConfig {
    @Bean
    public DataSource dataSource() {
        DriverManagerDataSource ds = new DriverManagerDataSource();
        ds.setDriverClassName("com.mysql.cj.jdbc.Driver");
        ds.setUrl("jdbc:mysql://localhost:3306/mydatabase");
        ds.setUsername("username");
        ds.setPassword("password");
        return ds;
    }
    @Bean
    public DataSourceTransactionManager transactionManager(DataSource ds) {
        return new DataSourceTransactionManager(ds);
    }
}

Service类

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@Service
public class AccountService {
    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Transactional
    public void transferMoney(int fromId, int toId, double amount) {
        String sql1 = "UPDATE accounts SET balance = balance ? WHERE id = ?";
        jdbcTemplate.update(sql1, amount, fromId);
        String sql2 = "UPDATE accounts SET balance = balance + ? WHERE id = ?";
        jdbcTemplate.update(sql2, amount, toId);
        // 可以在此处添加更多操作，所有操作都在一个事务中
    }
}

使用Service

import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
public class SpringTransactionExample {
    public static void main(String[] args) {
        ApplicationContext context = new AnnotationConfigApplicationContext(SpringTransactionConfig.class);
        AccountService accountService = context.getBean(AccountService.class);
        try {
            accountService.transferMoney(1, 2, 100);
            System.out.println("Spring事务提交成功！");
        } catch (Exception e) {
            System.out.println("Spring事务回滚！");
            e.printStackTrace();
        }
    }
}

关键点说明

步骤 描述
配置事务管理器 根据数据源类型配置相应的事务管理器，如DataSourceTransactionManager。
启用事务注解 使用@EnableTransactionManagement启用Spring的事务管理功能。
标注事务方法 在需要事务管理的方法上添加@Transactional注解，Spring会自动管理事务的开始和提交/回滚。
处理异常 如果方法抛出未捕获的异常，Spring会默认回滚事务，可以通过rollbackFor属性自定义回滚规则。
使用Service 通过Spring容器获取Service Bean，并调用带有事务的方法。

事务管理的最佳实践

  • 最小化事务范围：尽量缩短事务的持续时间，避免长时间持有锁,减少并发冲突。
  • 只读事务：对于不需要修改数据的操作,使用只读事务可以提高性能。
  • 异常处理：确保在发生异常时能够正确回滚事务,防止数据不一致。
  • 避免混合不同资源的事务：在分布式系统中，尽量避免在一个事务中操作多个资源,以减少复杂性和潜在的问题。
  • 日志记录：在事务操作中添加适当的日志记录,便于问题排查和审计。
  • 测试事务：在开发和测试阶段，充分测试事务的行为,确保其在各种情况下都能正确工作。

FAQs

Q1: 如何在Spring中配置只读事务？

A1: 在Spring中，可以通过在@Transactional注解中设置readOnly=true来配置只读事务。

@Transactional(readOnly = true)
public void fetchData(int id) {
    // 查询操作，不进行任何修改
}

只读事务有助于提高性能，因为数据库可以针对只读操作进行优化，并且避免了不必要的锁定，但需要注意的是，如果在只读事务中尝试执行写操作,会导致异常。

java中怎么写一个事务

Q2: 在使用JDBC进行事务管理时，为什么需要关闭自动提交？

A2: 默认情况下，JDBC连接处于自动提交模式，即每个SQL语句执行后都会自动提交事务，这意味着无法在多个SQL语句之间共享一个事务上下文，为了手动控制事务的边界（在一组操作成功后一起提交，或在发生错误时一起回滚），需要关闭自动提交模式，通过显式调用commit()或rollback()来管理事务。

原创文章，发布者：酷盾叔，转转请注明出处：https://www.kd.cn/ask/63229.html

赞 (0)
酷盾叔的头像酷盾叔
0 0
上一篇 2025年7月16日 17:16
下一篇 2025年7月16日 17:19

相关推荐

  • Java中如何调用sin函数 后端开发

    Java中如何调用sin函数

    在Java中调用Math.sin()方法，传入弧度值作为参数，double result = Math.sin(Math.PI/2); 该方法返回指定角度的正弦值，角度需以弧度表示。

    酷盾叔的头像 酷盾叔
    2025年5月30日
    200
  • Java不用框架如何实现数据库访问？ 后端开发

    Java不用框架如何实现数据库访问？

    在Java中无需框架访问网络，可使用java.net.HttpURLConnection类实现，步骤如下：创建URL对象，打开连接，设置请求方法（如GET/POST），添加请求头，获取输入流读取响应数据，最后关闭连接，需注意异常处理和资源释放。

    酷盾叔的头像 酷盾叔
    2025年6月24日
    100
  • xlsx文件java怎么读取 后端开发

    xlsx文件java怎么读取

    Java中读取xlsx文件，可使用Apache POI库，通过FileInputStream加载文件，用XSSFWorkbook解析，再遍历Sheet、Row和Cell读取数据

    酷盾叔的头像 酷盾叔
    2025年7月13日
    000
  • java怎么申请栈 后端开发

    java怎么申请栈

    在Java中可通过java.util.Stack类直接创建栈，或使用Deque接口实现（如ArrayDeque），后者更推荐，示例：Stack stack = new Stack(); 或 Deque deque = new ArrayDeque();，通过push()、pop()等方法操作栈结构。

    酷盾叔的头像 酷盾叔
    2025年5月28日
    400
  • Java如何高效批导入方法？ 后端开发

    Java如何高效批导入方法？

    Java中实现批量数据导入主要使用JDBC批处理机制：通过PreparedStatement的addBatch()累积SQL语句，再以executeBatch()一次性执行，结合事务控制（关闭自动提交）可大幅提升数据库写入效率，常用优化包括设置合理批处理大小、分批次提交避免内存溢出。

    酷盾叔的头像 酷盾叔
    2025年6月12日
    100

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

联系我们

400-880-8834

在线咨询： QQ交谈

邮件：HI@E.KD.CN

首页
联系我们