工作流性能優化（敢問activiti有擴展性？）（3）

本文轉載自查看原文 2015-04-23 17:23 2353 JAVA/ 工作日志

2015/4/20

周末回去想了下，hibernate、mybatis、jdbc，都行，最終定了用mybatis，誰叫它這么優雅，acvtiviti是依賴了mybatis的，就不用再引入包了；

看了配置文件，之前配置的是jpa，再配置mybatis，配置文件就顯得臃腫，很亂了；用jpa吧，貌似也不賴；

再寫一個Repository；

寫SQL的時候用到了，知識點：

instr：instr(t.DESCRIPTION_, 'conditionCountersign') > 0

mysql查詢最后一條記錄，不能用orderby：

需求：要取a1的最后一條數據來關聯，語句如下；

解決：不能在inner join里邊用order by xxx limit 1；

折中解決：用時間來限制；a1.START_TIME_>a2.START_TIME_

select distinct RES.*, a1.ID_, a2.ID_ from ACT_HI_PROCINST RES inner join ACT_HI_ACTINST a1 on (a1.PROC_INST_ID_ = RES.PROC_INST_ID_ and a1.ACT_TYPE_ != 'endEvent')

inner join ACT_RU_TASK t on (a1.TASK_ID_=t.ID_ and instr(t.DESCRIPTION_, 'conditionCountersign') > 0)

inner join ACT_HI_ACTINST a2 on (a1.ACT_ID_=a2.ACT_ID_ and a1.START_TIME_>a2.START_TIME_ and a2.ASSIGNEE_='324')

where RES.END_TIME_ is null

and exists (select LINK.USER_ID_ from ACT_HI_IDENTITYLINK LINK where USER_ID_ = '324' and LINK.PROC_INST_ID_ = RES.ID_) order by START_TIME_ desc;

jpa映射activiti的實體，各種報錯；

好麻煩，jpa要寫實體，要寫HQL，原來我都寫好SQL了，還要轉換為HQL，hibernate真麻煩；

慢慢拷貝表字段寫實體，每個實體要繼承原有的entity；

先寫一個測試用例，跑通了再說，別連查詢都查不了，就浪費時間了；貼一些主要的代碼：

實體：

Repository：

測試用例：

可以哦：

那開始慢慢寫實體吧，寫好再改HQL；

寫好了HQL，開始測試：

報錯：

Caused by: java.lang.IllegalArgumentException: node to traverse cannot be null!

摸不着頭腦，先精簡語句，先調通上半部分的union再說；

還是一樣；

問度娘；度娘說是HQL寫錯了，哪里錯了，她也不說，真是的；

再次精簡：

還是一樣；

再次精簡：

還是一樣；

哥，多了個左括號；繼續奮戰；

再加SQL：

加參數，加排序，很順利；

另一個union問題就很多，有點絕望；

換用jdbc試試；

遇到的錯誤：

錯誤代碼： 1248

Every derived table must have its own alias

解決：

select count(0) as total from (xxx)；后邊要帶別名；

select count(0) as total from (xxx) dd;

很快就寫好了，原生SQL就是好；

jdbc的dao層：

    /**
     * 分頁查詢待辦工作流記錄
     * @param involvedUser
     * @param firstResult
     * @param maxResults
     * @return
     */
    public List<HistoricProcessInstanceEntity> qryUnfinishedByInvolvedUser(HistoricProcessInstanceQuery query){
        StringBuilder sql = new StringBuilder();
        sql.append(" select  ");
        sql.append(HistoricProcessInstanceSQLFragment.baseColumnList());
        sql.append(" from (");
        sql.append("(select RES.* from ACT_HI_PROCINST RES ");
        sql.append("where RES.END_TIME_ is null ");
        sql.append("  and (exists (select LINK.USER_ID_ from ACT_HI_IDENTITYLINK LINK where USER_ID_ = ? and LINK.PROC_INST_ID_ = RES.PROC_INST_ID_)) ");
        sql.append("  and exists (select 1 from ACT_RU_TASK t where t.PROC_INST_ID_=RES.ID_ and t.ASSIGNEE_=? order by t.ID_ asc limit 1)) ");
        sql.append(" union ");
        sql.append(" (select distinct RES.* from ACT_HI_PROCINST RES inner join ACT_HI_ACTINST a1 on (a1.PROC_INST_ID_ = RES.PROC_INST_ID_ and a1.ACT_TYPE_ != 'endEvent') ");
        sql.append("     inner join ACT_RU_TASK t on (a1.TASK_ID_=t.ID_ and instr(t.DESCRIPTION_, 'conditionCountersign') > 0)  ");
        sql.append("     inner join ACT_HI_ACTINST a2 on (a1.ACT_ID_=a2.ACT_ID_ and a1.START_TIME_>a2.START_TIME_ and a2.ASSIGNEE_=?) ");
        sql.append("     where RES.END_TIME_ is null  ");
        sql.append("     and exists (select LINK.USER_ID_ from ACT_HI_IDENTITYLINK LINK where USER_ID_ = ? and LINK.PROC_INST_ID_ = RES.ID_)) ");
        sql.append("order by START_TIME_ desc) dd ");
        
        List<Object> param = new ArrayList<Object>();
        param.add(query.getInvolvedUser());
        param.add(query.getInvolvedUser());
        param.add(query.getInvolvedUser());
        param.add(query.getInvolvedUser());
        
        String countSql = PageUtils.getCountSQL(sql.toString());
        logger.info("About to excute sql=\n{}\n{}", countSql, BaseUtils.printList(param));
        Integer total = baseDao.getJdbcTemplate().queryForObject(countSql, param.toArray(), Integer.class);
        query.setTotalRecord(total);

        // 分頁設置
        PageUtils.buildPageSqlForMysql(sql, query);

        logger.info(" About to excute sql=\n{}\n{}", sql.toString(), BaseUtils.printList(param));
        List<HistoricProcessInstanceEntity> datas = baseDao.getJdbcTemplate().query(sql.toString(), param.toArray(), new BeanPropertyRowMapper<HistoricProcessInstanceEntity>(HistoricProcessInstanceEntity.class));
        return datas;
    }

啟動項目測試：

嚴重: Servlet.service() for servlet [spring] in context with path [] threw exception [Handler processing failed; nested exception is java.lang.NoSuchMethodError: com.sinotaiyo.srpm.activiti.DetailBuilder.BuildWorkflowDetailByEntity(Lorg/activiti/engine/impl/persistence/entity/HistoricProcessInstanceEntity;)Lcom/sinotaiyo/srpm/activiti/WorkflowDetail;] with root cause

java.lang.NoSuchMethodError: com.sinotaiyo.srpm.activiti.DetailBuilder.BuildWorkflowDetailByEntity(Lorg/activiti/engine/impl/persistence/entity/HistoricProcessInstanceEntity;)Lcom/sinotaiyo/srpm/activiti/WorkflowDetail;

方法是寫好的，debug進去是用代理模式；

javap –s DetailBuilder