wfroledao.java

公司自己开发的工作流引擎

package cn.com.iaspec.workflow.organize.dao;

import cn.com.iaspec.workflow.db.WorkflowDBConnectionManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.SQLException;
import java.util.List;
import java.sql.Connection;
import cn.com.iaspec.workflow.vo.db.WfRole;
import org.apache.log4j.Logger;
import cn.com.iaspec.workflow.WorkflowConstant;
import java.util.ArrayList;
import java.sql.PreparedStatement;
import cn.com.iaspec.workflow.vo.db.WfExtField;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: IASPEC Technologies</p>
 *
 * @author xiesonglin
 * @version 1.0
 */

public class WfRoleDAO{
  private static Logger logger=Logger.getLogger(WfRoleDAO.class);
  private static final String DB_TYPE = WorkflowDBConnectionManager.getInstance().getDataBaseType();

  Connection conn = null;
  PreparedStatement ptmt = null;
  ResultSet rowset = null;

  public WfRoleDAO(){
  }

  /**
   * 根据sWhereSQL条件进行查询
   * @param sWhereSQL where条件查询语句
   * @return List
   * @throws SQLException
   */
  public List query(String sWhereSQL)
      throws SQLException{
    Connection conn=null;
    Statement stm=null;
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      if (sWhereSQL==null)
        sWhereSQL="";
      String sql=" select * from wf_role ";
      sql=sql+sWhereSQL;
      logger.info("......query sql:"+sql);
      ResultSet rs=stm.executeQuery(sql);
      List list=resultsetToVO(rs);
      return list;
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
  }

  /**
   * 查询
   * @param role WfRole
   * @return List
   * @throws SQLException
   */
  public List query(WfRole role)
      throws SQLException{
    Connection conn=null;
    Statement stm=null;
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      String sql=" select * from wf_role ";
      StringBuffer sbWhere=getQueryString(role);
      sql=sql+sbWhere.toString();
      logger.info("......query sql:"+sql);
      ResultSet rs=stm.executeQuery(sql);
      List list=resultsetToVO(rs);
      return list;
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
  }

  /**
   * 更新wf_role信息
   * @param role WfRole
   * @throws SQLException
   * @return List
   */
  public void update(WfRole role,String roleId)
      throws Exception{
    Connection conn=null;
    Statement stm=null;
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      String sql=" update wf_role set ";
      StringBuffer sbWhere=new StringBuffer(" where role_id='"+roleId+"'");
      StringBuffer sbUpdata=getStrUpdateValues(role);
      if(sbWhere.length()<=0||sbUpdata.length()<=0){
        throw new Exception("更新数据为空！");
      }
      sql=sql+sbUpdata.toString()+sbWhere.toString();
      logger.info("......update sql:"+sql);
      stm.execute(sql);

      //更新业务系统扩展的字段
      this.delExtFieldDate(roleId);
      this.saveExtFieldData(roleId,role.getExtFieldList());
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
  }

  /**
   * 往表wf_role插入记录
   * @param role WfRole
   * @throws Exception
   */
  public void insert(WfRole role)
      throws Exception{
    logger.info("begin insert(WfRole role)...");
    Connection conn=null;
    Statement stm=null;
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      StringBuffer sbInsertValue=this.getStrInsertValues(role);
      String sql=" insert into wf_role ("+this.getStrFields()+") "+" values ("+
          sbInsertValue.toString()+")";
      logger.info("......insert sql:"+sql);
      stm.execute(sql);

      //保存业务系统角色扩展的字段内容
      this.saveExtFieldData(role.getRoleId(),role.getExtFieldList());
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
  }

  private List resultsetToVO(ResultSet rs)
      throws SQLException{
    List list=new ArrayList();
    while(rs.next()){
      WfRole role=new WfRole();
      role.setRoleCode(rs.getString("role_code"));
      role.setRoleDesc(rs.getString("role_desc"));
      role.setRoleId(rs.getString("role_id"));
      role.setRoleName(rs.getString("role_name"));
      role.setRoleOrder(rs.getLong("role_order"));
      role.setRoleState(rs.getString("role_state"));
      role.setRoleType(rs.getString("role_type"));
      list.add(role);
    }
    return list;
  }

  private StringBuffer getQueryString(WfRole role){
    StringBuffer sb=new StringBuffer();
    if(role!=null){
      if(role.getRoleCode()!=null&&!role.getRoleCode().equals("")){
        sb.append(" role_code = '"+role.getRoleCode()+"' ");
        sb.append(" and ");
      }
      if(role.getRoleDesc()!=null&&!role.getRoleDesc().equals("")){
        sb.append(" role_desc = '"+role.getRoleDesc()+"' ");
        sb.append(" and ");
      }
      if(role.getRoleId()!=null&&!role.getRoleId().equals("")){
        sb.append(" role_id = '"+role.getRoleId()+"' ");
        sb.append(" and ");
      }
      if(role.getRoleName()!=null&&!role.getRoleName().equals("")){
        sb.append(" role_name = '"+role.getRoleName()+"' ");
        sb.append(" and ");
      }
      if(role.getRoleOrder()!=WorkflowConstant.LONG_INIT_VALUE){
        sb.append(" role_order = "+role.getRoleOrder());
        sb.append(" and ");
      }
      if(role.getRoleState()!=null&&!role.getRoleState().equals("")){
        sb.append(" role_state = '"+role.getRoleState()+"' ");
        sb.append(" and ");
      }
      if(role.getRoleType()!=null&&!role.getRoleType().equals("")){
        sb.append(" role_type = '"+role.getRoleType()+"' ");
        sb.append(" and ");
      }
    }
    if(sb.length()>0){
      //增加查询条件关键字
      sb.insert(0," where ");
      //去除最后一个" AND "操作符
      sb.delete(sb.length()-5,sb.length());
    }
    return sb;
  }

  /**
   * 根据role取得insert语句
   * @param role WfRole
   * @throws Exception
   * @return StringBuffer
   */
  private StringBuffer getStrInsertValues(WfRole role)
      throws Exception{
    StringBuffer sbSQL=new StringBuffer();
    if(role.getRoleCode()!=null&&!role.getRoleCode().equals("")){
      sbSQL.append("'");
      sbSQL.append(role.getRoleCode());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(role.getRoleDesc()!=null&&!role.getRoleDesc().equals("")){
      sbSQL.append("'");
      sbSQL.append(role.getRoleDesc());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(role.getRoleId()!=null&&!role.getRoleId().equals("")){
      sbSQL.append("'");
      sbSQL.append(role.getRoleId());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(role.getRoleName()!=null&&!role.getRoleName().equals("")){
      sbSQL.append("'");
      sbSQL.append(role.getRoleName());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(role.getRoleOrder()!=WorkflowConstant.LONG_INIT_VALUE){
      sbSQL.append(role.getRoleOrder());
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(role.getRoleState()!=null&&!role.getRoleState().equals("")){
      sbSQL.append("'");
      sbSQL.append(role.getRoleState());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(role.getRoleType()!=null&&!role.getRoleType().equals("")){
      sbSQL.append("'");
      sbSQL.append(role.getRoleType());
      sbSQL.append("'");
      sbSQL.append(",");