zoukankan      html  css  js  c++  java
  • 企业分布式微服务云SpringCloud SpringBoot mybatis (十)Spring Boot多数据源配置与使用(Spring-data-jpa支持)

    Spring-data-jpa支持

    对于数据源的配置可以沿用上例中DataSourceConfig的实现。

    新增对第一数据源的JPA配置,注意两处注释的地方,用于指定数据源对应的Entity实体和Repository定义位置,用@Primary区分主数据源。

    @Configuration
    @EnableTransactionManagement
    @EnableJpaRepositories(
            entityManagerFactoryRef="entityManagerFactoryPrimary",
            transactionManagerRef="transactionManagerPrimary",
            basePackages= { "com.didispace.domain.p" }) //设置Repository所在位置
    public class PrimaryConfig {
    
        @Autowired @Qualifier("primaryDataSource")
        private DataSource primaryDataSource;
    
        @Primary
        @Bean(name = "entityManagerPrimary")
        public EntityManager entityManager(EntityManagerFactoryBuilder builder) {
            return entityManagerFactoryPrimary(builder).getObject().createEntityManager();
        }
    
        @Primary
        @Bean(name = "entityManagerFactoryPrimary")
        public LocalContainerEntityManagerFactoryBean entityManagerFactoryPrimary (EntityManagerFactoryBuilder builder) {
            return builder
                    .dataSource(primaryDataSource)
                    .properties(getVendorProperties(primaryDataSource))
                    .packages("com.didispace.domain.p") //设置实体类所在位置
                    .persistenceUnit("primaryPersistenceUnit")
                    .build();
        }
    
        @Autowired
        private JpaProperties jpaProperties;
    
        private Map<String, String> getVendorProperties(DataSource dataSource) {
            return jpaProperties.getHibernateProperties(dataSource);
        }
    
        @Primary
        @Bean(name = "transactionManagerPrimary")
        public PlatformTransactionManager transactionManagerPrimary(EntityManagerFactoryBuilder builder) {
            return new JpaTransactionManager(entityManagerFactoryPrimary(builder).getObject());
        }
    
    }
    

      

    新增对第二数据源的JPA配置,内容与第一数据源类似,具体如下:

    @Configuration
    @EnableTransactionManagement
    @EnableJpaRepositories(
            entityManagerFactoryRef="entityManagerFactorySecondary",
            transactionManagerRef="transactionManagerSecondary",
            basePackages= { "com.didispace.domain.s" }) //设置Repository所在位置
    public class SecondaryConfig {
    
        @Autowired @Qualifier("secondaryDataSource")
        private DataSource secondaryDataSource;
    
        @Bean(name = "entityManagerSecondary")
        public EntityManager entityManager(EntityManagerFactoryBuilder builder) {
            return entityManagerFactorySecondary(builder).getObject().createEntityManager();
        }
    
        @Bean(name = "entityManagerFactorySecondary")
        public LocalContainerEntityManagerFactoryBean entityManagerFactorySecondary (EntityManagerFactoryBuilder builder) {
            return builder
                    .dataSource(secondaryDataSource)
                    .properties(getVendorProperties(secondaryDataSource))
                    .packages("com.didispace.domain.s") //设置实体类所在位置
                    .persistenceUnit("secondaryPersistenceUnit")
                    .build();
        }
    
        @Autowired
        private JpaProperties jpaProperties;
    
        private Map<String, String> getVendorProperties(DataSource dataSource) {
            return jpaProperties.getHibernateProperties(dataSource);
        }
    
        @Bean(name = "transactionManagerSecondary")
        PlatformTransactionManager transactionManagerSecondary(EntityManagerFactoryBuilder builder) {
            return new JpaTransactionManager(entityManagerFactorySecondary(builder).getObject());
        }
    
    }
    

      

    完成了以上配置之后,主数据源的实体和数据访问对象位于:com.didispace.domain.p,次数据源的实体和数据访问接口位于:com.didispace.domain.s

    分别在这两个package下创建各自的实体和数据访问接口

    • 主数据源下,创建User实体和对应的Repository接口
      @Entity
      public class User {
      
          @Id
          @GeneratedValue
          private Long id;
      
          @Column(nullable = false)
          private String name;
      
          @Column(nullable = false)
          private Integer age;
      
          public User(){}
      
          public User(String name, Integer age) {
              this.name = name;
              this.age = age;
          }
      
          // 省略getter、setter
      
      }
      public interface UserRepository extends JpaRepository<User, Long> {
      
      }
      

        

    • 从数据源下,创建Message实体和对应的Repository接口
      @Entity
      public class Message {
      
          @Id
          @GeneratedValue
          private Long id;
      
          @Column(nullable = false)
          private String name;
      
          @Column(nullable = false)
          private String content;
      
          public Message(){}
      
          public Message(String name, String content) {
              this.name = name;
              this.content = content;
          }
      
          // 省略getter、setter
      
      }
      public interface MessageRepository extends JpaRepository<Message, Long> {
      
      }
      

        

      接下来通过测试用例来验证使用这两个针对不同数据源的配置进行数据操作。

      @RunWith(SpringJUnit4ClassRunner.class)
      @SpringApplicationConfiguration(Application.class)
      public class ApplicationTests {
      
      	@Autowired
      	private UserRepository userRepository;
      	@Autowired
      	private MessageRepository messageRepository;
      
      	@Test
      	public void test() throws Exception {
      
      		userRepository.save(new User("aaa", 10));
      		userRepository.save(new User("bbb", 20));
      		userRepository.save(new User("ccc", 30));
      		userRepository.save(new User("ddd", 40));
      		userRepository.save(new User("eee", 50));
      
      		Assert.assertEquals(5, userRepository.findAll().size());
      
      		messageRepository.save(new Message("o1", "aaaaaaaaaa"));
      		messageRepository.save(new Message("o2", "bbbbbbbbbb"));
      		messageRepository.save(new Message("o3", "cccccccccc"));
      
      		Assert.assertEquals(3, messageRepository.findAll().size());
      
      	}
      
      }
      

        

      源码来源

  • 相关阅读:
    管道通讯
    C++类型转换
    自定义数组容器MyArray框架
    vue 转场动画
    身份证信息 获取年龄性别生日
    element ui +vue 输入 身份证号获取 性别 年龄 籍贯
    获取地理位置
    post 下载二进制pdf文件
    post 文件下载二进制流
    遍历对象的几中方法
  • 原文地址:https://www.cnblogs.com/Abbie/p/8430282.html
Copyright © 2011-2022 走看看