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

Question

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

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，还有别的吗？

提前谢谢您!

Answer 1

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

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

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