PostgreSQL 中存储过程中使用多游标(refcursor)

当时在使用时有点迷惑，多次测试后找到了一些方法,不说了直接上代码：

存储过程:

CREATE OR REPLACE FUNCTION select_team(IN _roleuuid ch<a href="https://www.jb51.cc/tag/ara/" target="_blank" class="keywords">ara</a>cter <a href="https://www.jb51.cc/tag/varying/" target="_blank" class="keywords">varying</a>,OUT _code integer,OUT _ref refcursor,OUT _member refcursor) RETURNS record AS $BODY$ declare message_row team_member<a href="https://www.jb51.cc/tag/r/" target="_blank" class="keywords">%r</a>OWTYPE; team_row team<a href="https://www.jb51.cc/tag/r/" target="_blank" class="keywords">%r</a>OWTYPE; begin _code=0; perform * from role where role_uuid=_roleuuid; IF FOUND THEN select * into message_row from team_member where team_member_role_uuid=_roleuuid; IF FOUND THEN open _ref for SELECT * FROM team WHERE team_uuid=message_row.team_member_team_uuid; open _member for SELECT * FROM team_member JOIN role ON team_member.team_member_role_uuid = role.role_uuid and team_member.team_member_team_uuid=message_row.team_member_team_uuid; ELSE _code=121; END IF; ELSE _code=108; END IF; end; $BODY$ LANGUAGE 'plpg<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>' VOLATILE COST 100;

说下上面的存储过程，

message_row team_member%rOWTYPE;

team_row team%rOWTYPE;

定义两个行变量message_row 和team_row

open _ref for ```` 打开游标 记录下结果

下面的代码是演示在java中如何调用 存储过程：

public TeamData getTeam(String roleuuid) { int cord = 0; CallableStatement cs = null; Connection connection = null; ResultSet teamrs = null; ResultSet number = null; TeamData team = null; try { connection = JDBServer.instance().getConnection(); cs = connection.prepareCall("{call select_team(?,?,?)}"); connection.setAutoCommit(false); cs.setString(1,roleuuid); cs.registerOutP<a href="https://www.jb51.cc/tag/ara/" target="_blank" class="keywords">ara</a>meter(2,Types.INTEGER); cs.registerOutP<a href="https://www.jb51.cc/tag/ara/" target="_blank" class="keywords">ara</a>meter(3,Types.OTHER); cs.registerOutP<a href="https://www.jb51.cc/tag/ara/" target="_blank" class="keywords">ara</a>meter(4,Types.OTHER); cs.executeUpdate(); cord = cs.getInt(2); teamrs = (ResultSet) cs.g<a href="https://www.jb51.cc/tag/eto/" target="_blank" class="keywords">eto</a>bject(3); number = (ResultSet) cs.g<a href="https://www.jb51.cc/tag/eto/" target="_blank" class="keywords">eto</a>bject(4); if (teamrs != null && teamrs.next()) { team = getE(teamrs); team.setCode(cord); } if (number != null) { TeamMember<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a> <a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>=new TeamMember<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>(); team.setNumberList(<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>.getGoodArrayList(number)); } } catch (<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>Exception e) { team = null; e.<a href="https://www.jb51.cc/tag/printstacktrace/" target="_blank" class="keywords">printstacktrace</a>(); } finally { try { if (teamrs != null) { teamrs.close(); } if (number != null) { number.close(); } if (connection != null) { connection.close(); } } catch (<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>Exception e) { e.<a href="https://www.jb51.cc/tag/printstacktrace/" target="_blank" class="keywords">printstacktrace</a>(); } } return team; }

代码没什么特别难的地方，我不细解析了，说下要注意的地方

connection.setAutoCommit(false);一定要设置，要不会报错

cs.registerOutParameter(3,Types.OTHER);

cs.registerOutParameter(4,Types.OTHER);这两个是注册游标输出的

teamrs = (ResultSet) cs.getobject(3); //获得游标输出结果集 ResultSet

number = (ResultSet) cs.getobject(4);

剩下的就和平时的sql操作一样了！