1

Hibernate3とSpringを使用しています。スレッドを開始すると、例外が発生しました。

org.hibernate.HibernateException: Illegal attempt to associate a collection with two open sessions

エンティティを切り離す方法や、このアーキテクチャでセッションを閉じる方法がわかりません。助けてくれてありがとう。

CommunicationService.sendCommunications()コード：

public void sendCommunications(HibernateMessageToSendRepository messageToSendRepository)  {
    Long messageId = new Long(41); //this is only for test. the idea is get a list of id and generate a thread group.
    MessageSender sender = SmsSender(messageId, messageToSendRepository);
    sender.start();
}

呼び出しsendCommunicationsコード：

ApplicationContext appCont = new ClassPathXmlApplicationContext("appContext.xml");      
ServiceLocator serviceLocator = ServiceLocator.getInstance();
HibernateMessageToSendRepository messageToSendRepository = (HibernateMessageToSendRepository) appCont.getBean("messageToSendRepository");

CommunicationService communication = serviceLocator.getCommunicationService();
communication.sendCommunications(messageToSendRepository);

SmsSender（MessageSender（スレッド）から拡張）コード：

public class SmsSender extends MessageSender {

    public SmsSender(Long messageToSendId, HibernateMessageToSendRepository messageToSendRepository) {
        super(messageToSendRepository);
        MessageToSend messageToSendNew = this.messageToSendRepository.getById(messageToSendId);     
        this.messageToSend = messageToSendNew;
    }

    public void run() {
        try {
            MessageToSendSms messageToSendSms = (MessageToSendSms) this.messageToSend;
            Iterator<CustomerByMessage> itCbmsgs = messageToSendSms.getCustomerByMessage().iterator();          
            while (itCbmsgs.hasNext()) {                
                CustomerByMessage cbm = (CustomerByMessage) itCbmsgs.next();                        

                //sms sending
                this.getGateway().sendSMS(cbm.getBody(), cbm.getCellphone());                       
                cbm.setStatus(CustomerByMessageStatus.SENT_OK);
                cbm.setSendingDate(Calendar.getInstance().getTime());               
            }           

            messageToSendSms.getMessage().setStatus(messageToSendStatus.ALL_MESSAGES_SENT);
            this.messageToSendRepository.update(messageToSendSms);      
        } catch (Exception e) {         
            this.log.error("Error en sms sender " + e.getMessage());
        }

    }
}

MessageToSendRepositoryコード：

public void update(MessageToSend messageToSend) {
    try {
        this.getSession().update(messageToSend);
    } catch (HibernateException e) {
        this.log.error(e.getMessage(), e);
        throw e;
    }
}
4

1 に答える 1

0

messageToSendNew取得した後、別のスレッドと共有する前にデタッチする必要があります。Session.close()休止状態セッションを呼び出して、オブジェクトを切り離すことができます。

必要なすべてのフィールドに積極的に入力する必要があることに注意してください。

新しいセッションで再接続する必要がある場合は、merge()メソッドを使用できます。

于 2012-10-17T15:59:19.370 に答える