InsertP.java 文件源码

@Override
public List<CitizenDB> insert(List<CitizenDB> citizens) throws SQLException {
    EntityManager em = Jpa.createEntityManager();
    EntityTransaction trx = em.getTransaction();
    trx.begin();
    List<CitizenDB> users = new ArrayList<CitizenDB>();
    try{

        for(CitizenDB citizen : citizens)
            if(checkCitizen.checkCitizenInformation(citizen) && checkCitizen(citizen)){
                citizen.setPassword(generationPassword.passwordGenerator());
                Jpa.getManager().persist(citizen);
                users.add(citizen);
            }

    trx.commit();       
    }catch(RuntimeException e){
        trx.rollback();
        throw e;
    }
    finally{
        em.close();
    }
    return users;
}