spring - 子スローセッションエラーの遅延読み込み

Question

TagController内でpurchaseService.updatePurchase（purchase）を呼び出すと、次のエラーが発生します。

SEVERE: Servlet.service() for servlet [PurchaseAPIServer] in context with path [/PurchaseAPIServer] threw exception [Request processing failed; nested exception is org.hibernate.LazyInitializationException: failed to lazily initialize a collection of role: com.app.model.Purchase.tags, no session or session was closed] with root cause
org.hibernate.LazyInitializationException: failed to lazily initialize a collection of role: com.app.model.Purchase.tags, no session or session was closed
    at org.hibernate.collection.AbstractPersistentCollection.throwLazyInitializationException(AbstractPersistentCollection.java:383)
    at org.hibernate.collection.AbstractPersistentCollection.throwLazyInitializationExceptionIfNotConnected(AbstractPersistentCollection.java:375)
    at org.hibernate.collection.AbstractPersistentCollection.initialize(AbstractPersistentCollection.java:368)
    at org.hibernate.collection.PersistentSet.add(PersistentSet.java:212)
    at com.app.model.Purchase.addTags(Purchase.java:207)
    at com.app.controller.TagController.createAll(TagController.java:79)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
    at java.lang.reflect.Method.invoke(Method.java:597)
    at org.springframework.web.method.support.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:212)
    at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:126)
    at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:96)
    at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:617)
    at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:578)
    at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:80)
    at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:900)
    at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:827)
    at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:882)
    at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:789)
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:641)
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:722)
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:305)
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
    at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:225)
    at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:169)
    at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:472)
    at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:168)
    at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:98)
    at org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:927)
    at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:118)
    at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:407)
    at org.apache.coyote.http11.AbstractHttp11Processor.process(AbstractHttp11Processor.java:999)
    at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:565)
    at org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:309)
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
    at java.lang.Thread.run(Thread.java:662)

TagController：

@RequestMapping(value = "purchases/{purchaseId}/tags", method = RequestMethod.POST, params = "manyTags")
@ResponseStatus(HttpStatus.CREATED)
public void createAll(@PathVariable("purchaseId") final Long purchaseId, @RequestBody final Tag[] entities)
{
    Purchase purchase = purchaseService.getById(purchaseId);

    Set<Tag> tags = new HashSet<Tag>(Arrays.asList(entities));

    purchase.addTags(tags);
    purchaseService.updatePurchase(purchase);
}

購入：

@Entity
@XmlRootElement
public class Purchase implements Serializable
{

    /**
     * 
     */
    private static final long serialVersionUID = 6603477834338392140L;

    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    private Long id;

    @OneToMany(mappedBy = "purchase", fetch = FetchType.LAZY, cascade={CascadeType.ALL})
    private Set<Tag> tags;

    @JsonIgnore
    public Set<Tag> getTags()
    {
        if (tags == null)
        {
            tags = new LinkedHashSet<Tag>();
        }
        return tags;
    }

    public void setTags(Set<Tag> tags)
    {
        this.tags = tags;
    }

    public void addTag(Tag tag)
    {
        tag.setPurchase(this);
        this.tags.add(tag);
    }

    public void addTags(Set<Tag> tags)
    {
        Iterator<Tag> it = tags.iterator();

        while (it.hasNext())
        {
            Tag tag = it.next();
            tag.setPurchase(this);
            this.tags.add(tag);
        }
    }

    ...
}

鬼ごっこ：

@Entity
@XmlRootElement
public class Tag implements Serializable
{
    /**
     * 
     */
    private static final long serialVersionUID = 5165922776051697002L;

    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    private Long id;

    @ManyToOne(fetch = FetchType.LAZY)
    @JoinColumns({@JoinColumn(name = "PURCHASEID", referencedColumnName = "ID")})
    private Purchase purchase;

    @JsonIgnore
    public Purchase getPurchase()
    {
        return purchase;
    }

    public void setPurchase(Purchase purchase)
    {
        this.purchase = purchase;
    }
}

PurchaseService：

@Service
public class PurchaseService implements IPurchaseService
{
    @Autowired
    private IPurchaseDAO purchaseDAO;

    public PurchaseService()
    {

    }

    @Transactional
    public List<Purchase> getAll()
    {
        return purchaseDAO.findAll();
    }

    @Transactional
    public Purchase getById(Long id)
    {
        return purchaseDAO.findOne(id);
    }

    @Transactional
    public void addPurchase(Purchase purchase)
    {
        purchaseDAO.save(purchase);
    }

    @Transactional
    public void updatePurchase(Purchase purchase)
    {
        purchaseDAO.update(purchase);
    }
}

TagService：

@Service
public class TagService implements ITagService
{
    @Autowired
    private ITagDAO tagDAO;

    public TagService()
    {

    }

    @Transactional
    public List<Tag> getAll()
    {
        return tagDAO.findAll();
    }

    @Transactional
    public Tag getById(Long id)
    {
        return tagDAO.findOne(id);
    }

    @Transactional
    public void addTag(Tag tag)
    {
        tagDAO.save(tag);
    }

    @Transactional
    public void updateTag(Tag tag)
    {
        tagDAO.update(tag);
    }
}

これを修正する方法について何かアイデアはありますか？（EAGER読み込みの使用は避けたい）。

トランザクション用に何らかの形式のセッション管理を設定する必要がありますか？

ありがとう

JBの提案に基づく更新

TagController

@RequestMapping(value = "purchases/{purchaseId}/tags", method = RequestMethod.POST, params = "manyTags")
@ResponseStatus(HttpStatus.CREATED)
public void createAll(@PathVariable("purchaseId") final Long purchaseId, @RequestBody final Tag[] entities)
{
    Purchase purchase = purchaseService.getById(purchaseId);

    // Validation
    RestPreconditions.checkRequestElementNotNull(purchase);
    RestPreconditions.checkRequestElementIsNumeric(purchaseId);

    Set<Tag> tags = new HashSet<Tag>(Arrays.asList(entities));

    purchaseService.addTagsToPurchase(purchaseId, tags);
}

PurchaseService

@Transactional
public void addTagsToPurchase(Long purchaseId, Set<Tag> tags)
{
    Purchase p = purchaseDAO.findOne(purchaseId);

    p.addTags(tags);
}

score 0 · Accepted Answer

タグコレクションを初期化せずに購入をロードし、コントローラーでトランザクションがコミットされてセッションが閉じられると、この初期化されていないコレクションにタグを追加します。したがって、明らかに、この例外がスローされます。

2つの可能性があります。

を呼び出すか、Hibernate.initialize(purchase.getTags())タグと一緒にタグをロードするJPQLクエリを単一のクエリ（select distinct p from Purchase p left join fetch p.tags）で実行することにより、Purchaseでタグをロードします。
DAO以上の注目を提供するサービスクラスを持つ代わりにaddTagsToPurchase(Long purchaseId, Set<Tag> tags)、購入をリロードしてこの購入にタグを追加する実際のサービスメソッドを追加します。これは実際、コントローラーに必要なサービス方法です。

もちろん、私は2番目の解決策をはるかに好みます。

サービスレイヤーが役立つ理由を示しています。
プレゼンテーション層からビジネスコードを削除して、サービス層に配置します。
より効率的です
アタッチされたエンティティを使用するため、より安全であり、したがって、発生している種類の例外を回避できます。

一般に、コントローラーが単一のアトミックアクションを実行するために、サービスレイヤーへの複数の呼び出しが必要な場合、サービスレイヤーが必要な機能を提供せず、代わりにサービスがプレゼンテーションレイヤーに実装されることを意味します。

spring - 子スローセッションエラーの遅延読み込み

JBの提案に基づく更新

1 に答える 1

Related

Reference