SpringBoot基础教程(三)——多数据源结合

紧接上篇文章SpringBoot基础教程(二)——与Mybatis的结合,我们讨论了与Mybatis的结合，但是在实际工作中，我们操作的可能不是一个数据库，也就是说我们有可能操纵多个数据源，这个又该怎么配置呢？其实也是大同小异，总之就是一句话，把每个数据库的配置分隔开，不要让他们相互影响就行了。请看下面的示例

/**
 * pajk.com Inc.
 * Copyright (c) 2014-2015 All Rights Reserved.
 */
package com.shuqi;

import com.alibaba.druid.filter.Filter;
import com.alibaba.druid.filter.stat.StatFilter;
import com.alibaba.druid.pool.DruidDataSource;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.Resource;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import org.springframework.transaction.support.TransactionTemplate;

import javax.sql.DataSource;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;


@Configuration
public class DalConfig {


    @Configuration
    @MapperScan(basePackages = "com.shuqi.dal.mapper.user",sqlSessionFactoryRef = "userSqlSessionFactory")
    @EnableTransactionManagement
    static class UserDalConfig{

        @Value(value = "classpath:mybatis/sqlmap/user/*.xml")
        private Resource[] mapperLocations;

        @Value(value = "classpath:mybatis/mybatis-config.xml")
        private Resource configLocation;


        @Bean
        public SqlSessionFactoryBean userSqlSessionFactory(DruidDataSource userDataSource) {
            SqlSessionFactoryBean ssfb = new SqlSessionFactoryBean();
            ssfb.setMapperLocations(mapperLocations);
            ssfb.setConfigLocation(configLocation);
            ssfb.setDataSource(userDataSource);
            return ssfb;
        }

        @Bean(initMethod = "init", destroyMethod = "close")
        public DruidDataSource userDataSource(@Value("${ds.user.jdbc.url}") String url,
                                          @Value("${ds.user.jdbc.username}") String username,
                                          @Value("${ds.user.jdbc.password}") String password) throws SQLException {
            DruidDataSource druidDataSource = new DruidDataSource();
            druidDataSource.setUrl(url);
            druidDataSource.setUsername(username);
            druidDataSource.setPassword(password);
            druidDataSource.setMaxActive(60);
            druidDataSource.setInitialSize(1);
            druidDataSource.setMaxWait(60000);//60s
            druidDataSource.setMinIdle(1);
            druidDataSource.setTimeBetweenEvictionRunsMillis(3000);
            druidDataSource.setMinEvictableIdleTimeMillis(300000);
            druidDataSource.setValidationQuery("select 1");
            druidDataSource.setTestWhileIdle(true);
            druidDataSource.setTestOnBorrow(false);
            druidDataSource.setTestOnReturn(false);
            druidDataSource.setPoolPreparedStatements(true);
            druidDataSource.setMaxPoolPreparedStatementPerConnectionSize(20);
            druidDataSource.setFilters("config");
            Properties properties = new Properties();
            properties.put("config.decrypt", "false");
            druidDataSource.setConnectProperties(properties);

            StatFilter statFilter = new StatFilter();
            statFilter.setSlowSqlMillis(10000);//10s。。慢
            statFilter.setMergeSql(true);
            statFilter.setLogSlowSql(true);

            List<Filter> filterList = new ArrayList<Filter>();
            filterList.add(statFilter);
            druidDataSource.setProxyFilters(filterList);

            return druidDataSource;
        }



        @Bean
        public PlatformTransactionManager userTransactionManager(DataSource userDataSource) throws SQLException {
            return new DataSourceTransactionManager(userDataSource);
        }

        @Bean
        public TransactionTemplate userTransactionTemplate(PlatformTransactionManager userTransactionManager) {
            return new TransactionTemplate(userTransactionManager);
        }

    }

    @Configuration
    @MapperScan(basePackages = "com.shuqi.dal.mapper.log",sqlSessionFactoryRef = "logSqlSessionFactory")
    @EnableTransactionManagement
    static class LogDalConfig{

        @Value(value = "classpath:mybatis/sqlmap/log/*.xml")
        private Resource[] mapperLocations;

        @Value(value = "classpath:mybatis/mybatis-config.xml")
        private Resource configLocation;


        @Bean
        public SqlSessionFactoryBean logSqlSessionFactory(DruidDataSource logDataSource) {
            SqlSessionFactoryBean ssfb = new SqlSessionFactoryBean();
            ssfb.setMapperLocations(mapperLocations);
            ssfb.setConfigLocation(configLocation);
            ssfb.setDataSource(logDataSource);
            return ssfb;
        }

        @Bean(initMethod = "init", destroyMethod = "close")
        public DruidDataSource logDataSource(@Value("${ds.log.jdbc.url}") String url,
                                          @Value("${ds.log.jdbc.username}") String username,
                                          @Value("${ds.log.jdbc.password}") String password) throws SQLException {
            DruidDataSource druidDataSource = new DruidDataSource();
            druidDataSource.setUrl(url);
            druidDataSource.setUsername(username);
            druidDataSource.setPassword(password);
            druidDataSource.setMaxActive(60);
            druidDataSource.setInitialSize(1);
            druidDataSource.setMaxWait(60000);//60s
            druidDataSource.setMinIdle(1);
            druidDataSource.setTimeBetweenEvictionRunsMillis(3000);
            druidDataSource.setMinEvictableIdleTimeMillis(300000);
            druidDataSource.setValidationQuery("select 1");
            druidDataSource.setTestWhileIdle(true);
            druidDataSource.setTestOnBorrow(false);
            druidDataSource.setTestOnReturn(false);
            druidDataSource.setPoolPreparedStatements(true);
            druidDataSource.setMaxPoolPreparedStatementPerConnectionSize(20);
            druidDataSource.setFilters("config");
            Properties properties = new Properties();
            properties.put("config.decrypt", "false");
            druidDataSource.setConnectProperties(properties);

            StatFilter statFilter = new StatFilter();
            statFilter.setSlowSqlMillis(10000);//10s。。慢
            statFilter.setMergeSql(true);
            statFilter.setLogSlowSql(true);

            List<Filter> filterList = new ArrayList<Filter>();
            filterList.add(statFilter);
            druidDataSource.setProxyFilters(filterList);

            return druidDataSource;
        }



        @Bean
        public PlatformTransactionManager logTransactionManager(DataSource logDataSource) throws SQLException {
            return new DataSourceTransactionManager(logDataSource);
        }

        @Bean
        public TransactionTemplate logTransactionTemplate(PlatformTransactionManager logTransactionManager) {
            return new TransactionTemplate(logTransactionManager);
        }

    }
}

每个数据库的配置都通过一个静态内部类的形式进行定义，每个库的配置使用自己的那部分就行了，大家可以下载源码试一下。

下节将的内容是：SpringBoot基础教程(四)——与Swagger2的结合

本节项目源码