Transações e Sessões

Dados de amostra

Os exemplos neste guia usam a entidade Movie, que representa a coleção sample_mflix.movies dos conjuntos de dados de amostra do Atlas. A entidade Movie tem a seguinte definição:

import com.mongodb.hibernate.annotations.ObjectIdGenerator;
import org.bson.types.ObjectId;
import java.util.List;
import jakarta.persistence.Entity;
import jakarta.persistence.Id;
import jakarta.persistence.Table;
@Entity
@Table(name = "movies")
public class Movie {
   @Id
   @ObjectIdGenerator
   private ObjectId id;
   private String title;
   private String plot;
   private int year;
   private List<String> cast;
   public Movie(String title, String plot, int year, List<String> cast) {
      this.title = title;
      this.plot = plot;
      this.year = year;
      this.cast = cast;
   }
   public Movie() {
   }
   public ObjectId getId() {
      return id;
   }
   public String getTitle() {
      return title;
   }
   public void setTitle(String title) {
      this.title = title;
   }
   public String getPlot() {
      return plot;
   }
   public void setPlot(String plot) {
      this.plot = plot;
   }
   public int getYear() {
      return year;
   }
   public void setYear(int year) {
      this.year = year;
   }
   public List<String> getCast() {
      return cast;
   }
   public void setCast(List<String> cast) {
      this.cast = cast;
   }
}

Para aprender como criar um aplicativo Java que usa a Extensão MongoDB para Hibernate ORM para interação com esta coleção de amostra do MongoDB, veja o Get Started tutorial.

Usar uma Sessão de hibernação

Para iniciar um Session de hibernação, execute as seguintes etapas:

1. Recupere um SessionFactory da sua classe de utilidade HibernateUtil usando o método getSessionFactory(). O SessionFactory armazena sua configuração de conexão MongoDB e pode abrir novas sessões de banco de dados .

2. Crie um Session chamando o método openSession() em sua instância do SessionFactory.

3. Após executar as operações do banco de dados , feche o SessionFactory e o Session usando o método close() em ambas as instâncias.

O exemplo a seguir executa uma query de banco de dados em uma sessão e recupera um documento que tem um valor title de "Erin Brockovich" da coleção sample_mflix.movies:

var sf = HibernateUtil.getSessionFactory();
Session session = sf.openSession();
var movie = session.createQuery("from Movie where title = :t", Movie.class)
                    .setParameter("t", "Erin Brockovich")
                    .getSingleResult();
System.out.println("Title: " + movie.getTitle() + ", Year: " + movie.getYear());
session.close();
sf.close();

Title: Erin Brockovich, Year: 2000

Você também pode usar a declaração try-with-resources do Java para simplificar a lógica de gerenciamento da sessão e fechar automaticamente a sessão, conforme mostrado no código a seguir:

var sf = HibernateUtil.getSessionFactory();
try (Session session = sf.openSession()) {
    var movie = session.createQuery("from Movie where title = :t", Movie.class)
            .setParameter("t", "Erin Brockovich")
            .getSingleResult();
    System.out.println("Title: " + movie.getTitle() + ", Year: " + movie.getYear());
}
sf.close();

Usar um JPA EntityManager

Para iniciar uma API de Persistência de Jacarta (JPA) EntityManager, execute as seguintes etapas:

1. Crie um EntityManagerFactory a partir do seu arquivo persistence.xml chamando o método createEntityManagerFactory(), que cria um SessionFactory internamente.

2. Crie um EntityManager chamando o método createEntityManager() em sua instância do EntityManagerFactory, que cria um Session internamente.

3. Após executar as operações do banco de dados , feche seu EntityManagerFactory e EntityManager chamando o método close() em ambas as instâncias.

O exemplo a seguir executa uma query de banco de dados em um gerente de entidade e recupera documentos que têm um valor year de 1929 da coleção sample_mflix.movies:

// Replace <persistence unit> with the name of your persistence unit in the persistence.xml file
EntityManagerFactory emf = Persistence.createEntityManagerFactory("<persistence unit>");
EntityManager entityManager = emf.createEntityManager();
var results = entityManager.createQuery("select m from Movie m where m.year = :y", Movie.class)
        .setParameter("y", 1929)
        .getResultList();
results.forEach(movie -> System.out.println(movie.getTitle()));
entityManager.close();
emf.close();

The Broadway Melody
Queen Kelly
Asphalt
Hallelujah
Disraeli
Applause
Lambchops

In Jakarta Persistence v3.1 ou posterior, você pode usar a declaração try-with-resources do Java para fechar automaticamente o EntityManager, conforme mostrado na seção Sessão de hibernação.

Usar uma transação hibernar

Para iniciar um Transaction de hibernação, chame o método beginTransaction() em uma instância Session. Depois de executar as operações e usar o método persist() para registrar suas alterações na sessão, realize a confirmação da transação chamando o método commit().

O exemplo a seguir utiliza uma transação para executar as seguintes operações na coleção sample_mflix.movies:

• Cria uma nova entidade Movie e a insere como um documento na coleção

• Atualiza o campo cast de um documento que tem um valor title de "Black Swan"

As linhas destacadas iniciam a transação e a confirmação:

var sf = HibernateUtil.getSessionFactory();
Session session = sf.openSession();
Transaction tx = session.beginTransaction();
var newMovie = new Movie();
newMovie.setTitle("Lady Bird");
newMovie.setYear(2017);
session.persist(newMovie);
var movie = session.createQuery("from Movie where title = :t", Movie.class)
        .setParameter("t", "Black Swan")
        .getSingleResult();
var currentCast = new ArrayList<>(movie.getCast());
currentCast.add("Winona Ryder");
movie.setCast(currentCast);
tx.commit();
session.close();
sf.close();

Usar uma EntityTransaction JPA

Para criar um EntityTransaction JPA, chame o método getTransaction() no seu EntityManager. Este método recupera um EntityTransaction, que envolve o hibernação subjacente Transaction. Em seguida, chame o método begin() para iniciar a transação. Depois de executar as operações e usar o método persist() para registrar suas alterações com o gerente de entidades, faça a confirmação da transação chamando o método commit().

O exemplo a seguir usa um EntityTransaction para excluir um documento da coleção sample_mflix.movies e, em seguida, insere um novo documento que tem um valor de title de "The Favourite". As linhas destacadas iniciam e fazem a confirmação da transação:

// Replace <persistence unit> with the name of your persistence unit in the persistence.xml file
EntityManagerFactory emf = Persistence.createEntityManagerFactory("<persistence unit>");
EntityManager entityManager = emf.createEntityManager();
entityManager.getTransaction().begin();
// Your ObjectId value might differ
Movie movieToDelete = entityManager.find(Movie.class, new ObjectId("573a1399f29313caabcedc5d"));
entityManager.remove(movieToDelete);
var addMovie = new Movie();
addMovie.setTitle("The Favourite");
addMovie.setYear(2018);
entityManager.persist(addMovie);
entityManager.getTransaction().commit();
entityManager.close();
emf.close();