Begehen während der Transaktion in der @Transactional

Ist das möglich, das eine commit-Methode, die markiert ist wie der Frühling ist @Transactional?

@PersistenceContext
private EntityManager em;

@Transactional(propagation = Propagation.REQUIRED)
public void saveMembersWithMultipleCommits(List<Member> members)
    throws HibernateException
{
    Iterator<Member> it = members.iterator();
    while (it.hasNext())
    {
        while (it.hasNext())
        {
            Member wsBean = it.next();
            em.persist(wsBean); //overall commit will be made after method exit
            log.info("Webservices record " + wsBean + " saved. " + i++);
        }
    }
}

Ich würde gerne verpflichten, die DB nach sagen, jeder 500 Positionen. Ist das möglich mit oben genannten Kontext?

InformationsquelleAutor Michael Z | 2012-10-15

  1. 5

    Nein, Sie müssen es tun, programmgesteuert verwenden, zum Beispiel, die TransactionTemplate API. Lesen Sie mehr hier.

    Sähe es so etwas wie

    while (it.hasNext())
{
    transactionTemplate.execute(new TransactionCallbackWithoutResult() {
        protected void doInTransactionWithoutResult(TransactionStatus status) {
            int counter = 0;
            while (it.hasNext() && counter++ < 500) {
                Member wsBean = it.next();
                em.persist(wsBean);
                log.info("Webservices record " + wsBean + " saved. " + i++);
            }
        }
    );
}
    Ich muss also eine neue Verbindung zur DB für jeden Rückruf?
    Nein, nur eine neue Transaktion.

    InformationsquelleAutor pap

  2. 5

    Deine Frage deutet darauf hin, dass Sie verlegt haben, Ihre Transaktion-Grenze.

    Können Sie die persist Aufruf in eine private Methode und stellen die Methode Transaktions-statt der äußeren. Diese Methode akzeptieren konnten 500 Mitglieder zu einer Zeit, und dann Begehen wird, wenn er sich beendet.

    Erfordert load-time-oder compile-time-weaving, funktioniert nicht mit Federn "standard" proxy-basierte Weben.
    Ja, das ist wahr.

    InformationsquelleAutor Alex Barnes

  3. 1

    Wenn Sie auf der Suche nach vorn zu Begehen Transaktionen in Ihrem anderen Transaktion, die Sie möglicherweise verwenden müssen @Transactional (propagation = Propagation.REQUIRES_NEW)

    Muss ich die neue Verbindung zur DB geöffnet werden, für die zweite @Transactional method invocation oder wird es die gleiche Verbindung?
    Dies ist eine völlig getrennte transaction aber die Verbindung ist die gleiche. Prüfen Sie es für sich selbst. Ich könnte einen Fehler gemacht zu haben.

    InformationsquelleAutor Matin Kh

  4. -1

    Alternative Strategie erstellen Sie eine Methode in DAO und Marke it @Transactional. Diese Methode wird tun, bulk-update(für zB 500 nos). So können Sie eine Methode mit code

    @Transactional

public void mybatchUpdateMethod(){

    StatelessSession session = this.hibernateTemplate.getSessionFactory()
            .openStatelessSession();

    Transaction transaction = null;

    Long entryCounter = 0L;

    PreparedStatement batchUpdate = null;
    try {
        transaction = session.beginTransaction();
        batchUpdate = session.connection().prepareStatement(insertSql);

        for (BatchSnapshotEntry entry : entries) {
            entry.addEntry(batchUpdate);
            batchUpdate.addBatch();

            if (++entryCounter == 500) {
                //Reached limit for uncommitted entries, so commit
                batchUpdate.executeBatch();
            }
        }

        batchUpdate.executeBatch();
        batchUpdate.close();
        batchUpdate = null;
    }
    catch (HibernateException ex) {
        transaction.rollback();
        transaction = null;
    }
}

    Jedes mal, wenn Sie diese Methode aufrufen, es zu Begehen, nach 500 inserts/updates

    Und was ist hibernateTemplate hier? Welche Klasse?
    Sorry. sollte das geklärt haben. Ich gebe Beispiel von spring mit hibernate und mit hibernateTemplate. Sie sind mit EntityManager, die mit JPA und verwenden können. Sie können dies tun, Session session = entityManager.unwrap(Session.class); Die Sitzung ist hibernate-session

    InformationsquelleAutor vsingh

Schreibe einen Kommentar