首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >Micronaut数据延迟获取相关实体时出现问题

Micronaut数据延迟获取相关实体时出现问题
EN

Stack Overflow用户
提问于 2021-01-21 21:06:37
回答 1查看 414关注 0票数 2

我目前正在将micronaut的数据整合到现有的micronaut项目中(作为升级的一部分),并且我遇到了一些关于懒惰地获取相关集合(具有OneToMany关系)的问题。

我有以下实体结构:

代码语言:javascript
复制
@Data
@Entity
@NoArgsConstructor
@AllArgsConstructor
@Builder(toBuilder = true)
public class Merchant implements Serializable {

  @Id private String name;

  private String displayName;

  private String staticSiteAddress;

  private String emailFromAddress;

  private String emailFromName;

  private String etmEmailFromAddress;

  private String etmEmailFromName;

  private String phone;

  private String username;

  @Embedded private PasswordHash password;

  @ToString.Exclude
  @EqualsAndHashCode.Exclude
  @OneToMany(mappedBy = "merchant", fetch = FetchType.LAZY)
  @Builder.Default
  private Set<MerchantStore> stores = new HashSet<>();

  @ToString.Exclude
  @EqualsAndHashCode.Exclude
  @OneToMany(mappedBy = "merchant", fetch = FetchType.LAZY)
  @Builder.Default
  private Set<CustomWebLink> customWebLinks = new HashSet<>();

  @ToString.Exclude
  @EqualsAndHashCode.Exclude
  @OneToMany(mappedBy = "merchant", fetch = FetchType.LAZY)
  @Builder.Default
  private Set<LoyaltyPlan> loyaltyPlans = new HashSet<>();

  @ToString.Exclude
  @EqualsAndHashCode.Exclude
  @OneToMany(mappedBy = "merchant", fetch = FetchType.LAZY)
  @Builder.Default
  private Set<MerchantPref> merchantPrefs = new HashSet<>();

}

有了in,我可以使用以下存储库方法顺利地获取第一级相关实体(即merchantPrefs):

代码语言:javascript
复制
@NonNull
@Override
@Cacheable("merchant")
@Join(value = "stores", type = Join.Type.LEFT_FETCH)
@Join(value = "customWebLinks", type = Join.Type.LEFT_FETCH)
@Join(value = "merchantPrefs", type = Join.Type.LEFT_FETCH)
@Join(value = "loyaltyPlans", type = Join.Type.LEFT_FETCH)
Optional<Merchant> findById(@NonNull @NotNull String s);

但是,当我试图从这个实体获取最里面的集合时,例如awards

代码语言:javascript
复制
@Data
@Entity
public class LoyaltyPlan implements Serializable {

  @EmbeddedId private LoyaltyPlanID id;

  @ToString.Exclude
  @EqualsAndHashCode.Exclude
  @ManyToOne(fetch = FetchType.LAZY)
  @MapsId("merchant")
  @JoinColumn(name = "merchant", nullable = false)
  private Merchant merchant;

  private String displayName;

  private String emailFromName;

  private String emailFromAddress;

  private String uniqueId;

  private boolean defaultPlan;

  private float pointsFactor;

  private boolean hasGiftCards;

  private boolean hasLoyaltyCards;

  private boolean usesName;

  private boolean hasEmail;

  private boolean hasCellPhone;

  private boolean needsGiftCards;

  private boolean needsLoyaltyCards;

  private boolean needsName;

  private boolean needsEmail;

  private boolean needsCellPhone;

  private int signupBonus;

  private int closingAwardThreshold;

  private int maxPointsPerOrder;

  private int minPricePerOrder;

  private int recentHistoryDays;

  private int expiringCouponReminderDays;

  @ToString.Exclude
  @EqualsAndHashCode.Exclude
  @OneToMany(mappedBy = "loyaltyPlan", fetch = FetchType.LAZY)
  private List<LoyaltyPlanAward> awards;
}

我得到了一个LazyInitializationException

代码语言:javascript
复制
org.hibernate.LazyInitializationException: failed to lazily initialize a collection of role: fts.marketing.entities.plan.LoyaltyPlan.awards, could not initialize proxy - no Session
    at org.hibernate.collection.internal.AbstractPersistentCollection.throwLazyInitializationException(AbstractPersistentCollection.java:606)
    at org.hibernate.collection.internal.AbstractPersistentCollection.withTemporarySessionIfNeeded(AbstractPersistentCollection.java:218)
    at org.hibernate.collection.internal.AbstractPersistentCollection.initialize(AbstractPersistentCollection.java:585)
    at org.hibernate.collection.internal.AbstractPersistentCollection.read(AbstractPersistentCollection.java:149)
    at org.hibernate.collection.internal.PersistentBag.iterator(PersistentBag.java:387)
    at java.base/java.lang.Iterable.forEach(Iterable.java:74)
    at fts.marketing.TestController.doSomething(TestController.java:29)
    at fts.marketing.$TestControllerDefinition$Intercepted.$$access$$doSomething(Unknown Source)
    at fts.marketing.$TestControllerDefinition$$exec1.invokeInternal(Unknown Source)
    at io.micronaut.context.AbstractExecutableMethod.invoke(AbstractExecutableMethod.java:146)
    at io.micronaut.aop.chain.MethodInterceptorChain.proceed(MethodInterceptorChain.java:73)
    at io.micronaut.transaction.interceptor.TransactionalInterceptor.intercept(TransactionalInterceptor.java:134)
    at io.micronaut.aop.chain.MethodInterceptorChain.proceed(MethodInterceptorChain.java:82)
    at fts.marketing.$TestControllerDefinition$Intercepted.doSomething(Unknown Source)
    at fts.marketing.$TestControllerDefinition$$exec1.invokeInternal(Unknown Source)
    at io.micronaut.context.AbstractExecutableMethod.invoke(AbstractExecutableMethod.java:146)
    at io.micronaut.context.DefaultBeanContext$4.invoke(DefaultBeanContext.java:474)
    at io.micronaut.web.router.AbstractRouteMatch.execute(AbstractRouteMatch.java:312)
    at io.micronaut.web.router.RouteMatch.execute(RouteMatch.java:118)
    at io.micronaut.http.server.netty.RoutingInBoundHandler.lambda$buildResultEmitter$10(RoutingInBoundHandler.java:1369)
    at io.reactivex.internal.operators.flowable.FlowableDefer.subscribeActual(FlowableDefer.java:35)
    at io.reactivex.Flowable.subscribe(Flowable.java:14935)
    at io.reactivex.Flowable.subscribe(Flowable.java:14882)
    at io.micronaut.http.server.context.ServerRequestContextFilter.lambda$doFilter$0(ServerRequestContextFilter.java:62)
    at io.reactivex.internal.operators.flowable.FlowableFromPublisher.subscribeActual(FlowableFromPublisher.java:29)
    at io.reactivex.Flowable.subscribe(Flowable.java:14935)
    at io.reactivex.Flowable.subscribe(Flowable.java:14885)
    at io.micronaut.http.server.netty.RoutingInBoundHandler.lambda$buildExecutableRoute$6(RoutingInBoundHandler.java:1074)
    at io.micronaut.web.router.DefaultUriRouteMatch$1.execute(DefaultUriRouteMatch.java:80)
    at io.micronaut.web.router.RouteMatch.execute(RouteMatch.java:118)
    at io.micronaut.http.server.netty.RoutingInBoundHandler.handleRouteMatch(RoutingInBoundHandler.java:698)
    at io.micronaut.http.server.netty.RoutingInBoundHandler.channelRead0(RoutingInBoundHandler.java:554)
    at io.micronaut.http.server.netty.RoutingInBoundHandler.channelRead0(RoutingInBoundHandler.java:1

此外,这似乎是一个零星的问题,因为有时相同的代码似乎工作正常。我真的不确定哪里出了问题,我想我已经正确地对关系进行了建模,因为在迁移到micronaut-data之前,这些关系都很好。

我不知道我在这里做错了什么,任何帮助都会非常感谢,以便解决这个问题。

EN

回答 1

Stack Overflow用户

发布于 2021-01-26 21:13:59

在Micronaut中,OpenSessionInView的概念并不存在。当事务已经关闭时,您似乎正在尝试访问关系。看看这个:https://micronaut-projects.github.io/micronaut-sql/latest/guide/index.html#_understanding_lazyinitializationexception

解决方案:

  1. 不要使用Lazy。相反,每次需要列表时,请使用存储库访问数据库。
  2. 使用EAGER。
  3. 在进行查询的方法中使用@Transactional。
票数 2
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/65828085

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档