Hibernate4 執行存儲過程

Hibernate3.3.2版本中getSession().connection()已被棄用，hibernate4中官方推薦使用Session doWork()方法進行jdbc操作

當Hibernate的事務由Spring接管時,session的關閉由Spring管理.不用手動關閉,否則需要手動關閉

1、執行帶輸出參數存儲過程

/**
     * 執行帶輸出參數存儲過程
     * @param callSql
     * @param inParameters
     */
    public String prepareCallAndReturn(final String callSql,final Object... inParameters){
        Session session = getSession();
        return session.doReturningWork(new ReturningWork<String>() {
            @Override
            public String execute(Connection connection) throws SQLException {
                CallableStatement cs = connection.prepareCall(callSql);
                int inParametersLength = inParameters.length;
                for(int i=0;i<inParametersLength;i++){
                    cs.setObject(i+1, inParameters[i]);
                }
                cs.registerOutParameter(inParametersLength+1,Types.VARCHAR);
                cs.executeUpdate();
                return cs.getString(inParametersLength+1);
            }
        });
    }

 

2、執行不帶輸出參數存儲過程

/**
     * 執行不帶參數存儲過程
     * @param callSql
     * @param inParameters
     */
    public void prepareCallNoReturn(final String callSql,final Object... inParameters){
        Session session = getSession();
        session.doWork(new Work() {
            @Override
            public void execute(Connection connection) throws SQLException {
                CallableStatement cs = connection.prepareCall(callSql);
                int inParametersLength = inParameters.length;
                for(int i=0;i<inParametersLength;i++){
                    cs.setObject(i+1, inParameters[i]);
                }
                cs.executeUpdate();
            }
        });
    }

/**
     * 執行只有輸入參數存儲過程
     * @param callSql {call p_datasync(?)}
     * @param syncTimeType
     */
    private void callPro(final String callSql, final String syncTimeType){
        SQLQuery sqlQuery = getSession().createSQLQuery(callSql);
        sqlQuery.setString(0, syncTimeType);
        sqlQuery.executeUpdate();
    }