|
1 | 1 | package com.baeldung.persistencecontext;
|
2 | 2 |
|
| 3 | +import com.baeldung.persistencecontext.entity.User; |
| 4 | +import com.baeldung.persistencecontext.service.ExtendedPersistenceContextUserService; |
| 5 | +import com.baeldung.persistencecontext.service.TransctionPersistenceContextUserService; |
| 6 | + |
| 7 | +import javax.persistence.EntityExistsException; |
| 8 | +import javax.persistence.TransactionRequiredException; |
| 9 | + |
3 | 10 | import org.hamcrest.core.Is;
|
4 | 11 | import org.hamcrest.core.IsNull;
|
5 |
| -import org.junit.Before; |
6 | 12 | import org.junit.Test;
|
7 | 13 | import org.junit.runner.RunWith;
|
| 14 | +import org.springframework.beans.factory.annotation.Autowired; |
8 | 15 | import org.springframework.boot.test.context.SpringBootTest;
|
9 |
| -import org.springframework.boot.web.server.LocalServerPort; |
10 | 16 | import org.springframework.test.context.junit4.SpringRunner;
|
11 |
| -import org.springframework.web.client.HttpServerErrorException; |
12 |
| -import org.springframework.web.client.RestTemplate; |
13 |
| - |
14 |
| -import com.baeldung.persistencecontext.PersistenceContextDemoApplication; |
15 |
| -import com.baeldung.persistencecontext.entity.User; |
16 | 17 |
|
17 | 18 | import static org.junit.Assert.assertThat;
|
18 | 19 |
|
19 | 20 | @RunWith(SpringRunner.class)
|
20 |
| -@SpringBootTest(classes = PersistenceContextDemoApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT) |
21 |
| - |
| 21 | +@SpringBootTest(classes = PersistenceContextDemoApplication.class) |
22 | 22 | public class PersistenceContextIntegrationTest {
|
23 |
| - @LocalServerPort |
24 |
| - private int port; |
25 |
| - private RestTemplate restTemplate; |
26 |
| - |
27 |
| - @Before |
28 |
| - public void setUp() { |
29 |
| - restTemplate = new RestTemplate(); |
30 |
| - } |
| 23 | + |
| 24 | + @Autowired |
| 25 | + private TransctionPersistenceContextUserService transctionPersistenceContext; |
| 26 | + @Autowired |
| 27 | + private ExtendedPersistenceContextUserService extendedPersistenceContext; |
31 | 28 |
|
32 | 29 | @Test
|
33 | 30 | public void testThatWhenUserSavedWithTransctionPersistenceContextThenUserShouldGetSavedInDB() {
|
34 | 31 | User user = new User(121L, "Devender", "admin");
|
35 |
| - restTemplate.postForEntity(buildRequestUrl("v1/user/"), user, User.class); |
36 |
| - User userFromTransctionPersistenceContext = restTemplate.getForObject(buildRequestUrl("v1/user/121"), User.class); |
37 |
| - User userFromExtendedPersistenceContext = restTemplate.getForObject(buildRequestUrl("v2/user/121"), User.class); |
| 32 | + transctionPersistenceContext.insertWithTransaction(user); |
| 33 | + User userFromTransctionPersistenceContext = transctionPersistenceContext.find(user.getId()); |
| 34 | + User userFromExtendedPersistenceContext = extendedPersistenceContext.find(user.getId()); |
38 | 35 | assertThat(userFromTransctionPersistenceContext, Is.is(IsNull.notNullValue()));
|
39 | 36 | assertThat(userFromExtendedPersistenceContext, Is.is(IsNull.notNullValue()));
|
40 | 37 | }
|
41 | 38 |
|
42 |
| - @Test(expected = HttpServerErrorException.class) |
43 |
| - public void testThatWhenUserSaveWithOutTransactionInPersistenceContextTypeTransactionThenShouldWhtowTransactionRequiredExceptionOnPersist() { |
| 39 | + @Test(expected = TransactionRequiredException.class) |
| 40 | + public void testThatWhenUserSaveWithOutTransactionowTransactionRequiredExceptionOnPersist() { |
44 | 41 | User user = new User(122L, "Devender", "admin");
|
45 |
| - restTemplate.postForEntity(buildRequestUrl("v4/user/"), user, User.class); |
| 42 | + transctionPersistenceContext.insertWithoutTransaction(user); |
46 | 43 | }
|
47 | 44 |
|
48 | 45 | @Test
|
49 |
| - public void testThatWhenUserSavedWithExtendedPersistenceContextWithoutTransactionThenUserShouldGetBeCached() { |
| 46 | + public void testThatWhenUserSavedWithExtendedPersistenceContextWithoutTransactionThenUserShouldGetCached() { |
50 | 47 | User user = new User(123L, "Devender", "admin");
|
51 |
| - restTemplate.postForEntity(buildRequestUrl("v2/user/"), user, User.class); |
52 |
| - User userFromExtendedPersistenceContext = restTemplate.getForObject(buildRequestUrl("v2/user/123"), User.class); |
53 |
| - User userFromTransctionPersistenceContext = restTemplate.getForObject(buildRequestUrl("v1/user/123"), User.class); |
| 48 | + extendedPersistenceContext.insertWithoutTransaction(user); |
| 49 | + User userFromExtendedPersistenceContext = extendedPersistenceContext.find(user.getId()); |
| 50 | + User userFromTransctionPersistenceContext = transctionPersistenceContext.find(user.getId()); |
54 | 51 | assertThat(userFromExtendedPersistenceContext, Is.is(IsNull.notNullValue()));
|
55 | 52 | assertThat(userFromTransctionPersistenceContext, Is.is(IsNull.nullValue()));
|
56 | 53 | }
|
57 | 54 |
|
58 |
| - @Test(expected = HttpServerErrorException.class) |
| 55 | + @Test(expected = EntityExistsException.class) |
59 | 56 | public void testThatWhenAddUserWithSameIdentifierInPersistenceContextThenShouldThrowException() {
|
60 |
| - User user = new User(126L, "Devender", "admin"); |
61 |
| - restTemplate.postForEntity(buildRequestUrl("v2/user/"), user, User.class); |
62 |
| - restTemplate.postForEntity(buildRequestUrl("v2/user/"), user, User.class); |
| 57 | + User user1 = new User(126L, "Devender", "admin"); |
| 58 | + User user2 = new User(126L, "Devender", "admin"); |
| 59 | + extendedPersistenceContext.insertWithoutTransaction(user1); |
| 60 | + extendedPersistenceContext.insertWithoutTransaction(user2); |
63 | 61 | }
|
64 | 62 |
|
65 | 63 | @Test
|
66 | 64 | public void testThatWhenUserSavedWithExtendedPersistenceContextWithTransactionThenUserShouldSaveEntityIntoDB() {
|
67 | 65 | User user = new User(127L, "Devender", "admin");
|
68 |
| - restTemplate.postForEntity(buildRequestUrl("v3/user/"), user, User.class); |
69 |
| - User userFromDB = restTemplate.getForObject(buildRequestUrl("v1/user/127"), User.class); |
| 66 | + extendedPersistenceContext.insertWithTransaction(user); |
| 67 | + User userFromDB = transctionPersistenceContext.find(user.getId()); |
70 | 68 | assertThat(userFromDB, Is.is(IsNull.notNullValue()));
|
71 | 69 | }
|
72 | 70 |
|
73 | 71 | @Test
|
74 | 72 | public void testThatWhenUserSavedWithExtendedPersistenceContextWithTransactionThenUserShouldFlushCachedEntityIntoDB() {
|
75 |
| - User user = new User(124L, "Devender", "admin"); |
76 |
| - restTemplate.postForEntity(buildRequestUrl("v2/user/"), user, User.class); |
77 |
| - user = new User(125L, "Devender", "admin"); |
78 |
| - restTemplate.postForEntity(buildRequestUrl("v3/user/"), user, User.class); |
79 |
| - User userFromExtendedPersistenceContextuser1 = restTemplate.getForObject(buildRequestUrl("v2/user/124"), User.class); |
80 |
| - User userFromExtendedPersistenceContextuser2 = restTemplate.getForObject(buildRequestUrl("v2/user/125"), User.class); |
81 |
| - User userFromTransctionPersistenceContextuser1 = restTemplate.getForObject(buildRequestUrl("v1/user/124"), User.class); |
82 |
| - User userFromTransctionPersistenceContextuser2 = restTemplate.getForObject(buildRequestUrl("v1/user/125"), User.class); |
| 73 | + User user1 = new User(124L, "Devender", "admin"); |
| 74 | + extendedPersistenceContext.insertWithoutTransaction(user1); |
| 75 | + User user2 = new User(125L, "Devender", "admin"); |
| 76 | + extendedPersistenceContext.insertWithTransaction(user2); |
| 77 | + User userFromExtendedPersistenceContextuser1 = extendedPersistenceContext.find(user1.getId()); |
| 78 | + User userFromExtendedPersistenceContextuser2 = extendedPersistenceContext.find(user2.getId()); |
| 79 | + User userFromTransctionPersistenceContextuser1 = transctionPersistenceContext.find(user1.getId()); |
| 80 | + User userFromTransctionPersistenceContextuser2 = transctionPersistenceContext.find(user2.getId()); |
83 | 81 | assertThat(userFromExtendedPersistenceContextuser1, Is.is(IsNull.notNullValue()));
|
84 | 82 | assertThat(userFromExtendedPersistenceContextuser2, Is.is(IsNull.notNullValue()));
|
85 | 83 | assertThat(userFromTransctionPersistenceContextuser1, Is.is(IsNull.notNullValue()));
|
86 | 84 | assertThat(userFromTransctionPersistenceContextuser2, Is.is(IsNull.notNullValue()));
|
87 | 85 | }
|
88 | 86 |
|
89 |
| - private String buildRequestUrl(String path) { |
90 |
| - return "http://localhost:" + port + path; |
91 |
| - } |
92 | 87 | }
|
0 commit comments