高级特性—存储过程调用与结果集数据处理
针对于存储过程,JDBC模块提供了IProcedureOperator
操作器接口及其默认接口实现类DefaultProcedureOperator
来帮助你完成,存储过程有以下几种调用方式,举例说明:
-
有输入参数无输出参数:
IConnectionHolder _conn = JDBC.get().getDefaultConnectionHolder(); try { // 执行名称为`procedure_name`的存储过程,并向该存储过程转入两个字符串参数 IProcedureOperator<Object[]> _opt = new DefaultProcedureOperator<Object[]>("procedure_name", _conn) .addParameter("param1") .addParameter("param2") .execute(IResultSetHandler.ARRAY); // 遍历结果集集合 for (List<Object[]> _item : _opt.getResultSets()) { ResultSetHelper.bind(_item).forEach(new ResultSetHelper.ItemHandler() { public boolean handle(ResultSetHelper.ItemWrapper wrapper, int row) throws Exception { System.out.println(wrapper.toObject(new ArchiveVObject()).tojson()); return true; } }); } } finally { _conn.release(); }
-
有输入输出参数:
IConnectionHolder _conn = JDBC.get().getDefaultConnectionHolder(); try { // 通过addOutParameter方法按存储过程输出参数顺序指定JDBC参数类型 new DefaultProcedureOperator("procedure_name", _conn) .addParameter("param1") .addParameter("param2") .addOutParameter(Types.VARCHAR) .execute(new IProcedureOperator.IOutResultProcessor() { public void process(int idx, int paramType, Object result) throws Exception { System.out.println(result); } }); } finally { _conn.release(); }
-
另一种写法:
JDBC.get().opensession(new ISessionExecutor<List<List<Object[]>>>() { public List<List<Object[]>> execute(ISession session) throws Exception { // 创建存储过程操作器对象 IProcedureOperator<Object[]> _opt = new DefaultProcedureOperator<Object[]>("procedure_name", session.getConnectionHolder()) .addParameter("param1") .addParameter("param2") .addOutParameter(Types.VARCHAR) .addOutParameter(Types.INTEGER) .setOutResultProcessor(new IProcedureOperator.IOutResultProcessor() { public void process(int idx, int paramType, Object result) throws Exception { System.out.println(result); } }).setResultSetHandler(IResultSetHandler.ARRAY); // 执行 _opt.execute(); return _opt.getResultSets(); } });