本文源碼 GitHub:知了一笑 https://github.com/cicadasmile/spring-boot-base
在Spring Boot2.0框架下配置數據源和經過JdbcTemplate訪問數據庫的案例。
SpringBoot對數據庫的操做在jdbc上面作了深層次的封裝,使用spring的注入功能,能夠把DataSource註冊到JdbcTemplate之中。java
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 註解表示該數據源做爲默認的主數據庫。node
/** * 數據源一配置 */ @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)數據源二配置mysql
/** * 數據源二配置 */ @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/spring-boot-base 碼雲地址:知了一笑 https://gitee.com/cicadasmile/spring-boot-base