1
2
3
4
5
6
7
8
9
10
11
12
13
14
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
48
49
50
51
52
53
54
55
56
57
58
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 }