Hibernate4調用SQL和存儲過程

最近使用了新的Struts2.20+spring4.0+hibernate4.0，新框架移除了HibernateSupportDao，所以重寫了下Hibernate4對SQL和存儲過程的操作，以備后查

以下的sessionFactory 對象是通過spring注入

private SessionFactory sessionFactory;
    public void setSessionFactory(SessionFactory sessionFactory) {
        this.sessionFactory = sessionFactory;
    }

 

1、通過SQL查詢，以List的方式返回

    /**
     * 通過SQL查詢,結果集不作處理直接返回
     * @param queryString 查詢字符串
     * @param params 參數
     * @return
     */
    @SuppressWarnings("unchecked")
    public List<Object> find_sql(String queryString,Object[] params){
        Session session = sessionFactory.getCurrentSession();
        Query query = session.createSQLQuery(queryString);
        if(null!=params){
            for(int i=0;i<params.length;i++){
                query.setParameter(i, params[i]);
            }
        }
        List<Object> list = query.list();
        return list;
    }

2、SQL或存儲過程查詢，將返回的結果集轉換成Map，結果集列名作為鍵

    /**
     * 通過SQL查詢，將結果集轉換成Map對象，列名作為鍵(適用於有返回結果集的存儲過程或查詢語句)
     * @param queryString
     * @param params
     * @return
     */
    @SuppressWarnings("unchecked")
    public List<Map<String,Object>> find_sql_toMap(String queryString,Object[] params){
        Session session = sessionFactory.getCurrentSession();
        Query query = session.createSQLQuery(queryString);
        query.setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);
        if(null!=params){
            for(int i=0;i<params.length;i++){
                query.setParameter(i, params[i]);
            }
        }
        List<java.util.Map<String,Object>> list = query.list();
        return list;
    }

3、SQL執行增、刪、改操作，測試使用該方法執行存儲過程會報錯

/**
     * 通過SQL執行無返回結果的語句，執行修改、刪除、添加等(適用於無結果集返回SQL語句，不能用於存儲過程)
     * @param queryString
     * @param params
     */
    public void executeSql(String queryString,Object[] params){
        Session session = sessionFactory.getCurrentSession();
        Query query = session.createQuery(queryString);
        if(null!=params){
            for(int i=0;i<params.length;i++){
                query.setParameter(i, params[i]);
            }
        }
        query.executeUpdate();
    }

4、執行無結果集返回的存儲過程，是第3點的補充

/**
     * 通過SQL執行無返回結果的存儲過程(僅限於存儲過程)
     * @param queryString
     * @param params
     */
    public void executeVoidProcedureSql(final String queryString,final Object[] params) throws Exception{
        Session session = sessionFactory.getCurrentSession();
        session.doWork(new Work(){
          public void execute(Connection conn) throws SQLException {
            ResultSet rs = null;
            CallableStatement call = conn.prepareCall("{" + queryString + "}");
            if (null != params) {
                for (int i = 0; i <params.length; i++) {
                    call.setObject(i+1, params[i]);
                }
            }
            rs = call.executeQuery();
            call.close();
            rs.close();
          }
       });
    }

5、通過存儲過程查詢，返回的結果集必須為單結果集，與第2點方法效果一致

    /**
     * 通過存儲過程查詢(單結果集)
     * @param sql 查詢sql
     * @param params 參數
     * @param columnNum 返回的列數
     * @return
     */
    public List<Map<String, Object>> find_procedure(final String sql,final Object[] params){
        final List<Map<String, Object>> result = new ArrayList<Map<String, Object>>();
        try {
            Session session = sessionFactory.getCurrentSession();
            session.doWork(new Work(){
              public void execute(Connection conn) throws SQLException {
                  CallableStatement cs=null;
                  ResultSet rs=null;
                  cs = conn.prepareCall(sql);
                    for(int i=1;i<=params.length;i++){
                        cs.setObject(i, params[i-1]);//設置參數
                    }
                    rs = cs.executeQuery();
                    ResultSetMetaData metaData = rs.getMetaData();
                    int colCount=metaData.getColumnCount();
                    while(rs.next()){
                        Map<String, Object> map = new HashMap<String, Object>();
                        for(int i=1;i<=colCount;i++){
                            String colName=metaData.getColumnName(i);
                            map.put(colName, rs.getObject(colName));
                        }
                        result.add(map);
                    }
                    close( cs, rs);
              }
           });
            return result;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

6、通過存儲過程查詢，適用返回的結果集有一個或多個

/**
     * 通過存儲過程查詢(多結果集)
     * @param sql 查詢sql
     * @param params 參數
     * @param columnNum 返回的列數
     * @return
     */
    public List<List<Map<String, Object>>> find_procedure_multi(final String sql,final Object[] params){
        final List<List<Map<String, Object>>> result = new ArrayList<List<Map<String, Object>>>();
        try {
//            conn = SessionFactoryUtils.getDataSource(sessionFactory).getConnection();
            Session session = sessionFactory.getCurrentSession();
            session.doWork(new Work(){
                public void execute(Connection conn) throws SQLException {
                    CallableStatement cs=null;
                    ResultSet rs=null;
                    cs = conn.prepareCall(sql);
                    for(int i=1;i<=params.length;i++){
                        cs.setObject(i, params[i-1]);
                    }
                    boolean hadResults = cs.execute();
                    ResultSetMetaData metaData = null;
                    while(hadResults){//遍歷結果集
                        List<Map<String, Object>> rsList = new ArrayList<Map<String, Object>>();//用於裝該結果集的內容
                        rs = cs.getResultSet();//獲取當前結果集
                        metaData=rs.getMetaData();
                        int colCount=metaData.getColumnCount();//獲取當前結果集的列數
                        while(rs.next()){
                            Map<String, Object> map = new HashMap<String, Object>();
                            for(int i=1;i<=colCount;i++){
                                String colName=metaData.getColumnName(i);
                                map.put(colName, rs.getObject(colName));
                            }
                            rsList.add(map);
                        }
                        result.add(rsList);
                        close(null, rs);//遍歷完一個結果集，將其關閉
                        hadResults=cs.getMoreResults();//移到下一個結果集
                    }
                    close(cs, rs);
                }
            });
            return result;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

代碼中的close方法，執行doWork的execute方法中不能關閉connection，connection連同session由spring管理

private void close(CallableStatement cs,ResultSet rs){
        try {
            if(cs!=null){
                cs.close();
            }
            if(rs!=null){
                rs.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

 本文地址：http://www.cnblogs.com/wangjiajun/p/4208077.html