Discussion :

[sam69]

Bonjour,

J’ai crée une application qui gère la persistance avec JPA. J’ai géré facilement la sauvegarde à la demande (action save -> model enregistré en base).

Par contre, j’ai certaines Entity qui sont critiques, et qui ont besoin d’être sauvegardé en continue (toujours synchro avec la base).


Après quelques recherches, j’ai vu que l'on pouvait jouer sur la propriété EXTENDED du persistence context. Mais apparemment, l'entity manager doit être stocké dans un Stateful session bean.
Donc il faudrait que je construise un DAO comme ceci ?

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
 
@Stateful //Auparavant, mon DAO était Stateless
public class JPADAO {
 
	@PersistenceContext(type = PersistenceContextType.EXTENDED, name = ATMprojectV2Bean.ATMPROJECT_V2)
	private EntityManager emExtended;
...
}

Et c’est tout ? Toute mes Entity qui seront gérés par cet Entity Manager seront automatiquement sauvegardé en base à chaque commit de la transaction courante ?

Quelqu’un a un avis sur la façon de faire ?

Merci d’avance,

Samuel

[denisjava]

Bonjour,

Par contre, j’ai certaines Entity qui sont critiques, et qui ont besoin d’être sauvegardé en continue (toujours synchro avec la base).

Il n'y a aucun moyen de t'assurer que les données d'un entitée sont synchro avec les données de la base. le PC Extended ne t'aidera pas pour cela...

La seule chose que tu puisse faire est de limiter les risques de violations de l'intégrité des données en utilisant les verrou optimistes (@Version) cela te permet de vérifier qu'au moment de la sauvegarde les modifications sur une entité, les données de cet enregistrement n'ont pas été modifié depuis leur lecture (et donc que tu es toujours à jour).

Tu peux toujours rafraîchir une entité avec em.refresh(o); mais rien ne te permet d'affirmer que 2millième de secondes plus tard, l'enrigisrement n'a pas été modifié.... donc le refresh limite seuelemnt le pb

Après quelques recherches, j’ai vu que l'on pouvait jouer sur la propriété EXTENDED du persistence context. Mais apparemment, l'entity manager doit être stocké dans un Stateful session bean.
Donc il faudrait que je construise un DAO comme ceci ?

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
 
@Stateful //Auparavant, mon DAO était Stateless
public class JPADAO {
 
	@PersistenceContext(type = PersistenceContextType.EXTENDED, name = ATMprojectV2Bean.ATMPROJECT_V2)
	private EntityManager emExtended;
...
}

Et c’est tout ? Toute mes Entity qui seront gérés par cet Entity Manager seront automatiquement sauvegardé en base à chaque commit de la transaction courante ?

Quelqu’un a un avis sur la façon de faire ?

Merci d’avance,

Samuel

[sam69]

Merci denisjava pour ta réponse.

En fait il n'y a que moi qui modifie la base. C'est juste une histoire de sauvegarde en continue pour permettre de redémarrer le server après une panne, et de retrouver les dernières données enregistrés.
Donc je ne pense pas qu'il y a besoin de verrou optimistes.

J'ai simplement besoin que mes Entity soit sauvegardés automatiquement (sans appeller em.persist(myEntity) ) à chaque fin de transaction (JTA).

[sam69]

J'ai fait un petit programme de test pour vérifier le fonctionnement des EXTENDED PersistenceContext, mais cela ne tient pas ses promesses.
Lorsque je suis dans une autre transaction, les Entity managés par l'EntityManagerExtended ne sont pas sauvegardés en base automatiquement.

J'aimerais que mes Entity soit sauvegardées automatiquement dès lors qu'elles sont modifiées à l'interieur de n'importe quelle transaction pouvant être en dehors du DAO.
Je n'arrive pas à trouver des infos claires, et j'ai l'impression que mes besoins sortent un peu des fonctionnalités JEE

Voici mon code de test, si quelqu'un a des suggestions...

Mon statefull session bean qui fait office de DAO et qui contient extended EntityManager:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
 
@Remote({ SimpleJPADAOBeanInterface.class })
@RemoteBinding(jndiBinding = "JPADAO")
@Stateful
@TransactionManagement(TransactionManagementType.CONTAINER)
public class SimpleJPADAOBean implements SimpleJPADAOBeanInterface{
 
	@PersistenceContext(type = PersistenceContextType.EXTENDED, unitName = "testJPA2")
	private EntityManager emExtended;
 
	private MyEntity myEntity;
 
	public SimpleJPADAOBean() {
		super();
	}
	public void createEntity() {
 
		myEntity = new MyEntity();
	}
	public void persistEntity() {
		emExtended.persist(myEntity);
	}
	public void updateEntity() {
		myEntity.setStr(myEntity.getStr() + "_updated");
	}
	public MyEntity getEntity() {
		return myEntity;
	}
}

Et mon stateless qui fait office de client webservice pour tester le DAO:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
 
@Stateless
@Remote( { SimpleFronBeantStatelessInterface.class })
@WebService(serviceName = "testJPA2", targetNamespace = "http://service."+ "testJPA2" + "/jaws")
@WebContext(contextRoot = "testJPA2", urlPattern = "/" + "testJPA2")
public class SimpleFrontBeanStateless implements SimpleFronBeantStatelessInterface{
	public SimpleFrontBeanStateless() {
 
	}
	@WebMethod
	public void startTest() {
		try {
			SimpleJPADAOBeanInterface dao = SimpleDAOManager.getInstance().getDao();
			dao.createEntity();
			dao.persistEntity();
//			dao.updateEntity();
		} catch(Exception e) {
			e.printStackTrace();
		}
	}
 
	@WebMethod
	@TransactionAttribute(TransactionAttributeType.REQUIRED)
	public void update() {
		SimpleJPADAOBeanInterface dao = SimpleDAOManager.getInstance().getDao();
		MyEntity entity = dao.getEntity();
		entity.setStr(entity.getStr() + "_updated");
	}
}

Lors de l'appel d'update, l'Entity managés avec un context étendu n'est pas mis à jour, et pourtant, on est dans une transaction (@TransactionAttribute)

Merci d'avance pour votre aide !

[denisjava]

Avant toute chose je ne sais pas si l'injection de 2 PC (un de type trasncation et de type etendue) est quelques chose qui est sensé (ou en tout cas, la spec ne mentionne rien à ce sujet à ma connaissance). Aussi, afin d'éviter les effets de bord, je t'invite à n'injecter qu'un seul PC dans ton staful.

tu peux montrer le code de ton DAOManager stp ?

[sam69]

Je viens de simplifier l'exemple (edit), avec qu'un entityManager.

Voici le code de mon DAOMAnager, qui n'est q'un singleton stockant le DAO:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
 
public class SimpleDAOManager {
 
	private SimpleJPADAOBeanInterface dao;
 
	private static SimpleDAOManager instance;
 
	public synchronized static SimpleDAOManager getInstance() {
		if (instance == null) {
			instance = new SimpleDAOManager();
		}
		return instance;
	}
 
	protected SimpleDAOManager() {
		try {
			Context ctx = new InitialContext();
			Object lookupObject = ctx.lookup("JPADAO");
			dao = (SimpleJPADAOBeanInterface)lookupObject;
		} catch (NamingException e) {
			e.printStackTrace();
		}
 
	}
 
	public SimpleJPADAOBeanInterface getDao() {
		return dao;
	}
 
	public void setDao(SimpleJPADAOBeanInterface dao) {
		this.dao = dao;
	}
}