JdbcTemplate 是 Spring 提供的一套 JDBC 範本框架,利用 AOP 技術來解決直接使用 JDBC 時大量重複程式碼的問題。 JdbcTemplate 雖然沒有 Mybatis 靈活,但比直接使用 JDBC 方便很多。 Spring Boot 中對JdbcTemplate 的使用提供了自動化配置類別JdbcTemplateAutoConfiguration,部分原始碼如下:
@Configuration @ConditionalOnClass({DataSource.class, JdbcTemplate.class}) @ConditionalOnSingleCandidate(DataSource.class) @AutoConfigureAfter({DataSourceAutoConfiguration.class}) @EnableConfigurationProperties({JdbcProperties.class}) public class JdbcTemplateAutoConfiguration { public JdbcTemplateAutoConfiguration() { } @Configuration @Import({JdbcTemplateAutoConfiguration.JdbcTemplateConfiguration.class}) static class NamedParameterJdbcTemplateConfiguration { NamedParameterJdbcTemplateConfiguration() { } @Bean @Primary @ConditionalOnSingleCandidate(JdbcTemplate.class) @ConditionalOnMissingBean({NamedParameterJdbcOperations.class}) public NamedParameterJdbcTemplate namedParameterJdbcTemplate(JdbcTemplate jdbcTemplate) { return new NamedParameterJdbcTemplate(jdbcTemplate); } } @Configuration static class JdbcTemplateConfiguration { private final DataSource dataSource; private final JdbcProperties properties; JdbcTemplateConfiguration(DataSource dataSource, JdbcProperties properties) { this.dataSource = dataSource; this.properties = properties; } @Bean @Primary @ConditionalOnMissingBean({JdbcOperations.class}) public JdbcTemplate jdbcTemplate() { JdbcTemplate jdbcTemplate = new JdbcTemplate(this.dataSource); Template template = this.properties.getTemplate(); jdbcTemplate.setFetchSize(template.getFetchSize()); jdbcTemplate.setMaxRows(template.getMaxRows()); if (template.getQueryTimeout() != null) { jdbcTemplate.setQueryTimeout((int)template.getQueryTimeout().getSeconds()); } return jdbcTemplate; } } }
從原始碼中看出,當classpath 下存在DataSource 和JdbcTemplate 並且DataSource 只有一個實例時,自動配置才會生效,若開發者沒有提供JdbcOperations ,Spring Boot 會自動在容器中註入一個JdbcTemplate (JdbcTemplate 是JdbcOperations 的子類別)。因此,開發者想要使用JdbcTemplate 只需要提供JdbcTemplate 的依賴和DataSource 依賴即可
在資料庫中建立表,如下:
CREATE TABLE `book` ( `id` int(11) NOT NULL AUTO_INCREMENT, `name` varchar(128) DEFAULT NULL, `author` varchar(128) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8; INSERT INTO `chapter05`(`id`, `name`, `author`) VALUES (1, '斗罗大陆Ⅰ', '唐家三少'); INSERT INTO `chapter05`(`id`, `name`, `author`) VALUES (2, '斗罗大陆Ⅱ', '唐家三少');
創建Spring Boot 項目,添加依賴
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-jdbc</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> <version>1.1.9</version> </dependency>
spring-boot-starter-jdbc 中提供了spring-jdbc,另外還加入了資料庫驅動依賴和資料庫連接池依賴
在application.properties 中設定資料庫基本連接資訊
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
spring. datasource.url=jdbc:mysql://localhost:3306/weirdo
spring.datasource.username=root
spring.datasource.password=root
建立Book 實體類,程式碼如下:
public class Book { private int id; private String name; private String author; public int getId() { return id; } public void setId(int id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getAuthor() { return author; } public void setAuthor(String author) { this.author = author; } }
建立BookDao,程式碼如下:
@Repository public class BookDao { @Autowired JdbcTemplate jdbcTemplate; public int addBook(Book book) { return jdbcTemplate.update("INSERT INTO book(name,author) VALUES (?,?)", book.getName(), book.getAuthor()); } public int updateBook(Book book) { return jdbcTemplate.update("UPDATE book SET name=?,author=? WHERE id=?", book.getName(), book.getAuthor(), book.getId()); } public int deleteBookById(Integer id) { return jdbcTemplate.update("DELETE FROM book WHERE id=?", id); } public Book getBookById(Integer id) { return jdbcTemplate.queryForObject("select * from book where id=?", new BeanPropertyRowMapper<>(Book.class), id); } public List<Book> getAllBooks() { return jdbcTemplate.query("select * from book", new BeanPropertyRowMapper<>(Book.class)); } }
程式碼解釋:
#建立BookDao ,注入jdbcTemplate 。由於已經加入了spring-jdbc 相關依賴, JdbcTemplate 會被自動註冊到Spring 容器中,因此這裡可以直接注入JdbcTemplate 使用
在JdbcTemplate 中,增刪改三種類型的操作主要使用update 和batchUpdate 方法來完成,query 和queryForObject 方法主要用來完成查詢功能。另外,還有execute 方法可以用來執行任意的sql、call 方法用來呼叫預存程序等
在執行查詢操作時,需要有一個RowMapper 將查詢出來的列和實體類別中的屬性一一對應。如果列名和屬性名是相同的,那麼可以直接使用BeanPropertyRowMapper;如果列名和屬性名不同,需要開發者自己實作RowMapper 接口,將列和實體類屬性一一對應起來
建立BookService 和BooKController
@Service public class BookService { @Autowired BookDao bookDao; public int addBook(Book book) { return bookDao.addBook(book); } public int updateBook(Book book) { return bookDao.updateBook(book); } public int deleteBookById(Integer id) { return bookDao.deleteBookById(id); } public Book getBookById(Integer id) { return bookDao.getBookById(id); } public List<Book> getAllBooks() { return bookDao.getAllBooks(); } }
@RestController public class BookController { @Autowired BookService bookService; @GetMapping("/bookOps") public void bookOps() { Book b1 = new Book(); b1.setId(99); b1.setName("西厢记"); b1.setAuthor("王实甫"); int i = bookService.addBook(b1); System.out.println("addBook>>>" + i); Book b2 = new Book(); b2.setId(1); b2.setName("朝花夕拾"); b2.setAuthor("鲁迅"); int updateBook = bookService.updateBook(b2); System.out.println("updateBook>>>"+updateBook); Book b3 = bookService.getBookById(1); System.out.println("getBookById>>>"+b3); int delete = bookService.deleteBookById(2); System.out.println("deleteBookById>>>"+delete); List<Book> allBooks = bookService.getAllBooks(); System.out.println("getAllBooks>>>"+allBooks); } }
最後在瀏覽器中造訪http://localhost:8081/bookOps 位址,控制台列印日誌如下:
addBook>>>1
##資料庫中的資料如下:
updateBook>>>1
getBookById>>>com.sang.Book@35e33288
deleteBookById>>> #getAllBooks>>>[com.sang.Book@2f7c2d6d, com.sang.Book@32db4b36]
以上是Spring Boot怎麼整合JdbcTemplate的詳細內容。更多資訊請關注PHP中文網其他相關文章!