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

How to unproxy child objects from org.springframework.data.repository.CrudRepository descendant

我在 MySQL 数据库中创建了用户与项目的多对多关系,并使用了 hbm2java(生成 java classes 来自数据库表)。由于我使用的是 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 代码使用的默认延迟加载方法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 日上午更新

关于休眠配置

我不太清楚你的意思。我的 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, "");
}

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

@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$c9c1be1] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)

再次感谢!

2019 年 2 月 2 日下午更新

糟糕,我忘记检查 link 关于交易文件。

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

你能举个例子吗?

我见过的@Bean 示例 return 稍后神秘调用的 lambda。我需要将 lambda 声明为事务性的吗?那可能吗?如果不是,我是否需要用 java.util.function.Consumer<> 的后代替换 lambda,其接受函数是用 @Transactional 声明的?

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

我使用的是新的 Java8 lambda 语法,我不得不放弃它以支持旧的内部 class 语法,这样我就可以删除函数 @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;
  //  };

}

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

看起来事务只涉及对存储库的即时调用。

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

该方法需要 public 并且在 Spring bean 上。 有关详细信息,请参阅 https://docs.spring.io/spring/docs/4.2.x/spring-framework-reference/html/transaction.html