MyBatis-Plus联表查询（mybatis-plus-join）

一、引入依赖

<dependency><groupId>com.baomidou</groupId><artifactId>dynamic-datasource-spring-boot-starter</artifactId><version>3.2.1</version>
</dependency><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.1</version>
</dependency><dependency><groupId>com.github.yulichang</groupId><artifactId>mybatis-plus-join</artifactId><version>1.2.4</version>
</dependency>

这里建议使用此版本！！！

二、修改yml文件

server:port: 10001spring:application:name: special_work_uploaddatasource:dynamic:primary: masterstrict: false # 是否启用严格模式,默认不启动. 严格模式下未匹配到数据源直接报错, 非严格模式下则使用默认数据源primary所设置的数据源datasource:master:url: jdbc:mysql://localhost:3306/enterprise_psm?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&useSSL=falseusername: # 用户名password: # 密码driver-class-name: com.mysql.cj.jdbc.Driverslave_1:url: jdbc:mysql://localhost:3306/enterprise_authorization?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&useSSL=falseusername: # 用户名password: # 密码driver-class-name: com.mysql.cj.jdbc.Driver
#
#mybatis-plus:
#  configuration:
#    # 这个配置会将执行的sql打印出来，在开发或测试的时候可以用
#    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

三、修改主启动类

添加@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})

四、自定义注解

@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@DS("master")
public @interface Master {
}

Slave也同样如此

五、添加Mapper类，指定数据源

@Mapper
@Slave
public interface UserMapper extends MPJBaseMapper<User> {
}

六、添加Service类以及其实现

public interface UserService extends IService<User> {/*** 获取分析人信息* @return*/List<AnalystVO> getAnalystList();
}

@Service
public class UserServiceImpl extends ServiceImpl<UserMapper,User> implements UserService {@Resourceprivate WorkJsaMapper workJsaMapper;@Overridepublic List<AnalystVO> getAnalystList() {List<AnalystVO> analystVOList = new ArrayList<>();List<Long> analystList = workJsaMapper.selectList(null).stream().map(WorkJsa::getAnalyst).collect(Collectors.toList());this.getBaseMapper().selectBatchIds(analystList).parallelStream().forEach(user -> {AnalystVO analystVO = new AnalystVO();analystVO.setAnalyst(user.getId());analystVO.setUserName(user.getNickName());analystVOList.add(analystVO);});return analystVOList;}
}