springboot jdbctemplate如何实现多数据源
作者：在下，杨江河
这篇文章主要介绍了springboot jdbctemplate如何实现多数据源问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
1.简介
所谓多数据源，其实就是在一个项目中使用多个数据库实例中的数据库或者同一个数据库实例中多个不同的库。
在大部分情况下会使用更加强大的持久化框架来访问数据库，比如MyBatis、Hibernate或者Spring Data JPA等ORM框架。
使用JDBC是开发者必备的基础技能，只有熟悉了基础的JDBC，才能更加深入地学习其他的ORM框架。
2.举例
2.1配置多数据源连接信息
spring.datasource.primary.jdbc-url=jdbc:mysql://localhost:3306/jdbctest spring.datasource.primary.username=root spring.datasource.primary.password=Yjb123456 spring.datasource.primary.driver-class-name=com.mysql.cj.jdbc.Driver spring.datasource.secondary.jdbc-url=jdbc:mysql://localhost:3306/jdbctest2 spring.datasource.secondary.username=root spring.datasource.secondary.password=Yjb123456 spring.datasource.secondary.driver-class-name=com.mysql.cj.jdbc.Driver
2.2配置JDBC初始化
创建DataSourceConfig类，在项目启动时读取配置文件中的数据库信息，并对JDBC初始化，具体代码如下：
在上面的示例中，DataSourceConfig类的作用是在项目启动时根据特定的前缀加载不同的数据源，再根据构建好的数据源创建不同的JdbcTemplate。
由于Spring容器中存在两个数据源，使用默认的类型查找时会报错，因此加上@Qualifier注解，表示按照名称查找。
这里创建了两个JdbcTemplate实例，分别对应了两个数据源。
需要注意的是，使用多个数据源时需要添加@Primary注解，表示自动装配出现多个Bean候选者时，被注解为@Primary的Bean将作为首选者。
Primary表示“主要的”，类似于SQL语句中的“Primary Key”（主键），只能有唯一一个，否则会报错。
package com.yangjunbo.helloword.properties;
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;
@Configuration
public class DataSourceConfig {
@Primary
@Bean(name = "primaryDataSource")
@Qualifier("primaryDataSource")
@ConfigurationProperties(prefix="spring.datasource.primary")
public DataSource primaryDataSource() {
return DataSourceBuilder.create().build();
}
@Bean(name = "secondaryDataSource")
@Qualifier("secondaryDataSource")
@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);
}
}
2.3测试调用多数据源
package com.yangjunbo.helloword;
import com.yangjunbo.helloword.pojo.Student;
import com.yangjunbo.helloword.rowMapper.StudentRowMapper;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.CallableStatementCallback;
import org.springframework.jdbc.core.CallableStatementCreator;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.PreparedStatementCreator;
import org.springframework.jdbc.support.GeneratedKeyHolder;
import org.springframework.jdbc.support.KeyHolder;
import java.sql.*;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@SpringBootTest
public class RowMapper {
@Autowired
private JdbcTemplate primaryJdbcTemplate;
@Autowired
private JdbcTemplate secondaryJdbcTemplate;
@Test
public void dataSourceTest(){
Student student = new Student("weiz多数据源",0,30);
primaryJdbcTemplate.update("INSERT INTO Student(name, sex, age) values(?, ?, ?)",
student.getName(), student.getSex(), student.getAge());
secondaryJdbcTemplate.update("INSERT INTO Student(name, sex, age) values(?, ?, ?)",
student.getName(), student.getSex(), student.getAge());
}
}
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。