Skip to contentPackage: TxManagerImpl
TxManagerImpl
Coverage
1: /*
2: * *********************************************************************************************************************
3: *
4: * TheseFoolishThings: Miscellaneous utilities
5: * http://tidalwave.it/projects/thesefoolishthings
6: *
7: * Copyright (C) 2009 - 2023 by Tidalwave s.a.s. (http://tidalwave.it)
8: *
9: * *********************************************************************************************************************
10: *
11: * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
12: * the License. You may obtain a copy of the License at
13: *
14: * http://www.apache.org/licenses/LICENSE-2.0
15: *
16: * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
17: * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
18: * specific language governing permissions and limitations under the License.
19: *
20: * *********************************************************************************************************************
21: *
22: * git clone https://bitbucket.org/tidalwave/thesefoolishthings-src
23: * git clone https://github.com/tidalwave-it/thesefoolishthings-src
24: *
25: * *********************************************************************************************************************
26: */
27: package it.tidalwave.thesefoolishthings.examples.jpafinderexample.impl;
28:
29: import javax.annotation.Nonnull;
30: import java.util.function.Function;
31: import javax.persistence.EntityManager;
32: import javax.persistence.EntityManagerFactory;
33: import javax.persistence.EntityTransaction;
34: import javax.persistence.Persistence;
35: import it.tidalwave.thesefoolishthings.examples.jpafinderexample.TxManager;
36:
37: /***********************************************************************************************************************
38: *
39: * @author Fabrizio Giudici
40: *
41: **********************************************************************************************************************/
42: public class TxManagerImpl implements TxManager
43: {
44: private final EntityManagerFactory emf = Persistence.createEntityManagerFactory("example");
45:
46: @Override
47: public <T> T computeInTx (@Nonnull final Function<EntityManager, T> task)
48: {
49: EntityManager em = null;
50: EntityTransaction tx = null;
51:
52: try
53: {
54: em = emf.createEntityManager();
55: tx = em.getTransaction();
56: tx.begin();
57: final T result = task.apply(em);
58: tx.commit();
59: return result;
60: }
61: catch (Exception e)
62: {
63:• if (tx != null)
64: {
65: tx.rollback();
66: }
67:
68: throw new RuntimeException(e);
69: }
70: finally
71: {
72:• if (em != null)
73: {
74: em.close();
75: }
76: }
77: }
78:
79: @Override
80: public void close()
81: {
82: emf.close();
83: }
84: }