Java1.8在线运行
Boot 使用JPA实现CURD
优化或报错有奖注意：本页面内容为W3xue原创，未经授权禁止转载，违者必究！
来源：W3xue 发布时间：2019/8/26 15:34:09
在上一节中，我们已经使用 JPA连接了数据库，那么数据库的其他操作该如何进行？本章节就来介绍数据库的全套CURD（创建、更新、查找、删除）。
一、数据添加的优化
首先，我们来优化上一章节中提到的添加数据的功能。我们在这里做2个优化，第一，是加上用户自定义的参数，第二，是增加session验证。我们利用一个接口“adminlogin”，进行简单的身份验证，利用接口“adminlogin”，设置键为“admin”的session，然后，jpatest对键为“admin”的session进行判断，如果不出错，则身份验证通过。这里，“adminlogin”接口的代码非常简单，只要在地址栏加上参数“pwd=mypassword”即可，后面我们还会对这个接口进行改进。这里我们只需要明白，session验证是一种基本的安全手段。
除此之外，我们还用到了@RequestParam这个注解，这个注解的作用，是取得地址栏的参数。比如，@RequestParam(value = "name",defaultValue = "") String pName 加在方法体的参数pName前，用来为该参数赋值，而其地址栏对应的参数字符是name，而这个参数的默认值为空。
在MainRestController类添加如下代码：
@RequestMapping(value="/adminlogin",method= RequestMethod.GET)
public String adminlogin(@RequestParam(value = "pwd",defaultValue = "") String pPwd, HttpSession session) {
try {
if (pPwd.equals("mypassword")) {
session.setAttribute("admin", "管理员大大");
return "管理员大大，登录成功";
}
else
{
return "登录失败";
}
}catch (Exception e) {
return "登录失败";
}
}
@RequestMapping(value="/jpatest",method= RequestMethod.GET)
public String jpaTest(@RequestParam(value = "name",defaultValue = "") String pName,@RequestParam(value = "age",defaultValue = "0") Integer pAge,@RequestParam(value = "grade",defaultValue = "") String pGrade,@RequestParam(value = "studentclass",defaultValue = "") String pStudentClass,@RequestParam(value = "parent_name",defaultValue = "") String pParent_name,@RequestParam(value = "parent_mobilephone",defaultValue = "") String pParent_mobilephone, HttpSession session) {
MainBean mbStudent = new MainBean();
mbStudent.setName(pName);
mbStudent.setAge(pAge);
mbStudent.setGrade(pGrade);
mbStudent.setStudentClass(pStudentClass);
mbStudent.setParent_name(pParent_name);
mbStudent.setParent_mobilephone(pParent_mobilephone);
try
{
if (session.getAttribute("admin").toString().length()>0) {
mainServiceImpl.addMain(mbStudent);
return "添加学生" + mbStudent.getName() + "成功";
}
else
{
return "添加失败，没有权限";
}
}
catch (Exception e)
{
mainServiceImpl.addMain(mbStudent);
return "添加学生"+mbStudent.getName()+"失败";
}
}然后，我们先访问如下地址：
http://localhost:8080/jiaocheng/adminlogin?pwd=mypassword
访问这个页面后，就获得一个键为“user”的session，然后访问添加数据的这个接口地址：
http://localhost:8080/jiaocheng/jpatest?name=李四&age=11&grade=五年级&studentclass=二班&parent_name=李寻欢&parent_mobilephone=17722338899
如果没有意外，就会返回“添加学生李四成功”的信息。否则，如果session为空，或有其他错误，则提示添加失败。
二、通过JPA获取数据
现在，我们来获取刚才添加的数据。JPA有现成的数据获取的方法名规范，具体我们将在下一章节中展开，这里不再详细叙述。本小节只介绍单独一条数据的获取。
我们之前在MainServiceImpl类中已经添加了获取单个数据的方法：
//单个查找
@Override
public MainBean getMainById(Integer id) {
return mainDao.findById(id).get();
}现在，我们直接使用它即可。在MainRestController类中添加下面的方法：
@RequestMapping(value="/jpaget/{id}",method= RequestMethod.GET)
public String jpaGet(@PathVariable(value = "id",required = true) Integer pId) {
try
{
MainBean mbStudent = mainServiceImpl.getMainById(pId);
Map mapStudent = new HashMap();
mapStudent.put("ID", mbStudent.getId()); //添加键和值
mapStudent.put("姓名", mbStudent.getName());
mapStudent.put("年龄", mbStudent.getAge());
mapStudent.put("年级", mbStudent.getGrade());
mapStudent.put("班级",mbStudent.getStudentClass());
mapStudent.put("父母姓名", mbStudent.getParent_name());
mapStudent.put("父母电话", mbStudent.getParent_mobilephone());
JSONObject jsonResult = (JSONObject) JSON.toJSON(mapStudent); //强制转换为JSON格式
return jsonResult.toString();
}
catch (Exception e)
{
return "未查询到数据";
}
}我们看到，这里使用了一个@PathVariable 的注解，它和@RequestParam 注解不同，@RequestParam 注解获取的是在地址栏问号后的参数，而@PathVariable 注解，顾名思义，获取的是路径的值。在@RequestMapping 注解的value中，有一个申明的路径变量 {id}，在方法体的参数中，我们可以使用@PathVariable 注解来获取该路径的值，并且可以通过 required = true 规定它是必须的参数。例如，这个例子中，我们可以通过访问如下地址获取id为2的学生的信息：
http://localhost:8080/jiaocheng/jpaget/2
如果不出意外，我们就会获得在上一小节中添加的李四的信息：
{"姓名":"李四","父母电话":"17722338899","班级":"二班","年级":"五年级","ID":2,"父母姓名":"李寻欢","年龄":11}三、通过JPA更新数据
通过JPA更新数据也很方便，其方法和添加数据很相似。我们来在MainRestController类中添加如下方法：
@RequestMapping(value="/jpaupdate",method= RequestMethod.GET)
public String jpaUpdate(@RequestParam(value = "id",defaultValue = "") Integer pId,@RequestParam(value = "item",defaultValue = "") String pItem,@RequestParam(value = "value",defaultValue = "") String pValue, HttpSession session) {
try
{
MainBean mbStudent = mainServiceImpl.getMainById(pId);
switch (pItem)
{
case "name":
mbStudent.setName(pValue);
break;
case "age":
mbStudent.setAge(Integer.valueOf(pValue));
break;
case "grade":
mbStudent.setGrade(pValue);
break;
case "studentclass":
mbStudent.setStudentClass(pValue);
break;
case "parent_name":
mbStudent.setParent_name(pValue);
break;
case "parent_mobilephone":
mbStudent.setParent_mobilephone(pValue);
break;
}
if (session.getAttribute("admin").toString().length()>0) {
mainServiceImpl.updateMain(mbStudent);
return "更新ID为" + mbStudent.getId() + "的学生信息成功";
}
else
{
return "更新失败，没有权限";
}
}
catch (Exception e)
{
return "更新失败";
}
}这里，我们每次只更新一个字段，根据“item”的地址栏参数，来选择要更新的数据库字段。并且，我们需要验证身份。如果需要登录，你可以登录之前的接口：
http://localhost:8080/jiaocheng/adminlogin?pwd=mypassword
获取权限后，我们访问如下地址：
http://localhost:8080/jiaocheng/jpaupdate?id=2&item=studentclass&value=%E5%85%AD%E7%8F%AD
这个地址，作用是更新id为2的学生记录，修改项为班级（grade），值是“六班”。访问该地址后，如果没有出错，李四的班级就被调整为了“六班”，且会提示修改成功。其他数据库字段的调整，参照这个方法的具体参数switch分支就可以了。比如，要更新姓名，就把item的值设置为“name”。
四、删除数据
我们已经实现了数据的增加、查询、更新，最后我们来看下数据的删除。其实，数据的删除相当的简单。我们来在MainRestController类中添加如下方法：
@RequestMapping(value="/jpadel",method= RequestMethod.GET)
public String jpaDel(@RequestParam(value = "id",defaultValue = "") Integer pId, HttpSession session) {
try
{
if (session.getAttribute("admin").toString().length()>0) {
if (mainServiceImpl.delMain(pId))
return "删除ID为" + pId + "的学生成功";
else
return "删除ID为" + pId + "的学生失败";
}
else
{
return "删除失败，没有权限";
}
}
catch (Exception e)
{
return "删除失败";
}
}在这之前，我们先添加一条数据：
http://localhost:8080/jiaocheng/jpatest?name=将要删除的学生&grade=一年级&studentclass=一班&parent_name=无&parent_mobilephone=18888888888
添加之后，我们再登录获取权限（如果之前获取过就可以跳过这一步）：
http://localhost:8080/jiaocheng/adminlogin?pwd=mypassword
最后，我们访问这个地址，就可以删除这条ID为3的数据了：
http://localhost:8080/jiaocheng/jpadel?id=3
浏览器中会提示：
删除ID为3的学生成功
五、实现跨域更新数据
现代主流的框架，都是默认不支持跨域提交表单数据的。但是某些情况下，我们需要对外开放接口。这时，我们就可以通过“CorsFilter”这个Spring内置的库来实现开放跨域操作。
新建一个配置类，或将某个实体类作为配置类，然后加上如下代码，配置相关设置，这里在注释里已经说明了各个配置项的作用：
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.cors.CorsConfiguration;
import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
import org.springframework.web.filter.CorsFilter;
@Configuration
public class CorsConfig {
@Bean
public CorsFilter corsFilter() {
UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
CorsConfiguration config = new CorsConfiguration();
config.setAllowCredentials(true);
config.addAllowedOrigin("https://www.w3xue.com"); //允许进行跨域调用的网站，注意此处必须首先加上本应用的域名，否则就算是本应用内调用也会出现403错误。如果是允许任意网站，则设置为“*”，或者像本例一样设置特定的域，注意网址后不能有“/”和端口号。要设置多个域名则重复本语句即可。
config.setAllowCredentials(true); //允许跨越发送cookie
config.addAllowedHeader("*"); // 允许任何头
config.addAllowedMethod("*"); // 允许任何方法（如GET, POST, PUT, DELETE等）
source.registerCorsConfiguration("/**", config); //进行注册，无需更改
return new CorsFilter(source);
}
}项目里有这个类后，就可以允许其他网站调用你的接口了！
本章节已经实现了数据库的添加、搜索、更新、删除，已经基本可以实现对数据库的操作，但是我们仍然不能实现一些复杂的查询和操作。接下来的一节，会介绍更加灵活和复杂的查询和操作方法。
注意：本页面内容为W3xue原创，未经授权禁止转载，违者必究！
来源：W3xue 发布时间：2019/8/26 15:34:09