您好,登錄后才能下訂單哦!
在Spring Boot2.0框架下配置數據源和通過JdbcTemplate訪問數據庫的案例。
SpringBoot對數據庫的操作在jdbc上面做了深層次的封裝,使用spring的注入功能,可以把DataSource注冊到JdbcTemplate之中。
1)execute方法:可以用于執行任何SQL語句;
2)update方法batchUpdate方法:update方法用于執行新增、修改、刪除等語句;batchUpdate方法用于執行批處理相關語句;
3)query方法及queryFor方法:用于執行查詢相關語句;
4)call方法:用于執行存儲過程、函數相關語句。
<!-- 數據庫依賴 -->
<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>
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
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);
}
}
@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
碼云地址:知了一笑
https://gitee.com/cicadasmile
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。