SpringBoot20-基础案例06引入JdbcTemplate和多数据源配置

19次阅读

共计 2770 个字符,预计需要花费 7 分钟才能阅读完成。

 本文源码
GitHub: 知了一笑
https://github.com/cicadasmile/spring-boot-base

一、JdbcTemplate 对象

1、JdbcTemplate 简介

在 Spring Boot2.0 框架下配置数据源和通过 JdbcTemplate 访问数据库的案例。
SpringBoot 对数据库的操作在 jdbc 上面做了深层次的封装,使用 spring 的注入功能,可以把 DataSource 注册到 JdbcTemplate 之中。

2、JdbcTemplate 核心方法

1)execute 方法:可以用于执行任何 SQL 语句;2)update 方法 batchUpdate 方法:update 方法用于执行新增、修改、删除等语句;batchUpdate 方法用于执行批处理相关语句;3)query 方法及 queryFor 方法:用于执行查询相关语句;4)call 方法:用于执行存储过程、函数相关语句。

二、SpringBoot2 中用法

1、导入 Jar 包

<!-- 数据库依赖 -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.21</version>
</dependency>
<!-- JDBC 依赖 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>

2、配置数据源信息

spring:
  application:
    # 应用名称
    name: node06-boot-jdbc
  datasource:
    # 数据源一:data_one 库
    primary:
      # 2.0 开始的版本必须这样配置
      jdbc-url: jdbc:mysql://localhost:3306/data_one
      #url: jdbc:mysql://localhost:3306/data_one
      username: root
      password: 123
      driver-class-name: com.mysql.jdbc.Driver
    # 数据源二:data_two 库
    secondary:
      # 2.0 开始的版本必须这样配置
      jdbc-url: jdbc:mysql://localhost:3306/data_two
      #url: jdbc:mysql://localhost:3306/data_two
      username: root
      password: 123
      driver-class-name: com.mysql.jdbc.Driver

3、数据源代码配置

1)数据源一的配置
@Primary 注解表示该数据源作为默认的主数据库。

/**
 * 数据源一配置
 */
@Configuration
public class DataOneConfig {

    @Primary    // 主数据库
    @Bean(name = "primaryDataSource")
    @Qualifier("primaryDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.primary")
    public DataSource primaryDataSource (){return DataSourceBuilder.create().build() ;}

    @Bean(name = "primaryJdbcTemplate")
    public JdbcTemplate primaryJdbcTemplate (@Qualifier("primaryDataSource") DataSource dataSource){return new JdbcTemplate(dataSource);
    }
}

2)数据源二配置

/**
 * 数据源二配置
 */
@Configuration
public class DataTwoConfig {@Bean(name = "secondaryDataSource")
    @Qualifier("secondaryDataSource")
    @ConfigurationProperties(prefix="spring.datasource.secondary")
    public DataSource secondaryDataSource() {return DataSourceBuilder.create().build();}

    @Bean(name = "secondaryJdbcTemplate")
    public JdbcTemplate secondaryJdbcTemplate(@Qualifier("secondaryDataSource") DataSource dataSource) {return new JdbcTemplate(dataSource);
    }
}

4、编写一个简单的测试类

@RestController
public class JdbcController {private static final Logger LOG = LoggerFactory.getLogger(JdbcController.class);

    // 数据源一
    @Autowired
    @Qualifier("primaryJdbcTemplate")
    private JdbcTemplate primaryJdbcTemplate ;

    // 数据源二
    @Autowired
    @Qualifier("secondaryJdbcTemplate")
    private JdbcTemplate secondaryJdbcTemplate ;

    /**
     * 多数据源查询
     */
    @RequestMapping("/queryData")
    public String queryData (){String sql = "SELECT COUNT(1) FROM d_phone" ;
        Integer countOne = primaryJdbcTemplate.queryForObject(sql,Integer.class) ;
        Integer countTwo = secondaryJdbcTemplate.queryForObject(sql,Integer.class) ;
        LOG.info("countOne=="+countOne+";;countTwo=="+countTwo);
        return "SUCCESS" ;
    }
}

三、源代码地址

GitHub 地址:知了一笑
https://github.com/cicadasmile/spring-boot-base
码云地址:知了一笑
https://gitee.com/cicadasmile/spring-boot-base


正文完
 0