java - 如何从 org.springframework.data.repository.CrudRepository 后代取消代理子对象

Question

我在 MySQL 数据库中创建了用户与项目的多对多关系，并使用了 hbm2java(从数据库表生成 java 类的 hibernate 工具)。由于我使用 gradle 插件 org.hibernate.gradle.tools.Schema 我没有 hibernate.cfg.xml。

我可以从我的 CrudRepository<User,Long> 的后代中获取并正确打印用户列表(请参阅下面的代码)并且每个用户对象都有一个 getProjects()功能。当我尝试迭代用户拥有的项目时，出现此错误:

org.hibernate.LazyInitializationException: failed to lazily initialize a collection of role: com.xyz.dbmodel.orm.User.projects, could not initialize proxy - no Session

我想坚持使用 hbm2java 生成的 java 代码使用的默认延迟加载方法。

我尝试调用Hibernate.Initialize(user.getProjects()) (如 https://howtodoinjava.com/hibernate/use-hibernate-initialize-to-initialize-proxycollection/ 中所述)但是当我尝试这样做时仍然遇到相同的错误

for(Project project : user.getProjects()) {... }

我能找到的所有示例都假设我可以执行上述 for 循环并取消代理每个项目。我不能。

这是我的存储库:

import org.springframework.data.repository.CrudRepository;
import com.xyz.dataservice.dbmodel.orm.User;
public interface UserRepository extends CrudRepository<User, Long> {}

这里我创建存储库:

@Autowired com.xyz.repository.UserRepository userRepository;

这里我成功获取了用户列表

Iterable<User> users = userRepository.findAll();
for(User user : users) {
   log.info("User="+user.getName()); // this works!
   Set<Project> projects = user.getProjects();
   for(Project p : projects) // Error happens here!
   {
      log.info("  project="+p.getName());
   }
 }

预期结果是我获得每个用户的项目列表。实际结果是异常org.hibernate.LazyInitializationException .

谢谢!

2019 年 2 月 2 日早间更新

关于Hibernate配置

我不确定你的意思。我的 gradle 插件正在生成这个 hibernate.cfg.xml 文件:

 <?xml version="1.0" encoding="utf-8"?>
 <!DOCTYPE hibernate-configuration 
     SYSTEM "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">
 <hibernate-configuration>
   <session-factory>
     <property name="hibernate.dialect">org.hibernate.dialect.MySQL5Dialect</property>
     <property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
     <property name="hibernate.connection.url">jdbc:mysql://localhost:3306</property>
     <property name="hibernate.connection.username">searchapp_user</property>
     <property name="hibernate.connection.password">secret</property>
     <property name="hibernate.current_session_context_class">thread</property>
     <property name="hibernate.connection.zeroDateTimeBehavior">convertToNull</property>
   </session-factory>
 </hibernate-configuration>

…

添加事务

我已添加org.springframework.transaction.annotation.Transactional到我正在调用的新函数

@Transactional
public int fetchUsers() {
    Iterable<User> users = userRepository.findAll();
    return listUsers(users, "");
}

当这没有帮助时，我尝试使用事务属性增强我的存储库:

@Repository
public interface UserRepository extends CrudRepository<User, Long> {
  @Transactional
  public List<User> findAll();
}

糟糕，这也没有帮助。我确实在数英亩的日志条目中注意到了这个奇怪的条目。这是什么意思？

 2019-02-01 10:50:42.285  INFO 5096 --- [  restartedMain] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.transaction.annotation.ProxyTransactionManagementConfiguration' of type [org.springframework.transaction.annotation.ProxyTransactionManagementConfiguration$$EnhancerBySpringCGLIB$$6c9c1be1] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)

再次感谢!

2019 年 2 月 2 日下午更新

糟糕，我忘记检查有关交易文档的链接。

我不确定如何在同一函数上使用@Bean和@Transactional。

你能举个例子吗？

我见过的 @Bean 示例返回一个 lambda，然后稍后会神秘地调用该 lambda。我需要将 lambda 声明为事务性的吗？那可能吗？如果不是，我是否需要将 lambda 替换为 java.util.function.Consumer<> 的后代(其接受函数是用 @Transactional 声明的)？

2019 年 2 月 5 日更新:找到解决方案!

我使用的是新的 Java8 lambda 语法，我不得不放弃它，转而使用旧的内部类语法，这样我就可以 declere 函数 @Transactional。

  @Transactional
  class InitSpecialCommandLineRunner implements org.springframework.boot.CommandLineRunner{
      @Transactional // this is important!
      @Override
      public void run(String[] args) {
          int count = listProjectsForEachUser(); // this works!
      }
  }


  @org.springframework.context.annotation.Profile("initialize")
  @org.springframework.context.annotation.Bean
  @Transactional
  public org.springframework.boot.CommandLineRunner initSpecial() {
       return new InitSpecialCommandLineRunner(); // this works

  // How to declare this transactional?
  //  return args ->
  //  {
  //      int count = fetchUsers();
  //      Iterable<User> users;
  //  };

}

我希望有一天这会对其他人有所帮助。

Answer 1

看起来事务仅跨越对存储库的立即调用。

要解决此问题，请在应定义事务范围的方法上添加 @Transactional 注释。至少是托管您向我们展示的代码的方法。

该方法需要是公共(public)的并且位于 Spring bean 上。请参阅https://docs.spring.io/spring/docs/4.2.x/spring-framework-reference/html/transaction.html了解详情。