springboot2+jpa+hikari+oracle实战

1.技术选型

---

jpa：简单方便，基于Spring构建，简化了持久层开发，只要继承Repository就有简单的增删改查功能了，且自带分页功能

hikari：最快的数据库连接池，springboot2自带，不需要用到监控页面的话推荐使用hikari

oracle：生产环境最常用

2.代码实例

---

 

主要依赖pom.xml:

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        <dependency>
            <groupId>com.oracle</groupId>
            <artifactId>ojdbc7</artifactId>
            <version>12.1.0.1.0</version>
        </dependency>
        <!--很不错的一个工具类库-hutool，推荐使用-->
        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>5.4.2</version>
        </dependency>

 配置文件application.yml:

spring:
  datasource:
    ##使用hikari数据源
    type: com.zaxxer.hikari.HikariDataSource
    ##使用oracle连接驱动
    driver-class-name: oracle.jdbc.driver.OracleDriver
    ##数据库连接地址
    url: jdbc:oracle:thin:@000.000.000.000:1520:orcl
    ##数据库连接用户名
    username: xxx
    ##数据库连接密码
    password: xxxxxx
    hikari:
      ##池中维护的最小空闲连接数
      minimum-idle: 5
      ##池中最大连接数，包括闲置和使用中的连接
      maximum-pool-size: 15
      ##自动提交从池中返回的连接
      auto-commit: true
      ##连接允许在池中闲置的最长时间
      idle-timeout: 30000
      ##连接池的用户定义名称，主要出现在日志记录和JMX管理控制台中以识别池和池配置
      pool-name: DatebookHikariCP
      ##池中连接最长生命周期
      max-lifetime: 18000000
      ##等待来自池的连接的最大毫秒数
      connection-timeout: 30000
      ##验证该连接是否是有效的查询语句
      connection-test-query: select 1 from dual

jpa自动生成实体类TestUserEntity:

package com.project.demo.spring.boot.model;

import javax.persistence.*;
import java.util.Objects;

/**
 * @author:wk
 * @date:2020/9/16
 */
@Entity
@Table(name = "TEST_USER", schema = "TW_E", catalog = "")
public class TestUserEntity {
    private String name;
    private String password;
    private String phoneNo;
    private String remark;
    private String id;

    @Basic
    @Column(name = "NAME")
    public String getName() {
        return name;
    }

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

    @Basic
    @Column(name = "PASSWORD")
    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    @Basic
    @Column(name = "PHONE_NO")
    public String getPhoneNo() {
        return phoneNo;
    }

    public void setPhoneNo(String phoneNo) {
        this.phoneNo = phoneNo;
    }

    @Basic
    @Column(name = "REMARK")
    public String getRemark() {
        return remark;
    }

    public void setRemark(String remark) {
        this.remark = remark;
    }

    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        TestUserEntity that = (TestUserEntity) o;
        return Objects.equals(name, that.name) &&
                Objects.equals(password, that.password) &&
                Objects.equals(phoneNo, that.phoneNo) &&
                Objects.equals(remark, that.remark);
    }

    @Override
    public int hashCode() {
        return Objects.hash(name, password, phoneNo, remark);
    }

    @Id
    @Column(name = "ID")
    public String getId() {
        return id;
    }

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

创建TestUserRepository，继承JpaRepository,可实现简单的增删改查，TestUserEntity和String参数为实体类和主键，加@Query注解实现自定义查询语句:

package com.project.demo.spring.boot.repository;

import com.project.demo.spring.boot.model.TestUserEntity;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.List;

/**
 * @author:wk
 * @date:2020/9/16
 */
public interface TestUserRepository extends JpaRepository<TestUserEntity, String> {

    /**
     * 自定义查询语句接口
     *
     * @param name
     * @return
     */
    @Query(nativeQuery = true, value = "SELECT * FROM TEST_USER WHERE name = :name  ")
    List<TestUserEntity> findUserByName(@Param("name") String name);
}

 测试用的controller:

package com.project.demo.spring.boot.controller;

import cn.hutool.core.collection.CollectionUtil;
import com.project.demo.spring.boot.model.TestUserEntity;
import com.project.demo.spring.boot.repository.TestUserRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;

import java.util.List;

/**
 * @author:wk
 * @date:2020/9/11
 */
@ResponseBody
@Controller
@RequestMapping("/demo")
public class TestUserController {
    @Autowired
    private TestUserRepository testUserRepository;

    @GetMapping("/getAllUser")
    public List<TestUserEntity> getAllUser() {
        List<TestUserEntity> allUser = testUserRepository.findAll();
        return allUser;
    }

    @PostMapping("/saveAllUser")
    public List<TestUserEntity> saveAllUser(@RequestBody List<TestUserEntity> resource) {
        List<TestUserEntity> allUser = CollectionUtil.newArrayList(resource);
        List<TestUserEntity> successUser = testUserRepository.saveAll(allUser);
        return successUser;
    }

    @DeleteMapping("/deleteUserById")
    public String deleteUserById(@RequestBody String ids) {
        List<String> idList = CollectionUtil.toList(ids.split(","));
        idList.parallelStream().forEach(id -> testUserRepository.deleteById(id));
        return "success";
    }

    @GetMapping("/findUserByName")
    public List<TestUserEntity> findUserByName(@RequestBody String name) {
        List<TestUserEntity> allUser = testUserRepository.findUserByName(name);
        return allUser;
    }

}

3.演示

---

新增两个用户，添加成功：

获取到所有的user：

 调用自定义查询接口，通过name查找用户：

 删除id为1和2的用户

成功删除后查询为空：