Création d'un entity Manager pour transaction

Version imprimable

Bonjour,
je développe une appli EJB3.

Jusqu'a présent j'utilisais pour mon contexte :
Code:

1 2 3 4 5 6 @Stateful public class PassengerManagerBean implements PassengerManagerRemote { @PersistenceContext EntityManager manager; ...
Et tout fonctionnait tres bien, pas de probleme pour gerer les bases de donnée et persistence.
Maintenant je veux compliquer un peu et ajouter des transanctions et c'est la que ca bloque.

J'ai tenté plusieurs configurations de persistence mais a chaque fois je rencontre une erreur. Voila mon code :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 @Stateful public class PassengerManagerBean implements PassengerManagerRemote { // @PersistenceContext // EntityManager manager; // EntityTransaction transact = manager.getTransaction(); @PersistenceUnit(unitName="Airlines-ejbPU") private EntityManagerFactory factory ; private EntityManager manager; private EntityTransaction transact; ..... public PassengerManagerBean() { factory =Persistence.createEntityManagerFactory("Airlines-ejbPU"); manager = factory.createEntityManager( ); transact = manager.getTransaction( ); } ... public void persist_passenger(){ passenger.setAddress(address); passenger.setPhone(ListNumber); manager.persist(passenger); ... }
Comme vous pouvez le voir, je gere pas encore les transactions car mon manager n'arrive plus a persister dans la base l'erreur étant :
Code:

1 2 3 4 5 Caused by: java.lang.IllegalArgumentException: Object: airlines.entity.Passenger@1f566bc is not a known entity type. at oracle.toplink.essentials.internal.sessions.UnitOfWorkImpl.registerNewObjectForPersist(UnitOfWorkImpl.java:3178) at oracle.toplink.essentials.internal.ejb.cmp3.base.EntityManagerImpl.persist(EntityManagerImpl.java:170) at airlines.bean.PassengerManagerBean.persist_passenger(PassengerManagerBean.java:87)
la ligne 87 est celle ou il y a "manager.persist(passenger);"

Il s'agit en fait du premier persist que je fais sur mon manager.

je suis donc a la recherche de quelques explications sur la gestion de mon manager et comment faire pour le créer correctement et qu'il puisse gérer des transactions.

Merci

Tu n'as pas besoin de spécifier un manager de transaction tu dois simplement utiliser l'annotation @TransactionAttribute au niveau de ta classe
ou au niveau de ta méthode

tu peux choisir entre les différents type d'attribut (si tu regardes la classe)
Code:

1 2 3 4 5 6 7 8 9 public enum TransactionAttributeType { MANDATORY, REQUIRED, REQUIRES_NEW, SUPPORTS, NOT_SUPPORTED, NEVER }
Dans ton context je placerais donc chacune des méthodes nécessitant d'être transactionel par
Code:

1 2 3 4 5 6 @TransactionAttribute(TransactionAttributeType.REQUIRES_NEW) public void persist_passenger(){ passenger.setAddress(address); passenger.setPhone(ListNumber); manager.persist(passenger);
Requires_new va créer une transaction indépendante pour chaque appel, ce qui je pense est le plus adapté

Hello,

merci de ta réponse et désolé de ce retard, mais beaucoup de taff sur de nombreux projets.

Avec cette annotation, je n'ai donc pas besoin de placer de commit ou de rollback. Mais cela veut dire que ma fonction va faire le rollback si elle passe dans une exception?? Comment une simple annotation fait tourner ma transaction?

Voici le code d'une de mes fonctions :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
@TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
    public boolean remove_passenger(int id){
 
        Passenger pass; 
        boolean result=false;
 
        try
        {
            Query q = manager.createQuery("SELECT p FROM Passenger AS p WHERE p.id=:id");
            q.setParameter("id", id);
            pass = (Passenger)q.getSingleResult(); 
 
            Collection<PhoneNumber> phone=pass.getPhone();
 
            manager.remove(pass);
            manager.flush();
 
            Iterator it = phone.iterator();
            while (it.hasNext())
            {
                 PhoneNumber ph = new PhoneNumber();
                 ph=(PhoneNumber) it.next();
 
                 manager.remove(ph);                   
            }
            manager.flush();
 
            result=true;                 
        }
        catch(Exception e){
            System.out.println(e.toString());
            result=false;
        }
        finally
        {
            return result;
        }
 
    }

Est ce que si il y a un probleme lors de la suppression d'un des numéros de telephone (boucle while), la suppression de mon passager ainsi que des numeros précédents sera annulée??

Merci de vos précisions.

Bizet

23/02/2007, 08h24
*alexandre*

Oui. Vu que c'est l'ensemble de ta méthode qui est placé dans un context transactionel.

Petite précision concernant l'attribut require_new, si dans ton appel de remove_passenger tu es déjà dans un context transactionel une nouvelle transaction est créer séparément du context initial de ton appel (le rollback ici ne se fera que sur les opération faite dans remove_passenger)

Si tu choisis REQUIRED à la place de REQUIRED_NEW alors ton appel à remove_passenger fait partie de la transaction initial (de ton appellant)
23/02/2007, 08h58
bizet

Ok, merci beaucoup de tes précisions et bon coruage pour la recherche de taff :D