Exemplo de DAO (CRUD) utilizando JPA
Nesse exemplo, vamos criar uma aplicativo Java (console) chamado Exemplo, para salvar, alterar, consultar por id e apagar um registro de pessoa, utilizaremos o banco de dados Oracle.
Observação: Lembre de adicionar as bibliotecas do Hibernate JPA e Oracle (ojdbc6.jar) no seu projeto.
Vamos criar uma Entity para representar a tabela Pessoa a seguir:
CREATE SEQUENCE PESSOA_SEQ INCREMENT BY 1
START WITH 1 NOCACHE NOCYCLE;
CREATE TABLE Pessoa (
id NUMBER(5) NOT NULL,
nome VARCHAR2(100) NOT NULL,
dataNasc DATE NOT NULL,
email VARCHAR2(150),
PRIMARY KEY(ID)
);
Criando a entity para representar a tabela Pessoa:
package pbc.jpa.exemplo1.modelo;
import java.io.Serializable;
import java.util.Date;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.SequenceGenerator;
import javax.persistence.Temporal;
import javax.persistence.TemporalType;
/**
* Classe utilizada para representar uma pessoa.
*/
@Entity
@SequenceGenerator(name="PES_SEQ",
sequenceName="PESSOA_SEQ", allocationSize=1,
initialValue=1)
public class Pessoa implements Serializable {
private static final long serialVersionUID = 1L;
@Id
@GeneratedValue(strategy=GenerationType.SEQUENCE,
generator="PES_SEQ")
private Long id;
@Column(nullable = false)
private String nome;
@Temporal(TemporalType.DATE)
@Column(name = "dataNasc", nullable = false)
private Date dataNascimento;
private String email;
public Date getDataNascimento() {
return dataNascimento;
}
public void setDataNascimento(Date dataNascimento) {
this.dataNascimento = dataNascimento;
}
public String getEmail() { return email; }
public void setEmail(String email) {
this.email = email;
}
public Long getId() { return id; }
public void setId(Long id) { this.id = id; }
public String getNome() { return nome; }
public void setNome(String nome) { this.nome = nome; }
}
Vamos criar o arquivo persistence.xml, O NetBeans possui um wizard que permite de forma fácil a criação desta unidade de persistência, para isto, clique com o botão direito do mouse no nome do projeto, selecione a opção Novo -> Outro..., na tela de Novo arquivo selecione a categoria Persistence e o tipo de arquivo Unidade de Persistência.
Na tela de Novo Unidade de persistência, informe:
- Nome da unidade de persistência: ExemplosJPAPU
- Biblioteca de persistência: Hibernate JPA (1.0)
- Conexão com o banco de dados: Aqui vamos criar uma nova conexão com o Oracle, então selecione a opção Nova conexão com banco de dados...
Na tela Nova Conexão do Banco de Dados, selecione no campo Nome do driver a opção Novo driver...
Na tela de Novo driver JDBC, clique em Adicionar... e procure pelo arquivo com o driver do Oracle, neste caso o arquivo ojdbc6.jar. Após isso clique em OK para prosseguir.
Voltando na tela Nova Conexão do Banco de Dados, configure as seguintes informações:
- Modo de entrada de dados: Entrada direta de URL
- Nome do usuário: Informe seu usuário
- Senha do usuário: Informe sua senha
- URL JDBC: Para conectar no banco de dados utilize a URL
jdbc:oracle:thin:@localhost:1521:XEou outra de acordo com o local que foi instalado o seu banco de dados.
Clique em OK para prosseguir, a conexão com o banco de dados será testada e apresentará a mensagem na tela “Conexão estabelecida”. Clique em OK para prosseguir.
Ao clicar em Finalizar será gerado o arquivo persistence.xml.
<?xml version="1.0" encoding="UTF-8"?>
<persistence version="1.0"
xmlns="http://java.sun.com/xml/ns/persistence"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/persistence
http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd">
<persistence-unit name="ExemplosJPAPU"
transaction-type="RESOURCE_LOCAL">
<provider>org.hibernate.ejb.HibernatePersistence</provider>
<class>pbc.jpa.exemplo1.modelo.Pessoa</class>
<properties>
<property name="hibernate.connection.username"
value="usuario"/>
<property name="hibernate.connection.password"
value="senha"/>
<property name="hibernate.connection.driver_class"
value="oracle.jdbc.driver.OracleDriver"/>
<property name="hibernate.connection.url"
value="jdbc:oracle:thin:@localhost:1521:XE"/>
<property name="hibernate.cache.provider_class"
value="org.hibernate.cache.NoCacheProvider"/>
<property name="hibernate.dialect"
value="org.hibernate.dialect.Oracle9Dialect"/>
<property name="hibernate.show_sql" value="true"/>
</properties>
</persistence-unit>
</persistence>
Vamos criar uma classe PessoaDAO que possui os métodos para manipular (salvar, atualizar, apagar e consultar por id) um objeto Pessoa.
package pbc.jpa.exemplo.dao;
import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.Persistence;
import pbc.jpa.exemplo.modelo.Pessoa;
/**
* Classe utilizada para fazer realizar as operações de
* banco de dados sobre a entity Pessoa.
*/
public class PessoaDAO {
/**
* Método utilizado para obter o entity manager.
* @return
*/
private EntityManager getEntityManager() {
EntityManagerFactory factory = null;
EntityManager entityManager = null;
try {
//Obtém o factory a partir da unidade de persistência.
factory = Persistence.createEntityManagerFactory
("ExemplosJPAPU");
//Cria um entity manager.
entityManager = factory.createEntityManager();
//Fecha o factory para liberar os recursos utilizado.
} finally {
factory.close();
}
return entityManager;
}
/**
* Método utilizado para salvar ou atualizar as
* informações de uma pessoa.
* @param pessoa
* @return
* @throws java.lang.Exception
*/
public Pessoa salvar(Pessoa pessoa) throws Exception {
EntityManager entityManager = getEntityManager();
try {
// Inicia uma transação com o banco de dados.
entityManager.getTransaction().begin();
System.out.println("Salvando a pessoa.");
/* Verifica se a pessoa ainda não está salva
no banco de dados. */
if(pessoa.getId() == null) {
entityManager.persist(pessoa);
} else {
pessoa = entityManager.merge(pessoa);
}
// Finaliza a transação.
entityManager.getTransaction().commit();
} finally {
entityManager.close();
}
return pessoa;
}
/**
* Método que apaga a pessoa do banco de dados.
* @param id
*/
public void excluir(Long id) {
EntityManager entityManager = getEntityManager();
try {
// Inicia uma transação com o banco de dados.
entityManager.getTransaction().begin();
/* Consulta a pessoa na base de dados através
do seu ID. */
Pessoa pessoa = consultarPorId(id);
System.out.println("Excluindo a pessoa: "
+ pessoa.getNome());
// Remove a pessoa da base de dados.
entityManager.remove(pessoa);
// Finaliza a transação.
entityManager.getTransaction().commit();
} finally {
entityManager.close();
}
}
/**
* Consulta o pessoa pelo ID.
* @param id
* @return o objeto Pessoa.
*/
public Pessoa consultarPorId(Long id) {
EntityManager entityManager = getEntityManager();
Pessoa pessoa = null;
try {
pessoa = entityManager.find(Pessoa.class, id);
} finally {
entityManager.close();
}
return pessoa;
}
}
O método salvar recebe o objeto Pessoa que será salvo, neste exemplo usaremos este método para salvar uma nova pessoa ou atualizar os dados de uma pessoa.
Mas como sabemos quando temos que salvar e quando tem que atualizar, basta olhar o atributo id da classe Pessoa, se o id for null significa que é um novo objeto que ainda não foi salvo no banco de dados, então utilizaremos o método persist da EntityManager para salva-lo, caso o id tenha algum valor então significa que o objeto já foi salvo anteriormente portanto ele deve ser atualizado então utilizaremos o método merge da EntityManager para atualiza-lo.
Note que como vamos salvar ou atualizar os dados, precisamos criar uma transação, com o método getTransaction() do EntityManager obtemos um objeto EntityTransaction com ele podemos iniciar a transação através do método begin(), finalizar a transação com sucesso através do método commit() ou desfazer as alterações em caso de erro com o método rolback(). Este mesmo conceito de transação será utilizado no método excluir.
O método excluir não precisa receber todos os dados da Pessoa, recebendo apenas o seu ID através do parâmetro Long id, podemos utilizar o método find do EntityManager para consultar os dados da Pessoa, depois com o objeto Pessoa consultado podemos usar o método remove do EntityManager para apagar os dados da Pessoa.
O método consultarPorId recebe um objeto Long chamado id, com o ID da tabela Pessoa, utilizando o método find do EntityManager passamos a classe da entidade Pessoa.class e seu id para que possamos consultar os dados da Pessoa.
Vamos criar uma classe PessoaDAOTeste para testarmos os métodos da classe PessoaDAO:
package pbc.jpa.exemplo1.teste;
import java.util.Calendar;
import java.util.GregorianCalendar;
import pbc.jpa.exemplo1.dao.PessoaDAO;
import pbc.jpa.exemplo1.modelo.Pessoa;
/**
* Classe utilizada para testar os métodos do PessoaDAO.
*/
public class PessoaDAOTeste {
public static void main(String[] args) throws Exception {
Pessoa pessoa = new Pessoa();
pessoa.setId(1L);
pessoa.setNome("Rafael Sakurai");
Calendar data = new GregorianCalendar();
data.set(Calendar.YEAR, 1983);
data.set(Calendar.MONTH, 11);
data.set(Calendar.DAY_OF_MONTH, 26);
pessoa.setDataNascimento(data.getTime());
pessoa.setEmail("[email protected]");
PessoaDAO dao = new PessoaDAO();
System.out.println("Salvando a pessoa: "
+ pessoa.getNome());
pessoa = dao.salvar(pessoa);
pessoa.setNome("Rafael Guimarães Sakurai");
pessoa = dao.salvar(pessoa);
System.out.println("Alterando a pessoa: "
+ pessoa.getNome());
Pessoa pessoa2 = dao.consultarPorId(pessoa.getId());
System.out.println("Consultando: " + pessoa2.getNome());
System.out.println("Removendo a pessoa: "
+ pessoa.getId());
dao.excluir(pessoa.getId());
}
}
Neste teste vamos criar um objeto pessoa e salva-lo, depois vamos altera o nome da pessoa, vamos consultar a pessoa pelo id e no final vamos apagar o registro da pessoa.