从PostgreSQL调用存储过程

我正在尝试调用存储过程。存储过程是在数据库测试证明和执行从PostgreSQL调用存储过程

CREATE OR REPLACE FUNCTION statapi.pui_src_ter(p_src_ter_id id_t, p_aname name_t, p_adesc desc_t, p_sortord sortord_t) 
    RETURNS integer AS 
$BODY$ 
DECLARE 
    afected_rows integer := 0; 
BEGIN 
update statdwh.src_ter 
    set aname = p_aname, 
    adesc = p_adesc, 
    sortord = p_sortord, 
    actdt = current_timestamp 
where src_ter_id = p_src_ter_id; 
get diagnostics afected_rows = row_count; 
if (afected_rows = 0) then 
    insert into statdwh.src_ter(src_ter_id, aname, adesc, sortord, actdt) 
     values (p_src_ter_id, p_aname, p_adesc, p_sortord, current_timestamp) 
     returning src_ter_id into p_src_ter_id; 
    get diagnostics afected_rows = row_count; 
end if; 

return afected_rows; 
END; 
$BODY$ 
    LANGUAGE plpgsql VOLATILE 
    COST 100; 
ALTER FUNCTION statapi.pui_src_ter(id_t, name_t, desc_t, sortord_t) 
    OWNER TO postgres;

调用本身

public void storedProcedureCall() throws ClassNotFoundException, SQLException { 
    CallableStatement cst = connection.prepareCall("{call statapi.pui_src_ter(?,?,?,?)}"); 
    cst.setInt(1, 11); 
    cst.setString(2, "aname_att"); 
    cst.setString(3, "adesc_att"); 
    cst.setInt(4, 222); 
    ResultSet result3 = cst.executeQuery(); 
    while (result3.next()){ 
     System.out.println(result3.getString(1)); 
    } 
    cst.execute(); 
}

预期收益“1”，因为修改的一个记录，但在数据库（我通过看pgAdmin）记录没有出现我做错了什么？

来源

2015-10-08 liketheother

您是否承诺交易？ –

高级研究员简单回答“add connection.commit（）;”

来源

2015-10-08 09:41:54 liketheother

从PostgreSQL调用存储过程

回答

相关问题