我实现了DTO业务从TomEE到JBoss的迁移。
我有这个实体:
@NamedQueries({
@NamedQuery(name = "common.plagebusiness.plage.getAllPlages", query = "SELECT p FROM Plage p ORDER BY p.plageRgMax, p.plageCReseau") })
@Entity
@Table(name = "PLAGE")
public class Plage {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "idPlage")
private Integer idPlage;
@Column(name = "rgMin")
private String plageRgMin;
使用此接口:
@Local
public interface PlagePersistenceManager {
public void importPlages(List<DetailFH55> listeEnregDetail) throws PlageBusinessException, ParseException;
}
和实施:
@Stateless(name = "common.plagebusiness.PlagePersistenceManager")
public class PlagePersistenceManagerImpl implements PlagePersistenceManager {
private static final Logger LOGGER = Logger.getLogger(PlagePersistenceManager.class);
@PersistenceContext(unitName = "PlageBusiness")
private EntityManager em;
@Override
public void importPlages(final List<DetailFH55> listeEnregDetail) throws PlageBusinessException, ParseException {
LOGGER.debug("Entree dans importPlages");
if (null != listeEnregDetail) {
LOGGER.info("Debut Delete");
// suppression des plages
this.deleteAllPlages();
LOGGER.info("Fin Delete et Debut Insertion en bdd");
for (final DetailFH55 myEnreg : listeEnregDetail) {
// insertion des nouvelles plages
final Plage plage = this.convertEnregDetailToPersist(myEnreg);
this.em.persist(plage);
}
LOGGER.info("Fin Insertion en bdd");
}
LOGGER.debug("Sortie dans importPlages");
}
}
不幸的是, em.persist 不起作用,我有这个例外:
Caused by: javax.transaction.RollbackException: JBAS014585: Transaction 'TransactionImple < ac, BasicAction: 0:ffff0a48268b:4bc8a0e:56f01b76:18 status: ActionStatus.ABORTED >' was already rolled back
我在论坛上看到这是因为Jboss超时。我不想改变 Jboss 的配置,所以我尝试输入,
@org.jboss.annotation.ejb.TransactionTimeout(10000000)
public void importPlages(final List<DetailFH55> listeEnregDetail) throws PlageBusinessException, ParseException
仍然是同样的异常...这段代码有什么问题。
方法deleteAllPlages包含:
@Override
public int deleteAllPlages() throws PlageBusinessException {
final Query query = this.em.createNativeQuery("DELETE FROM `PLAGE`");
return query.executeUpdate();
}
我尝试在 persist(plage) 之后放置一个lush()和clear(),但仍然出现相同的异常。
final Plage plage = this.convertEnregDetailToPersist(myEnreg);
this.em.persist(plage);
this.em.flush();
this.em.clear();
Thxs.