Grails, Promise API 및 두 개의 열린 세션

Question

컬렉션을 지우고 동시에 업데이트하려고합니다. 그것은 자식이 있고 컬렉션의 현재 항목을 찾고이를 비동기 적으로 삭제하면 많은 시간을 절약 할 수 있습니다.

1 단계. 컬렉션의 모든 항목을 찾습니다. 2 단계. 항목이 무엇인지 알고 나면 프로세스를 포크하여 삭제하십시오.

def memberRedbackCriteria = MemberRedback.createCriteria() 
    // #1 Find all the items in the collection. 
    def oldList = memberRedbackCriteria.list { fetchMode("memberCategories", FetchMode.EAGER) } 
    // #2 Delete them. 
    Promise deleteOld = task { 
     oldList.each { MemberRedback rbMember -> 
       rbMember.memberCategories.clear() 
       rbMember.delete() 
     } 
} 

오류 메시지는 다음과 같습니다 불법 시도가 두 개의 열린 세션

과 모음을 연결하는

난 후, 포크 항목을 찾을 수 있기 때문에 컬렉션이 구축 될 수 있도록이 과정이 새로운 세션을 생성하는 추측하고있다 forking 전에 새 세션을 사용하여 항목을 삭제합니다.

현재 스레드에서 항목을 수집해야합니다. 그렇지 않으면 상태가 무엇인지 알 수 없습니다.

Answer 1

해결책을 찾았습니다. 목록에 ID를 넣고 비동기 폐쇄의 일부로 ID를 수집하십시오. 당신은 모든 삭제에 대해 하나의 비동기 작업을 사용하여 효율적으로 단일 스레드에서 시리즈의 모든 삭제 작업이 실행되고 있는지 http://jira.grails.org/browse/GRAILS-1967

// #1 find the ids 
def redbackIds = MemberRedback.executeQuery(
       'select mr.id from MemberRedback mr',[]) 

// #2 Delete them. 
Promise deleteOld = task { 
     redbackIds.each { Long rbId -> 
      def memberRedbackCriteria = MemberRedback.createCriteria() 
      MemberRedback memberRedback = memberRedbackCriteria.get { 
       idEq(rbId) 
       fetchMode("memberCategories", FetchMode.EAGER) } 
      memberRedback.memberCategories.clear() 
      memberRedback.delete() 
     } 
} 
deleteOld.onError { Throwable err -> 
     println "deleteAllRedbackMembers An error occured ${err.message}" 
} 

Answer 2

주에 따라 기준을 다시 사용할 수 없습니다 것이

는

참고. 데이터베이스가 여러 연결 및 테이블의 동시 수정을 처리 할 수 ​​있다고 가정하면 다음과 같이 PromiseList를 사용하여 삭제를 병렬 처리 할 수 ​​있습니다 (테스트되지 않은 코드 참고).

def deletePromises = new PromiseList() 
redbackIds.each { Long rbId -> 
    deletePromises << MemberRedback.async.task { 
     withTransaction { 
      def memberRedbackCriteria = createCriteria() 
      MemberRedback memberRedback = memberRedbackCriteria.get { 
       idEq(rbId) 
       fetchMode("memberCategories", FetchMode.EAGER) } 
      memberRedback.memberCategories.clear() 
      memberRedback.delete() 
     } 
    } 
} 
deletePromises.onComplete { List results -> 
    // do something with the results, if you want 
} 
deletePromises.onError { Throwable err -> 
    // do something with the error 
}