2

複数のスレッドから呼び出すことができるトランザクション メソッドがあります。

同時呼び出しが発生するのを避けるためStaleStateExceptionに、休止状態で悲観的ロックを使用しましたが、期待どおりに機能せず、StaleStateException. 次に、ログを調べたところ、オブジェクトが適切にロックされていないことがわかりました。これが私のログです。

2014-09-17_19:12:19.078 INFO  c.c.p.a.w.m.ImportExportManagerImpl - ************************Test Name: Requirement Coverage Test
2014-09-17_19:12:19.079 INFO  c.c.p.a.w.m.ImportExportManagerImpl - ************************Test folder ID: 9312
2014-09-17_19:12:19.525 INFO  c.c.p.a.w.m.ImportExportManagerImpl - Test Case Id: P072051933
2014-09-17_19:12:19.615 WARN  org.hibernate.loader.Loader - HHH000444: Encountered request for locking however dialect reports that database prefers locking be done in a separate select (follow-on locking); results will be locked after initial query executes
Hibernate: 
    select
        requiremen0_."RC_ITEM_ID" as RC_ITEM_ID1_1_,
        requiremen0_."RC_ENTITY_ID" as RC_ENTITY_ID2_1_,
        requiremen0_."RC_ENTITY_TYPE" as RC_ENTITY_TYPE3_1_,
        requiremen0_.RC_REQ_ID as RC_REQ_ID4_1_ 
    from
        "OME6500_OM65_OME6500_R9_2_DB"."REQ_COVER" requiremen0_ 
    where
        requiremen0_."RC_ENTITY_ID"=?
Hibernate: 
    select
        requiremen0_."RQ_REQ_ID" as RQ_REQ_ID1_2_0_,
        requiremen0_."RQ_USER_03" as RQ_USER_2_2_0_ 
    from
        "OME6500_OM65_OME6500_R9_2_DB"."REQ" requiremen0_ 
    where
        requiremen0_."RQ_REQ_ID"=?
Hibernate: 
    select
        "RC_ITEM_ID" 
    from
        "OME6500_OM65_OME6500_R9_2_DB"."REQ_COVER" 
    where
        "RC_ITEM_ID" =? for update

2014-09-17_19:12:19.631 INFO  c.c.p.a.w.m.ImportExportManagerImpl - Requirement Coverages Size:1
2014-09-17_19:12:19.631 INFO  c.c.p.a.w.m.ImportExportManagerImpl - Deleting requirement coverage id: 130967
2014-09-17_19:12:19.634 INFO  c.c.p.a.w.m.ImportExportManagerImpl - Requirement in testcase table Size:1
2014-09-17_19:12:19.669 INFO  c.c.p.a.w.m.ImportExportManagerImpl - Checking if requirement coverage exists: test case id: 51933, req id:  7760
Hibernate: 
    delete 
    from
        "OME6500_OM65_OME6500_R9_2_DB"."REQ_COVER" 
    where
        "RC_ITEM_ID"=?

私の取引方法はここにあります：

@Transactional(readOnly = false)
    public void importTestCases(String domain, String project, List<TestCase> testCases,
                                Boolean onlyUpdateReqCover, Boolean foldersExist)
            throws RequestFailureException, RESTAPIException, InvalidDataException,
            UnAuthorizedOperationException {

        setDBSchema(domain, project);

        for (TestCase testCase : testCases) {
            TestFolder testFolder = retrieveTestFolderFromPath(domain, project, testCase.getFolderPath(),
                                                               foldersExist, testCase);
            Test test = new Test(testCase, testFolder);
            ALMEntity almEntity = null;
            LOGGER.info("************************Test Name: " + test.getName());
            LOGGER.info("************************Test folder ID: " + test.getParent_id());
            ...
            ...
            LOGGER.info("Test Case Id: " + existingTest.getQc_tcid());

            List<RequirementCoverage> requirementCoverages = requirementCoverageDao.findAllFromTestId(Integer
                    .parseInt(existingTest.getId()));

            LOGGER.info("Requirement Coverages Size:" + requirementCoverages.size());

            for (RequirementCoverage requirementCoverage : requirementCoverages) {
                LOGGER.info("Deleting requirement coverage id: " + requirementCoverage.getId());
                requirementCoverageDao.delete(requirementCoverage);
            }

           ...
           ...
           }
}

ロックを使用した私のDAOメソッドは次のとおりです。

@Override
    public List<RequirementCoverage> findAllFromTestId(int testId) {
        List<RequirementCoverage> list = sessionFactory.getCurrentSession()
                .createQuery("from RequirementCoverage where entityId = :testId")
                .setLockOptions(new LockOptions(LockMode.PESSIMISTIC_WRITE)).setParameter("testId", testId)
                .list();
        return list;
    }

ログからわかるように、requirementCoveragesによって返されたfindAllFromTestIdものはロックされていません。それぞれのロックはrequirementCoverage、開始後にのみ取得されますfor (RequirementCoverage requirementCoverage : requirementCoverages)。

StaleStateExceptionその原因は、あるスレッドがリストrequirementCoveragesを取得して各オブジェクトにアクセスしようとしているのに、同時にrequirementCoverages別のスレッドによって変更されていることだと思います。

私は正しいですか？requirementCoverages別のスレッドがアクセスするのをブロックするリストをロックする方法はありますか? どんな助けでも大歓迎です。

4

2 に答える 2

0

LockMode.PESSIMISTIC_FORCE_INCREMENT を使用する別のオプションがあります。このソリューションを確認してください。

于 2015-04-30T14:32:57.163 に答える
0

コードを再構築してこの問題を解決しました。

いくつかのエンティティの名前付きクエリで悲観的ロックを使用する代わりに、これらのエンティティの親エンティティに悲観的ロックを適用し、読み取り時にロックします。

次に、これらのサブ エンティティを更新します。

最後に、親エンティティを解放します。

于 2014-09-22T16:33:46.630 に答える