开发者社区 > 云原生 > 正文

seata1.5.1 AT模式支持 业务代码中Oracle批量新增吗?

seata1.5.1 AT模式支持 业务代码中Oracle批量新增吗?

展开
收起
真的很搞笑 2023-05-24 18:52:37 109 0
5 条回答
写回答
取消 提交回答
  • 十分耕耘,一定会有一分收获!

    楼主你好,据我知道的情况来看Seata 的 AT 模式是可以通过记录数据变更前后的镜像(前镜像和后镜像)来支持事务的回滚,所以支持批量新增操作。

    2023-12-25 19:42:29
    赞同 展开评论 打赏
  • Seata 的 AT (Automatic Transaction) 模式是为了简化分布式事务处理而设计的。它通过拦截数据库操作并记录相应的 before image(前镜像)和 after image(后镜像),以支持在分布式事务中的回滚操作。

    关于 Oracle 批量操作,Seata 官方文档并没有明确说明不支持。

    如果你的业务代码是通过单个 INSERT 语句插入多条数据,理论上 Seata 应该可以支持,因为从 Seata 的角度来看,这依然是单条 SQL 语句。但如果是通过 JDBC 的批处理接口(如 addBatch / executeBatch)执行的批量操作,可能会有一些兼容性问题。

    2023-12-23 14:20:21
    赞同 1 展开评论 打赏
  • Seata 1.5.1 的 AT 模式确实支持在 Oracle 数据库中进行批量新增操作。在使用 Seata 进行分布式事务管理时,你需要在业务代码中使用 @GlobalTransactional 注解来标记那些需要进行全局事务管理的方法。这些被 @GlobalTransactional 注解标记的方法会成为一个全局事务的一部分,从而可以一起提交或回滚。

    然后,在这些被 @GlobalTransactional 注解标记的方法中,你可以调用其他需要进行分支事务管理的方法。这些被 @Transactional 注解标记的方法会成为一个分支事务,并且会在全局事务提交时一并提交,或者在全局事务回滚时一并回滚。

    2023-12-13 17:37:23
    赞同 展开评论 打赏
  • 在Seata 1.5.1的AT模式下,支持业务代码中的Oracle批量新增操作。该模式的运行基于支持本地ACID事务的关系型数据库,并能通过JDBC访问数据库。在两阶段提交协议中,一阶段将业务数据和回滚日志记录在同一个本地事务中提交,释放本地锁和连接资源。二阶段则是提交异步化,使得整个流程非常快速。因此,对于需要在Oracle数据库中进行批量新增的业务需求,可以利用Seata AT模式进行处理。

    2023-12-13 16:48:05
    赞同 展开评论 打赏
  • 北京阿里云ACE会长

    是的,Seata 1.5.1 的 AT 模式支持在业务代码中进行 Oracle 批量新增。在 AT 模式下,Seata 提供了事务协调服务,可以确保在分布式环境下的数据一致性。您可以在业务代码中使用 Seata 的 AT 模式,结合 Oracle 的批量插入操作,实现批量新增数据。
    以下是一个使用 Seata 1.5.1 AT 模式在业务代码中进行 Oracle 批量新增的示例:

    1. 首先,在您的业务代码中,需要引入 Seata 的相关依赖。例如,在 Maven 项目的 pom.xml 文件中添加 Seata 的依赖:


    com.alibaba.seata
    seata-all
    1.5.1

    CopyCopy

    1. 然后,在业务代码中,使用 Seata 的 AT 模式进行事务管理。以下是一个使用 Seata 事务管理器进行 Oracle 批量新增的示例:

    import com.alibaba.seata.core.context.Context;
    import com.alibaba.seata.core.context.RootContext;
    import com.alibaba.seata.core.exception.SeataException;
    import com.alibaba.seata.core.model.TransactionMode;
    import com.alibaba.seata.core.model.TransactionStatus;
    import com.alibaba.seata.core.service.TransactionManager;
    import com.alibaba.seata.core.service.TransactionTemplate;
    import com.alibaba.seata.sql.SQLUtils;
    import com.alibaba.seata.sql.parser.SqlParser;
    import com.alibaba.seata.sql.parser.SqlParserFactory;
    import com.alibaba.seata.sql.statement.SqlStatement;
    import com.alibaba.seata.sql.statement.insert.Insert;
    import com.alibaba.seata.sql.statement.insert.InsertSet;
    import com.alibaba.seata.sql.statement.update.Update;
    import com.alibaba.seata.sql.statement.update.UpdateSet;
    import org.apache.ibatis.session.SqlSession;
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import java.util.List;
    import java.util.Map;
    @Service
    public class BusinessService {
    @Autowired
    private SqlSessionFactory sqlSessionFactory;
    @Autowired
    private TransactionManager transactionManager;
    public void batchInsert(List dataList) {
    // 使用 Seata 事务管理器创建一个本地事务
    LocalTransactionContext transactionContext = new LocalTransactionContext();
    transactionManager.begin(transactionContext);
    try {
    SqlSession sqlSession = sqlSessionFactory.openSession();
    for (Object data : dataList) {
    // 构建批量插入的 SQL 语句
    String sql = "INSERT INTO your_table (column1, column2, column3) VALUES " +
    "(#{column1}, #{column2}, #{column3})";
    // 创建批量插入的 SQL 语句对象
    SqlStatement sqlStatement = SQLUtils.parse(sql);
    // 构建批量插入的数据
    InsertSet insertSet = new InsertSet();
    insertSet.set("column1", data.getColumn1());
    insertSet.set("column2", data.getColumn2());
    insertSet.set("column3", data.getColumn3());
    sqlStatement.setInsertSet(insertSet);
    // 执行批量插入操作
    sqlSession.insert(sqlStatement);
    }
    // 提交事务
    transactionManager.commit(transactionContext);
    } catch (Exception e) {
    // 如果发生异常,回滚事务
    transactionManager.rollback(transactionContext);
    throw new SeataException("Oracle 批量新增失败", e);
    } finally {
    // 关闭事务

    2023-12-11 19:50:50
    赞同 展开评论 打赏

阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。

相关电子书

更多
PostgresChina2018_樊文凯_ORACLE数据库和应用异构迁移最佳实践 立即下载
PostgresChina2018_王帅_从Oracle到PostgreSQL的数据迁移 立即下载
Oracle云上最佳实践 立即下载

相关镜像