Skip to content
Snippets Groups Projects
Commit 09bb4c31 authored by opitzju's avatar opitzju
Browse files

EntityManager sollte jetzt immer sauber geschlossen werden

parent c47e81c8
Branches
Tags
No related merge requests found
...@@ -38,6 +38,7 @@ public class MovieManager extends Manager { ...@@ -38,6 +38,7 @@ public class MovieManager extends Manager {
update(movie.get(), movieDTO); update(movie.get(), movieDTO);
else else
insert(movieDTO); insert(movieDTO);
closeEntityManager();
} }
private void updateMapper() { private void updateMapper() {
...@@ -58,6 +59,7 @@ public class MovieManager extends Manager { ...@@ -58,6 +59,7 @@ public class MovieManager extends Manager {
public void deleteMovie(final long movieId) { public void deleteMovie(final long movieId) {
var movie = findMovieById(movieId); var movie = findMovieById(movieId);
movie.ifPresent(this::delete); movie.ifPresent(this::delete);
closeEntityManager();
} }
private void delete(Movie movie) { private void delete(Movie movie) {
...@@ -66,11 +68,12 @@ public class MovieManager extends Manager { ...@@ -66,11 +68,12 @@ public class MovieManager extends Manager {
public MovieDTO getMovie(final long movieId) { public MovieDTO getMovie(final long movieId) {
var movie = findMovieById(movieId); var movie = findMovieById(movieId);
closeEntityManager();
return movie.map(mapper::map).orElse(null); return movie.map(mapper::map).orElse(null);
} }
private Optional<Movie> findMovieById(final long id) { private Optional<Movie> findMovieById(final long id) {
return query(Movie.class, (cb, cq) -> { return queryNoClose(Movie.class, (cb, cq) -> {
var root = cq.from(Movie.class); var root = cq.from(Movie.class);
cq.select(root).where(cb.equal(root.get("id"), id)); cq.select(root).where(cb.equal(root.get("id"), id));
}).stream().findAny(); }).stream().findAny();
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment