编辑推荐

网易数帆开源API网关与容器云项目，让云原生生产落地“多快好

网易汪源：统一负载与多云环境的“开放姿态”，才是云原生

网易数帆如何用 Kubernetes“原语”搞定云原生中间件

快手打新挤爆券商系统，网易数帆推出券商稳定性保障方案

探索智慧校园新模式，网易有数在教育行业的实践分享

金融行业大数据治理之路——数据模型篇

Kaola-Dubbo-Test工程引入MyBatis相关改动

达芬奇密码2018-08-06 09:19

1、目的

Dubbo接口测试中希望方便快捷的校验比对接口返回数据与数据库的实际存储值，将实际SQL语句和接口测试代码分离；

什么是 MyBatis ？参考文档

MyBatis 是一款优秀的持久层框架，它支持定制化 SQL、存储过程以及高级映射。MyBatis 避免了几乎所有的 JDBC 代码和手动设置参数以及获取结果集。MyBatis 可以使用简单的 XML 或注解来配置和映射原生信息，将接口和 Java 的 POJOs(Plain Old Java Objects,普通的 Java对象)映射成数据库中的记录。

2、过程：

（1）pom.xml添加相关maven依赖

<dependency>
    <groupId>org.mybatis</groupId>
    <artifactId>mybatis</artifactId>
    <version>3.2.7</version>
</dependency>
<dependency>
    <groupId>org.mybatis</groupId>
    <artifactId>mybatis-spring</artifactId>
    <version>1.2.2</version>
</dependency>

（2）Resource资源目录下添加数据库连接配置及对应的属性值配置

applicationContext_database_inventory.xml:

<bean id="inventoryDataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
    <property name="username" value="${jdbc.inventory.username}" />
    <property name="password" value="${jdbc.inventory.password}" />
    <property name="driverClassName" value="${jdbc.common.driverClassName}" />
    <property name="url" value="${jdbc.inventory.url}" />
    <property name="maxActive" value="${jdbc.inventory.maximumConnectionCount}"/>
    <property name="initialSize" value="${jdbc.inventory.minimumConnectionCount}"/>
    <property name="minIdle" value="${jdbc.inventory.minimumConnectionCount}"/>

oracle.properties:

# inventory
jdbc.inventory.url=jdbc:oracle:thin:@(DESCRIPTION =(ADDRESS_LIST ...
jdbc.inventory.username=global_app
jdbc.inventory.password=jReSebMb9Finw
jdbc.inventory.maximumConnectionCount=10
jdbc.inventory.minimumConnectionCount=2
jdbc.inventory.houseKeepingTestSql=select sysdate from DUAL
jdbc.inventory.readonly.url=jdbc:oracle:thin:@(DESCRIPTION =(ADDRESS_LIST...

（3）编写dao文件（com.netease.qa.dao.InventoryDao）

public interface InventoryDao {
    List<Inventory> getInventoryBySkuId(@Param("skuId") String skuId);
    List<Inventory> getInventoryBySkuIdFromYZ(@Param("skuId") String skuId);
}

（4）dao对应XML文件，实际的SQL语句（Kaola-Dubbo-Test/src/main/resources/mappers/InventoryDao.xml）

<mapper namespace="com.netease.qa.dao.InventoryDao">
    <select id="getInventoryBySkuId" parameterType="String" resultMap="inventoryMap">
        SELECT *
        FROM GLOBAL_PRODUCT.TB_INVENTORY
        WHERE SKU_Id =#{skuId}
    </select>
</mapper>

（5）实际dubbo接口测试中调用（com.netease.qa.dubboTest.inventory.ShadowTest）

public class ShadowTest extends BaseDubboTest {
    @Resource
    private StoreForOnlineFacade storeForOnlineFacade;
    @Resource
    private InventoryDao inventoryDao;   //依赖注入

    Long goodsId = 59081265L;
    String skuId = "59081265-ecc4090b639c47f89b453980923afb8e";

    @Test
    public void shadowTest_trace() throws InvException {
        List resultList = storeForOnlineFacade.queryInvBySkuIds(skuId);
        Assert.assertNotNull(resultList);
        Assert.assertTrue(resultList.get(0).getStore().equals(inventoryDao.getInventoryBySkuId(skuId).get(0).getStore()));  //dao调用
}