Session flush et multithread

Version imprimable

J'utilise Hibernate dans une application Java2E. A partir d'un fichier XML contenant "n" enregistrements, des lignes sont insérées en base.
La lecture du fichier est réalisé via un parseur SAX et les enregistrements sont traités l'un après l'autre de manière séquentielle, jusqu'à là pas de problème.
Je tente de paralléliser les traitements afin de pouvoir traiter "simultanément" plusieurs enregistrements, chacun dans un thread propre. Pour cela, la session Hibernate est attaché au thread via un ThreadLocal. De manière aléatoire, l'exception suivante est produite lors de l'appel à Session.flush() :
Code:

1 2 3 4 ... Caused by: org.hibernate.exception.ConstraintViolationException: Could not execute JDBC batch update ... Caused by: java.sql.BatchUpdateException: ORA-00001: violation de contrainte unique (XX.YY)
Je ne vois pas d'où vient l'exception car lorsque je la catche, je parcours le cache Hibernate (la collection renvoyée par Session.getStatistics().getEntityKeys()), et je ne détecte aucun doublon :(
Quelqu'un aurait-il une idée sur ce qui se passe ? Merci pour vos réponses

15/06/2010, 11h02
OButterlin

Je pense qu'il serait bon de montrer les classes concernées et le mapping.

Le mapping de la clef primaire est le même pour tous les objets :

Code:

1
2
3
4
5
6
7
<hibernate-mapping>
  <class name="xx.yy" table="XX.YY">
 
  <composite-id>
        <key-property name="a" column="A" type="java.lang.String" length="50"/>
        <key-property name="b" column="B" type="java.util.Integer" length="2" />
  </composite-id>

Le code de la méthode flush dans le Dao est le suivant :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
public class DaoImpl extends HibernateDaoSupport
 
	private static final ThreadLocal<Session> session = new ThreadLocal<Session>();
 
	public void flush() {
		getSession().flush();
	}
 
	public Session getSession() {
		Session s = (Session) session.get();
 
		if (s == null || !s.isOpen()) {
			s = getSessionFactory().openSession();
			session.set(s);	
		} 
 
		return s;
	}