spring jdbctemplate调用存储过程，返回list对象

Posted 2020-12-25 ✧*꧁一品堂.技术学习笔记꧂*✧.

注：本文来源于《  spring jdbctemplate调用存储过程，返回list对象 》

spring jdbctemplate调用存储过程，返回list对象

方法：

/**
	 * 调用存储过程
	 * @param spName
	 */
	@SuppressWarnings("unchecked")
	public List<HashMap<String, Object>> executeSP(String procedure) {
		//procedure = "{call WCITY2_STATISTIC.sp_uservisit_stat(?)}";
		return (List<HashMap<String, Object>>) jdbcTemplate.execute(procedure,
				new CallableStatementCallback() {
					public Object doInCallableStatement(
							CallableStatement cs) throws SQLException,
							DataAccessException {

						List<HashMap<String, Object>> list = new ArrayList<HashMap<String, Object>>();

						cs.registerOutParameter(1, OracleTypes.CURSOR);
						cs.execute();
						ResultSet rs = (ResultSet) cs.getObject(1);

						while (rs.next()) {
							HashMap<String, Object> dataMap = new HashMap<String, Object>();
							ResultSetMetaData rsMataData = rs.getMetaData();
							for (int i = 1; i <= rsMataData.getColumnCount(); i++) {
								dataMap.put(rsMataData.getColumnName(i), rs
										.getString(rsMataData.getColumnName(i)));
							}
							list.add(dataMap);
						}

						return list;
					}
				});

	}

存储过程：

create or replace package WCITY2_STATISTIC is

  -- Author  : ADMINISTRATOR
  -- Created : 2012/10/24 9:48:34
  -- Purpose : 

  type Ref_Cursor is ref cursor;

  --
  procedure sp_pager_stats;

  --访问信息
  procedure sp_uservisit_stat(c_uservisit out Ref_Cursor);

end WCITY2_STATISTIC;

create or replace package body WCITY2_STATISTIC is

  --页面信息
  procedure sp_pager_stats is

  begin
    -- cur_page as select * from OMS_WIRELESS. TEMPLATE_FILE_WORKING;

    null;
  end sp_pager_stats;

  --访问信息
  procedure sp_uservisit_stat(c_uservisit out Ref_Cursor) as
    --定义游标
    /*
    cursor c_uservisit is
    select t.city,t.username,t.username as telphone,‘‘ as ip
    from INTERFACE_WIRELESS.USER_LOGIN_LOG t ;*/
  begin
    open c_uservisit For

      select t.city, t.username, t.username as telphone, ‘‘ as ip
        from INTERFACE_WIRELESS.USER_LOGIN_LOG t;

  end;

end WCITY2_STATISTIC;

调用方法：

	@SuppressWarnings("rawtypes")
	public String getUserVisitStat(){
		//List lst=jdbcService.executeSP("");

		String procedure = "{call WCITY2_STATISTIC.sp_uservisit_stat(?)}";
		List lst=spService.executeSP(procedure);
		if(lst!=null){
			System.out.println(lst.size());
		}

		return SUCCESS;
	}

自己编写的代码

import java.sql.CallableStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.CallableStatementCallback;
import org.springframework.jdbc.core.JdbcTemplate;

import com.tt.pwp.framework.data.dao.DaoFactory;

import oracle.jdbc.OracleTypes;

public class FuncReportTaskService {
    protected final Logger logger = LoggerFactory.getLogger(this.getClass());

    @Autowired
    private DaoFactory daoFactory;


    /**
     * 调用存储过程
     * @param spName
     */
    @SuppressWarnings("unchecked")
    public List<HashMap<String, Object>> executeSP(String procedure) {
    	JdbcTemplate jdbcTemplate = daoFactory.getDao().getJdbcTemplate();
        //procedure = "{call WCITY2_STATISTIC.sp_uservisit_stat(?)}";
        return (List<HashMap<String, Object>>) jdbcTemplate.execute(procedure,
                new CallableStatementCallback() {
                    public Object doInCallableStatement(
                            CallableStatement cs) throws SQLException,
                            DataAccessException {

                        List<HashMap<String, Object>> list = new ArrayList<HashMap<String, Object>>();

                        cs.registerOutParameter(1, OracleTypes.CURSOR);
                        cs.execute();
                        ResultSet rs = (ResultSet) cs.getObject(1);

                        while (rs.next()) {
                            HashMap<String, Object> dataMap = new HashMap<String, Object>();
                            ResultSetMetaData rsMataData = rs.getMetaData();
                            for (int i = 1; i <= rsMataData.getColumnCount(); i++) {
                                dataMap.put(rsMataData.getColumnName(i), rs
                                        .getString(rsMataData.getColumnName(i)));
                            }
                            list.add(dataMap);
                        }

                        return list;
                    }
                });

    }
}