【问题标题】:Do you need a database transaction for reading data?您需要数据库事务来读取数据吗?
【发布时间】:2014-12-07 06:25:05
【问题描述】:

当我尝试从数据库中读取数据时,至少使用

((Session)em.getDelegate()).createCriteria()

抛出异常,表示事务不存在。

当我添加注释时:

@Transactional(
    value = SomeClass.TRANSACTIONAL_MANAGER, 
    propagation = Propagation.SUPPORTS, 
    readOnly = true
)

效果很好。

但是,由于每秒会发生数百万次读取数据以访问和读取数据,因此我想确保我们的环境不会被不必要地阻塞。

如果不是,创建只读Propagation.Supports 事务的成本是多少?

我不能在没有事务的情况下与 Spring 结合创建 Hibernate Criteria Query 吗?

【问题讨论】:

标签: java spring hibernate jdbc transactions


【解决方案1】:

所有数据库语句都在物理事务的上下文中执行,即使我们没有明确声明事务边界 (BEGIN/COMMIT/ROLLBACK)。

如果您不声明事务边界,则每个语句都必须在单独的事务中执行(autocommit 模式)。这甚至可能导致每个语句打开和关闭一个连接,除非您的环境可以处理每个线程的连接绑定。

将服务声明为@Transactional 将在整个事务期间为您提供一个连接,并且所有语句都将使用该单个隔离连接。这比一开始就不使用显式事务要好得多。

在大型应用程序上,你可能有很多并发请求,降低数据库连接获取请求率肯定会提高你的整体应用程序性能。

JPA 不对读取操作强制执行事务。只有在您忘记启动事务上下文的情况下,写入才会抛出 TransactionRequiredException。尽管如此,即使是只读事务,也最好声明事务边界(在 Spring 中 @Transactional 允许您标记只读事务,这具有很大的性能优势)。

现在,如果您使用声明式事务边界(例如@Transactional),您需要确保数据库连接获取延迟,直到有要执行的 JDBC 语句。在 JTA 中,这是默认行为。使用 RESOURCE_LOCAL 时,需要设置 hibernate.connection.provider_disables_autocommit 配置属性,并确保底层连接池设置为禁用自动提交模式。

【讨论】:

  • 参见:ibm.com/developerworks/library/j-ts1 它说:“更好的是,在执行读取操作时完全避免使用@Transactional 注释,如清单10 所示:”。 .所以我得到的印象是一个不需要一个。考虑到它是关于执行读取 sql 语句,我认为不需要开销
  • 其他系统对非常只读的单语句事务使用自动提交模式。当每个逻辑事务(您的服务方法)有多个语句时,就会出现问题。
  • 连接开销是一回事,但更重要的是 ACID 中的 D-保证 - 带有提交 - 即在自动提交模式下的每个语句之后! - 数据库必须保证您的更改会命中磁盘(而不仅仅是磁盘缓存!)。在已读取的数据库块上的打开事务操作仅在 DMBS 内存中执行,直到执行提交。顺便说一句,回滚是丢弃脏内存块的简单过程,几乎没有任何成本。
  • 数据库只在提交后fsyncs重做日志,而不是在检查点期间刷新的整个缓冲池。回滚不一定是免费的。在 Oracle 和 MySQL 上,需要从回滚段重新构建元组。此外,必须重新平衡索引。
  • 您总是将事务与 RDBMS 一起使用,即使在您没有明确声明它们的自动提交模式下也是如此。自动提交使用默认隔离级别并将语句包装在一个事务中。
【解决方案2】:

根据我在 J2EE 中实现 JPA 的经验,始终需要 事务管理器 来执行 CRUD 操作安全,通过保证回滚以保持数据完整性。

企业应用程序使用不同的资源来保存数据和发送消息,例如数据库或消息队列。如果我们想顺序查询这些资源,一旦出现问题就取消整个操作,我们必须把这个查询放在一个工作单元中,这样才能作为一个整体来执行。

你可以定义它:

  • 通过使用相关注释(如问题所示);这样,容器会自动加载给定持久性上下文的事务管理器;

  • 通过手动注入事务管理器,如下:

    public class sample {
    
        @PersistenceContext
        EntityManager em;
    
        // Injected transaction manager
        @Inject
        UserTransaction utx;
    
        private static final String[] GAME_TITLES = {
            "Super Mario Brothers",
            "Mario Kart",
            "F-Zero"
        };
    
        private void clearData() throws Exception {
            utx.begin();
            em.joinTransaction();
            System.out.println("Dumping old records...");
            em.createQuery("delete from Game").executeUpdate();
            utx.commit();
        }
    
        private void insertData() throws Exception {
            utx.begin();
            em.joinTransaction();
            System.out.println("Inserting records...");
            for (String title : GAME_TITLES) {
                Game game = new Game(title);
                em.persist(game);
            }
            utx.commit();
            // clear the persistence context (first-level cache)
            em.clear();
        }
    
        // ...
    
    }
    

Spring Data,作为 JPA 规范的实现,可能遵循相同的方法。

您可以通过阅读以下文章找到更多信息:Java_Persistence/Transactions

【讨论】:

    猜你喜欢
    • 2011-01-13
    • 2017-12-30
    • 2011-07-26
    • 2015-06-24
    • 1970-01-01
    • 1970-01-01
    • 2019-10-24
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多