Discussion :

[thefutureisnow]

Salut,

Je bosse sur une appli sous eclipse qui utilise tomcat et hibernate, j'ai nécessité de la modifier pour configurer dynamiquement la classe : HibernateSessionFactory.java avec une variable de session (qui dépend du login de l'utilisateur)

Celle ci est récupérable dans le code d'une jsp via cette variable :
#{sessionScope.utilisateur.datasource}

J'aimerais savoir comment récupérer cette variable dans cette classe.

Si un maitre java pouvait éclairer ma petite lanterne, ca serait génial!

Par avance merci !

[aragon]

Hello,

Pourrais-tu fournir plus de détails sur ton application: les technos utilisées, l'architecture, les différentes couches...

Sans ça... je ne peux pas t'aider.

A plus

[thefutureisnow]

Salut,

Merci de ta réponse, en faite c'est un projet utilisant donc hibernate et richfaces.
L'application fonctionne avec un logging d'une personne sr une base principale, quand l'utilisateur se logue l'appli extrait plusieurs champs dont un champs "datasource", ces informations sont ensuite stockés en session.

Mon objectif est de reconfigurer hibernate à chaque fois qu'un utilisateur se logue. J'ai eu l'idée de faire une classe listener de session qui à la création de la variable session "utilisateur" modifis la configuration hibernate et à la destruction de la session la sessionfactory de hibernate.

Sauf que c'est assez instable...
Je me pose donc la question de savoir si en utilisant plusieurs sessionfactory (1 par datasource) ca ne serait pas mieux ?

Je sais pas si j'ai été clair sur le topo ! Je dois avouer que je nage un peu dans le flou... :/

[tchize_]

si ce sont des bases différentes, effectivement, il vaux mieux une sessionfactory par utilisateur. Pour récupérer ton information, les infos disponibles dépendront d'à quel endroit dans ton code tu te trouve. Par exemple, si t'es dans une bean JSF, le mieux est de passer par une managed-property dans ton faces-config.xml. Si t'est dans un filtre servlet, ou dans une servlet, le mieux est de passer par l'objet HttpSession qui y est disponible.

[thefutureisnow]

Merci de tes éclaircissements,

En faite, par exemple, j'ai une classe bean de cette structure :

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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
package lims.jsf.service;
 
import java.util.Collection;
import java.util.List;
import lims.jsf.filtre.FiltreProduit;
import lims.jsf.hibernate.HibernateSessionFactory;
import lims.jsf.model.Fournisseur;
import lims.jsf.model.Produit;
import org.hibernate.Criteria;
import org.hibernate.SQLQuery;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.hibernate.criterion.Expression;
import org.hibernate.criterion.Restrictions;
 
 
public class SrvProduit {
 
	public List<Produit> list(FiltreProduit filtre) {
 
		Session session = HibernateSessionFactory.getSession();
		Transaction tr = session.beginTransaction();
 
		Criteria cr = session.createCriteria(Produit.class);
		if (filtre.getLib() != null && !"".equals(filtre.getLib())) {
			cr.add(Restrictions.like("libelle", filtre.getLib() + '%'));
		}
		if (filtre.getSecteur() != null && !"".equals(filtre.getSecteur())) {
			cr.createCriteria("secteur").add(Restrictions.like("libelle", filtre.getSecteur() + '%'));
		}
		if (filtre.getSsecteur() != null && !"".equals(filtre.getSsecteur())) {
			cr.createCriteria("soussecteur").add(Restrictions.like("libelle", filtre.getSsecteur() + '%'));
		}
		if (filtre.getFournisseur() != null && !"".equals(filtre.getFournisseur())) {
			cr.createCriteria("fournisseur").add(Restrictions.like("libelle", filtre.getFournisseur() + '%'));
		}
 
		List<Produit> res = cr.list();
 
		tr.commit();
 
		return res;
 
	}
 
 
	public Collection<Produit> list() {
		Session session = HibernateSessionFactory.getSession();
		//session.clear();
		Transaction tr = session.beginTransaction();
		Criteria cr = session.createCriteria(Produit.class);
		List<Produit> res = cr.list();
		tr.commit();
		session.close();
		return res;
 
	}
 
 
	public Collection<Produit> listPF(Fournisseur fournisseur) {
		Session session = HibernateSessionFactory.getSession();
		Transaction tr = session.beginTransaction();
		Criteria cr = session.createCriteria(Produit.class);
		cr.add(Expression.eq("fournisseur", fournisseur));
 
		Collection<Produit> res = cr.list();
		tr.commit();
		return res;
	}
 
 
	public void supprimer(Produit produit) {
		Session session = HibernateSessionFactory.getSession();
		Transaction tr = session.beginTransaction();
		session.delete(produit);
		tr.commit();
 
	}
 
 
	public Produit retourner(Long id) {
		Session session = HibernateSessionFactory.getSession();
		Transaction tr = session.beginTransaction();
		Produit produit = (Produit) session.get(Produit.class, id);
 
		tr.commit();
 
		return produit;
	}
 
 
	public List<Fournisseur> list(String produit) {
		Session session = HibernateSessionFactory.getSession();
		Transaction tr = session.beginTransaction();
		SQLQuery query = session.createSQLQuery("selected * from produit where libelle=" + produit).addEntity(Produit.class);
 
		List res = ((Criteria) query).list();
		tr.commit();
		return res;
	}
 
 
	public void add(Produit prod) {
 
		Session session = HibernateSessionFactory.getSession();
		session.clear();
		Transaction tr = session.beginTransaction();
 
		session.save(prod);
		tr.commit();
	}
 
 
	public void update(Produit produit) {
		Session session = HibernateSessionFactory.getSession();
		Transaction tr = session.beginTransaction();
		session.update(produit);
		tr.commit();
	}
 
 
	public List<Produit> ListProduitFournisseur(Fournisseur fournisseur) {
		Session session = HibernateSessionFactory.getSession();
		Transaction tr = session.beginTransaction();
		Criteria cr = session.createCriteria(Produit.class);
		cr.add(Expression.eq("fournisseur", fournisseur));
		List<Produit> res = cr.list();
		tr.commit();
		return res;
	}
}

Ce bean appel la classe HibernateSessionFactory.java pour récupérer les données, c'est pour l'instant dans cette classe que j'ai modifié comme ceci :

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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
package lims.jsf.hibernate;
 
import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.hibernate.cfg.Configuration;
 
 
public class HibernateSessionFactory {
 
	private static String CONFIG_FILE_LOCATION = "/hibernate.cfg.xml";
	private static final ThreadLocal<Session> threadLocal = new ThreadLocal<Session>();
	private static Configuration configuration = new Configuration();
	private static org.hibernate.SessionFactory sessionFactory;
	private static String configFile = CONFIG_FILE_LOCATION;
	private static String dsource = "";
 
 
	private HibernateSessionFactory() {
 
	}
 
 
	public static Session getSession() throws HibernateException {
 
		Session session = (Session) threadLocal.get();
		if (session == null || !session.isOpen()) {
			if (sessionFactory == null) {
				//MODIF A VERIFIER
				System.out.println("########## REBUILD : " + dsource);
				rebuildSessionFactory(dsource);
			}
			session = (sessionFactory != null) ? sessionFactory.openSession() : null;
			threadLocal.set(session);
		}
 
		return session;
 
	}
 
 
	public static void rebuildSessionFactory(String datasource) {
 
		dsource = datasource;
 
		System.out.println("### CONFIG HIBERNATE AVEC DATASOURCE : " + dsource);
 
		try {
			configuration = new Configuration();
			configuration.configure(configFile);
 
			//reconfiguration du datasource en fonction de l'utilisateur
			configuration.setProperty("hibernate.connection.datasource", "java:comp/env/" + dsource);
 
			sessionFactory = configuration.buildSessionFactory();
 
		} catch (Exception e) {
			System.err.println("%%%% Error Creating SessionFactory %%%%");
			e.printStackTrace();
		}
	}
 
 
	public static void closeSession() throws HibernateException {
 
		Session session = (Session) threadLocal.get();
		threadLocal.set(null);
 
		if (session != null) {
			session.close();
			System.out.println("FERMETURE SESSION HIBERNATE");
		}
	}
 
 
	public static org.hibernate.SessionFactory getSessionFactory() {
 
		return sessionFactory;
	}
 
 
	public static void setConfigFile(String configFile) {
 
		HibernateSessionFactory.configFile = configFile;
		sessionFactory = null;
	}
 
 
	public static Configuration getConfiguration() {
 
		return configuration;
	}
 
}

Et enfin ma classe SessionListener :

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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
package lims.jsf.hibernate;
 
import java.util.HashMap;
import java.util.Iterator;
import javax.servlet.ServletContext;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.http.HttpSession;
import javax.servlet.http.HttpSessionAttributeListener;
import javax.servlet.http.HttpSessionBindingEvent;
import javax.servlet.http.HttpSessionEvent;
import javax.servlet.http.HttpSessionListener;
 
 
public class SessionListener implements ServletContextListener, HttpSessionAttributeListener, HttpSessionListener {
 
	private ServletContext context = null;
	private HashMap<String, HttpSession> sessions = new HashMap<String, HttpSession>();
	private static SessionListener me;
 
 
	public void attributeAdded(HttpSessionBindingEvent event) {
 
		System.out.println(("attributeAdded('" + event.getSession().getId() + "', '" + event.getName() + "', '"
				+ event.getValue() + "')"));
 
		//on récupère le datasource quand la session utilisateur est renseigné
		if ("utilisateur".equalsIgnoreCase(event.getName())) {
			HibernateSessionFactory.rebuildSessionFactory(event.getValue().toString());
 
		}
 
	}
 
 
	public void attributeRemoved(HttpSessionBindingEvent event) {
 
		//System.out.println("attributeRemoved('" + event.getSession().getId() + "', '" + event.getName() + "', '"
		//		+ event.getValue() + "')");
 
	}
 
 
	public void attributeReplaced(HttpSessionBindingEvent event) {
		System.out.println(("attributeReplaced('" + event.getSession().getId() + "', '" + event.getName() + "', '"
				+ event.getValue() + "')"));
 
	}
 
 
	public void contextDestroyed(ServletContextEvent event) {
		System.out.println("contextDestroyed()");
		this.context = null;
 
	}
 
 
	public void contextInitialized(ServletContextEvent event) {
 
		this.context = event.getServletContext();
		System.out.println("contextInitialized()");
 
	}
 
 
	public void sessionCreated(HttpSessionEvent event) {
		sessions.put(event.getSession().getId(), event.getSession());
 
		System.out.println("sessionCreated('" + event.getSession().getId() + "')");
	}
 
 
	public static SessionListener getInstance() {
		return me;
	}
 
 
	public Iterator<HttpSession> getSessions() {
		return sessions.values().iterator();
	}
 
 
	public void sessionDestroyed(HttpSessionEvent event) {
		sessions.remove(event.getSession().getId());
		System.out.println("sessionDestroyed('" + event.getSession().getId() + "')");
		//on ferme la sessionfactory dès la destruction de la session
		HibernateSessionFactory.closeSession();
	}
 
}

Je vois pas trop comment modifier le bean pour qu'il puisse bien prendre en compte la bonne factory et pas rester avec une ancienne sessionfactory en memoire ...

[tchize_]

puisque tu travaille avec une threadlocal et un session listener, le plus porpre serait peut etre

1) dans le session listener tu créer un session factory associée à l'utilisateur, tu l'associe aussi au thread courant via ton threadlocal.set(....)
2) dans le requestfilter (à créer) tu récupère la session factory depuis la session http, et tu la stock dans le threadlocal avant de faire le forward vers la requete en elle meme. A coté de ca, après l'exécution de la requete, tu nettoie la treadlocal (set(null))

J'espère que tu a peu d'utilisateurs et un bonne raison de devoir travailler avec des connections différenciées par utilisateur, parce qu'une session factory hibernate, c'est long à initialiser et c'est emcombrant en mémoire.