wfactinstanceextdao.java

来自「公司自己开发的工作流引擎」· Java 代码 · 共 131 行

package cn.com.iaspec.workflow.engine.dao;
import java.io.*;
import cn.com.iaspec.workflow.db.WorkflowDBConnectionManager;
import java.sql.Statement;
import java.sql.ResultSet;
import org.apache.log4j.Logger;
import java.sql.PreparedStatement;
import java.sql.Connection;
import java.sql.Timestamp;
import cn.com.iaspec.workflow.vo.db.WfActInstanceExt;

/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: iASPEC Technologies</p>
 *
 * @author xiesonglin
 * @version 1.5
 */
public class WfActInstanceExtDAO
    implements Serializable{
  private static Logger logger=Logger.getLogger(WfProcInstanceExtDAO.class);
  public WfActInstanceExtDAO(){
  }

  public WfActInstanceExt getWfActInstanceExt(long actInstanceId)
      throws Exception{
    Connection conn=null;
    Statement stm=null;
    WfActInstanceExt actInstExt=null;
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      String sql=" select * from wf_actinstance_ext where act_instance_id="+
          actInstanceId;
      logger.info("......query sql:"+sql);
      ResultSet rs=stm.executeQuery(sql);
      if(rs.next()){
        actInstExt=new WfActInstanceExt();
        actInstExt.setIfMaxTimeOut(rs.getString("if_max_timeout")==null?false:
            (rs.getString("if_max_timeout").toUpperCase().equals("Y")?true:false));
        actInstExt.setIfWarningTimeOut(rs.getString("if_warning_timeout")==null?false:
            (rs.getString("if_warning_timeout").toUpperCase().equals("Y")?true:false));
        actInstExt.setActInstanceId(rs.getLong("act_instance_id"));
        actInstExt.setActMaxTime(rs.getLong("act_max_time"));
        actInstExt.setActMaxTimeOut(rs.getTimestamp("act_max_timeout"));
        actInstExt.setActPassTime(rs.getLong("act_pass_time"));
        actInstExt.setActTimeUnitType(rs.getString("act_time_unit_type"));
        actInstExt.setActWarningTime(rs.getLong("act_warning_time"));
        actInstExt.setActWarningTimeOut(rs.getTimestamp(
            "act_warning_timeout"));
      }
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
    return actInstExt;
  }

  public void insertActInstanceExt(WfActInstanceExt actInstExt)
      throws Exception{
    Connection conn=null;
    PreparedStatement ptmt=null;
    String sql=
        " insert into wf_actinstance_ext (act_instance_id,act_max_time,act_warning_time,"+
        " act_time_unit_type,act_max_timeout,act_warning_timeout,if_max_timeout,if_warning_timeout"+
        ",act_pass_time) values (?,?,?,?,?,?,?,?,?)";
    logger.info("......query sql:"+sql);

    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      ptmt=conn.prepareStatement(sql);
      ptmt.setLong(1,actInstExt.getActInstanceId());
      ptmt.setLong(2,actInstExt.getActMaxTime());
      ptmt.setLong(3,actInstExt.getActWarningTime());
      ptmt.setString(4,actInstExt.getActTimeUnitType());
      ptmt.setTimestamp(5,actInstExt.getActMaxTimeOut()==null ? null:(new Timestamp(actInstExt.getActMaxTimeOut().getTime())));
      ptmt.setTimestamp(6,actInstExt.getActWarningTimeOut()==null ? null:(new Timestamp(actInstExt.getActWarningTimeOut().getTime())));
      ptmt.setString(7,actInstExt.isIfMaxTimeOut()?"Y":"N");
      ptmt.setString(8,actInstExt.isIfWarningTimeOut()?"Y":"N");
      ptmt.setLong(9,actInstExt.getActPassTime());
      logger.info("......ptmt is:"+ptmt.toString());
      ptmt.execute();

    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(ptmt,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
  }

  public int updateActInstanceExt(WfActInstanceExt actInstExt)
      throws Exception{
    Connection conn=null;
    PreparedStatement ptmt=null;
    String sql=
        " update wf_actinstance_ext set act_max_time=?,act_warning_time=?,"+" act_time_unit_type=?,act_max_timeout=?,act_warning_timeout=?,if_max_timeout=?,"+
        "if_warning_timeout=?,act_pass_time=? where act_instance_id=?";
    logger.info("......query sql:"+sql);
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      ptmt=conn.prepareStatement(sql);
      ptmt.setLong(1,actInstExt.getActMaxTime());
      ptmt.setLong(2,actInstExt.getActWarningTime());
      ptmt.setString(3,actInstExt.getActTimeUnitType());
      ptmt.setTimestamp(4,
          actInstExt.getActMaxTimeOut()==null?null:
          new Timestamp(actInstExt.getActMaxTimeOut().getTime()));
      ptmt.setTimestamp(5,
          actInstExt.getActWarningTimeOut()==null?null:
          new Timestamp(actInstExt.getActWarningTimeOut().getTime()));
      ptmt.setString(6,actInstExt.isIfMaxTimeOut()?"Y":"N");
      ptmt.setString(7,actInstExt.isIfWarningTimeOut()?"Y":"N");
      ptmt.setLong(8,actInstExt.getActPassTime());
      ptmt.setLong(9,actInstExt.getActInstanceId());
      logger.info("......ptmt is:"+ptmt.toString());
      return ptmt.executeUpdate();
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(ptmt,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
  }

}