MyBatis初级实战之四：druid多数据源

Stella981
• 阅读 618

欢迎访问我的GitHub

https://github.com/zq2599/blog_demos
内容：所有原创文章分类汇总及配套源码，涉及Java、Docker、Kubernetes、DevOPS等；

关于druid多数据源

本文是《MyBatis初级实战》系列的第四篇，一个springboot应用同时操作两个数据库的场景，在平时也会遇到，今天要实战的就是通过druid配置两个数据源，让一个springboot应用同时使用这两个数据源；

多数据源配置的基本思路

  1. 首先要明确的是：数据源是通过配置类实现的，因此要去掉springboot中和数据源相关的自动装配；

  2. 最核心的问题有两个，第一个是确定表和数据源的关系，这个关系是在SqlSessionFactory实例中确立的，代码如下所示：

    @Bean(name = "secondSqlSessionFactory")
public SqlSessionFactory sqlSessionFactory(@Qualifier("secondDataSource") DataSource dataSource) throws Exception {



    SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    bean.setDataSource(dataSource);
    bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mappers/second/**/*Mapper.xml"));
    return bean.getObject();
}

  3. 第二个核心问题是包扫描，即指定的mapper接口要使用指定的sqlSessionTemplat，这个关系在SqlSessionTemplate配置类中(相当于旧版的xml配置bean)，如下图所示：
    MyBatis初级实战之四：druid多数据源

  4. 从上述代码可见，如果上层的业务代码想操作secondDataSource这个数据源的表，只要把对应的*Mapper.xml文件和Mapper接口文件对应的目录下即可；

  5. 整个配置的关键步骤如下图所示：
    MyBatis初级实战之四：druid多数据源

实战概览

本次实战的内容如下：

  1. 一共有两个数据库：mybatis和mybatis_second；
  2. mybatis中有名为user的表，mybatis_second中有名为address的表；
  3. 新建名为druidtwosource的springboot应用，里面有两个controller，可以分别对user、address这两个表进行操作；
  4. 编写单元测试用例，通过调用controller接口验证应用功能正常；
  5. 启动springboot应用，通过swagger验证功能正常；
  6. 进入druid监控页面；

源码下载

  1. 如果您不想编码，可以在GitHub下载所有源码，地址和链接信息如下表所示(https://github.com/zq2599/blog\_demos)：

名称

链接

备注

项目主页

https://github.com/zq2599/blog\_demos

该项目在GitHub上的主页

git仓库地址(https)

https://github.com/zq2599/blog\_demos.git

该项目源码的仓库地址，https协议

git仓库地址(ssh)

git@github.com:zq2599/blog_demos.git

该项目源码的仓库地址，ssh协议

  1. 这个git项目中有多个文件夹，本章的应用在mybatis文件夹下，如下图红框所示：
    MyBatis初级实战之四：druid多数据源

创建数据库和表

  1. 创建名为mybatis的数据库，建表语句如下：

    DROP TABLE IF EXISTS user;

    CREATE TABLE user ( id int(32) NOT NULL AUTO_INCREMENT, name varchar(32) NOT NULL, age int(32) NOT NULL, PRIMARY KEY (id) ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;

  2. 创建名为mybatis_second的数据库，建表语句如下：

    DROP TABLE IF EXISTS address;

    CREATE TABLE address ( id int(32) NOT NULL AUTO_INCREMENT, city varchar(32) NOT NULL, street varchar(32) NOT NULL, PRIMARY KEY (id) ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;

编码

  1. 前文《MyBatis初级实战之一：Spring Boot集成》创建了父工程mybatis，本文继续在此工程中新增子工程，名为druidtwosource，先提前看整个子工程文件结构，如下图，要注意的是红框1中的mapper接口，以及红框2中的mapper映射文件，这两处都按照数据库的不同放入各自文件夹：
    MyBatis初级实战之四：druid多数据源

  2. druidtwosource工程的pom.xml内容如下：

    4.0.0 com.bolingcavalry mybatis 1.0-SNAPSHOT ../pom.xml com.bolingcavalry druidtwosource 0.0.1-SNAPSHOT druidtwosource Demo project for Mybatis Druid (two datasource) in Spring Boot <java.version>1.8</java.version> org.springframework.boot spring-boot-starter-web org.mybatis.spring.boot mybatis-spring-boot-starter mysql mysql-connector-java runtime org.springframework.boot spring-boot-starter-test test org.junit.vintage junit-vintage-engine io.springfox springfox-swagger2 io.springfox springfox-swagger-ui com.alibaba druid-spring-boot-starter junit junit test com.google.code.gson gson org.springframework.boot spring-boot-maven-plugin

  3. 配置文件application.yml，可见这里面有first和second两个数据源配置，而druid的web-stat-filter和stat-view-servlet这两个配置是公用的：

    server: port: 8080

    spring: #1.JDBC数据源 datasource: druid: first: username: root password: 123456 url: jdbc:mysql://192.168.50.43:3306/mybatis?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC driver-class-name: com.mysql.cj.jdbc.Driver #初始化连接池的连接数量 大小，最小，最大 initial-size: 5 min-idle: 5 max-active: 20 #配置获取连接等待超时的时间 max-wait: 60000 #配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 time-between-eviction-runs-millis: 60000 # 配置一个连接在池中最小生存的时间，单位是毫秒 min-evictable-idle-time-millis: 30000 # 配置一个连接在池中最大生存的时间，单位是毫秒 max-evictable-idle-time-millis: 300000 validation-query: SELECT 1 FROM user test-while-idle: true test-on-borrow: true test-on-return: false # 是否缓存preparedStatement，也就是PSCache 官方建议MySQL下建议关闭 个人建议如果想用SQL防火墙 建议打开 pool-prepared-statements: true max-pool-prepared-statement-per-connection-size: 20 # 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙 filters: stat,wall,slf4j filter: stat: merge-sql: true slow-sql-millis: 5000 second: username: root password: 123456 url: jdbc:mysql://192.168.50.43:3306/mybatis_second?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC driver-class-name: com.mysql.cj.jdbc.Driver #初始化连接池的连接数量 大小，最小，最大 initial-size: 5 min-idle: 5 max-active: 20 #配置获取连接等待超时的时间 max-wait: 60000 #配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 time-between-eviction-runs-millis: 60000 # 配置一个连接在池中最小生存的时间，单位是毫秒 min-evictable-idle-time-millis: 30000 # 配置一个连接在池中最大生存的时间，单位是毫秒 max-evictable-idle-time-millis: 300000 validation-query: SELECT 1 FROM user test-while-idle: true test-on-borrow: true test-on-return: false # 是否缓存preparedStatement，也就是PSCache 官方建议MySQL下建议关闭 个人建议如果想用SQL防火墙 建议打开 pool-prepared-statements: true max-pool-prepared-statement-per-connection-size: 20 # 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙 filters: stat,wall,slf4j filter: stat: merge-sql: true### slow-sql-millis: 5000 #3.基础监控配置 web-stat-filter: enabled: true url-pattern: /* #设置不统计哪些URL exclusions: ".js,.gif,.jpg,.png,.css,.ico,/druid/" session-stat-enable: true session-stat-max-count: 100 stat-view-servlet: enabled: true url-pattern: /druid/ reset-enable: true #设置监控页面的登录名和密码 login-username: admin login-password: admin allow: 127.0.0.1 #deny: 192.168.1.100

    日志配置

    logging: level: root: INFO com: bolingcavalry: druidtwosource: mapper: debug

  4. user的映射配置，请注意文件位置：

    <!--新增单条记录-->
<insert id="insertWithFields" useGeneratedKeys="true" keyProperty="id">
    insert into user (id, name, age) values (#{id}, #{name}, #{age})
</insert>

<!--按照名称查找-->
<select id="findByName" parameterType="String" resultType="com.bolingcavalry.druidtwosource.entity.User">
    select id, name, age from user where name like concat('%', #{name}, '%')
</select>

<!--删除指定数据-->
<delete id="delete">
    delete from user where id= #{id}
</delete>

  5. address的映射配置：

    <!--新增单条记录-->
<insert id="insertWithFields" useGeneratedKeys="true" keyProperty="id">
    insert into address (id, city, street) values (#{id}, #{city}, #{street})
</insert>

<!--按照名称查找-->
<select id="findByCityName" parameterType="String" resultType="com.bolingcavalry.druidtwosource.entity.Address">
    select id, city, street from address where city like concat('%', #{cityname}, '%')
</select>

<!--删除指定数据-->
<delete id="delete">
    delete from address where id= #{id}
</delete>

  6. user表的实体类，注意swagger用到的注解：

    package com.bolingcavalry.druidtwosource.entity;

    import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty;

    @ApiModel(description = "用户实体类") public class User {

    @ApiModelProperty(value = "用户ID")
private Integer id;

@ApiModelProperty(value = "用户名", required = true)
private String name;

@ApiModelProperty(value = "用户地址", required = false)
private Integer age;

@Override
public String toString() {



    return "User{" +
            "id=" + id +
            ", name='" + name + '\'' +
            ", age=" + age +
            '}';
}
...省略get和set方法

    }

  7. address表的实体类：

    package com.bolingcavalry.druidtwosource.entity;

    import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty;

    @ApiModel(description = "地址实体类") public class Address {

    @ApiModelProperty(value = "地址ID")
private Integer id;

@ApiModelProperty(value = "城市名", required = true)
private String city;

@ApiModelProperty(value = "街道名", required = true)
private String street;

@Override
public String toString() {



    return "Address{" +
            "id=" + id +
            ", city='" + city + '\'' +
            ", street='" + street + '\'' +
            '}';
}
...省略get和set方法

    }

  8. 启动类DuridTwoSourceApplication.java，要注意的是排除掉数据源和事务的自动装配，因为后面会手动编码执行这些配置：

    package com.bolingcavalry.druidtwosource;

    import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; import org.springframework.boot.autoconfigure.jdbc.DataSourceTransactionManagerAutoConfiguration;

    @SpringBootApplication(exclude={

        DataSourceAutoConfiguration.class,
    DataSourceTransactionManagerAutoConfiguration.class,

    }) public class DuridTwoSourceApplication {

    public static void main(String[] args) {



    SpringApplication.run(DuridTwoSourceApplication.class, args);
}

    }

  9. swagger配置：

    package com.bolingcavalry.druidtwosource;

    import springfox.documentation.service.Contact; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import springfox.documentation.builders.ApiInfoBuilder; import springfox.documentation.builders.PathSelectors; import springfox.documentation.builders.RequestHandlerSelectors; import springfox.documentation.service.ApiInfo; import springfox.documentation.service.Tag; import springfox.documentation.spi.DocumentationType; import springfox.documentation.spring.web.plugins.Docket; import springfox.documentation.swagger2.annotations.EnableSwagger2;

    /**

    • @Description: swagger配置类
    • @author: willzhao E-mail: zq2599@gmail.com
    • @date: 2020/8/11 7:54

    */ @Configuration @EnableSwagger2 public class SwaggerConfig {

    @Bean
public Docket createRestApi() {



    return new Docket(DocumentationType.SWAGGER_2)
            .apiInfo(apiInfo())
            .tags(new Tag("UserController", "用户服务"),
                    new Tag("AddressController", "地址服务"))
            .select()
            // 当前包路径
            .apis(RequestHandlerSelectors.basePackage("com.bolingcavalry.druidtwosource.controller"))
            .paths(PathSelectors.any())
            .build();
}

//构建 api文档的详细信息函数,注意这里的注解引用的是哪个
private ApiInfo apiInfo() {



    return new ApiInfoBuilder()
            //页面标题
            .title("MyBatis CURD操作")
            //创建人
            .contact(new Contact("程序员欣宸", "https://github.com/zq2599/blog_demos", "zq2599@gmail.com"))
            //版本号
            .version("1.0")
            //描述
            .description("API 描述")
            .build();
}

    }

  10. 数据源配置TwoDataSourceConfig.java，可见是通过ConfigurationProperties注解来确定配置信息，另外不要忘记在默认数据源上添加Primary注解：

    package com.bolingcavalry.druidtwosource;

    import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Primary;

    import javax.sql.DataSource;

    /**

    • @Description: druid配置类
    • @author: willzhao E-mail: zq2599@gmail.com
    • @date: 2020/8/18 08:12

    */ @Configuration public class TwoDataSourceConfig {

    @Primary
@Bean(name = "firstDataSource")
@ConfigurationProperties("spring.datasource.druid.first")
public DataSource first() {



    return DruidDataSourceBuilder.create().build();
}

@Bean(name = "secondDataSource")
@ConfigurationProperties("spring.datasource.druid.second")
public DataSource second() {



    return DruidDataSourceBuilder.create().build();
}

    }

  11. 第一个数据源的mybatis配置类DruidConfigFirst.java，可以结合本篇的第一幅图来看，注意MapperScan注解的两个属性basePackages和sqlSessionTemplateRef是关键，它们最终决定了哪些mapper接口使用哪个数据源，另外注意要带上Primary注解：

    package com.bolingcavalry.druidtwosource;

    import org.apache.ibatis.session.SqlSessionFactory; import org.mybatis.spring.SqlSessionFactoryBean; import org.mybatis.spring.SqlSessionTemplate; import org.mybatis.spring.annotation.MapperScan; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Primary; import org.springframework.core.io.support.PathMatchingResourcePatternResolver; import org.springframework.jdbc.datasource.DataSourceTransactionManager;

    import javax.sql.DataSource;

    /**

    • @Description: druid配置类
    • @author: willzhao E-mail: zq2599@gmail.com
    • @date: 2020/8/18 08:12

    */ @Configuration @MapperScan(basePackages = "com.bolingcavalry.druidtwosource.mapper.first", sqlSessionTemplateRef = "firstSqlSessionTemplate") public class DruidConfigFirst {

    @Bean(name = "firstSqlSessionFactory")
@Primary
public SqlSessionFactory sqlSessionFactory(@Qualifier("firstDataSource") DataSource dataSource) throws Exception {



    SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    bean.setDataSource(dataSource);
    bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mappers/first/**/*Mapper.xml"));
    return bean.getObject();
}

@Bean(name = "firstTransactionManager")
@Primary
public DataSourceTransactionManager transactionManager(@Qualifier("firstDataSource") DataSource dataSource) {



    return new DataSourceTransactionManager(dataSource);
}

@Bean(name = "firstSqlSessionTemplate")
@Primary
public SqlSessionTemplate sqlSessionTemplate(@Qualifier("firstSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {



    return new SqlSessionTemplate(sqlSessionFactory);
}

    }

  12. 第二个数据源的mybatis配置DruidConfigSecond.java，注意不要带Primary注解：

package com.bolingcavalry.druidtwosource;

import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;

/**
 * @Description: druid配置类
 * @author: willzhao E-mail: zq2599@gmail.com
 * @date: 2020/8/18 08:12
 */
@Configuration
@MapperScan(basePackages = "com.bolingcavalry.druidtwosource.mapper.second", sqlSessionTemplateRef  = "secondSqlSessionTemplate")
public class DruidConfigSecond {
   
   
   

    @Bean(name = "secondSqlSessionFactory")
    public SqlSessionFactory sqlSessionFactory(@Qualifier("secondDataSource") DataSource dataSource) throws Exception {
   
   
   
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mappers/second/**/*Mapper.xml"));
        return bean.getObject();
    }

    @Bean(name = "secondTransactionManager")
    public DataSourceTransactionManager transactionManager(@Qualifier("secondDataSource") DataSource dataSource) {
   
   
   
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean(name = "secondSqlSessionTemplate")
    public SqlSessionTemplate sqlSessionTemplate(@Qualifier("secondSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
   
   
   
        return new SqlSessionTemplate(sqlSessionFactory);
    }

}
  1. user表的mapper接口类很简单，只有三个接口，注意package位置：
package com.bolingcavalry.druidtwosource.mapper.first;

import com.bolingcavalry.druidtwosource.entity.User;
import org.springframework.stereotype.Repository;

import java.util.List;

@Repository
public interface UserMapper {
   
   
   

    int insertWithFields(User user);

    List<User> findByName(String name);

    int delete(int id);
}
  1. address表的Mapper接口类：
package com.bolingcavalry.druidtwosource.mapper.second;

import com.bolingcavalry.druidtwosource.entity.Address;
import org.springframework.stereotype.Repository;

import java.util.List;

/**
 * @Description: 地址实体的接口类
 * @author: willzhao E-mail: zq2599@gmail.com
 * @date: 2020/8/4 8:32
 */

@Repository
public interface AddressMapper {
   
   
   

    int insertWithFields(Address address);

    List<Address> findByCityName(String cityName);

    int delete(int id);

}
  1. user表的service类：
package com.bolingcavalry.druidtwosource.service;

import com.bolingcavalry.druidtwosource.entity.User;
import com.bolingcavalry.druidtwosource.mapper.first.UserMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;

public class UserService {
   
   
   
    @Autowired
    UserMapper userMapper;

    public User insertWithFields(User user) {
   
   
   
        userMapper.insertWithFields(user);
        return user;
    }

    public List<User> findByName(String name) {
   
   
   
        return userMapper.findByName(name);
    }

    public int delete(int id) {
   
   
   
        return userMapper.delete(id);
    }

}
  1. address表的service类：
package com.bolingcavalry.druidtwosource.service;

import com.bolingcavalry.druidtwosource.entity.Address;
import com.bolingcavalry.druidtwosource.entity.User;
import com.bolingcavalry.druidtwosource.mapper.first.UserMapper;
import com.bolingcavalry.druidtwosource.mapper.second.AddressMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;

@Service
public class AddressService {
   
   
   

    @Autowired
    AddressMapper addressMapper;

    public Address insertWithFields(Address address) {
   
   
   
        addressMapper.insertWithFields(address);
        return address;
    }

    public List<Address> findByCityName(String cityName) {
   
   
   
        return addressMapper.findByCityName(cityName);
    }

    public int delete(int id) {
   
   
   
        return addressMapper.delete(id);
    }

}
  1. user表的controller：
package com.bolingcavalry.druidtwosource.controller;

import com.bolingcavalry.druidtwosource.entity.User;
import com.bolingcavalry.druidtwosource.service.UserService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;

@RestController
@RequestMapping("/user")
@Api(tags = {
   
   
   "UserController"})
public class UserController {
   
   
   

    @Autowired
    private UserService userService;

    @ApiOperation(value = "新增user记录", notes="新增user记录")
    @RequestMapping(value = "/insertwithfields",method = RequestMethod.PUT)
    public User create(@RequestBody User user) {
   
   
   
        return userService.insertWithFields(user);
    }

    @ApiOperation(value = "删除指定ID的user记录", notes="删除指定ID的user记录")
    @ApiImplicitParam(name = "id", value = "用户ID", paramType = "path", required = true, dataType = "Integer")
    @RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
    public int delete(@PathVariable int id){
   
   
   
        return userService.delete(id);
    }

    @ApiOperation(value = "根据名称模糊查找所有user记录", notes="根据名称模糊查找所有user记录")
    @ApiImplicitParam(name = "name", value = "用户名", paramType = "path", required = true, dataType = "String")
    @RequestMapping(value = "/findbyname/{name}", method = RequestMethod.GET)
    public List<User> findByName(@PathVariable("name") String name){
   
   
   
        return userService.findByName(name);
    }
}
  1. address表的controller：
package com.bolingcavalry.druidtwosource.controller;

import com.bolingcavalry.druidtwosource.entity.Address;
import com.bolingcavalry.druidtwosource.service.AddressService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;

/**
 * @Description: user表操作的web接口
 * @author: willzhao E-mail: zq2599@gmail.com
 * @date: 2020/8/4 8:31
 */
@RestController
@RequestMapping("/address")
@Api(tags = {
   
   
   "AddressController"})
public class AddressController {
   
   
   

    @Autowired
    private AddressService addressService;


    @ApiOperation(value = "新增address记录", notes="新增address记录")
    @RequestMapping(value = "/insertwithfields",method = RequestMethod.PUT)
    public Address create(@RequestBody Address address) {
   
   
   
        return addressService.insertWithFields(address);
    }

    @ApiOperation(value = "删除指定ID的address记录", notes="删除指定ID的address记录")
    @ApiImplicitParam(name = "id", value = "地址ID", paramType = "path", required = true, dataType = "Integer")
    @RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
    public int delete(@PathVariable int id){
   
   
   
        return addressService.delete(id);
    }

    @ApiOperation(value = "根据城市名模糊查找所address记录", notes="根据城市名模糊查找所address记录")
    @ApiImplicitParam(name = "name", value = "城市名", paramType = "path", required = true, dataType = "String")
    @RequestMapping(value = "/findbycityname/{cityname}", method = RequestMethod.GET)
    public List<Address> findByName(@PathVariable("cityname") String cityName){
   
   
   
        return addressService.findByCityName(cityName);
    }
}
  • 至此，编码完成，接下来编写单元测试代码；

单元测试

  1. 新增配置文件application-test.yml，其内容仅有下图红框位置与application.yml不同，其他的全部一致：
    MyBatis初级实战之四：druid多数据源

  2. user表的测试用例如下：

    package com.bolingcavalry.druidtwosource.controller;

    import com.bolingcavalry.druidtwosource.entity.User; import com.google.gson.Gson; import com.google.gson.JsonArray; import com.google.gson.JsonParser; import org.junit.jupiter.api.*; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.http.MediaType; import org.springframework.test.context.ActiveProfiles; import org.springframework.test.context.junit4.SpringRunner; import org.springframework.test.web.servlet.MockMvc; import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;

    import java.util.UUID;

    import static org.hamcrest.Matchers.hasSize; import static org.hamcrest.Matchers.is; import static org.hamcrest.core.IsEqual.equalTo; import static org.springframework.test.web.servlet.result.MockMvcResultHandlers.print; import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.*;

    /**

    • @Description: 单元测试类
    • @author: willzhao E-mail: zq2599@gmail.com
    • @date: 2020/8/9 23:55

    */ @RunWith(SpringRunner.class) @SpringBootTest @AutoConfigureMockMvc @TestMethodOrder(MethodOrderer.OrderAnnotation.class) @ActiveProfiles("test") class UserControllerTest {

    @Autowired
private MockMvc mvc;

// user表的name字段，这里为了保证测试时新增和删除的记录是同一条，用UUID作为用户名
static String testName;

@BeforeAll
static void init() {



    testName = UUID.randomUUID().toString().replaceAll("-","");
}

@Test
@Order(1)
void insertWithFields() throws Exception {



    String jsonStr = "{\"name\": \"" + testName + "\", \"age\": 10}";

    mvc.perform(
            MockMvcRequestBuilders.put("/user/insertwithfields")
                    .contentType(MediaType.APPLICATION_JSON)
                    .content(jsonStr)
                    .accept(MediaType.APPLICATION_JSON))
            .andExpect(status().isOk())
            .andExpect(jsonPath("$.name", is(testName)))
            .andDo(print())
            .andReturn()
            .getResponse()
            .getContentAsString();
}

@Test
@Order(2)
void findByName() throws Exception {



    mvc.perform(MockMvcRequestBuilders.get("/user/findbyname/"+ testName).accept(MediaType.APPLICATION_JSON))
            .andExpect(status().isOk())
            .andExpect(jsonPath("$", hasSize(1)))
            .andDo(print());
}


@Test
@Order(3)
void delete() throws Exception {



    // 先根据名称查出记录
    String responseString = mvc.perform(MockMvcRequestBuilders.get("/user/findbyname/"+ testName).accept(MediaType.APPLICATION_JSON))
            .andExpect(status().isOk())
            .andExpect(jsonPath("$", hasSize(1)))
            .andDo(print())
            .andReturn()
            .getResponse()
            .getContentAsString();

    // 反序列化得到数组
    JsonArray jsonArray = JsonParser.parseString(responseString).getAsJsonArray();

    // 反序列化得到user实例
    User user = new Gson().fromJson(jsonArray.get(0), User.class);

    // 执行删除
    mvc.perform(MockMvcRequestBuilders.delete("/user/"+ user.getId()).accept(MediaType.APPLICATION_JSON))
            .andExpect(status().isOk())
            .andExpect(content().string(equalTo("1")))
            .andDo(print());
}

    }

  3. address表的单元测试如下：

    package com.bolingcavalry.druidtwosource.controller;

    import com.bolingcavalry.druidtwosource.entity.Address; import com.google.gson.Gson; import com.google.gson.JsonArray; import com.google.gson.JsonParser; import org.junit.jupiter.api.*; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.http.MediaType; import org.springframework.test.context.ActiveProfiles; import org.springframework.test.context.junit4.SpringRunner; import org.springframework.test.web.servlet.MockMvc; import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;

    import java.util.UUID;

    import static org.hamcrest.Matchers.hasSize; import static org.hamcrest.Matchers.is; import static org.hamcrest.core.IsEqual.equalTo; import static org.springframework.test.web.servlet.result.MockMvcResultHandlers.print; import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.*;

    @RunWith(SpringRunner.class) @SpringBootTest @AutoConfigureMockMvc @TestMethodOrder(MethodOrderer.OrderAnnotation.class) @ActiveProfiles("test") class AddrestControllerTest {

    @Autowired
private MockMvc mvc;

// address表的cityName字段，这里为了保证测试时新增和删除的记录是同一条，用UUID作为用户名
static String testCityName;

@BeforeAll
static void init() {



    testCityName = UUID.randomUUID().toString().replaceAll("-","");
}

@Test
@Order(1)
void insertWithFields() throws Exception {



    String jsonStr = "{\"city\": \"" + testCityName + "\", \"street\": \"streetName\"}";

    mvc.perform(
            MockMvcRequestBuilders.put("/address/insertwithfields")
                    .contentType(MediaType.APPLICATION_JSON)
                    .content(jsonStr)
                    .accept(MediaType.APPLICATION_JSON))
            .andExpect(status().isOk())
            .andExpect(jsonPath("$.city", is(testCityName)))
            .andDo(print())
            .andReturn()
            .getResponse()
            .getContentAsString();
}

@Test
@Order(2)
void findByName() throws Exception {



    mvc.perform(MockMvcRequestBuilders.get("/address/findbycityname/"+ testCityName).accept(MediaType.APPLICATION_JSON))
            .andExpect(status().isOk())
            .andExpect(jsonPath("$", hasSize(1)))
            .andDo(print());
}


@Test
@Order(3)
void delete() throws Exception {



    // 先根据名称查出记录
    String responseString = mvc.perform(MockMvcRequestBuilders.get("/address/findbycityname/"+ testCityName).accept(MediaType.APPLICATION_JSON))
            .andExpect(status().isOk())
            .andExpect(jsonPath("$", hasSize(1)))
            .andDo(print())
            .andReturn()
            .getResponse()
            .getContentAsString();

    // 反序列化得到数组
    JsonArray jsonArray = JsonParser.parseString(responseString).getAsJsonArray();

    // 反序列化得到user实例
    Address address = new Gson().fromJson(jsonArray.get(0), Address.class);

    // 执行删除
    mvc.perform(MockMvcRequestBuilders.delete("/address/"+ address.getId()).accept(MediaType.APPLICATION_JSON))
            .andExpect(status().isOk())
            .andExpect(content().string(equalTo("1")))
            .andDo(print());
}

    }

  • 至此，编码完成，而可以开始验证了；

验证，单元测试

  1. user表对应的单元测试操作如下图，三个测试方法先后新增记录，查询记录，然后删除掉：
    MyBatis初级实战之四：druid多数据源
  2. AddrestControllerTest也按照上图做同样的操作；

验证，swagger

  1. 浏览器访问：http://localhost:8080/swagger-ui.html ，会展示swagger页面如下：
    MyBatis初级实战之四：druid多数据源
  2. 先来试试新增操作：
    MyBatis初级实战之四：druid多数据源
  3. 返回数据如下图：
    MyBatis初级实战之四：druid多数据源
  4. 以下是用MySQL数据库客户端工具查看到的mybatis.user表的数据，可见服务功能正常：
    MyBatis初级实战之四：druid多数据源
  5. 其他接口请自行操作验证；

进入druid监控页面

  1. druid监控页面地址是：http://localhost:8080/druid ， 账号密码都是admin：
    MyBatis初级实战之四：druid多数据源
  2. 登录后可见数据库操作：
    MyBatis初级实战之四：druid多数据源
  3. 在数据源页面可以见到两个数据源，如下图：
    MyBatis初级实战之四：druid多数据源
    MyBatis初级实战之四：druid多数据源
  • 以上就是完整的springboot+mybatis+druid多数据源开发和验证过程，希望能给您一些参考；

欢迎关注我的公众号：程序员欣宸

MyBatis初级实战之四：druid多数据源

本文同步分享在 博客“程序员欣宸”（CSDN）。
如有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一起分享。

mybatisdruidspringfoxdeletebeanmapperstat前端前端
点赞
收藏
评论区
推荐文章
blmius blmius
•
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时，报错：原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等，这样可以更容易地在不同的环境中使用MySQL。全局s
4134
0
0
Easter79 Easter79
•
3年前
swap空间的增减方法
（1）增大swap空间去激活swap交换区：swapoff v /dev/vg00/lvswap扩展交换lv：lvextend L 10G /dev/vg00/lvswap重新生成swap交换区：mkswap /dev/vg00/lvswap激活新生成的交换区：swapon v /dev/vg00/lvswap
1269
0
0
helloworld_34035044 helloworld_34035044
•
2年前
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时，如何在新增行里自动增加id呢？能新增整数排序id吗？目前可以在新增行里自动增加id，但只能用uuid函数增加UUID编码，不能新增整数排序id。uuid函数说明：获取一个UUID，可以在填报表中用来创建数据ID语法：uuid()或uuid(sep)参数说明：sep布尔值，生成的uuid中是否包含分隔符''，缺省为
1150
0
0
Jacquelyn38 Jacquelyn38
•
3年前
2020年前端实用代码段，为你的工作保驾护航
有空的时候，自己总结了几个代码段，在开发中也经常使用，谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
2390
0
0
Wesley13 Wesley13
•
3年前
Java获得今日零时零分零秒的时间（Date型）
publicDatezeroTime()throwsParseException{    DatetimenewDate();    SimpleDateFormatsimpnewSimpleDateFormat("yyyyMMdd00:00:00");    SimpleDateFormatsimp2newS
1261
0
0
Wesley13 Wesley13
•
3年前
mysql设置时区
mysql设置时区mysql\_query("SETtime\_zone'8:00'")ordie('时区设置失败，请联系管理员！');中国在东8区所以加8方法二：selectcount(user\_id)asdevice,CONVERT\_TZ(FROM\_UNIXTIME(reg\_time),'08:00','0
1320
0
0
Wesley13 Wesley13
•
3年前
Java日期时间API系列36
　　十二时辰，古代劳动人民把一昼夜划分成十二个时段，每一个时段叫一个时辰。二十四小时和十二时辰对照表：时辰时间24时制子时深夜11：00凌晨01：0023：0001：00丑时上午01：00上午03：0001：0003：00寅时上午03：00上午0
1219
0
0
Wesley13 Wesley13
•
3年前
00：Java简单了解
浅谈Java之概述Java是SUN(StanfordUniversityNetwork)，斯坦福大学网络公司)1995年推出的一门高级编程语言。Java是一种面向Internet的编程语言。随着Java技术在web方面的不断成熟，已经成为Web应用程序的首选开发语言。Java是简单易学，完全面向对象，安全可靠，与平台无关的编程语言。
1259
0
0
Stella981 Stella981
•
3年前
Django中Admin中的一些参数配置
设置在列表中显示的字段，id为django模型默认的主键list_display('id','name','sex','profession','email','qq','phone','status','create_time')设置在列表可编辑字段list_editable
1177
0
0
Wesley13 Wesley13
•
3年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
1527
0
0
Python进阶者 Python进阶者
•
10个月前
Excel中这日期老是出来00：00：00，怎么用Pandas把这个去除
大家好，我是皮皮。一、前言前几天在Python白银交流群【上海新年人】问了一个Pandas数据筛选的问题。问题如下：这日期老是出来00：00：00，怎么把这个去除。二、实现过程后来【论草莓如何成为冻干莓】给了一个思路和代码如下：pd.toexcel之前把这
512
0
0
Stella981
Stella981
Lv1
接天莲叶无穷碧，映日荷花别样红。
文章
1.7w
粉丝
42
获赞
28
热门文章
OpenVPN下载、安装、配置及使用详解
GitHub神器，一个可以白嫖全网无损音乐的神器
OpenWrt 路由器过滤广告的N种方法
Python—执行系统命令的四种方法（os.system、os.popen、commands、subprocess）
SS端加密以及obfs混淆