База данных не обновляется после совершения()

Question

У меня есть метод, который существует множество строк в базе данных, это что-то вроде этого:

private EntityManager em; 

@PostConstruct 
public void init() { 
    Map props = new HashMap(); 
    props.put(PersistenceUnitProperties.JTA_DATASOURCE, dataSource()); 
    EntityManagerFactory emf = Persistence.createEntityManagerFactory("db1", props); 
    em = emf.createEntityManager(); 
} 

public void persistAll(List list) { 
    int count = 0; 
    for (Object o : list) { 

     if (count == 0) { 
      em.getTransaction().begin(); 
     } 
     em.persist(o); 

     count++; 
     if (count >= 500) { 
      em.getTransaction().commit(); 
      count = 0; 
     } 
    } 
    if (count > 0) { 
     em.getTransaction().commit(); 
    } 
} 

А вот мой persistence.xml:

<?xml version="1.0" encoding="UTF-8"?> 
<persistence version="2.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_2_0.xsd"> 
    <persistence-unit name="db1" transaction-type="JTA"> 
     <jta-data-source>db1</jta-data-source> 
     <mapping-file>orm.xml</mapping-file> 
     <class>com.entities.entity1</class> 
     <class>com.entities.entity2</class> 
     <class>com.entities.entity3</class> 
     <exclude-unlisted-classes>true</exclude-unlisted-classes> 
     <validation-mode>NONE</validation-mode> 
     <properties> 
      <property name="eclipselink.cache.size.default" value="0"/> 
      <property name="eclipselink.cache.shared.default" value="false"/> 
      <property name="eclipselink.logging.level" value="FINE"/> 
     </properties> 
    </persistence-unit> 
</persistence> 

Сделка открывается в начале и фиксируется после сохранения 500 объектов, затем транзакция снова открывается и т. Д. Этот процесс будет повторяться до тех пор, пока все объекты не будут сохранены.

Проблема заключается в том, что объекты сохраняются только в базе данных после обработки всего списка, если я прерываю выполнение, даже если транзакция уже совершена, она ничего не сохраняет.

Кто-нибудь имеет представление о том, что я делаю неправильно?

Answer 1

Вместо фиксации вызовите флеш(); делать что-то вроде

// open the transaction 
// start the loop 
// for each 500 call entityManager.flush(); 
// when the loop finishes, call commit() and finish the entityManagfer