[技术笔记] [杭州校区][技术笔记] Spring Boot JPA

本帖最后由小江哥于 2018-12-17 15:29 编辑

一、Spring Boot JPA介绍

1、什么是JPA

JPA全称Java Persistence API.JPA通过JDK 5.0注解或XML描述对象－关系表的映射关系，并将运行期的实体对象持久化到数据库中。

JPA(Java Persistence API)是Sun官方提出的Java持久化规范。它为Java开发人员提供了一种对象/关系映射工具来管理Java应用中的关系数据。

2、什么是Spring Data

Spring Data是一个用于简化数据库访问，并支持云服务的开源框架。其主要目标是使得数据库的访问变得方便快捷，并支持map-reduce框架和云计算数据服务。此外，它还支持基于关系型数据库的数据服务，如Oracle RAC等。对于拥有海量数据的项目，可以用Spring Data来简化项目的开发，就如Spring Framework对JDBC、ORM的支持一样，Spring Data会让数据的访问变得更加方便。

3、什么是Spring Data JPA

我们先看一个描述：Spring Data JPA能干什么？

可以极大的简化JPA的写法，可以在几乎不用写实现的情况下，实现对数据的访问和操作。除了CRUD外，还包括如分页、排序等一些常用的功能。

首先我们需要清楚的是Spring Data是一个开源框架，在这个框架中Spring Data JPA只是这个框架中的一个模块，所以名称才叫Spring Data JPA。如果单独使用JPA开发，你会发现这个代码量和使用JDBC开发一样有点烦人，所以Spring Data JPA的出现就是为了简化JPA的写法，让你只需要编写一个接口继承一个类就能实现CRUD操作了。

二、Spring Boot JPA使用

1、搭建maven项目环境

pom.xml

[HTML] 纯文本查看 复制代码

<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 [url=http://maven.apache.org/xsd/maven-4.0.0.xsd]http://maven.apache.org/xsd/maven-4.0.0.xsd[/url]">
        <modelVersion>4.0.0</modelVersion>
        <groupId>cn.itcast.springboot</groupId>
        <artifactId>springboot_jpa</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <!-- spring boot 父节点依赖，引入这个之后相关的引入就不需要添加version配置，springboot会自动选择最合适的版本进行添加 -->
        <parent>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-parent</artifactId>
                <version>1.4.1.RELEASE</version>
        </parent>
 
        <dependencies>
                <!-- spring-boot-starter-web：提供了MVC、AOP等常见的依赖包 -->
                <dependency>
                        <groupId>org.springframework.boot</groupId>
                        <artifactId>spring-boot-starter-web</artifactId>
                        <!-- 此处因为上面已经配置了parent，因此就不需要指定版本了 -->
                </dependency>
 
                <!-- 引入fastjson依赖库 -->
                <dependency>
                        <groupId>com.alibaba</groupId>
                        <artifactId>fastjson</artifactId>
                        <version>1.2.15</version>
                </dependency>
 
                <!-- 添加热部署devtools的依赖 包，该jar包和热部署插件不能同时使用 -->
                <dependency>
                        <groupId>org.springframework.boot</groupId>
                        <artifactId>spring-boot-devtools</artifactId>
                        <optional>true</optional>
                        <scope>true</scope>
                </dependency>
        </dependencies>
 
        <build>
                <plugins>
                        <!-- java编译插件 -->
                        <plugin>
                                <groupId>org.apache.maven.plugins</groupId>
                                <artifactId>maven-compiler-plugin</artifactId>
                                <configuration>
                                        <source>1.7</source>
                                        <target>1.7</target>
                                        <encoding>UTF-8</encoding>
                                </configuration>
                        </plugin>
                        <!-- 热启动插件 -->
                        <plugin>
                                <groupId>org.springframework.boot</groupId>
                                <artifactId>spring-boot-maven-plugin</artifactId>
                                <configuration>
                                        <!-- fork:如果没有该配置，则devtools不会生效 -->
                                        <fork>true</fork>
                                </configuration>
                        </plugin>
 
                </plugins>
        </build>
</project>

App.java

[HTML] 纯文本查看 复制代码

package cn.itcast.test;
 
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.web.HttpMessageConverters;
import org.springframework.context.annotation.Bean;
import org.springframework.http.converter.HttpMessageConverter;
 
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.alibaba.fastjson.support.config.FastJsonConfig;
import com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter;
 
/**
 * 启动springboot的类
 * 
 * @author Administrator
 *
 */
@SpringBootApplication
public class App {
 
        @Bean//该注解作用是注入第三方的解析框架
        public HttpMessageConverters fastJsonHttpMessageConverters() {
                // 定义Converter转换消息对象
                FastJsonHttpMessageConverter fastConverter = new FastJsonHttpMessageConverter();
                // 添加fastJson的配置信息
                FastJsonConfig fastJsonConfig = new FastJsonConfig();
                // 添加是否格式化的配置
                fastJsonConfig.setSerializerFeatures(SerializerFeature.PrettyFormat);
                // 在converter中添加配置信息
                fastConverter.setFastJsonConfig(fastJsonConfig);
 
                HttpMessageConverter<?> converter = fastConverter;
 
                return new HttpMessageConverters(converter);
 
        }
 
        public static void main(String[] args) {
 
                SpringApplication.run(App.class, args);
        }
}

2、在pom.xml中添加MySQL数据库驱动依赖、spring-data-jpa依赖

[AppleScript] 纯文本查看 复制代码

<!-- 添加MySQL数据库依赖 -->
                <dependency>
                        <groupId>mysql</groupId>
                        <artifactId>mysql-connector-java</artifactId>
                </dependency>
                
                <!-- 添加spring-data-jpa依赖 -->
                <dependency>
                        <groupId>org.springframework.boot</groupId>
                        <artifactId>spring-boot-starter-data-jpa</artifactId>
                </dependency>

3、编写mysql连接信息的资源文件和Spring jpa的配置信息

[Bash shell] 纯文本查看 复制代码

########################################################
###datasource：配置数据库连接信息
########################################################
spring.datasource.url = jdbc:mysql://localhost:3306/test
spring.datasource.username = root
spring.datasource.password = root
spring.datasource.driverClassName = com.mysql.jdbc.Driver
spring.datasource.max-active=20
spring.datasource.max-idle=8
spring.datasource.min-idle=8
spring.datasource.initial-size=10


########################################################
### Java Persistence Api：配置hibernate的其他参数
########################################################
# Specify the DBMS
spring.jpa.database = MYSQL
# Show or not log for each sql query
spring.jpa.show-sql = true
# Hibernate ddl auto (create, create-drop, update)
spring.jpa.hibernate.ddl-auto = update
# Naming strategy
#[org.hibernate.cfg.ImprovedNamingStrategy  #org.hibernate.cfg.DefaultNamingStrategy]
spring.jpa.hibernate.naming-strategy = org.hibernate.cfg.ImprovedNamingStrategy
# stripped before adding them to the entity manager)
spring.jpa.properties.hibernate.dialect = org.hibernate.dialect.MySQL5Dialect

4、编写pojo类

[Java] 纯文本查看 复制代码

package cn.itcast.pojo;
 
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
 
/**
 * 
 * 
 * @author Administrator
 *
 */
@Entity // 1、使用 @Entity 进行实体类的持久化操作，当JPA检测到实体类中的@Entity注解的时候，就会在数据库中生成一张对应的表结构
public class Cat {
 
        @Id // 使用@Id指定主键
        @GeneratedValue(strategy = GenerationType.AUTO) // 使用 @GeneratedValue指定主键生成策略
        private Integer id;
 
        private String catName;
        private Integer catAge;
 
        public Integer getId() {
                return id;
        }
 
        public void setId(Integer id) {
                this.id = id;
        }
 
        public String getCatName() {
                return catName;
        }
 
        public void setCatName(String catName) {
                this.catName = catName;
        }
 
        public Integer getCatAge() {
                return catAge;
        }
 
        public void setCatAge(Integer catAge) {
                this.catAge = catAge;
        }
 
        @Override
        public String toString() {
                return "Cat [id=" + id + ", catName=" + catName + ", catAge=" + catAge + "]";
        }
 
}

5、创建jpa repository类操作持久化接口

[Java] 纯文本查看 复制代码

package cn.itcast.dao;
 
import org.springframework.data.jpa.repository.JpaRepository;
 
import cn.itcast.pojo.Cat;
 
public interface CatRepository extends JpaRepository<Cat, Integer> {
 
}

6、创建Service层接口和实现类

[Java] 纯文本查看 复制代码

package cn.itcast.service;
 
import cn.itcast.pojo.Cat;
 
public interface CatService {
 
        public void save(Cat cat);
        
        public void delete(Integer id);
        
        public Iterable<Cat> getAll();
}

[Java] 纯文本查看 复制代码

package cn.itcast.service.impl;
 
import javax.transaction.Transactional;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
 
import cn.itcast.dao.CatRepository;
import cn.itcast.pojo.Cat;
import cn.itcast.service.CatService;
 
@Service
public class CatServiceImpl implements CatService {
 
        @Autowired
        private CatRepository catRepository;
 
        @Transactional
        public void save(Cat cat) {
                catRepository.save(cat);
 
        }
 
        @Transactional
        public void delete(Integer id) {
                catRepository.delete(id);
 
        }
 
        @Override
        public Iterable<Cat> getAll() {
                return catRepository.findAll();
 
        }
 
}

7、Controller

[AppleScript] 纯文本查看 复制代码

package cn.itcast.controller;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
 
import cn.itcast.pojo.Cat;
import cn.itcast.service.CatService;
 
@RestController
@RequestMapping("/cat")
public class CatController {
 
        @Autowired
        private CatService catService;
 
        @RequestMapping("/save")
        public void save() {
                Cat cat = new Cat();
                cat.setCatName("呵呵");
                cat.setCatAge(18);
                catService.save(cat);
        }
 
        @RequestMapping("/delete")
        public void delete() {
                catService.delete(1);
        }
}

本帖最后由小江哥于 2018-11-15 17:17 编辑

一：什么是REST服务
1.REST是一种编程的风格，作用是可以精确定位网上的资源（接口、方法、参数），效率高

2.REST支持的数据格式：JSON，XML

3. REST支持的发送方式：GET，POST

二：发布REST服务
1.开发步骤
(1.) 引入jar包

activemq-openwire-lcgacy-5.8.0.jar

(2.) 创建实体类

● 注意：类上加入注解：@XMLRootElement，该注解表示java对象和XML数据之间可以转换

[Java] [color=rgb(51, 102, 153) !important]纯文本查看 [color=rgb(51, 102, 153) !important]复制代码
[color=white !important]

[color=white !important]?

01

02

03

04

05

06

07

08

09

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

package com.cxf.rest.pojo;

import java.util.Date;

import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement
public class Student {

      private Integer id;
      private String name;
      private Date birthday;

      public Integer getId() {
            return id;
      }

      public void setId(Integer id) {
            this.id = id;
      }

      public String getName() {
            return name;
      }

      public void setName(String name) {
            this.name = name;
      }

      public Date getBirthday() {
            return birthday;
      }

      public void setBirthday(Date birthday) {
            this.birthday = birthday;
      }

}

(3.) 创建SEI接口

● 加入注解：@WebService

[Java] [color=rgb(51, 102, 153) !important]纯文本查看 [color=rgb(51, 102, 153) !important]复制代码
[color=white !important]

[color=white !important]?

01

02

03

04

05

06

07

08

09

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

package com.cxf.rest.service;

import java.util.List;

import javax.jws.WebService;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

import com.cxf.rest.pojo.Student;

@WebService
@Path("/student")//将请求路径中的"/student"映射到该接口上
public interface StudentInterface {

      //查询单个学生
      @POST//指定请求方式，服务端如果发布时指定为GET（POST），客户端访问时必须使用GET（POST）
      @Produces(MediaType.APPLICATION_XML)//指定媒体类型，XML
      @Path("/query/{id}")//@Path("/query/{id}")的意思是将请求路径中的/query映射到方法上，/{id}映射到对应的参数上，如果有多个参数以/隔开加入到{}
      public Student query(@PathParam("id")Integer id);

      //查询多个学生
      @POST//指定请求方式，服务端如果发布时指定为GET（POST），客户端访问时必须使用GET（POST）
      @Produces({"application/json;charset=utf-8",MediaType.APPLICATION_XML})//指定媒体类型，JSON
      @Path("/queryList/{name}")//@Path("/queryList/{name}")的意思是将请求路径中的/queryList映射到方法上，/{name}映射到对应的参数上，如果有多个参数以/隔开加入到{}
      public List<Student> queryList(@PathParam("name")String name);
}

(4.) 创建实现类

[Java] [color=rgb(51, 102, 153) !important]纯文本查看 [color=rgb(51, 102, 153) !important]复制代码
[color=white !important]

[color=white !important]?

01

02

03

04

05

06

07

08

09

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

package com.cxf.rest.service.impl;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import com.cxf.rest.pojo.Student;
import com.cxf.rest.service.StudentInterface;

public class StudentInterfaceImpl implements StudentInterface {

      @Override
      public Student query(Integer id) {
            Student st = new Student();
            st.setId(110);
            st.setName("张三");
            st.setBirthday(new Date());
            return st;
      }

      @Override
      public List<Student> queryList(String name) {
            Student st = new Student();
            st.setId(110);
            st.setName("张三");
            st.setBirthday(new Date());

            Student st2 = new Student();
            st2.setId(120);
            st2.setName("李四");
            st2.setBirthday(new Date());

            List<Student> list = new ArrayList<Student>();
            list.add(st);
            list.add(st2);
            return list;
      }

}

(5.) 发布服务

● 使用JAXRSServerFactoryBean发布rest服务，3个参数：

A、setServiceBean：设置服务实现类

B、setResourceClasses：设置资源类

C、setAddress：设置服务地址

● crate：发布服务

[Java] [color=rgb(51, 102, 153) !important]纯文本查看 [color=rgb(51, 102, 153) !important]复制代码
[color=white !important]

[color=white !important]?

01

02

03

04

05

06

07

08

09

10

11

12

13

14

15

16

17

18

19

20

package com.cxf.rest.server;

import org.apache.cxf.jaxrs.JAXRSServerFactoryBean;

import com.cxf.rest.service.impl.StudentInterfaceImpl;

public class StudentServer {
      public static void main(String[] args) {
            // JAXRSServerFactoryBean发布REST服务
            JAXRSServerFactoryBean jaxRSServerFactoryBean = new JAXRSServerFactoryBean();
            // 设置服务实现类
            jaxRSServerFactoryBean.setServiceBean(new StudentInterfaceImpl());
            // 设置资源类，如果有多个资源类，以,隔开；如果是多个，将资源类放到一个类中，设置那一个类就可以了
            jaxRSServerFactoryBean.setResourceClasses(StudentInterfaceImpl.class);
            // 设置服务地址
            jaxRSServerFactoryBean.setAddress("http://127.0.0.1:12345/user");
            // 发布服务
            jaxRSServerFactoryBean.create();
      }
}

(6.) 测试服务是否发布成功

● 查询单个学生，返回XML数据

http://127.0.0.1:12345/user/student/query/110

</student>

● 查询多个学生，返回XML数据

http://127.0.0.1:12345/user/student/queryList/110

</student>

</student>

</students>

● 查询多个学生，指定媒体类型

http://127.0.0.1:12345/user/student/queryList/110?_type=json

{"student":[{"birthday":"2016-09-03T13:00:10.803+08:00","id":110,"name":"张三"},{"birthday":"2016-09-03T13:00:10.803+08:00","id":120,"name":"李四"}]}

● 注意：

如果在同一个方法上同时指定XML和JSON两种格式，在GET请求下默认返回XML数据；在POST情况下默认返回JSON

2.使用httpClient访问服务端

[Java] [color=rgb(51, 102, 153) !important]纯文本查看 [color=rgb(51, 102, 153) !important]复制代码
[color=white !important]

[color=white !important]?

01

02

03

04

05

06

07

08

09

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

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;

/**
*
* <p>Title: HttpClient.java</p>
* <p>Description:HttpURLConnection调用方式</p>
*/
public class HttpClient {

      public static void main(String[] args) throws IOException {
            //1：创建服务地址
            URL url = new URL("http://127.0.0.1:12345/user/student/queryList/110");
            //2：打开到服务地址的一个连接
            HttpURLConnection connection = (HttpURLConnection) url.openConnection();
            //3：设置连接参数
            //3.1设置发送方式：POST必须大写
            connection.setRequestMethod("POST");
            //3.3设置输入输出，新创建的connection默认是没有读写权限的，
            connection.setDoInput(true);
//             connection.setDoOutput(true);

            //5：接收服务端的响应
            int responseCode = connection.getResponseCode();
            if(200 == responseCode){//表示服务端响应成功
                     InputStream is = connection.getInputStream();
                     InputStreamReader isr = new InputStreamReader(is);
                     BufferedReader br = new BufferedReader(isr);

                     StringBuilder sb = new StringBuilder();
                     String temp = null;

                     while(null != (temp = br.readLine())){
                              sb.append(temp);
                     }

                     System.out.println(sb.toString());

                     is.close();
                     isr.close();
                     br.close();
            }

      }

}

帐号		自动登录	找回密码
密码			加入黑马

[技术笔记] [杭州校区][技术笔记] Spring Boot JPA

0 个回复

浏览过的版块