spring boot整合jpa实现CRUD、分页、排序等功能

一、使用IDE新建一个spring boot项目:


File --> Project

选择JDK版本

自己写好包名,填写Group和Artifact

版本默认,选择web复选框

填好项目名和路径

这几个可以的删掉

这个是我pom里的maven依赖:

<?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.hyw</groupId>
    <artifactId>lhrz</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <!--默认为jar方式-->
    <!--<packaging>jar</packaging>-->
    <!--改为war方式,部署-->
    <packaging>war</packaging>

    <name>lhrz</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.0.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.8</java.version>
    </properties>

    <dependencies>
        <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>
        <!-- mysql依赖 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.44</version>
        </dependency>
        <!-- durid连接池 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.0.28</version>
        </dependency>
        <!--JPA-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
            <version>2.1.0.RELEASE</version>
        </dependency>
        <!-- alibaba fastjson -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.31</version>
        </dependency>
        <!-- lombok -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.16.20</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-tomcat</artifactId>
            <!--打包的时候可以不用包进去,别的设施会提供。事实上该依赖理论上可以参与编译,测试,运行等周期。
        相当于compile,但是打包阶段做了exclude操作-->
            <scope>provided</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
    <!-- 使用alibaba远程仓库 -->
    <repositories>
        <repository>
            <id>public</id>
            <name>aliyun nexus</name>
            <url>http://maven.aliyun.com/nexus/content/groups/public/</url>
            <releases>
                <enabled>true</enabled>
            </releases>
        </repository>
    </repositories>
    <pluginRepositories>
        <pluginRepository>
            <id>public</id>
            <name>aliyun nexus</name>
            <url>http://maven.aliyun.com/nexus/content/groups/public/</url>
            <releases>
                <enabled>true</enabled>
            </releases>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
        </pluginRepository>
    </pluginRepositories>
</project>
我们新建的项目默认配置文件是叫 application.properties,我们这里给他改名为 application.yml; 因本人习惯,喜欢分开配置,所以建了两个yml文件

这是我的application.yml文件

server:
  #端口号
  port: 80 
 #项目路径,可以不填
  servlet:
    context-path: /jpaTest
spring:
  profiles:
    #在这里配置需要加载哪个配置文件
    active: dev

 #jpa
  jpa:
    database: MySQL
    #每个SQL查询显示或不记录
    show-sql: false
    #格式化sql
    properties:
      hibernate:
        format_sql: true
        #use_sql_comments: true
        #hibernate:
        #自动建表
        #ddl-auto: update
        #hibernate:
        #naming:
        #implicit-strategy: org.springframework.boot.orm.jpa.hibernate.SpringImplicitNamingStrategy

这是我的application-dev.yml文件

#mysql和druid配置:
spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.jdbc.Driver
    username: test
    password: 123456
    url: jdbc:mysql://127.0.0.1:3306/jpatest?useUnicode=true&characterEncoding=utf8
    # 下面为连接池的补充设置,应用到上面所有数据源中
    # 初始化大小,最小,最大
    initialSize: 10
    minIdle: 10
    maxActive: 200
    # 配置获取连接等待超时的时间
    maxWait: 60000
    # 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒
    timeBetweenEvictionRunsMillis: 60000
    # 配置一个连接在池中最小生存的时间,单位是毫秒
    minEvictableIdleTimeMillis: 30000
    validationQuery: select 'x'
    testWhileIdle: true
    testOnBorrow: false
    testOnReturn: false
    # 打开PSCache,并且指定每个连接上PSCache的大小
    poolPreparedStatements: true
    maxPoolPreparedStatementPerConnectionSize: 20
    # 配置监控统计拦截的filters,去掉后监控界面sql无法统计,'wall'用于防火墙
    filters: stat,wall,slf4j
    # 通过connectProperties属性来打开mergeSql功能;慢SQL记录
    connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
    # 合并多个DruidDataSource的监控数据
    useGlobalDataSourceStat: true

二、entity实体类(可用jpa工具生成)

package com.hyw.jpatest.model;

import lombok.Data;

import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;

/**
 * @author huyw
 * @date 2018/11/12
 */
@Data
@Entity(name = "user")
public class User {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    private String mobile;

    private String password;

    private String headPic;

    private Integer type;

    private String region;

    private Integer isDel;
}

三、dao层

package com.hyw.jpatest.mapper;

import com.hyw.jpatest.model.User;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.CrudRepository;
import org.springframework.data.repository.query.Param;
import org.springframework.transaction.annotation.Transactional;

/**
 * @author
 * @date 2018/11/09 18:09
 */
public interface UserMapper extends CrudRepository<User, Long> {

    /**
     * 根据id获取用户信息
     *
     * @param id
     * @return User
     */
    User getUserById(Long id);

    /**
     * 分页查询
     *
     * @param pageable
     * @return Page
     */
    Page<User> findAll(Pageable pageable);

    /**
     * 根据id删除
     *
     * @param id
     */
    void deleteById(Long id);

    /**
     * 插入用户
     *
     * @param user
     * @return User
     */
    User save(User user);

    /**
     * 修改用户
     *
     * @param id
     * @param mobile
     * @return int
     */
    @Transactional(rollbackFor = Exception.class)
    @Modifying
    @Query(value = "update user set mobile = :mobile where id = :id", nativeQuery = true)
    int updateMobileById(@Param("id") Long id, @Param("mobile") String mobile);
}

四、service层

package com.hyw.jpatest.service;

import com.hyw.jpatest.model.User;
import com.hyw.jpatest.result.PageResultEntity;
import com.hyw.jpatest.result.ResultEntity;

/**
 * @author
 * @date 2018/11/09 18:09
 */
public interface UserService {

    /**
     * 根据id获取用户信息
     *
     * @param id 主键
     * @return ResultEntity
     */
    ResultEntity getUserById(Long id);

    /**
     * 分页查询
     *
     * @param pageNo   页码
     * @param pageSize 页数
     * @return PageResultEntity
     */
    PageResultEntity findAll(Integer pageNo, Integer pageSize);

    /**
     * 根据id删除
     *
     * @param id
     * @return ResultEntity
     */
    ResultEntity deleteUserById(Long id);

    /**
     * 插入用户
     * @param user
     * @return ResultEntity
     */
    ResultEntity saveUser(User user);

    /**
     * 修改用户
     * @param id
     * @param name
     * @return ResultEntity
     */
    ResultEntity updateMobileById(Long id, String name);
}

五、Impl

package com.hyw.jpatest.service.impl;

import com.hyw.jpatest.mapper.UserMapper;
import com.hyw.jpatest.model.User;
import com.hyw.jpatest.result.PageResultEntity;
import com.hyw.jpatest.result.ResultEntity;
import com.hyw.jpatest.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * @author huyw
 * @create 2018/11/9
 * @since 1.0.0
 */
@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private UserMapper userMapper;

    @Override
    public ResultEntity getUserById(Long id) {

        User user = userMapper.getUserById(id);
        if (user == null) {
            return ResultEntity.error("用户不存在");
        } else {
            return ResultEntity.success(user);
        }
    }

    @Override
    public PageResultEntity findAll(Integer pageNo, Integer pageSize) {

        Sort sort = new Sort(Sort.Direction.ASC, "id");
        Pageable pageable = PageRequest.of(pageNo, pageSize, sort);
        Page<User> datas = userMapper.findAll(pageable);
        //总条数
        int total = (int) datas.getTotalElements();
        //总页数
        int totalPages = datas.getTotalPages();
        //数据列表
        List<User> rows = datas.getContent();
        return PageResultEntity.success(total, rows);
    }

    @Override
    public ResultEntity deleteUserById(Long id) {
        userMapper.deleteById(id);
        return ResultEntity.success();
    }

    @Override
    public ResultEntity saveUser(User user) {
        User saveUser = userMapper.save(user);
        if(saveUser!=null){
            return  ResultEntity.success(saveUser);
        }else {
            return  ResultEntity.error("插入失败");
        }
    }

    @Override
    public ResultEntity updateMobileById(Long id, String mobile) {
        int count = userMapper.updateMobileById(id,mobile);
        if(count==0){
            return  ResultEntity.error("修改失败");
        }else{
            return ResultEntity.success();
        }
    }
}

六、controller层:

package com.hyw.jpatest.controller;

import com.hyw.jpatest.model.User;
import com.hyw.jpatest.result.PageResultEntity;
import com.hyw.jpatest.result.ResultEntity;
import com.hyw.jpatest.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

/**
 * @author huyw
 * @create 2018/11/9
 * @since 1.0.0
 */
@RestController
public class UserController {

    @Autowired
    private UserService userService;

    @GetMapping("/user/get/{id}")
    public ResultEntity get(@PathVariable("id") Long id) {
        return userService.getUserById(id);
    }

    @GetMapping("/user/list")
    public PageResultEntity list(Integer pageNo, Integer pageSize) {

        return userService.findAll(pageNo, pageSize);
    }

    @PostMapping("/user/add")
    public ResultEntity add(String mobile, String password, String headPic, Integer type, String region) {
        User user = new User();
        user.setMobile(mobile);
        user.setPassword(password);
        user.setHeadPic(headPic);
        user.setType(type);
        user.setRegion(region);
        return userService.saveUser(user);
    }

    @PutMapping("/user/update")
    public ResultEntity update(@RequestParam Long id, String mobile) {

        return userService.updateMobileById(id, mobile);
    }

    @DeleteMapping("/user/delete/{id}")
    public ResultEntity delete(@PathVariable("id") Long id) {

        return userService.deleteUserById(id);
    }
}
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 205,132评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,802评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,566评论 0 338
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,858评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,867评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,695评论 1 282
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,064评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,705评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 42,915评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,677评论 2 323
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,796评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,432评论 4 322
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,041评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,992评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,223评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,185评论 2 352
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,535评论 2 343

推荐阅读更多精彩内容