19.Spring-Boot多数据源配置

Myth丶恋晨 2022-05-30 09:52 204阅读 0赞

[参考SpingBoot官网文档][SpingBoot]

主要要是基于MyBatis的SpringBoot多数据源配置，这里利用多数据源演示读写分离，只是纯粹的样式。

application.properties

#读数据库配置
    spring.datasource.db1.type=com.alibaba.druid.pool.DruidDataSource
    spring.datasource.db1.driverClassName = com.mysql.jdbc.Driver
    spring.datasource.db1.url=jdbc:mysql://localhost:3306/springboot?useUnicode=true&characterEncoding=utf8 
    spring.datasource.db1.username = root
    spring.datasource.db1.password = 123456
    
    #写数据库配置
    spring.datasource.db2.type=com.alibaba.druid.pool.DruidDataSource
    spring.datasource.db2.driverClassName = com.mysql.jdbc.Driver
    spring.datasource.db2.url=jdbc:mysql://localhost:3306/springboot?useUnicode=true&characterEncoding=utf8 
    spring.datasource.db2.username = root
    spring.datasource.db2.password = 123456

ReadDataSourceConfig.java读数据源配置

package com.niugang;
    import javax.sql.DataSource;
    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.boot.context.properties.ConfigurationProperties;
    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 org.springframework.transaction.PlatformTransactionManager;
    import org.springframework.transaction.annotation.TransactionManagementConfigurer;
    import com.alibaba.druid.pool.DruidDataSource;
    /**
     * 数据源配置 1
     * 
     * @author niugang
     *
    
     */
    
    @Configuration
    @MapperScan(value = { "com.niugang.dao.read" }, sqlSessionTemplateRef = "sqlSessionTemplate1")
    public class ReadDataSourceConfig implements TransactionManagementConfigurer {
    @Bean(name = "dataSource1")
    @ConfigurationProperties(prefix = "spring.datasource.db1")
    @Primary //配置主数据库
    public DataSource dataSource() {
    DruidDataSource druidDataSource = new DruidDataSource();
    return druidDataSource;
    }
    @Bean(name = "sqlSessionFactory1")
    @Primary
    public SqlSessionFactory testSqlSessionFactory() throws Exception {
    SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    
    bean.setDataSource(dataSource());
     //读的myBatis配置文件位置
    
    bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/read/*.xml"));
    return bean.getObject();
    
    
    
    }
    
    
    
    @Bean(name = "sqlSessionTemplate1")
    @Primary
    public SqlSessionTemplate testSqlSessionTemplate() throws Exception {
    return new SqlSessionTemplate(testSqlSessionFactory());
    }
    @Bean(name = "transactionManager1")
    @Primary
    public DataSourceTransactionManager testTransactionManager() {
    return new DataSourceTransactionManager(dataSource());
    }
    @Override
    public PlatformTransactionManager annotationDrivenTransactionManager() {
    return testTransactionManager() ;
    }
    
    }

WriterDataSourceConfig.java写数据库配置

package com.niugang;
    import javax.sql.DataSource;
    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.boot.context.properties.ConfigurationProperties;
    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 org.springframework.transaction.PlatformTransactionManager;
    import org.springframework.transaction.annotation.TransactionManagementConfigurer;
    import com.alibaba.druid.pool.DruidDataSource;
    
    /**
     * 数据源配置 1
     * 
     * @author niugang
     **/
    @Configuration
    // @EnableTransactionManagement springboot默认是开启事务的
    @MapperScan(value = { "com.niugang.dao.writer" }, sqlSessionTemplateRef = "sqlSessionTemplate2")
    public class WriterDataSourceConfig implements TransactionManagementConfigurer {
    
    
    @Bean(name = "dataSource2")
    @ConfigurationProperties(prefix = "spring.datasource.db2")
    public DataSource dataSource() {
    DruidDataSource druidDataSource = new DruidDataSource();
    return druidDataSource;
    }
    
    
    @Bean(name = "sqlSessionFactory2")
    public SqlSessionFactory testSqlSessionFactory() throws Exception {
    SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    bean.setDataSource(dataSource());
    bean.setMapperLocations(
    new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/writer/*.xml"));
    return bean.getObject();
    
    }
    
    @Bean(name = "sqlSessionTemplate2")
    public SqlSessionTemplate testSqlSessionTemplate() throws Exception {
    return new SqlSessionTemplate(testSqlSessionFactory());
    }
        
    /**
    * 配置事务所必须要的
    * @return
    */
    @Bean(name = "transactionManager2")
    public DataSourceTransactionManager testTransactionManager() {
    return new DataSourceTransactionManager(dataSource());
    }
        /**
         * 配置事务所必须要
         */
    @Override
    public PlatformTransactionManager annotationDrivenTransactionManager() {
    return testTransactionManager();
    }
    
    }

Dao层

如果真的要这么做，那么接口命名必须规范，防止调错

---ReadUserDao.java 读持久化接口

package com.niugang.dao.read;
    import java.util.List;
    import org.springframework.stereotype.Repository;
    import com.niugang.entity.User;
    @Repository
    public interface ReadUserDao {
    List<User> queryList(User user);
    User get(Integer id);
    }

---WriterUserDao.java写持久化接口

package com.niugang.dao.writer;
    import org.springframework.stereotype.Repository;
    import com.niugang.entity.User;
    import org.springframework.transaction.annotation.Transactional;
    @Repository
    public interface WriterUserDao {
       @Transactional
       void save(User user);
        void delete(Integer id);
    }

Mapper文件

\---ReadUser.xml

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
    <mapper namespace="com.niugang.dao.read.ReadUserDao">
    <resultMap id="BaseResultMap" type="com.niugang.entity.User">
    <result column="id" property="id" />
    <result column="name" property="name" />
    <result column="age" property="age" />
    <result column="phone" property="phone" />
    </resultMap>
    
    <sql id="Base_Column_List">
    id, name, age,phone
    </sql>
    
    <sql id="queryCondition">
    <where>
    <if test="id!=null">
    and id=#{id}
    </if>
    <if test="name!=null">
    and name=#{name}
    </if>
    <if test="age!=null">
    and age=#{age}
    </if>
    <if test="phone!=null">
    and phone=#{phone}
    </if>
    </where>
    </sql>
    <select id="queryList" resultMap="BaseResultMap" parameterType="com.niugang.entity.User">
    select
    <include refid="Base_Column_List" />
    from user
    <include refid="queryCondition" />
    </select>
    <select id="get" parameterType="int" resultMap="BaseResultMap">
    select
    <include refid="Base_Column_List" />
    from user
    where id =#{id}
    </select>
    </mapper>

\---WriterUser.xml

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
    <mapper namespace="com.niugang.dao.writer.WriterUserDao">
    <insert id="save" parameterType="com.niugang.entity.User">
    insert into user (name,password,age,phone)
    values(#{name},#{password},#{age},#{phone})
    </insert>
    <delete id="delete" parameterType="int">
    delete from user where id =#{id}
    </delete>
    </mapper>

**微信公众号**               ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25pdWdhbmcwOTIw_size_16_color_FFFFFF_t_70][]

[SpingBoot]: https://docs.spring.io/spring-boot/docs/1.5.10.RELEASE/reference/htmlsingle/#howto-two-datasources
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25pdWdhbmcwOTIw_size_16_color_FFFFFF_t_70]: /images/20220530/d87794b574ac45e0b61214303d6183f7.png