Hibernate3.3.2版本中getSession().connection()已被棄用,hibernate4中官方推薦使用Session doWork()方法進行jdbc操做sql
當Hibernate的事務由Spring接管時,session的關閉由Spring管理.不用手動關閉,不然須要手動關閉session
一、執行帶輸出參數存儲過程async
/** * 執行帶輸出參數存儲過程 * @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); } }); }
二、執行不帶輸出參數存儲過程ide
/** * 執行不帶參數存儲過程 * @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(); }