脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → springboot采用多数据源对JdbcTemplate配置的方法

详解springboot采用多数据源对JdbcTemplate配置的方法

 更新时间：2018年10月12日 14:13:12   投稿：laozhang  
在本篇文章中我们给大家详细分享了springboot采用多数据源对JdbcTemplate配置的方法，有需要的朋友们可以学习参考下。

springboot多数据源配置，代码如下

DataSourceConfig

package com.rookie.bigdata.config;
 
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.jdbc.core.JdbcTemplate;
 
import javax.sql.DataSource;
 
/**
 * @author
 * @date 2018/10/10
 */
@Configuration
public class DataSourceConfig {
 
 @Bean(name = "primaryDataSource")
 @Qualifier("primaryDataSource")
 @ConfigurationProperties(prefix="spring.datasource.primary")
 public DataSource primaryDataSource() {
  return DataSourceBuilder.create().build();
 }
 
 @Bean(name = "secondaryDataSource")
 @Qualifier("secondaryDataSource")
 @Primary
 @ConfigurationProperties(prefix="spring.datasource.secondary")
 public DataSource secondaryDataSource() {
  return DataSourceBuilder.create().build();
 }
 
 @Bean(name = "primaryJdbcTemplate")
 public JdbcTemplate primaryJdbcTemplate(
   @Qualifier("primaryDataSource") DataSource dataSource) {
  return new JdbcTemplate(dataSource);
 }
 
 @Bean(name = "secondaryJdbcTemplate")
 public JdbcTemplate secondaryJdbcTemplate(
   @Qualifier("secondaryDataSource") DataSource dataSource) {
  return new JdbcTemplate(dataSource);
 }
 
}

StudentServiceImpl

package com.rookie.bigdata.service;
 
import com.rookie.bigdata.domain.Student;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
 
/**
 * @author
 * @date 2018/10/9
 */
@Service
public class StudentServiceImpl implements StudentService {
 
 @Autowired
 @Qualifier("primaryJdbcTemplate")
 private JdbcTemplate jdbcTemplate;
 
 @Autowired
 @Qualifier("secondaryJdbcTemplate")
 private JdbcTemplate jdbcTemplate2;
 
 /**
  * 采用第一个暑假源进行插入数据
  * @param student
  */
 @Override
 public void create(Student student) {
 
  jdbcTemplate.update("INSERT INTO student(stu_no,name,age)VALUE (?,?,?)", student.getStuNo(), student.getName(), student.getAge());
 
 }
 
 /**
  * 第一个数据源进行插入数据
  * @param stuNo
  */
 @Override
 public void deleteByNo(Integer stuNo) {
  jdbcTemplate.update("DELETE FROM student WHERE stu_no=?", stuNo);
 }
 
 /**
  * 第二个数据源进行查询数据
  * @param stuNo
  * @return
  */
 @Override
 public Integer queryByStuNo(Integer stuNo) {
  return jdbcTemplate2.queryForObject("select count(1) from student", Integer.class);
 }
}

配置文件 application.properties

spring.datasource.primary.url=jdbc:mysql://localhost:3306/springboot
spring.datasource.primary.username=root
spring.datasource.primary.password=root
spring.datasource.primary.driver-class-name=com.mysql.jdbc.Driver
 
spring.datasource.secondary.url=jdbc:mysql://localhost:3306/springboot
spring.datasource.secondary.username=root
spring.datasource.secondary.password=root
spring.datasource.secondary.driver-class-name=com.mysql.jdbc.Driver

测试代码如下

package com.rookie.bigdata.service;
 
import com.rookie.bigdata.domain.Student;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
 
/**
 * @author liuxili
 * @date 2018/10/10
 */
 
@RunWith(SpringRunner.class)
@SpringBootTest
public class StudentServiceImplTest {
 
 @Autowired
 private StudentServiceImpl studentService;
 
 @Test
 public void create1() throws Exception {
  Student student = new Student();
  student.setStuNo(1L);
  student.setName("张三");
  student.setAge(23);
  studentService.create(student);
 }
 @Test
 public void deleteByName1() throws Exception {
  studentService.deleteByNo(1);
 }
 @Test
 public void queryByStuNo1() throws Exception {
  System.out.println(studentService.queryByStuNo(1));
 
 }
}

在运行的时候会出现如下异常问题，运行失败，报出java.lang.IllegalArgumentException: jdbcUrl is required with driverClassName.异常

后来经过查资料，发现出现该问题的原因是由于springboot版本的问题，本实例采用的springboot版本为2.0.5，如果将版本改为1.5以前的版本就不会出现如上的问题，其实解决上面的异常主要有如下两种解决方案

方案一：

按照如下方案进行修改application.properties配置文件，如下：修改完成后，上面的异常不会再出现

spring.datasource.primary.jdbc-url=jdbc:mysql://localhost:3306/springboot
spring.datasource.primary.username=root
spring.datasource.primary.password=root
spring.datasource.primary.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.secondary.jdbc-url=jdbc:mysql://localhost:3306/springboot
spring.datasource.secondary.username=root
spring.datasource.secondary.password=root
spring.datasource.secondary.driver-class-name=com.mysql.jdbc.Driver

方案二：

原有的application.properties配置文件不进行修改，修改DataSourceConfig类中的信息，如下:修改完成后，异常也不会再出现能够正常运行

application.properties

spring.datasource.primary.url=jdbc:mysql://localhost:3306/springboot
spring.datasource.primary.username=root
spring.datasource.primary.password=root
spring.datasource.primary.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.secondary.url=jdbc:mysql://localhost:3306/springboot
spring.datasource.secondary.username=root
spring.datasource.secondary.password=root
spring.datasource.secondary.driver-class-name=com.mysql.jdbc.Driver

DataSourceConfig

package com.rookie.bigdata.config;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
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.jdbc.core.JdbcTemplate;
import javax.sql.DataSource;
/**
 * @author
 * @date 2018/10/10
 */
@Configuration
public class DataSourceConfig {
 @Bean(name = "primaryJdbcTemplate")
 public JdbcTemplate primaryJdbcTemplate(
   @Qualifier("primaryDataSource") DataSource dataSource) {
  return new JdbcTemplate(dataSource);
 }
 @Bean(name = "secondaryJdbcTemplate")
 public JdbcTemplate secondaryJdbcTemplate(
   @Qualifier("primaryDataSource") DataSource dataSource) {
  return new JdbcTemplate(dataSource);
 }
 @Primary
 @Bean(name = "primaryDataSourceProperties")
 @Qualifier("primaryDataSourceProperties")
 @ConfigurationProperties(prefix = "spring.datasource.primary")
 public DataSourceProperties primaryDataSourceProperties() {
  return new DataSourceProperties();
 }
 @Bean(name = "secondaryDataSourceProperties")
 @Qualifier("secondaryDataSourceProperties")
 @ConfigurationProperties(prefix = "spring.datasource.secondary")
 public DataSourceProperties secondaryDataSourceProperties() {
  return new DataSourceProperties();
 }
 
 @Primary
 @Bean(name = "primaryDataSource")
 @Qualifier("primaryDataSource")
 @ConfigurationProperties(prefix = "spring.datasource.primary")
 public DataSource primaryDataSource() {
 
  return primaryDataSourceProperties().initializeDataSourceBuilder().build();
 }
 @Bean(name = "secondaryDataSource")
 @Qualifier("secondaryDataSource")
 @ConfigurationProperties(prefix = "spring.datasource.secondary")
 public DataSource secondaryDataSource() {
 
  return primaryDataSourceProperties().initializeDataSourceBuilder().build();
 }
}

至此，springboot 采用多数据源对JdbcTemplate进行配置完美解决，感谢大家对脚本之家的支持。

您可能感兴趣的文章:

相关文章

  • JAVA POI设置EXCEL单元格格式用法举例

    JAVA POI设置EXCEL单元格格式用法举例

    这篇文章主要给大家介绍了关于JAVA POI设置EXCEL单元格格式用法的相关资料,POI中可能会用到一些需要设置EXCEL单元格格式的操作,需要的朋友可以参考下
    2023-08-08
  • 一文详解SpringBoot中CommandLineRunner接口

    一文详解SpringBoot中CommandLineRunner接口

    Spring Boot的CommandLineRunner接口是一个函数式接口,用于在Spring Boot应用程序启动后执行一些初始化操作,它提供了一个run方法,该方法在应用程序启动后被调用,本文给大家详细介绍了SpringBoot中CommandLineRunner接口,需要的朋友可以参考下
    2023-10-10
  • Maven依赖junit @Test报错的解决方案

    Maven依赖junit @Test报错的解决方案

    这篇文章主要介绍了Maven依赖junit @Test报错的解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-03-03
  • Jenkins Host key verification failed问题解决

    Jenkins Host key verification failed问题解决

    这篇文章主要介绍了Jenkins Host key verification failed问题解决,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-11-11
  • Java Applet查找素数小程序代码实例

    Java Applet查找素数小程序代码实例

    这篇文章主要介绍了Java Applet查找素数小程序代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-02-02
  • 深入讲解Java中的多态和抽象类

    深入讲解Java中的多态和抽象类

    这篇文章主要介绍了深入讲解Java中的多态和抽象类,有时候，设计一个数组或方法的参数，返回值类型时，无法确定具体的类型，只能确定是某个系列的类型，这时就引入了多态,需要的朋友可以参考下
    2023-08-08
  • SpringBoot主键ID传到前端后精度丢失的问题解决

    SpringBoot主键ID传到前端后精度丢失的问题解决

    这篇文章主要通过示例为大家详细介绍一些SpringBoot如何解决雪花算法主键ID传到前端后精度丢失问题，文中的示例代码讲解详细，需要的可以参考一下
    2022-05-05
  • hadoop 全面解读自定义分区

    hadoop 全面解读自定义分区

    Hadoop是一个由Apache基金会所开发的分布式系统基础架构。用户可以在不了解分布式底层细节的情况下，开发分布式程序。充分利用集群的威力进行高速运算和存储
    2022-02-02
  • springmvc用于方法鉴权的注解拦截器的解决方案代码

    springmvc用于方法鉴权的注解拦截器的解决方案代码

    这篇文章主要介绍了springmvc用于方法鉴权的注解拦截器的解决方案代码，具有一定借鉴价值，需要的朋友可以参考下。
    2017-12-12
  • Spring Boot中使用LDAP来统一管理用户信息的示例

    Spring Boot中使用LDAP来统一管理用户信息的示例

    本篇文章主要介绍了Spring Boot中使用LDAP来统一管理用户信息的示例，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2018-01-01

最新评论