1.需要導(dǎo)入相關(guān)的依賴

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
</dependency>

2.數(shù)據(jù)源配置

#數(shù)據(jù)源配置
spring.datasource.url=jdbc:mysql://localhost:3308/test?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=true
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

3.建表

CREATE TABLE `book` (
  `book_id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主鍵id',
  `book_name` varchar(32) DEFAULT NULL COMMENT '書名',
  `book_descript` varchar(32) DEFAULT NULL COMMENT '書本描述',
  `book_price` float(11) DEFAULT NULL COMMENT '書本價(jià)格',
  PRIMARY KEY (`book_id`)
) ENGINE=InnoDB AUTO_INCREMENT=102 DEFAULT CHARSET=utf8;

4.創(chuàng)建實(shí)體類

public class Book {
    private Long bookId;
    private String bookName;
    private String bookDescript;
    private float bookPrice;

    public Book(String bookName, String bookDescript, float bookPrice) {
        this.bookName = bookName;
        this.bookDescript = bookDescript;
        this.bookPrice = bookPrice;
    }

    public Long getBookId() {
        return bookId;
    }

    public String getBookName() {
        return bookName;
    }

    public String getBookDescript() {
        return bookDescript;
    }

    public float getBookPrice() {
        return bookPrice;
    }
}

5.封裝Repository

public interface BookRepository {
    int save(Book book);
    int update(Book book);
    int delete(Long id);
    List<Book> findAll();
    Book findById(Long id);
}

6.創(chuàng)建Repository的實(shí)現(xiàn)類

其中findById方法和findAll的查詢結(jié)果需要進(jìn)行封裝，其中findById使用了new BeanPropertyRowMapper<Book>(Book.class)對返回結(jié)果進(jìn)行了封裝，它可自動(dòng)將一行數(shù)據(jù)映射到指定類的實(shí)例中，首先先將這個(gè)類實(shí)例化，然后通過名稱匹配的方式，映射到屬性中去。findAll方法的返回結(jié)果通過創(chuàng)建的內(nèi)部類BookRowMapper進(jìn)行封裝。

@Repository
public class BookRepositoryImpl implements BookRepository {
    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Override
    public int save(Book book) {
        return jdbcTemplate.update("insert into book(book_name,book_descript,book_price) value(?,?,?)",book.getBookName(),book.getBookDescript(),book.getBookPrice());
    }

    @Override
    public int update(Book book) {
        return 0;
    }

    @Override
    public int delete(Long id) {
        return 0;
    }

    @Override
    public List<Book> findAll() {
        return jdbcTemplate.query("select * from book",new BookRowMapper());
    }

    @Override
    public Book findById(Long id) {
        return jdbcTemplate.queryForObject("select * from book where book_id = ?",new Object[]{id},new BeanPropertyRowMapper<Book>(Book.class));
    }
}

class BookRowMapper implements RowMapper<Book>{

    @Override
    public Book mapRow(ResultSet resultSet, int i) throws SQLException {
        Book book = new Book();
        book.setBookId(resultSet.getLong("book_id"));
        book.setBookName(resultSet.getString("book_name"));
        book.setBookDescript(resultSet.getString("book_descript"));
        book.setBookPrice(resultSet.getFloat("book_price"));
        return book;
    }
}

7.測試

@SpringBootTest
class D8ApplicationTests {
    @Autowired
    private BookRepository bookRepository;  
    @Test
    void saveBook(){
        Book book = new Book("西游記","西游記是一本xxx的小說",36);
        bookRepository.save(book);
    }
    @Test
    void findBookById(){
        Long id = new Long(102);
        Book book = bookRepository.findById(id);
        System.out.println(book.getBookName());
        System.out.println(book.getBookDescript());
        System.out.println(book.getBookPrice());

    }

    @Test
    void findAll(){
        List<Book> bookList = bookRepository.findAll();
        System.out.println(bookList.get(0).getBookName());
    }
}

8.總結(jié)

感覺spring jdbc對結(jié)果集的處理不太好用