記錄一次bug解決過程：resultType和手動開啓事務

時間 2019-11-06

標籤記錄一次 bug 解決過程 resulttype 手動開啓事務欄目快樂工作简体版

原文原文鏈接

1、總結前端

2、BUG描述：MyBatis中resultType使用java

　　MyBatis中的resultType相似於入參：parameterType。先看IDCM項目中的實際使用案例代碼，以下：web

// List<Integer> orderIds = assetBeanMapperExt.getOrderIdsByParentIds(SqlStringUtil.formatInStr(logisticsOrder.getParentIds()));

　　咱們的目的是經過*Ext層直接返回一個list，list中有咱們所須要操縱的數據。logisticsOrder.getParentIds()是前端傳入的String類型的id字符串，用逗號或者封號分隔，這裏，咱們用工具類SqlStringUtil來處理它：spring

package com.alibaba.tboss.workorder.util;
public class SqlStringUtil {

    private final static String replaceChar_comma     = ",";
    private final static String replaceChar_semicolon = ";";

    // 格式化多個key值查詢
    public static String formatInStr(String queryStr) {
        return queryInStr(sliptQueryStr(queryStr));
    }

    // 返回sql查詢中的in集合
    public static String queryInStr(String[] queryStrs) {
        if (null == queryStrs || 0 == queryStrs.length) return null;
        StringBuffer buf = new StringBuffer();
        for (int i = 0; i < queryStrs.length; i++) {
            if (i != 0) buf.append(",");
            buf.append("'").append(queryStrs[i]).append("'");
        }
        return buf.toString();
    }

    // 查詢字符串分割字符串數組
    public static String[] sliptQueryStr(String queryStr) {
        if (null == queryStr || "".equals(queryStr.trim())) return null;
        queryStr = queryStr.replaceAll(SqlStringUtil.replaceChar_comma, " ").replaceAll(replaceChar_semicolon, " ");
        return queryStr.split("\\s+");
    }
}

上面的代碼是將web端傳入的字符串id，拼接成SQL中的字符串，採用${}替換符，將結果直接拼接到SQL語句中，完成SQL語句的查詢。sql

// List<Integer> getOrderIdsByParentIds(String parentIds);

在*MapperExt.java中定義了上述方法後，咱們在*MapperExt.xml中的代碼以下：數據庫

    <select id="getOrderIdsByParentIds" parameterType="java.lang.String" resultType="java.lang.Integer">
    　　SELECT
        　　DISTINCT order_id
    　　FROM
        　　idc_asset_list
    　　WHERE
        　　is_deleted = 'n'
    　　AND parent_order_id IN (${_parameter})
    </select>

注意咱們這裏的傳入參數是String，傳出參數是Integer類型，因爲是多個數據，因此用List來接收返回的數據。特別地，當有多個參數的時候，咱們可使用resultType="java.util.HashMap"。實例以下：express

    /**
     * 
    * @Title: getAllPermissions
    * @Description: 獲取全部的權限
    * @author： liupeng.lp@alibaba-inc.com
    * @Date: 2014年5月12日
     */
    @Override
    public DataResult<Map<String, Object>> getAllPermissions(
            PagePara pagePara,
            String permission_name) {
        Map<String, Object> _map_result = new HashMap<String, Object>();
        if(pagePara == null){
            pagePara = new PagePara();
            pagePara.setSkip(0);
            pagePara.setTake(10);
        }
        _map_result.put("begin", pagePara.getSkip());
        _map_result.put("length", pagePara.getTake());
        
        if(!StringUtil.isBlank(permission_name)){
            _map_result.put("permission_name", permission_name.trim());
        }
        DataResult<Map<String, Object>> dataResult = new DataResult<Map<String, Object>>();
        List<Map<String, Object>> dataRes = appPermissionMapperExt.getAllPermissions(_map_result);
        int count = appPermissionMapperExt.countAllPermissions(_map_result);
        dataResult.setCount(count);
        dataResult.setData(dataRes);
        return dataResult;
    }

其中關鍵代碼：List<Map<String, Object>> dataRes = appPermissionMapperExt.getAllPermissions(_map_result);傳入一個map結構，輸出一個map結構的數據。其*MapperExt.xml層代碼以下：數組

<SELECT id = "getAllPermissions" parameterType = "java.util.HashMap" resultType = "java.util.HashMap" > 
　　SELECT
        p.id,
        p.res_type AS permission_type,
        p.res_name AS permission_name
    FROM
        app_permission AS p
    WHERE
        p.is_deleted = 'n' 
    <IF test = "permission_name!=null" >
        AND p.res_name LIKE CONCAT('%', #{permission_name}, '%')
    </IF >
    ORDER BY
        CONVERT (p.res_name USING gbk)
    LIMIT #{begin},#{length}
</SELECT>

值得注意的是：resultType爲HashMap類型，使用了List<Map<String,Object>>來接收。此外，對於排序：數據庫中存儲res_name的字段採用的是utf8字符集，須要在排序的時候對字段進行轉碼，轉碼方式CONVERT (p.res_name USING gbk)。mybatis

3、BUG描述：標準的列表頁查詢代碼如何寫app

　　業務邏輯層的實現以下：

    /**
     * 分頁獲取工單列表
     * 
     * @return
     */
    @Override
    public DataResult<WorkOrderMain> queryOrderPagination(WorkOrderMain orderMain, PagePara pagePara) {
        DataResult<WorkOrderMain> dr = new DataResult<WorkOrderMain>();
        try {
            Map<String, Object> queryPara = getQueryPara(orderMain, pagePara);

            int count = assetUpDownMapperExt.selectAssetUpDownCnt(queryPara);
            List<WorkOrderMain> list = null;
            if (count > 0) {
                list = assetUpDownMapperExt.selectAssetUpDownOrder(queryPara);
                if (null != list) {
                    AssetUpDownOrderUtil.transValueForPage(list);
                    AssetUpDownOrderUtil.setWorkOrderSla(list);
                    AssetUpDownOrderUtil.setShowValue(list);
                }

            } else {
                list = new ArrayList<WorkOrderMain>();
            }
            dr.setData(list);
            dr.setCount(count);
        } catch (Exception e) {
            logger.error(" WorkOrderUpDownBoImpl_queryOrderPagination_error [orderMain={}]:",
                         JSON.toJSON(orderMain).toString(), e);
            throw new ServiceException(ErrorCode.Query_Error, e);
        }
        return dr;
    }

　　先count，而後再select，接着對查詢出來的數據轉義。對於*MapperExt中的查詢最好共用一個where來查詢，以下：

    <select id="selectAssetUpDownCnt" parameterType="java.util.HashMap" resultType="java.lang.Integer">
        select count(t.id) 
        <include refid="page_WhereSql"/>
    </select>

    <select id="selectAssetUpDownOrder" parameterType="java.util.HashMap" resultMap="assetUpDownMap">
        select t.id, t.title, t.category,t.order_device_type, t.subject, t.demander, t.is_atomic, t.atomic_id, t.operationer, 
               t.operation_role, t.state, t.sub_state, t.expect_time, t.sla, t.evaluation, t.creator, t.create_source, 
               t.source_key, t.gmt_create, t.modifier, t.gmt_modified, t.is_deleted, t.remark, t.parent_id,
               t.asset_total,t.sla_standard,t.sla_unit,t.effective_date,t.is_timeout,t.statement_date,t.finish_asset_total,t.identify_type,
               a.updown_id, a.asset_type, a.opt_type, a.take_over_time,a.site,a.site_name 
            <include refid="page_WhereSql"/>
            order by t.gmt_create desc
            limit #{begin},#{length}
    </select>

    <sql id="page_WhereSql">
        from idc_work_order_main t , idc_asset_updown a 
        where t.atomic_id =a.atomic_id and
            (
                <if test="showAll!=null">
                    ( t.creator = #{appUserId} and t.state = 'created') or (t.creator != #{appUserId} and t.state != 'created')
                </if>
                <if test="showAll==null">
                    t.creator = #{appUserId}  or t.operationer = #{workNo} 
                    <if test="sites!=null">
                        or( t.site in (${sites}) and t.state != 'created') 
                    </if>
                </if>
            )
        <if test = "title!=null">
            and t.title like CONCAT('%', #{title}, '%')
        </if>
        <if test = "startTime!=null">
            and t.effective_date &gt;= CONCAT(#{startTime},' 00:00:00')
        </if>
        <if test = "endTime!=null">
            and t.effective_date &lt;= CONCAT(#{endTime},' 23:59:59')
        </if>
        <if test = "queryIds!=null" >
            and t.id in (${queryIds})
        </if>
        <if test = "state!=null">
            and (t.state =#{state} or t.sub_state =#{state}) 
        </if>
        <if test ="isTimeout!=null">
            and t.is_timeout =#{isTimeout}
        </if>
        <if test ="evaluation!=null">
            and t.evaluation =#{evaluation}
        </if>
        <if test="siteName!=null">
            and a.site_name = #{siteName}
        </if>
        <if test ="assetType!=null">
            and a.asset_type =#{assetType}
        </if>
        <if test ="optType!=null">
            and a.opt_type =#{optType}
        </if>
        <if test ="orderDeviceType!=null">
            and t.order_device_type=#{orderDeviceType}
        </if>
        <if test ="parentId!=null">
            and t.parent_id=#{parentId}
        </if>
        <if test = "sourceKey!=null">
            and t.source_key in (${sourceKey})
        </if>
        <if test = "identifyType !=null and identifyType !=''">
            and t.identify_type =#{identifyType}
        </if>
        and t.is_deleted ='n'
        and t.subject='assetUpdown'
    </sql>

4、Spring手動開啓事務

　　手動控制事務在項目IDCM中的使用以下，首先在配置文件datasource.xml中作出以下配置：

    <bean id="transactionManager"
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    </bean>
    
    <tx:annotation-driven transaction-manager="transactionManager" />

　　此外，該配置文件還配置了其餘信息，以下：

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
 4     xmlns:context="http://www.springframework.org/schema/context"
 5     xmlns:aop="http://www.springframework.org/schema/aop"
 6     xmlns:tx="http://www.springframework.org/schema/tx"
 7     xsi:schemaLocation="
 8     http://www.springframework.org/schema/beans
 9     http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
10     http://www.springframework.org/schema/context
11     http://www.springframework.org/schema/context/spring-context-3.0.xsd
12     http://www.springframework.org/schema/aop 
13     http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
14     http://www.springframework.org/schema/tx 
15     http://www.springframework.org/schema/tx/spring-tx-3.0.xsd"
16     default-autowire="byName">
17 
18     <bean id="dataSource" class="com.taobao.tddl.jdbc.group.TGroupDataSource" init-method="init">
19         <property name="appName" value="IDCM_APP"/>
20         <property name="dbGroupKey" value="IDCM_GROUP"/>
21     </bean>
22 
23 
24     <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
25                 <property name="mapperLocations" value="classpath*:com/**/dal/**/*Mapper*.xml" /> 
26        <property name="dataSource" ref="dataSource" />
27         <property name="typeAliasesPackage" value="com.alibaba.***.dal" />
28     </bean>
29 
30     <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
31             <property name="annotationClass" value="javax.annotation.Resource"></property>
32         <property name="basePackage" value="com.alibaba.***.dal.***.mapper,com.alibaba.***.dal.***.***.mapper" />
33     </bean>
34 
35     <bean id="transactionManager"
36         class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
37     </bean>
38     
39     <tx:annotation-driven transaction-manager="transactionManager" />
40 
41     <context:annotation-config />    
42         <tx:advice id="defaultTxAdvice">
43         <tx:attributes>
44             <tx:method name="*" rollback-for="Exception" />
45         </tx:attributes>
46     </tx:advice>
47 
48     <aop:config>
49         <aop:pointcut id="ao_bo"
50             expression="(execution(* *..*BoImpl.*(..))) or ( execution(* *..*AoImpl.*(..)) and ( not execution(* *..*AoImpl.mtx_*(..)) ) )" />
51         <aop:advisor pointcut-ref="ao_bo" advice-ref="defaultTxAdvice" />
52     </aop:config>
53     
54     <context:component-scan base-package="com.alibaba.tboss.biz" />
55     
56 </beans>

datasource.xml配置文件

　　再須要使用手動事務的地方，使用方式以下：（事務的name不須要配置，先後約定一致就好）

import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;

public class TransactionManagerTest{
    @Autowired
    DataSourceTransactionManager                      transactionManager;

    private static final DefaultTransactionDefinition assetUpdateTx         = new DefaultTransactionDefinition();
    static {
        assetUpdateTx.setName("assetUpdateTx");
        assetUpdateTx.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
    }

    //測試方法
    public void test() {

        // 單獨開啓事務, 提交數據庫
        TransactionStatus status = transactionManager.getTransaction(assetUpdateTx);

        try{
            //TODO 業務邏輯
        } catch (Exception e) {
            logger.error("transactionManager-updateAssetList :", e.getMessage(), e);
            transactionManager.rollback(status);
            throw new ServiceException("更新數據失敗");
        }
        transactionManager.commit(status);
    }
}