Как вызвать функцию Oracle из Hibernate с параметром return?

Ответ 1

Сессия Hibernate предоставляет метод doWork(), который дает вам прямой доступ к java.sql.Connection. Затем вы можете создать и использовать java.sql.CallableStatement для выполнения своей функции:

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

Ответ 2

Я написал статью о различных способах вызова хранимых процедур и функций Oracle из Hibernate, поэтому, чтобы подвести итог, у вас есть следующие варианты:

1. С @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. С 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. С собственным запросом Oracle:

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

Ответ 3

Да, вам нужно использовать параметр out. Если вы используете метод doWork(), вы бы сделали что-то вроде этого:

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

Ответ 4

Альтернативный код :)

если вы хотите направить результат, вы можете использовать ниже код

 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

Ответ 5

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

Ответ 6

При использовании Spring Data JPA/Spring JDBC вы можете использовать SimpleJdbcCall для вызова функций и процедур.

Для заголовка такой функции:

FUNCTION get_text (p_param IN VARCHAR2) RETURN VARCHAR2

Используйте этот вызов:

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
import org.springframework.jdbc.core.simple.SimpleJdbcCall;
import org.springframework.stereotype.Repository;

@Repository
public class MyRepository {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    @Override
    public String callGetTextFunction(String param) {
        SimpleJdbcCall jdbcCall = new SimpleJdbcCall(jdbcTemplate)
                .withCatalogName("PKG_PACKAGE") //package name
                .withFunctionName("GET_TEXT"); //function name
        SqlParameterSource paramMap = new MapSqlParameterSource()
                .addValue("p_param", param));
        //First parameter is function output parameter type.
        return jdbcCall.executeFunction(String.class, paramMap));
    }

}