解决spring boot 1.5.4 配置多数据源的问题

2024-02-19 12:50:04 286

springboot已经支持多数据源配置了，无需网上好多那些编写什么类的，特别麻烦，看看如下解决方案，官方的，放心！

1.首先定义数据源配置

#=====================multipledatabaseconfig============================
#ds1
first.datasource.url=jdbc:mysql://localhost/test?characterEncoding=utf8&useSSL=true
first.datasource.username=root
first.datasource.password=123456
first.datasource.driver-class-name=com.mysql.jdbc.Driver
first.datasource.type=org.apache.tomcat.jdbc.pool.DataSource
first.datasource.max-wait=10000
first.datasource.max-active=200
first.datasource.test-on-borrow=true
first.datasource.initial-size=10

#ds2
second.datasource.url=jdbc:mysql://localhost/test2?characterEncoding=utf8&useSSL=true
second.datasource.username=root
second.datasource.password=123456
second.datasource.driver-class-name=com.mysql.jdbc.Driver
second.datasource.type=org.apache.tomcat.jdbc.pool.DataSource
second.datasource.max-wait=10000
second.datasource.max-active=200
second.datasource.test-on-borrow=true
second.datasource.initial-size=10

#=====================jpaconfig================================
#实体类维护数据库表结构的具体行为：update/create/create-drop/validate/none
spring.jpa.hibernate.ddl-auto=none
#打印sql语句
spring.jpa.show-sql=true
#格式化输出的json字符串
spring.jackson.serialization.indent_output=true

2.配置ds1的相关注入对象和启用jpa支持

/**
*Createdbyhdwangon2017-06-16.
*第一个数据源配置
*IfyouareusingSpringData,youneedtoconfigure@EnableJpaRepositories
*/
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(basePackages="com.hdwang.dao.datajpa.firstDs",entityManagerFactoryRef="firstEntityManagerFactory",transactionManagerRef="firstTransactionManager")
publicclassFirstDsConfig{

/**
*数据源配置对象
*Primary表示默认的对象，Autowire可注入，不是默认的得明确名称注入
*@return
*/
@Bean
@Primary
@ConfigurationProperties("first.datasource")
publicDataSourcePropertiesfirstDataSourceProperties(){
returnnewDataSourceProperties();
}

/**
*数据源对象
*@return
*/
@Bean
@Primary
@ConfigurationProperties("first.datasource")
publicDataSourcefirstDataSource(){
returnfirstDataSourceProperties().initializeDataSourceBuilder().build();
}

/**
*实体管理对象
*@parambuilder由spring注入这个对象，首先根据type注入（多个就取声明@Primary的对象），否则根据name注入
*@return
*/
@Bean
@Primary
publicLocalContainerEntityManagerFactoryBeanfirstEntityManagerFactory(
EntityManagerFactoryBuilderbuilder){
returnbuilder
.dataSource(firstDataSource())
.packages("com.hdwang.entity.dbFirst")
.persistenceUnit("firstDs")
.build();
}

/**
*事务管理对象
*@return
*/
@Bean(name="firstTransactionManager")
@Primary
publicPlatformTransactionManagertransactionManager(EntityManagerFactoryemf){
JpaTransactionManagertransactionManager=newJpaTransactionManager();
transactionManager.setEntityManagerFactory(emf);
returntransactionManager;
}

@Bean
@Primary
publicJdbcTemplatejdbcTemplate(){
returnnewJdbcTemplate(firstDataSource());
}

@Bean
@Primary
publicTransactionTemplatetransactionTemplate(PlatformTransactionManagerplatformTransactionManager){
returnnewTransactionTemplate(platformTransactionManager);
}
}

相关知识点：

1.使用@Bean可以创建一个bean对象交给spring容器管理

2.@Bean创建的bean对象的名称默认为方法名，也可以指定

3.@Bean方法参数表示，接收一个bean对象，默认按照type类型接收注入的对象，若要修改为byName方式，可以使用@Qualifier注解注入准确的对象

4.@Primary表示该bean为此类型的默认bean，在其他地方引用的时候用@Autowired即可按照类型注入，不受同类型多个对象影响

5.EnableJpaRepositories表示启用springdatajpa的支持，也就是jpa的新使用方式，注意basePackages指的事@Repository接口的所在包位置，可配置多个

其他注解就不清楚了！

2.配置ds2的相关注入对象和启用jpa支持

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(basePackages="com.hdwang.dao.datajpa.secondDs",entityManagerFactoryRef="secondEntityManagerFactory",transactionManagerRef="secondTransactionManager")
publicclassSecondDsConfig{

@Bean
@ConfigurationProperties("second.datasource")
publicDataSourcePropertiessecondDataSourceProperties(){
returnnewDataSourceProperties();
}

@Bean
@ConfigurationProperties("second.datasource")
publicDataSourcesecondDataSource(){
returnsecondDataSourceProperties().initializeDataSourceBuilder().build();
}

/**
*实体管理对象
*@parambuilder由spring注入这个对象，首先根据type注入（多个就取声明@Primary的对象），否则根据name注入
*@return
*/
@Bean
publicLocalContainerEntityManagerFactoryBeansecondEntityManagerFactory(
EntityManagerFactoryBuilderbuilder){
returnbuilder
.dataSource(secondDataSource())
.packages("com.hdwang.entity.dbSecond")
.persistenceUnit("secondDs")
.build();
}

/**
*事物管理对象
*@paramsecondEntityManagerFactory实体管理工厂对象（按照名称注入）
*@return平台事物管理器
*/
@Bean(name="secondTransactionManager")
publicPlatformTransactionManagertransactionManager(@Qualifier("secondEntityManagerFactory")LocalContainerEntityManagerFactoryBeansecondEntityManagerFactory){
JpaTransactionManagertransactionManager=newJpaTransactionManager();
transactionManager.setEntityManagerFactory(secondEntityManagerFactory.getObject());
returntransactionManager;
}

@Bean(name="jdbcTemplate2")
publicJdbcTemplatejdbcTemplate(){
returnnewJdbcTemplate(secondDataSource());
}

@Bean(name="transactionTemplate2")
publicTransactionTemplatetransactionTemplate(@Qualifier("secondTransactionManager")PlatformTransactionManagertransactionManager){
returnnewTransactionTemplate(transactionManager);
}
}

3.Repository数据持久层

packagecom.hdwang.dao.datajpa.firstDs;

@Repository
publicinterfaceUserRepositoryextendsJpaRepository{
/**
*springdatajpa会自动注入实现（根据方法命名规范）
*@return
*/
UserfindByNumber(Stringnumber);


@Modifying
@Query("deletefromUseruwhereu.id=:id")
voiddeleteUser(@Param("id")intid);
}

packagecom.hdwang.dao.datajpa.secondDs;

@Repository
publicinterfaceOrderRepositoryextendsJpaRepository{
/**
*springdatajpa会自动注入实现（根据方法命名规范）
*@return
*/
UserfindByNumber(Stringnumber);


@Modifying
@Query("deletefromOrderowhereo.id=:id")
voiddeleteUser(@Param("id")intid);
}

上面两个接口分属两个数据源，在@EnableJpaRepositories配置好后，这里就可以正确操作相应的数据源了

4.Service服务层，注意事物（接口我就不贴了）

@Service
@Transactional("firstTransactionManager")
publicclassUserServiceImplimplementsUserService{

@Autowired
privateUserRepositoryuserRepository;

@Override
publicUserfindById(intid){
returnthis.userRepository.findOne(id);
}

@Override
publicUserfindByNumber(Stringnumber){
returnthis.userRepository.findByNumber(number);
}

@Override
publicListfindAllUserByPage(intpage,intsize){
Pageablepageable=newPageRequest(page,size);
Pageusers=this.userRepository.findAll(pageable);
returnusers.getContent();
}

@Override
publicUserupdateUser(Useruser,booleanthrowEx){
UseruserNew=this.userRepository.save(user);
if(throwEx){
thrownewRuntimeException("throwaex");
}
returnuserNew;
}

@Override
publicvoiddeleteUser(intid){
this.userRepository.deleteUser(id);
}
}

@Service
@Transactional("secondTransactionManager")
publicclassOrderServiceImplimplementsOrderService{

@Autowired
privateOrderRepositoryorderRepository;


@Override
publicOrderfindById(intid){
returnthis.orderRepository.findOne(id);
}

@Override
publicOrderupdateOrder(Orderorder,booleanthrowEx){
OrderorderNew=this.orderRepository.save(order);
if(throwEx){
thrownewRuntimeException("throwaex");
}
returnorderNew;
}
}

知识扩展

1.如果采用传统jpa方式，@EnableJpaRepositories无需配置，配置了也无影响。实现方式如下：

ds1相关DaoImpl
@PersistenceContext
privateEntityManagerentityManager;

ds2相关DaoImpl
@PersistenceContext(unitName="secondDs")
privateEntityManagerentityManager;

因为ds1的entityManger声明了@Primary，所以无需指明unitName,ds2必须指明。注入了准确的entityManager，就可以直接拿来操作数据库了。service层和上面一样的，@Transactional("xxxManager")指明事物管理器即可！

2.采用jdbcTemplate方式，直接注入到Service层对象即可，soeasy!

@Autowired
privateJdbcTemplatejdbcTemplate;

@Autowired
privateTransactionTemplatetransactionTemplate;

@Resource(name="jdbcTemplate2")
privateJdbcTemplatejdbcTemplate2;

@Resource(name="transactionTemplate2")
privateTransactionTemplatetransactionTemplate2;

好了，springboot多数据源，完美解决！而且三种数据库操作方法均支持，包括事物。已经经过实践证明了！这是官方给出的最佳实践，只是官方文档没写细。导致整整坑了我几天。至此，springboot框架的使用就告一段落了！

以上这篇解决springboot1.5.4配置多数据源的问题就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持毛票票。

解决spring boot 1.5.4 配置多数据源的问题

热门推荐

随机推荐