<!-- Spring Boot Mybatis 依赖 -->
<dependency>
 <groupId>org.mybatis.spring.boot</groupId>
 <artifactId>mybatis-spring-boot-starter</artifactId>
 <version>1.2.0</version>
</dependency>

<!-- MySQL 连接驱动依赖 -->
<dependency>
 <groupId>mysql</groupId>
 <artifactId>mysql-connector-java</artifactId>
 <version>5.1.39</version>
</dependency>

<!-- Druid 数据连接池依赖 -->
<dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>druid</artifactId>
 <version>1.0.18</version>
</dependency>

# master 数据源配置
master.datasource.url=jdbc:mysql://localhost:3306/springbootdb?useUnicode=true&characterEncoding=utf8
master.datasource.username=root
master.datasource.password=xieshuai6666
master.datasource.driverClassName=com.mysql.jdbc.Driver

# second 数据源配置
second.datasource.url=jdbc:mysql://localhost:3306/springbootdb_second?useUnicode=true&characterEncoding=utf8
second.datasource.username=root
second.datasource.password=xieshuai6666
second.datasource.driverClassName=com.mysql.jdbc.Driver

@Configuration
// 扫描 Mapper 接口并容器管理
@MapperScan(basePackages = MasterDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "masterSqlSessionFactory")
public class MasterDataSourceConfig {

  // 精确到 master 目录，以便跟其他数据源隔离
  static final String PACKAGE = "org.spring.springboot.dao.master";
  static final String MAPPER_LOCATION = "classpath:mapper/master/*.xml";

  @Value("${master.datasource.url}")
  private String url;

  @Value("${master.datasource.username}")
  private String user;

  @Value("${master.datasource.password}")
  private String password;

  @Value("${master.datasource.driverClassName}")
  private String driverClass;

  @Bean(name = "masterDataSource")
  @Primary
  public DataSource masterDataSource() {
    DruidDataSource dataSource = new DruidDataSource();
    dataSource.setDriverClassName(driverClass);
    dataSource.setUrl(url);
    dataSource.setUsername(user);
    dataSource.setPassword(password);
    return dataSource;
  }

  @Bean(name = "masterTransactionManager")
  @Primary
  public DataSourceTransactionManager masterTransactionManager() {
    return new DataSourceTransactionManager(masterDataSource());
  }

  @Bean(name = "masterSqlSessionFactory")
  @Primary
  public SqlSessionFactory masterSqlSessionFactory(@Qualifier("masterDataSource") DataSource masterDataSource)
      throws Exception {
    final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
    sessionFactory.setDataSource(masterDataSource);
    sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
        .getResources(MasterDataSourceConfig.MAPPER_LOCATION));
    return sessionFactory.getObject();
  }
}

@Configuration
// 扫描 Mapper 接口并容器管理
@MapperScan(basePackages = ClusterDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "clusterSqlSessionFactory")
public class ClusterDataSourceConfig {

  // 精确到 cluster 目录，以便跟其他数据源隔离
  static final String PACKAGE = "org.spring.springboot.dao.cluster";
  static final String MAPPER_LOCATION = "classpath:mapper/cluster/*.xml";

  @Value("${cluster.datasource.url}")
  private String url;

  @Value("${cluster.datasource.username}")
  private String user;

  @Value("${cluster.datasource.password}")
  private String password;

  @Value("${cluster.datasource.driverClassName}")
  private String driverClass;

  @Bean(name = "clusterDataSource")
  public DataSource clusterDataSource() {
    DruidDataSource dataSource = new DruidDataSource();
    dataSource.setDriverClassName(driverClass);
    dataSource.setUrl(url);
    dataSource.setUsername(user);
    dataSource.setPassword(password);
    return dataSource;
  }

  @Bean(name = "clusterTransactionManager")
  public DataSourceTransactionManager clusterTransactionManager() {
    return new DataSourceTransactionManager(clusterDataSource());
  }

  @Bean(name = "clusterSqlSessionFactory")
  public SqlSessionFactory clusterSqlSessionFactory(@Qualifier("clusterDataSource") DataSource clusterDataSource)
      throws Exception {
    final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
    sessionFactory.setDataSource(clusterDataSource);
    sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
        .getResources(ClusterDataSourceConfig.MAPPER_LOCATION));
    return sessionFactory.getObject();
  }
}

@Service
public class UserAndCityServiceImpl implements UserAndCityService{

  @Autowired
  private UserDao userDao;
  @Autowired
  private CityDao cityDao;

  @Override
  public UserVo getUser(String userName) {
    UserVo userVo = userDao.selectByUserName(userName);
    CityVo cityVo = cityDao.selectByCityName("北京市");
    userVo.setDescription(cityVo.getCityName());
    return userVo;
  }
}