insert de masse avec createSQLQuery

**KristofNancy** · 07/05/2010, 09h31

Bonjour,
J'essaie de faire un insert de masse (insert into .. select"dans une requête hibernate en utilisant le sql natif : voici mon code

Code :

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

1
2
3
4
5
6
7
 Transaction transaction = session.beginTransaction();
           String sqlRequete = "insert into T1";
           sqlRequete = sqlRequete + "select T2.code, T2.nom";
           sqlRequete = sqlRequete + " from T2  where T2.TYPE='N'" ;
 
           SQLQuery query = session.createSQLQuery(sqlRequete);
           query.executeUpdate();

Et voici ce que j'ai comme message erreur

Code :

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

1
2
3
4
5
6
7
8
javax.servlet.ServletException: java.lang.UnsupportedOperationException: Update queries only supported through HQL
	org.apache.struts.action.RequestProcessor.processException(RequestProcessor.java:516)
	org.apache.struts.action.RequestProcessor.processActionPerform(RequestProcessor.java:423)
	org.apache.struts.action.RequestProcessor.process(RequestProcessor.java:226)
	org.apache.struts.action.ActionServlet.process(ActionServlet.java:1164)
	org.apache.struts.action.ActionServlet.doPost(ActionServlet.java:415)
	javax.servlet.http.HttpServlet.service(HttpServlet.java:710)
	javax.servlet.http.HttpServlet.service(HttpServlet.java:803)

J'ai écrit une requête avec un "update" et c'est la même chose.
J'ai essayé aussi en vain avec "Query query = session.createSQLQuery(sqlRequete);"

Je précise que cette application utilise hibernate ; mais que pour des besoins internes et exceptionnellement je dois utiliser cet insert de masse.

Merci d'avance
Chris.

**Miday** · 07/05/2010, 10h06

D'après la documentation, tu ne peux pas faire d'inserts avec executeUpdate() MAIS uniquement des updates et des deletes

public int executeUpdate() throws HibernateException

Execute the update or delete statement. The semantics are compliant with the ejb3 Query.executeUpdate() method.

Returns:
The number of entities updated or deleted.
Throws:
HibernateException

**Miday** · 07/05/2010, 10h36

Ajoute un espace

à la deuxième ligne déjà

Au lieu de :

Code :

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

1
2
3
String sqlRequete = "insert into T1";
sqlRequete = sqlRequete + "select T2.code, T2.nom";
sqlRequete = sqlRequete + " from T2  where T2.TYPE='N'" ;

Mais plutot :

Code :

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

1
2
3
String sqlRequete = "insert into T1";
        sqlRequete = sqlRequete + " select T2.code, T2.nom";
        sqlRequete = sqlRequete + " from T2  where T2.TYPE='N'" ;

**KristofNancy** · 07/05/2010, 10h44

Effectivement , c'est une erreur de recopie. Mais bon ça ne change rien.
C'est bien ce qui me semblait : pas de possibilité d'insert,
Me reste la solution basique de récupérer mes infos de ma table T1 dans une liste java puis de faire un save hibernate ligne par ligne ; en espérant que ça ne prendra pas trop de temps.
Sinon je regarde l'utilisation d'un proc stockée dans hibernate

**Miday** · 07/05/2010, 12h49

passe une bonne journée hibernante

**sandrine49** · 07/05/2010, 15h35

Bonjour

J'ai été confrontée à ce problème : côté hibernate, tu ne peux rien faire.
Il faut une connection jdbc mais que tu peux récupérer à partir d'une connection hibernate.

Voici mon code :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
try {   
Transaction transaction = session.beginTransaction();
String sqlRequete = "insert into T1";
        sqlRequete = sqlRequete + " select T2.code, T2.nom";
        sqlRequete = sqlRequete + " from T2  where T2.TYPE='N'" ;
Statement statement  = session.connection().createStatement();          
           int cpt =statement.executeUpdate(sqlRequete); (cpt = nbre de ligne insérées) transaction.commit();           
        } catch (SQLException e) {
            throw new SQLException(e);
..........

Effectivement si tu as plusieurs requêtes, tu peux utiliser une proc stockée : ci joint un exemple :

Code :

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

1
2
3
4
 
CallableStatement callSmt = session.connection().prepareCall("{call MY_PROC(?)}");
callSmt.setString(1, identifiant);
callSmt.executeUpdate();

Bonne continuation

**Miday** · 07/05/2010, 18h17

session.connection() est deprecated.

Il faut utiliser session.doWork().

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
 
import java.sql.Connection;
import java.sql.SQLException;
 
import org.hibernate.jdbc.Work;
 
public class PersonalWork implements Work {
 
	public void execute(Connection connection) throws SQLException {
		//Code SQL classique
	}
 
}
 
et executer : session.doWork( new PersonalWork() );