¿Cómo llamar a una función de Oracle desde Hibernate con un parámetro de retorno?

Question

Mi pregunta es muy similar a Getting the return value of a PL/SQL function via Hibernate

Tengo una función que hace algunas modificaciones internamente y devuelve un valor.

La idea original era hacer algo como esto:

protected Integer checkXXX(Long id, Long transId) 
     throws Exception { 
    final String sql = "SELECT MYSCHEMA.MYFUNC(" + id + ", " 
      + transId + ") FROM DUAL"; 
    final BigDecimal nr = (BigDecimal) this.getHibernateTemplate() 
      .getSessionFactory().getCurrentSession().createSQLQuery(sql) 
      .uniqueResult(); 
    return nr.intValue(); 
} 

Desafortunadamente esto no funciona con Oracle. ¿Cuál es la forma recomendada de hacer algo como esto?

¿Hay una manera de extraer las variables declaradas dentro de mi estado de cuenta?

Answer 1

Session de Hibernate proporciona un método doWork() que le da acceso directo a java.sql.Connection. A continuación, puede crear y utilizar java.sql.CallableStatement para ejecutar su función:

session.doWork(new Work() { 
    public void execute(Connection connection) throws SQLException { 
    CallableStatement call = connection.prepareCall("{ ? = call MYSCHEMA.MYFUNC(?,?) }"); 
    call.registerOutParameter(1, Types.INTEGER); // or whatever it is 
    call.setLong(2, id); 
    call.setLong(3, transId); 
    call.execute(); 
    int result = call.getInt(1); // propagate this back to enclosing class 
    } 
}); 

Answer 2

Sí, usted tiene que utilizar un parámetro de salida. Si se utiliza el método DoWork(), que haría algo como esto:

session.doWork(new Work() { 
    public void execute(Connection conn) { 
     CallableStatement stmt = conn.prepareCall("? = call <some function name>(?)"); 
     stmt.registerOutParameter(1, OracleTypes.INTEGER); 
     stmt.setInt(2, <some value>); 
     stmt.execute(); 
     Integer outputValue = stmt.getInt(1); 
     // And then you'd do something with this outputValue 
    } 
}); 

Answer 3

public static void getThroHibConnTest() throws Exception { 
    logger.debug("UsersActiion.getThroHibConnTest() | BEG "); 
    Transaction tx = null; 
    Connection conn = null; 
    CallableStatement cs = null; 
    Session session = HibernateUtil.getInstance().getCurrentSession(); 
    try { 
     tx = session.beginTransaction(); 
     conn = session.connection(); 

     System.out.println("Connection = "+conn); 
     if (cs == null) 
     { 
      cs = 
       conn.prepareCall("{ ?=call P_TEST.FN_GETSUM(?,?) }"); 
     } 
     cs.clearParameters(); 
     cs.registerOutParameter(1,OracleTypes.INTEGER); 
     cs.setInt(2,1); 
     cs.setInt(3,2); 
     cs.execute(); 
     int retInt=cs.getInt(1); 
     tx.commit();    
    }catch (Exception ex) { 
     logger.error("UsersActiion.getThroHibConnTest() | ERROR | " , ex); 
     if (tx != null && tx.isActive()) { 
      try { 
       // Second try catch as the rollback could fail as well 
       tx.rollback(); 
      } catch (HibernateException e1) { 
       logger.debug("Error rolling back transaction"); 
      } 
      // throw again the first exception 
      throw ex; 
     } 
    }finally{ 
     try { 
      if (cs != null) { 
       cs.close(); 
       cs = null; 
      } 
      if(conn!=null)conn.close(); 

     } catch (Exception ex){;} 
    } 
    logger.debug("UsersActiion.getThroHibConnTest() | END "); 
} 

Answer 4

Alternativa Código :)

si quieres resultado que se puede utilizar a continuación el código dirigir

int result = session.doReturningWork(new ReturningWork<Integer>() { 
    @Override 
    public Integer execute(Connection connection) throws SQLException { 
    CallableStatement call = connection.prepareCall("{ ? = call MYSCHEMA.MYFUNC(?,?) }"); 
    call.registerOutParameter(1, Types.INTEGER); // or whatever it is 
    call.setLong(2, id); 
    call.setLong(3, transId); 
    call.execute(); 
    return call.getInt(1); // propagate this back to enclosing class 
    } 
}); 

http://keyurj.blogspot.com.tr/2012/12/dowork-in-hibernate.html

Answer 5

me escribió an article about various ways of calling Oracle stored procedures and functions from Hibernate tanto, para resumir, usted tiene las siguientes opciones:

1. Con una @NamedNativeQuery:

   @org.hibernate.annotations.NamedNativeQuery(
       name = "fn_my_func", 
       query = "{ ? = call MYSCHEMA.MYFUNC(?, ?) }", 
       callable = true, 
       resultClass = Integer.class 
   ) 
   
   Integer result = (Integer) entityManager.createNamedQuery("fn_my_func") 
       .setParameter(1, 1) 
       .setParameter(2, 1) 
       .getSingleResult();  
   

2. con la API JDBC:

   Session session = entityManager.unwrap(Session.class); 
   
   final AtomicReference<Integer> result = 
       new AtomicReference<>(); 
   
   session.doWork(connection -> { 
       try (CallableStatement function = connection 
         .prepareCall(
          "{ ? = call MYSCHEMA.MYFUNC(?, ?) }" 
         ) 
        ) { 
        function.registerOutParameter(1, Types.INTEGER); 
        function.setInt(2, 1); 
        function.setInt(3, 1); 
        function.execute(); 
        result.set(function.getInt(1)); 
       } 
   });    
   

3. Con una consulta nativa de Oracle:

   Integer result = (Integer) entityManager.createNativeQuery(
       "SELECT MYSCHEMA.MYFUNC(:id, :transId) FROM DUAL") 
       .setParameter("postId", 1) 
       .setParameter("transId", 1) 
       .getSingleResult();