I am new to to Hibernate and JPA and trying some examples for an evaluation of JPA in a larger project. So the question might be very basic for you but I'ld apreciate some help.
In a transactional method of a session bean I read an Entity and change it. Hibernate is only updating the DB when I'am explicitely calling flush.
I thougt that with JPA end EJB 3 CMT the DB update is done automatically on commit without that I am calling any method to indicate so, also not flush. Am I wrong? If yes what would be a correct way to do it?
<?xml version="1.0"?>
<persistence 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"
version="1.0">
<!-- TODO switch to DataSource -->
<persistence-unit name="MedRec" transaction-type="JTA">
<provider>org.hibernate.ejb.HibernatePersistence</provider>
<jta-data-source>jdbc/MedRecGlobalDataSourceXA</jta-data-source>
<class>com.bea.medrec.model.Address</class>
<class>com.bea.medrec.model.Administrator</class>
<class>com.bea.medrec.model.BaseEntity</class>
<class>com.bea.medrec.model.PersonName</class>
<class>com.bea.medrec.model.Patient</class>
<class>com.bea.medrec.model.Physician</class>
<class>com.bea.medrec.model.Prescription</class>
<class>com.bea.medrec.model.Record</class>
<class>com.bea.medrec.model.RegularUser</class>
<class>com.bea.medrec.model.User</class>
<class>com.bea.medrec.model.VersionedEntity</class>
<class>com.bea.medrec.model.VitalSigns</class>
<properties>
<!-- SQL stdout logging -->
<property name="hibernate.show_sql" value="true"/>
<property name="hibernate.format_sql" value="true"/>
<property name="use_sql_comments" value="true"/>
<!-- to prevent the ClassDefNotFound problem with weblogic -->
<property name="hibernate.query.factory_class" value="org.hibernate.hql.classic.ClassicQueryTranslatorFactory"/>
<property name="hibernate.c3p0.min_size" value="5"/>
<property name="hibernate.c3p0.max_size" value="20"/>
<property name="hibernate.c3p0.timeout" value="300"/>
<property name="hibernate.c3p0.max_statements" value="50"/>
<property name="hibernate.c3p0.idle_test_period" value="3000"/>
<property name="hibernate.transaction.manager_lookup_class" value="org.hibernate.transaction.WeblogicTransactionManagerLookup"/>
<property name="hibernate.transaction.factory_class" value="org.hibernate.transaction.CMTTransactionFactory"/>
<property name="hibernate.dialect" value="org.hibernate.dialect.PointbaseDialect"/>
</properties>
</persistence-unit>
</persistence>
package com.bea.medrec.repository.impl;
import java.util.List;
import javax.ejb.Remote;
import javax.ejb.Stateless;
import javax.ejb.TransactionAttribute;
import javax.ejb.TransactionAttributeType;
import javax.persistence.EntityManager;
import javax.persistence.NoResultException;
import javax.persistence.PersistenceContext;
import javax.persistence.Query;
import com.bea.medrec.model.Patient;
import com.bea.medrec.repository.PatientRepository;
/**
* @author Copyright (c) 2007 by BEA Systems. All Rights Reserved.
* @author <a href="mailto:shli@bea.com">Li Shen</a>
*/
@Stateless
@Remote(PatientRepository.class)
public class PatientRepositoryImpl implements PatientRepository {
// TODO customize persistence unit?
@PersistenceContext(name = "MedRec")
private EntityManager entityManager;
protected int countByProperties(String namedQuery, Property... properties) {
return countByProperties(namedQuery, properties);
}
public int countBySsn(String ssn) {
String query = "Patient.countPatientBySsn";
return countByProperties(query, new Property("ssn", ssn));
}
public int countBySsnAndId(String ssn, Long id) {
String query = "Patient.countPatientBySsnAndId";
return countByProperties(query, new Property("ssn", ssn), new Property("id", id));
}
public int countByUsername(String username) {
return countByProperties(getQueryForCountByUsername(), new Property("username", username));
}
public int countByUsernameAndPassword(String username, String password) {
return countByProperties("Patient.countPatientByUsernameAndPassword", new Property("username", username),
new Property("password", password));
}
public int countByUsernameAndPasswordAndStatus(String username, String password, Patient.Status status) {
String query = "Patient.countPatientByUsernameAndPasswordAndStatus";
return countByProperties(query, new Property("username", username), new Property("password", password),
new Property("status", status.toString()));
}
private Query createNamedQuery(String namedQuery, Property... propertyValues) {
Query query = getEntityManager().createNamedQuery(namedQuery);
int i = 1;
for (Object propertyValue : propertyValues) {
Property property = (Property) propertyValue;
query.setParameter(property.name, property.value);
i++;
}
return query;
}
@TransactionAttribute(TransactionAttributeType.REQUIRED)
public void delete(Long id) {
// TODO maybe use a query instead
entityManager.remove(find(id));
}
public Patient find(Long id) {
return entityManager.find(Patient.class, id);
}
public List<Patient> findByLastNameAndStatus(String lastName, Patient.Status status) {
String query = "Patient.findPatientByLastNameAndStatus";
return findByProperties(query, new Property("lastName", lastName),
new Property("status", status.toString()));
}
protected List<Patient> findByProperties(String namedQuery, Property... properties) {
return createNamedQuery(namedQuery, properties).getResultList();
}
public Patient findBySsnAndStatus(String ssn, Patient.Status status) {
String query = "Patient.findPatientBySsnAndStatus";
return findByUniqueProperties(query, new Property("ssn", ssn), new Property("status", status.toString()));
}
public List<Patient> findByStatus(Patient.Status status) {
return createNamedQuery("Patient.findPatientByStatus", new Property("status", status.toString()))
.getResultList();
}
protected Patient findByUniqueProperties(String namedQuery, Property... properties) {
try {
return (Patient) createNamedQuery(namedQuery, properties).getSingleResult();
}
catch (NoResultException e) {
return null;
}
}
protected Patient findByUniqueProperty(String namedQuery, String propertyName, Object propertyValue) {
return findByUniqueProperties(namedQuery, new Property(propertyName, propertyValue));
}
public Patient findByUsernameAndPassword(String username, String password) {
return findByUniqueProperties("Patient.findPatientByUsernameAndPassword",
new Property("username", username), new Property("password", password));
}
public Patient findByUsernameAndPasswordAndStatus(String username, String password, Patient.Status status) {
String query = "Patient.findPatientByUsernameAndPasswordAndStatus";
return findByUniqueProperties(query, new Property("username", username),
new Property("password", password), new Property("status", status.toString()));
}
protected EntityManager getEntityManager() {
return entityManager;
}
protected String getQueryForCountByUsername() {
return "Patient.countPatientByUsername";
}
@TransactionAttribute(TransactionAttributeType.REQUIRED)
public void save(Patient entity) {
entityManager.persist(entity);
}
public void setEntityManager(EntityManager entityManager) {
this.entityManager = entityManager;
}
@TransactionAttribute(TransactionAttributeType.REQUIRED)
public Patient update(Patient entity) {
Patient retVal = entityManager.merge(entity);
//entityManager.flush();
return retVal;
}
class Property {
public String name;
public Object value;
public Property(String name, Object value) {
this.name = name;
this.value = value;
}
}
}
Login
FAQ
Search
