Discussion :

[herve91]

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 :

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

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

[OButterlin]

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

[herve91]

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

Code :

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

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 :

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
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;
	}