如何在流程流转结束步骤，调用自定义action

zsj5237 · 发表于 2014-11-19 08:51:29

jishuang 发表于 2014-11-18 10:35
// 异常情况
int abc = 2 / 0;
...

事务，我讲的是事务，报错了，应该rollback，现在数据入库了，你明白我说什么？

67886387 · 发表于 2014-11-19 08:58:42

手动回滚参考一下：

} catch (NamingException e) {
e.printStackTrace();
return 1;
} catch (SQLException e) {
//手工回滚事务或者抛出异常都可以
ContextHelper.getTransaction().rollback();
e.printStackTrace();
return 1;
} finally {
try {
if (ps != null) {
ps.close();
}
if(con != null) {
con.close();
}
} catch (SQLException e) {
System.out.println("##close.SQLException");
}
}

复制代码

zsj5237 · 发表于 2014-11-19 09:57:32

67886387 发表于 2014-11-19 08:58
手动回滚参考一下：

try {
//tx.rollback();
ContextHelper.getTransaction().rollback();
System.out.println("rollback ok?");
} catch (SQLException ex) {
System.out.println("rollback exception"+ex.getMessage());
}

这句总会报错：
rollback exception回滚事务出错

暗夜的忧伤 · 发表于 2014-11-19 10:02:30

回滚参考
http://bbs.justep.com/thread-33592-1-1.html
自己控制事务

67886387 · 发表于 2014-11-19 10:10:28

zsj5237 发表于 2014-11-19 09:57
try {
//tx.rollback();
ContextHelper.getTransaction().rollback();

// 创建连接，放到方法外，参考一下java.sql.Connection conn = null;
com.justep.system.data.Transaction tx = null;
CallableStatement proc = null;

public class GetQsMdb {
Connection conn = null;
PreparedStatement ps = null;
CallableStatement proc = null;
public void getSql(String lujin) throws FileNotFoundException, SQLException, IOException {
// TODO Auto-generated method stub
try {
// 取得数据库连接
conn = com.justep.model.ModelUtils.getConnectionInTransaction("/LandManagerSys/LandInfoMgr/data");
proc = conn.prepareCall("{ call HR_Interface_Generate1(?,?,?,?) }");
} catch (NamingException e) {
e.printStackTrace();
} catch (SQLException e) {
//手工回滚事务或者抛出异常都可以
ContextHelper.getTransaction().rollback();
e.printStackTrace();
} finally {
try {
if (ps != null) {
ps.close();
}
if(conn != null) {
conn.close();
}
} catch (SQLException e) {
System.out.println("##close.SQLException");
}
}
}
}

复制代码

zsj5237 · 发表于 2014-11-19 10:35:14

67886387 发表于 2014-11-19 10:10
// 创建连接，放到方法外，参考一下java.sql.Connection conn = null;
com.justep.system.data.Transact ...

放外面一样，rollback exception回滚事务出错

jishuang · 发表于 2014-11-19 14:56:17

action中如下，测试没问题

public static void Transaction(){
System.out.println("##自己控制事务");
java.sql.Connection conn = null;
java.sql.PreparedStatement pstmt = null;
com.justep.system.data.Transaction tx = null;
try {
// 取得数据库连接
tx = new com.justep.system.data.Transaction();
conn = tx.getConnection("/appdemo/test/data");
tx.begin();
// 更新一个字段
pstmt = conn.prepareStatement("update AP_RQ set fName = 'Transaction' where fID = '183C666F7FD94622B79D5D985064731C'");
pstmt.execute();
// 更新另一个字段
pstmt = conn.prepareStatement("update AP_RQ set fCode = '审批中' where fID = '183C666F7FD94622B79D5D985064731C'");
int abc = 2 / 0;
pstmt.execute();
tx.commit();
} catch (NamingException e) {
throw new RuntimeException(e);
} catch (SQLException e) {
try {
tx.rollback();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
throw new RuntimeException(e);
} finally {
try {
if (pstmt != null) {
pstmt.close();
}
if (conn != null) {
conn.close();
}
} catch (SQLException e) {
System.out.println("##close.SQLException");
}
}
}

复制代码

zsj5237 · 发表于 2014-11-19 15:38:45

jishuang 发表于 2014-11-19 14:56
action中如下，测试没问题

private static void synchronousHr(Iterator<Row> rows) {
// 创建连接
java.sql.Connection conn = null;
com.justep.system.data.Transaction tx = null;
CallableStatement proc = null;
try {
// 取得数据库连接
tx = new com.justep.system.data.Transaction();
//conn = ModelUtils.getConnectionInTransaction("/dngt/hr/data");
conn = tx.getConnection("/dngt/hr/data");
tx.begin();
// 存储过程对象
proc = conn.prepareCall("{ call HR_Interface_Generate1(?,?,?,?) }");
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
executeProcedure(proc, "123", sdf.format(new Date()), getFirstDayType(new Date()), "321");
int abc = 2/0;
executeProcedure(proc, "456", sdf.format(new Date()), getFirstDayType(new Date()), "654");

tx.commit();
} catch (Exception e) {
try {
tx.rollback();
System.out.println("execute exception:"+e.getMessage());
} catch (SQLException ex) {
System.out.println("rollback exception:"+ex.getMessage());
}
} finally {
try {
if (proc != null) {
proc.close();
}
if(conn != null){
conn.close();
}
} catch (Exception e) {
e.printStackTrace();
System.out.println("close exception" + e.getMessage());
}
}
}

private static void executeProcedure(CallableStatement proc, String empNo, String date, String type, String no) throws Exception {
//赋值参数
proc.setString(1, empNo); //@EmpNo 工号
proc.setString(2, date); //@Date 请假时间
proc.setString(3, type); //@Type 请假半天类型
proc.setString(4, no); //@No 请假单号
proc.execute();
}

一样写法，我执行，俩条插库操作，有一条能入库，第二条操作异常，不入库，事务没有回滚。
我不知道，你的update，是否真正检测过值变化，我这里是清楚的看到，库记录数的变化。

或者麻烦使用我的俩个方法检测。存储过程如下：
create procedure HR_Interface_Generate1
(
@EmpNo varchar(255) ,
@Date datetime,
@Type varchar(255) ,
@No varchar(255)
) as
begin
  insert into HR_Leave
(EmpNo, Date, Type, No)
  values
(@EmpNo, @Date, @Type, @No);
  commit;
end;

jishuang · 发表于 2014-11-19 16:42:12

你好楼主，这个问题需要我在本地环境进行问题重现，所以会花费较长时间，请你耐心等待，我完成后会第一时间反馈结果，谢谢！

jishuang · 发表于 2014-11-20 11:03:06

把存储过程中的commit去掉

		自动登录	找回密码
密码			注册

[结贴] 如何在流程流转结束步骤，调用自定义action

浏览过的版块