Eclipselink JPA, Oracle, WebLogic, chamando persiste não se compromete com o banco de dados
-
18-09-2019 - |
Pergunta
Estou apenas começando a dar uma olhada na persistência de Java (no momento com o fornecedor padrão do Eclipselink do Eclipse). Basicamente, apenas criando um objeto e tentando persistir no banco de dados (Oracle). Entendi -me que a transacionalidade padrão deveria comprometer o novo objeto com o banco de dados quando o método retornar, mas nada parece estar acontecendo. Alguma ideia?
@Stateless
public class RegisterUser implements RegisterUserLocal {
@PersistenceContext
private EntityManager entityManager;
public void registerNewUser(String username, String password){
User user = new User();
user.setPassword(password);
user.setUsername(username);
entityManager.persist(user);
entityManager.getTransaction().commit();
}
}
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="SCBCDEntities" transaction-type="RESOURCE_LOCAL">
<provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
<class>examples.persistence.User</class>
<properties>
<property name="eclipselink.target-server" value="WebLogic_10"/>
<property name="eclipselink.jdbc.driver" value="oracle.jdbc.OracleDriver"/>
<property name="eclipselink.jdbc.url" value="jdbc:oracle:thin:@localhost:1521:db4"/>
<property name="eclipselink.jdbc.user" value="SCBCD"/>
<property name="eclipselink.jdbc.password" value="123456"/>
<property name="eclipselink.logging.level" value="FINEST"/>
</properties>
</persistence-unit>
</persistence>
Classe de entidade:
@Entity
@Table(name="USERS")
public class User implements Serializable {
private static final long serialVersionUID = 1L;
@Id
private String username;
private String password;
public User() {
}
public String getUsername() {
return this.username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return this.password;
}
public void setPassword(String password) {
this.password = password;
}
}
Além disso, para responder a respostas a essa pergunta, com o código que listei os logs mostram um comprometimento executando (alguns detalhes removidos para a brevidade)
[EL Finest]: 2010-01-05 22:58:07.468--UnitOfWork(25499586)--Thread(Thread[[ACTIVE] ExecuteThread: '0' for queue: 'weblogic.kernel.
Default (self-tuning)',5,Pooled Threads])--PERSIST operation called on: examples.persistence.User@191ed96.
<Jan 5, 2010 10:58:07 PM EST> <Debug> <JTA2PC> <BEA-000000> <BEA1-001959ECF50B251A451D: [EJB examples.session.stateless.RegisterUs
er.registerNewUser(java.lang.String,java.lang.String)]: ServerTransactionImpl.commit()>
<Jan 5, 2010 10:58:07 PM EST> <Debug> <JTA2PC> <BEA-000000> <BEA1-001959ECF50B251A451D: [EJB examples.session.stateless.RegisterUs
er.registerNewUser(java.lang.String,java.lang.String)]: TX[BEA1-001959ECF50B251A451D] active-->pre_preparing
<Jan 5, 2010 10:58:07 PM EST> <Debug> <JTA2PC> <BEA-000000> <SC[mr_domain+AdminServer] active-->pre-preparing
er.registerNewUser(java.lang.String,java.lang.String)]: TX[BEA1-001959ECF50B251A451D] prepared-->committing
<Jan 5, 2010 10:58:07 PM EST> <Debug> <JTA2PC> <BEA-000000> <SC[mr_domain+AdminServer] pre-prepared-->committed
er.registerNewUser(java.lang.String,java.lang.String)]: TX[BEA1-001959ECF50B251A451D] committing-->committed
...
...
Mas se eu adicionar 'Flush' depois do persistência, eu recebo 'Notransaction' ...
[EL Finest]: 2010-01-05 22:44:55.218--UnitOfWork(113017)--Thread(Thread[[ACTIVE] ExecuteThread: '2' for queue: 'weblogic.kernel.De
fault (self-tuning)',5,Pooled Threads])--PERSIST operation called on: examples.persistence.User@1717dea.
<Jan 5, 2010 10:44:55 PM EST> <Info> <EJB> <BEA-010227> <EJB Exception occurred during invocation from home or business: weblogic.
ejb.container.internal.StatelessEJBLocalHomeImpl@1509b8 threw exception: javax.persistence.TransactionRequiredException:
Exception Description: No transaction is currently active>
<Jan 5, 2010 10:44:55 PM EST> <Debug> <JTA2PC> <BEA-000000> <BEA1-001859ECF50B251A451D: [EJB examples.session.stateless.RegisterUs
er.registerNewUser(java.lang.String,java.lang.String)]: TX[BEA1-001859ECF50B251A451D] active-->rolling back
...
...
Solução
Após muita investigação, incluindo a tentativa de transações gerenciadas por contêineres e gerenciados pelo usuário, parece que o problema é que o tipo de transação é especificado como Resource_local. Nesse caso, as seguintes regras se aplicam:
* You must use the EntityManagerFactory to get an EntityManager
* The resulting EntityManager instance is a PersistenceContext/Cache
* An EntityManagerFactory can be injected via the @PersistenceUnit annotation only (not @PersistenceContext)
* You are not allowed to use @PersistenceContext to refer to a unit of type RESOURCE_LOCAL
* You must use the EntityTransaction API to begin/commit around every call to your EntityManger
* Calling entityManagerFactory.createEntityManager() twice results in two separate EntityManager instances and therefor two separate PersistenceContexts/Caches.
* It is almost never a good idea to have more than one instance of an EntityManager in use (don't create a second one unless you've destroyed the first)
No meu caso, eu precisava usar a fábrica do gerente para acessar o EntityManager e usar uma unidade de persistência em vez de um persistencEContext. O código a seguir funciona muito bem:
@Stateless
@TransactionManagement(TransactionManagementType.CONTAINER)
public class RegisterUser implements RegisterUserLocal {
@PersistenceUnit(unitName = "SCBCDEntities")
private EntityManagerFactory factory;
public void registerNewUser(String username, String password) {
EntityManager entityManager = factory.createEntityManager();
EntityTransaction entityTransaction = entityManager.getTransaction();
entityTransaction.begin();
User user = new User();
user.setPassword(password);
user.setUsername(username);
entityManager.persist(user);
entityTransaction.commit();
}
}
Informações adicionais sobre a configuração de transações e as configurações na persistência.xml podem ser encontradas aqui: http://openejb.apache.org/3.0/jpa-concepts.html
Outras dicas
Você não pode usar o entitytransaction (em.gettransaction ()) porque está usando um gerenciador de entidade gerenciado por contêineres (injetado), portanto, deve confiar no contêiner para transações. Você definiu alguma configuração transacional para o feijão de sessão sem estado em XML? Se você não tiver, ele deve funcionar, pois o padrão deve ser 'necessário'. Você pode tentar anotar 'RegisterNewUser' com @TransactionAttribute (transactionAttributetype.Required)
Como alternativa, você pode criar uma transação do usuário antes de acessar o EM, mas uma transação gerenciada pelo contêiner seria melhor.
Isso pode ser porque você não iniciou uma transação. Tentar:
public void registerNewUser(String username, String password){
entityManager.getTransaction().begin();
User user = new User();
user.setPassword(password);
user.setUsername(username);
entityManager.persist(user);
entityManager.getTransaction().commit();
}
Embora eu prefira não fazer o manuseio de transações dessa maneira. Em vez disso, tendem a usar as transações declarativas da Spring, o que seria assim:
@Transactional
public void registerNewUser(String username, String password){
User user = new User();
user.setPassword(password);
user.setUsername(username);
entityManager.persist(user);
}
quando configurado.
Editar: Outra possibilidade é um problema que já tive com o Eclipselink, onde não estava escrevendo tudo no banco de dados quando eu o estava executando em um ambiente J2SE (um aplicativo de console para carregar alguns arquivos em um banco de dados). Nesse caso eu tive que explicitamente flush()
a EntityManager
Para escrever todos os registros.