前面關(guān)于spring Boot的文章已經(jīng)介紹了很多了,但是一直都沒有涉及到數(shù)據(jù)庫的操作問題,數(shù)據(jù)庫操作當(dāng)然也是我們在開發(fā)中無法回避的問題,那么今天我們就來看看Spring Boot給我們提供了哪些瘋狂的方式來解決數(shù)據(jù)庫的操作問題。
OK,廢話不多說,讓我們愉快的開啟今天的數(shù)據(jù)庫操作之旅吧!
什么是JPA
一說JavaWeb,很多小伙伴都知道SSH,這個(gè)H代表的就是hibernate框架,這個(gè)小伙伴們都知道,可是什么又是JPA呢?相信許多剛?cè)腴T的小伙伴聽說過但不是特別清楚,首先JPA的全稱叫做Java Persistence API,JPA是一個(gè)基于O/R映射的標(biāo)準(zhǔn)規(guī)范,在這個(gè)規(guī)范中,JPA只定義標(biāo)準(zhǔn)規(guī)則,不提供實(shí)現(xiàn),使用者則需要按照規(guī)范中定義的方式來使用。目前JPA的主要實(shí)現(xiàn)有Hibernate、EclipseLink、OpenJPA等,事實(shí)上,由于Hibernate在數(shù)據(jù)訪問解決技術(shù)領(lǐng)域的絕對霸主地位,JPA的標(biāo)準(zhǔn)基本是由Hibernate來主導(dǎo)的。雖然做開發(fā)的小伙伴不怎么喜歡度娘,不過度娘關(guān)于JPA的介紹個(gè)人覺得倒是比較清晰,有興趣的小伙伴可前去了解下。另外,Spring框架為我們提供了Spring Data JPA這樣一個(gè)東東,可以減少我們使用JPA時(shí)的代碼量。
使用流程
創(chuàng)建工程并添加相關(guān)依賴
在Spring Boot中使用JPA,我們在創(chuàng)建工程的時(shí)候需要選擇JPA依賴,如下:
其他的步驟和我們創(chuàng)建一個(gè)普通的Spring Boot項(xiàng)目是一樣的
項(xiàng)目創(chuàng)建成功之后,我這里是使用MySQL做演示,因此還需要添加MySql驅(qū)動(dòng),在pom.xml文件中添加如下依賴:
1
2
3
4
5
|
< dependency > < groupId >mysql</ groupId > < artifactId >mysql-connector-java</ artifactId > < version >5.1.40</ version > </ dependency > |
配置基本屬性
接下來需要我們在application.properties中配置數(shù)據(jù)源和jpa的基本的相關(guān)屬性,如下:
1
2
3
4
5
6
7
8
|
spring.datasource.driver-class-name=com.mysql.jdbc.Driver spring.datasource.url=jdbc:mysql://localhost:3306/jpatest spring.datasource.username=root spring.datasource.password=123456 spring.jpa.hibernate.ddl-auto=update spring.jpa.show-sql=true spring.jackson.serialization.indent_output=true |
關(guān)于這里的配置我說如下幾點(diǎn):
1.第一行表示驅(qū)動(dòng)的名稱,這個(gè)和具體的數(shù)據(jù)庫驅(qū)動(dòng)有關(guān),視情況而定,我這里使用了MySql數(shù)據(jù)庫,所以驅(qū)動(dòng)名為com.mysql.jdbc.Driver
2.第二行表示數(shù)據(jù)庫連接地址,當(dāng)然也是視情況而定
3.第三四行表示數(shù)據(jù)庫連接的用戶名和密碼
4.第五行則配置了實(shí)體類維護(hù)數(shù)據(jù)庫表結(jié)構(gòu)的具體行為,update表示當(dāng)實(shí)體類的屬性發(fā)生變化時(shí),表結(jié)構(gòu)跟著更新,這里我們也可以取值create,這個(gè)create表示啟動(dòng)的時(shí)候刪除上一次生成的表,并根據(jù)實(shí)體類重新生成表,這個(gè)時(shí)候之前表中的數(shù)據(jù)就會(huì)被清空;還可以取值create-drop,這個(gè)表示啟動(dòng)時(shí)根據(jù)實(shí)體類生成表,但是當(dāng)sessionFactory關(guān)閉的時(shí)候表會(huì)被刪除;validate表示啟動(dòng)時(shí)驗(yàn)證實(shí)體類和數(shù)據(jù)表是否一致;none表示啥都不做。
5.第六行表示hibernate在操作的時(shí)候在控制臺(tái)打印真實(shí)的sql語句
6.第七行表示格式化輸出的json字符串
OK,以上就是我們在application.properties中對JPA進(jìn)行的一個(gè)簡單配置。
定義映射實(shí)體類
接下來,定義相應(yīng)的實(shí)體類,在Project啟動(dòng)時(shí),系統(tǒng)會(huì)根據(jù)實(shí)體類創(chuàng)建相應(yīng)的數(shù)據(jù)表,我的實(shí)體類如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
@Entity @NamedQuery (name = "Person.withNameAndAddressNamedQuery" , query = "select p from Person p where p.name=?1 and p.address=?2" ) public class Person { @Id @GeneratedValue private Long id; private String name; private Integer age; private String address; public Person() { } public Person(Long id, String name, Integer age, String address) { this .id = id; this .name = name; this .age = age; this .address = 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 Integer getAge() { return age; } public void setAge(Integer age) { this .age = age; } public String getAddress() { return address; } public void setAddress(String address) { this .address = address; } } |
首先在實(shí)體類上我們使用了@Entity注解,這個(gè)表示這是一個(gè)和數(shù)據(jù)庫表映射的實(shí)體類,在屬性id上我們添加了@Id注解,表示該字段是一個(gè)id,@GeneratedValue注解則表示該字段自增。@NamedQuery注解表示一個(gè)NamedQuery查詢,這里一個(gè)名稱代表一個(gè)查詢語句,我們一會(huì)可以在控制器中直接調(diào)用@NamedQuery中的withNameAndAddressNamedQuery方法,該方法代表的查詢語句是select p from Person p where p.name=?1 and p.address=?2。
定義數(shù)據(jù)訪問接口
OK,做好上面幾個(gè)步驟之后,接下來我們就可以定義數(shù)據(jù)訪問接口了,我們的數(shù)據(jù)訪問接口需要繼承JpaRepository類,我在數(shù)據(jù)訪問接口中一共定義了四個(gè)方法,如下:
1
2
3
4
5
6
7
8
9
10
11
|
public interface PersonRepository extends JpaRepository<Person, Long> { List<Person> findByAddress(String name); Person findByNameAndAddress(String name, String address); @Query ( "select p from Person p where p.name=:name and p.address=:address" ) Person withNameAndAddressQuery( @Param ( "name" ) String name, @Param ( "address" ) String address); Person withNameAndAddressNamedQuery(String name, String address); } |
關(guān)于這個(gè)數(shù)據(jù)訪問接口,我說如下幾點(diǎn):
1.當(dāng)我們繼承JpaRepository接口后,我們就自動(dòng)具備了如下數(shù)據(jù)訪問方法:
1
2
3
4
5
6
7
8
9
10
11
|
List<T> findAll(); List<T> findAll(Sort var1); List<T> findAll(Iterable<ID> var1); <S extends T> List<S> save(Iterable<S> var1); void flush(); <S extends T> S saveAndFlush(S var1); void deleteInBatch(Iterable<T> var1); void deleteAllInBatch(); T getOne(ID var1); <S extends T> List<S> findAll(Example<S> var1); <S extends T> List<S> findAll(Example<S> var1, Sort var2); |
2.我們可以在接口中定義查詢方法,可以按照屬性名來查詢,但是方法的命名方式是固定的,比如第一個(gè)方法和第二個(gè)方法,第一個(gè)方法表示根據(jù)一個(gè)屬性查詢,第二個(gè)方法表示根據(jù)多個(gè)屬性查詢,findBy、And等可以算作是這里的查詢關(guān)鍵字了,如果寫作其他名稱則系統(tǒng)不能識(shí)別,類似的關(guān)鍵字還有Like、Or、Is、Equals、Between等,而這里的findBy關(guān)鍵字又可以被find、read、readBy、query、queryBy、get、getBy等來代替。
3.在查詢的過程中我們也可以限制查詢結(jié)果,這里使用的關(guān)鍵字是top、first等,比如查詢前10條數(shù)據(jù)我們可以寫作:
List<Person> findFirst10ByName(String name);
4.使用NamedQuery來查詢,就是我們直接在實(shí)體類上使用@NamedQuery注解來定義查詢方法和方法名,一個(gè)名稱對應(yīng)一個(gè)查詢語句,具體可以參考我們上文的實(shí)體類
5.我們也可以向第三個(gè)方法那樣添加@Query注解,當(dāng)我調(diào)用這個(gè)方法的時(shí)候使用這個(gè)注解中的sql語句進(jìn)行查詢,方法的參數(shù)則是注解中的占位符的值。
編寫測試Controller
數(shù)據(jù)訪問接口都有了,接下來就是一個(gè)Controller了,我們寫一個(gè)簡單的Controller,用來測試一下上文中的數(shù)據(jù)訪問接口是否正確,如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
|
@RestController public class DataController { @Autowired PersonRepository personRepository; @RequestMapping ( "/save" ) public Person save(String name,String address,Integer age) { Person person = personRepository.save( new Person( null , name, age, address)); return person; } @RequestMapping ( "/q1" ) public List<Person> q1(String address) { List<Person> people = personRepository.findByAddress(address); return people; } @RequestMapping ( "/q2" ) public Person q2(String name, String address) { Person people = personRepository.findByNameAndAddress(name, address); return people; } @RequestMapping ( "/q3" ) public Person q3(String name, String address) { Person person = personRepository.withNameAndAddressQuery(name, address); return person; } @RequestMapping ( "/q4" ) public Person q4(String name, String address) { Person person = personRepository.withNameAndAddressNamedQuery(name, address); return person; } @RequestMapping ( "/sort" ) public List<Person> sort() { List<Person> people = personRepository.findAll( new Sort(Sort.Direction.ASC, "age" )); return people; } @RequestMapping ( "/page" ) public Page<Person> page( int page, int size){ Page<Person> all = personRepository.findAll( new PageRequest(page, size)); return all; } @RequestMapping ( "/all" ) public List<Person> all(){ return personRepository.findAll(); } } |
這里的代碼都很簡單,我就不再一一進(jìn)行解釋了,值得說的是第36行代碼表示根據(jù)age對查詢結(jié)果進(jìn)行排序然后顯示出來,第40行的方法表示一個(gè)分頁查詢,第一個(gè)參數(shù)表示頁數(shù),從0開始計(jì),第二個(gè)參數(shù)表示每頁的數(shù)據(jù)量。最后在瀏覽器中分別測試這幾個(gè)接口就可以了,我這里就不再展示測試頁面了,小伙伴們自行測試。
本文源碼下載:本文GitHub地址
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持服務(wù)器之家。
原文鏈接:http://blog.csdn.net/u012702547/article/details/53946440