时间戳

首页 > 解决方案 > JPA在多个事务中插入行，限制单个事务中的最大行数

java - JPA在多个事务中插入行，限制单个事务中的最大行数

问题描述

我想在单独的事务中插入每 1000 行。因此，如果有 3000 行，则应将其插入 3 个不同的事务中。我不使用弹簧。

import com.company.UserDAO;
import javax.inject.Inject;
import javax.transaction.Transactional;

public class Round{

    UserDAO userDao;

    @Inject 
    public Round(UserDAO userDao){
        this.userDao = userDao;
    }


    @Transactional
    @Scheduled(every = "10s")
    void schedule() {

        Synchronization synchronization = new Synchronization();
        synchronization.setUserDAO( userDao );

        synchronization.synchronize();
    }

}


public class Synchronization{

    UserDAO userDao;


    public void synchronize(){

        List<User> newUsers = Arrays.asList( new User(a1), new User(a2), ..., new User(a170.000);

        for( User user : newUsers){
            saveCreate( user )
        }

    }

    saveCreate(User user){
        userDao.create(user);
        // which is calling somewhere the: getEntityManager().persist(entity);
    }
}

如何为每 1000 行创建新事务？

1、每1000行刷新清除entityManager。它会创建一个新的交易吗？

int i = 0;
for( User user : newUsers){
saveCreate( user )
i++;

    if( i % 1000 == 0 ){
        userDao.getEntityManager.flush();
        userDao.getEntityManager.clear();
    }
}

2，使 saveCreate 方法 @Transactional ，而不是 schedule() ？

3，创建新类，使用@Transactional注释的新方法，并从中创建新实例，当有超过1000行时？

Transaction tr = new Transaction;
int i = 0;
for( User user : newUsers){
    i++;
    tr.singleTransaction( user );
    if( i % 1000 == 0 ){
        tr = = new Transaction;
    }
}

public class Transaction{

    @Transactional
    public void singleTransaction( User user){
        saveCreate( user );
    }
}

4、还有什么？

先感谢您！

标签： javahibernatejpatransactionsjpa-2.0

解决方案

编写一个插入 1000 条记录的方法并将其标记为 @Transactional(propagation = Propagation.REQUIRES_NEW)

@Transactional(propagation = Propagation.REQUIRES_NEW)
public void saveData(List<Object> data)..

然后，多次调用该方法，每当调用该方法时，都会创建新的事务。

推荐阅读