Spring Data JPA例子代碼[基於Spring Boot、Mysql]

關於Spring Data

Spring社區的一個頂級工程，主要用於簡化數據（關係型&非關係型）訪問，如果我們使用Spring Data來開發程序的話，那麼可以省去很多低級別的數據訪問操作，如編寫數據查詢語句、DAO類等，我們僅需要編寫一些抽象接口並定義相關操作即可，Spring會在運行期間的時候創建代理實例來實現我們接口中定義的操作。

關於Spring Data子項目

Spring Data擁有很多子項目，除了Spring Data Jpa外，還有如下子項目。

Spring Data Commons

Spring Data MongoDB

Spring Data Redis

Spring Data Solr

Spring Data Gemfire

Spring Data REST

Spring Data Neo4j

關於Spring Data Jpa

Spring Data Jpa是Spring Data的一個子項目，主要用於簡化數據訪問層的實現，使用Spring Data Jpa可以輕鬆實現增刪改查、分頁、排序等。

例子，Spring Boot + Spring Data Jpa

1、添加POM.XML文件

如下所示:

 <?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.example</groupId> <artifactId>demo</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>spring-data-jpa-example</name> <description>Demo project for Spring Boot</description> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.4.4.RELEASE</version> <relativePath /> <!-- lookup parent from repository --> </parent> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.7</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jpa</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-cache</artifactId> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build></project>

其中，spring-boot-starter-parent會加載Spring Boot應用所需的所有默認配置；

spring-boot-starter-data-jpa會下載所有Spring Data Jpa所需的依賴；

添加spring-boot-starter-web是因為我們的工程是一個Web應用；

另外我們的數據庫是mysql，所以還需要mysql-connector-java依賴；

由於使用了緩存，所以再添加一個spring-boot-starter-cache依賴；

2、編寫實體類User

 package com.example.domain;import java.io.Serializable;import javax.persistence.Column;import javax.persistence.Entity;import javax.persistence.Id;import javax.persistence.NamedQuery;@Entity@NamedQuery(name = "User.findByName", query = "select name,address from User u where u.name=?1")public class User implements Serializable{ private static final long serialVersionUID = 1L; @Id long id; @Column(name = "name") String name; @Column(name = "address") String address; public long getId() { return id; } public void setId(long id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getAddress() { return address; } public void setAddress(String address) { this.address = address; }}

其它沒啥好說的，注意下這裡的@NamedQuery註解，大致意思就是讓我們在Repository接口中定義的findByName方法不使用默認的查詢實現，取而代之的是使用這條自定義的查詢語句去查詢，如果這裡沒有標註的話，會使用默認實現的。

3、編寫Repository接口

這裡將編寫兩個Repository接口，僅僅用於示例，實際中可以合併成一個：

UserJpaRepository

 package com.example.repository;import org.springframework.data.jpa.repository.JpaRepository;import com.example.domain.User;public interface UserJpaRepository extends JpaRepository<User,Long> {}

這裡的UserJpaRepository接口實現了JpaRepository接口；

實際上JpaRepository實現了PagingAndSortingRepository接口，PagingAndSortingRepository接口實現了CrudRepository接口，CrudRepository接口實現了Repository接口；

簡單說明下：

Repository接口是一個標識接口，裡面是空的；

CrudRepository接口定義了增刪改查方法；

PagingAndSortingRepository接口用於分頁和排序；

由於JpaRepository接口繼承了以上所有接口，所以擁有它們聲明的所有方法；

另外注意下，以findAll方法為例，JpaRepository接口返回的是List, PagingAndSortingRepository和CrudRepository返回的是迭代器；

UserRepository

 package com.example.repository;import java.util.List;import org.springframework.data.jpa.repository.Query;import org.springframework.data.repository.Repository;import org.springframework.data.repository.query.Param;import com.example.domain.User;public interface UserRepository extends Repository<User, Long>{ List<User> findByNameAndAddress(String name, String address); @Query(value = "from User u where u.name=:name") List<User> findByName1(@Param("name") String name); @Query(value = "select * from #{#entityName} u where u.name=?1", nativeQuery = true) List<User> findByName2(String name); List<User> findByName(String name);}

這裡的UserRepository接口主要定義了一些查詢方法；

比如這裡的findByNameAndAddress和findByName方法，我們是不需要額外定義其它查詢語句就可以直接執行的，Spring Data Jpa會根據實體類的屬性名字以及方法名自動實現該方法；PS:由於我們在實體類中聲明了@NamedQuery註解，實際上findByName方法會使用@NamedQuery註解標註的查詢語句去查詢；

另外這裡的findByName1方法使用了HQL語句查詢；

findByName2方法使用了原始的sql語句查詢；

4、編寫Service

service接口：

 package com.example.service;import java.util.List;import com.example.domain.User;public interface IUserService{ public List<User> findAll(); public void saveUser(User book); public User findOne(long id); public void delete(long id); public List<User> findByName(String name);}

接口實現類：

 package com.example.service.impl;import java.util.List;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.cache.annotation.Cacheable;import org.springframework.stereotype.Service;import org.springframework.transaction.annotation.Transactional;import com.example.domain.User;import com.example.repository.UserRepository;import com.example.repository.UserJpaRepository;import com.example.service.IUserService;@Service@Transactionalpublic class UserServiceImpl implements IUserService{ @Autowired private UserJpaRepository userJpaRepository; @Autowired private UserRepository userRepository; public List<User> findAll() { return userJpaRepository.findAll(); } public List<User> findByName(String name) { List<User> userList1 = userRepository.findByName1(name); List<User> userList2 = userRepository.findByName2(name); List<User> userList3 = userRepository.findByNameAndAddress(name, "3"); System.out.println("userList1:" + userList1); System.out.println("userList2:" + userList2); System.out.println("userList3:" + userList3); return userRepository.findByName(name); } public void saveUser(User book) { userJpaRepository.save(book); } @Cacheable("users") public User findOne(long id) { System.out.println("Cached Pages"); return userJpaRepository.findOne(id); } public void delete(long id) { userJpaRepository.delete(id); }}

這個沒啥好說的，調用Repository接口接口的方法即可。

5、編寫Controller

Controller也沒啥好說的，調用Service即可，注意下這裡的Controller使用@RestController註解來標註，另外URL路徑命名按照RESTful風格來命名；

 package com.example.web;import java.util.List;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;import com.example.domain.User;import com.example.service.IUserService;@RestController@RequestMapping(value = "/users")public class UserController{ @Autowired private IUserService userService; @RequestMapping(value = "/add/{id}/{name}/{address}") public User addUser(@PathVariable int id, @PathVariable String name, @PathVariable String address) { User user = new User(); user.setId(id); user.setName(name); user.setAddress(address); userService.saveUser(user); return user; } @RequestMapping(value = "/delete/{id}") public void deleteBook(@PathVariable int id) { userService.delete(id); } @RequestMapping(value = "/") public List<User> getBooks() { return userService.findAll(); } @RequestMapping(value = "/{id}") public User getUser(@PathVariable int id) { User user = userService.findOne(id); return user; } @RequestMapping(value = "/search/name/{name}") public List<User> getBookByName(@PathVariable String name) { List<User> users = userService.findByName(name); return users; }}

6、配置datasource

在application.properties文件中添加如下配置：

 spring.jpa.show-sql = truelogging.level.org.springframework.data=DEBUGspring.jpa.hibernate.ddl-auto=spring.datasource.url=jdbc:mysql://localhost:3306/demospring.datasource.username=rootspring.datasource.password=rootspring.datasource.driver-class-name=com.mysql.jdbc.Driver

如果你使用STS IDE的話，這些屬性配置都會自動提示的，省的去查找。

想查看spring.datasource的配置，可以參考這個類:DataSourceProperties.java

7、編寫啟動類

比較簡單，注意下該類所屬的包級別要大於或等於其它類，以保證其它類的註解可以被掃描到。

 package com.example;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cache.annotation.EnableCaching;@SpringBootApplication@EnableCachingpublic class SpringDataJpaExampleApplication { public static void main(String[] args) { SpringApplication.run(SpringDataJpaExampleApplication.class, args); }}

運行、測試程序

啟動main方法，或打成jar包運行；

瀏覽器輸入以下URL，測試即可：

http://localhost:8080/users/

http://localhost:8080/users/add/100/110/111

http://localhost:8080/users/delete/100

http://localhost:8080/users/2

http://localhost:8080/users/search/name/2

程序源碼

https://github.com/peterchenhdu/spring-data-jpa-example

參考資料

http://docs.spring.io/spring-data/jpa/docs/1.11.0.RELEASE/reference/html/

http://javabeat.net/spring-data-jpa/

https://spring.io/guides/gs/caching/

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。