insert de masse avec createSQLQuery

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:

---

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:

---

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.

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

Ajoute un espace :) à la deuxième ligne déjà

Au lieu de :

Code:

---

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:

---

1 2 3

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

---

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

passe une bonne journée hibernante ;)

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:

---

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:

---

1 2 3 4

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

---

Bonne continuation

session.connection() est deprecated.

Il faut utiliser session.doWork().

Code:

---

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() );

---

:D

Merci Sandrine49,
J'ai testé , ça répond à mes besoins : réponse précise et efficace

Chris

Ca pose pas des problèmes de fraîcheur de cache ?