Jak wywołać funkcję Oracle z Hibernate z parametrem zwracającym?

Question

Moje pytanie jest bardzo podobne do: Getting the return value of a PL/SQL function via Hibernate

Mam funkcję, która wykonuje pewne modyfikacje wewnętrznie i zwraca wartość.

Oryginalny pomysł żeby zrobić coś takiego:

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

Niestety to nie działa z Oracle. Jaki jest zalecany sposób zrobienia czegoś takiego?

Czy istnieje sposób wyodrębniania zadeklarowanych zmiennych z mojego wyciągu?

Answer 1

Sesja hibernacji zapewnia metodę doWork(), która umożliwia bezpośredni dostęp do java.sql.Connection. Następnie można utworzyć i używać java.sql.CallableStatement wykonywać swoją funkcję:

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

Tak, trzeba używać parametr wyjściowy. Jeśli używasz metody DoWork(), można zrobić coś takiego:

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

kod alternatywna :)

jeśli chcesz bezpośredni rezultat można skorzystać z poniższego kodu

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

pisałem an article about various ways of calling Oracle stored procedures and functions from Hibernate tak, aby ją podsumować, masz następujące opcje:

1. z @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. z JDBC API:

   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. z macierzyste zapytanie Oracle:

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