SpringCloud的多数据库源的java代码配置

蔚落 2023-07-06 08:44 3阅读 0赞

@Configuration
    @MapperScan(basePackages = "com.order.mapper", sqlSessionFactoryRef = "orderSqlSessionFactory")
    public class OrderDataSourceConfig {
    
        /**
         * 将订单db注册到容器中
         *
         * @return
         */
        @Bean(name = "orderDataSource")
        @ConfigurationProperties(prefix = "spring.datasource.order")
        public DataSource orderDataSource() {
            return DataSourceBuilder.create().build();
        }
    
        /**
         * 将订单SqlSessionFactory注册到容器中
         *
         * @param dataSource
         * @return
         * @throws Exception
         */
        @Bean(name = "orderSqlSessionFactory")
        public SqlSessionFactory orderSqlSessionFactory(@Qualifier("orderDataSource") DataSource dataSource) throws Exception {
            SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
            sqlSessionFactoryBean.setDataSource(orderDataSource());
            return sqlSessionFactoryBean.getObject();
        }
    
        /**
         * 创建订单管理器
         *
         * @param dataSource
         * @return
         */
        @Bean(name = "orderTransactionManager")
        public DataSourceTransactionManager orderTransactionManager(@Qualifier("orderDataSource") DataSource dataSource) {
            return new DataSourceTransactionManager(dataSource);
        }
    
        /**
         * 创建订单sqlSesion模版
         *
         * @param sqlSessionFactory
         * @return
         * @throws Exception
         */
        @Bean(name = "orderSqlSessionTemplate")
        public SqlSessionTemplate menberSqlSessionTemplate(
                @Qualifier("orderSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
            return new SqlSessionTemplate(sqlSessionFactory);
        }
    
    
    }

# application.yml配置 #

spring:
      datasource:
        ###会员数据库
        member:
          jdbc-url: jdbc:mysql://localhost:3306/user
          username: root
          password: 
          driver-class-name: com.mysql.jdbc.Driver
        ###订单数据库
        order:
          jdbc-url: jdbc:mysql://localhost:3306/order
          username: root
          password: 
          driver-class-name: com.mysql.jdbc.Driver