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的用戶

 

成功刪除后查詢為空：