View Javadoc
1   /**
2    *    Copyright 2009-2019 the original author or authors.
3    *
4    *    Licensed under the Apache License, Version 2.0 (the "License");
5    *    you may not use this file except in compliance with the License.
6    *    You may obtain a copy of the License at
7    *
8    *       http://www.apache.org/licenses/LICENSE-2.0
9    *
10   *    Unless required by applicable law or agreed to in writing, software
11   *    distributed under the License is distributed on an "AS IS" BASIS,
12   *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13   *    See the License for the specific language governing permissions and
14   *    limitations under the License.
15   */
16  package org.apache.ibatis.submitted.heavy_initial_load;
17  
18  import java.io.Reader;
19  import java.util.ArrayList;
20  import java.util.Collections;
21  import java.util.List;
22  
23  import org.apache.ibatis.io.Resources;
24  import org.apache.ibatis.session.SqlSession;
25  import org.apache.ibatis.session.SqlSessionFactory;
26  import org.apache.ibatis.session.SqlSessionFactoryBuilder;
27  import org.junit.jupiter.api.Assertions;
28  import org.junit.jupiter.api.BeforeAll;
29  import org.junit.jupiter.api.Test;
30  
31  class HeavyInitialLoadTest {
32  
33    private static SqlSessionFactory sqlSessionFactory;
34  
35    @BeforeAll
36    static void initSqlSessionFactory() throws Exception {
37      try (Reader reader = Resources.getResourceAsReader("org/apache/ibatis/submitted/heavy_initial_load/ibatisConfig.xml")) {
38        sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);
39      }
40  
41      sqlSessionFactory.getConfiguration().getEnvironment().getDataSource().getConnection().close();
42    }
43  
44    private static final int THREAD_COUNT = 5;
45  
46    /**
47     * Test to demonstrate the effect of the
48     * https://issues.apache.org/jira/browse/OGNL-121 issue in ognl on mybatis.
49     *
50     * Use the thing mapper for the first time in multiple threads. The mapper contains
51     * a lot of ognl references to static final class members like:
52     *
53     * <code>@org.apache.ibatis.submitted.heavy_initial_load.Code@_1.equals(code)</code>
54     *
55     * Handling of these references is optimized in ognl (because they never change), but
56     * version 2.6.9 has a bug in caching the result . As a result the reference is
57     * translated to a 'null' value, which is used to invoke the 'equals' method on
58     * (hence the 'target is null for method equals' exception).
59     */
60    @Test
61    void selectThingsConcurrently_mybatis_issue_224() throws Exception {
62      final List<Throwable> throwables = Collections.synchronizedList(new ArrayList<>());
63  
64      Thread[] threads = new Thread[THREAD_COUNT];
65      for (int i = 0; i < THREAD_COUNT; i++) {
66        threads[i] = new Thread(() -> {
67          try {
68            selectThing();
69          } catch(Exception exception) {
70            throwables.add(exception);
71          }
72        });
73  
74        threads[i].start();
75      }
76  
77      for (int i = 0; i < THREAD_COUNT; i++) {
78        threads[i].join();
79      }
80  
81      Assertions.assertTrue(throwables.isEmpty(), "There were exceptions: " + throwables);
82    }
83  
84    void selectThing() {
85      try (SqlSession sqlSession = sqlSessionFactory.openSession()) {
86        ThingMapper mapper = sqlSession.getMapper(ThingMapper.class);
87        Thing selected = mapper.selectByCode(Code._1);
88        Assertions.assertEquals(1, selected.getId().longValue());
89      }
90    }
91  }