1. 程式人生 > >SpringBoot專案開發(五):HikariCP資料庫連線池

SpringBoot專案開發(五):HikariCP資料庫連線池

1.前兩篇是介紹控制器與頁面的,本篇將介紹 資料庫連線池 ,它很重要,SpringBoot 2.0 預設連線池就是Hikari
2.可以看一下這位朋友對幾大主流資料庫連線池的測試報告,結論是:hikariCP在併發較高的情況下,效能基本上沒有下降。我自己也測試過,迴圈查詢500次,13秒多

這裡寫圖片描述

3.在專案中整合 Hikari 與Spring Data JPA,做個數據展示demo,實際專案中使用的 mybatis,後面會專文介紹
  • 請在pom.xml中新增Maven依賴:HikariCP 、mysql-connector-java 、spring-boot-starter-data-jpa
<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
   <groupId>mysql</groupId>
   <artifactId>mysql-connector-java</artifactId>
   <scope>
runtime</scope> </dependency> <dependency> <groupId>com.zaxxer</groupId> <artifactId>HikariCP</artifactId> <version>3.1.0</version> </dependency> <!-- 序列化與反序列化 --> <dependency> <groupId>com.alibaba</groupId> <artifactId
>
fastjson</artifactId> <version>1.2.47</version> </dependency>

在application.properties中新增資料庫配置,可在正式環境中加大maximum-pool-size值

spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/bigdata?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&failOverReadOnly=false&maxReconnects=15000&allowMultiQueries=true&useSSL=false
spring.datasource.username=root
spring.datasource.password=root
# Hikari will use the above plus the following to setup connection pooling
spring.datasource.type=com.zaxxer.hikari.HikariDataSource
spring.datasource.hikari.minimum-idle=10
spring.datasource.hikari.maximum-pool-size=25
spring.datasource.hikari.auto-commit=true
spring.datasource.hikari.idle-timeout=30000
spring.datasource.hikari.pool-name=ExpendHikariCP
spring.datasource.hikari.max-lifetime=1800000
spring.datasource.hikari.connection-timeout=30000
spring.datasource.hikari.connection-test-query=SELECT 1

接下來需要在專案中新增entity、repository 架包
在entity架包下,新增 User.java檔案,與資料庫表字段對應,本文使用spring-data-jpa,後面會分享mybatis

@Entity
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY) //id自動增長
    private int id;
    @Column(nullable = false)
    private String name;
    @Column(nullable = false)
    private int age;

    getter and setter ...
}

在repository架包下,新建UserRepository.java檔案,繼承 CrudRepository


@Repository
@Transactional
public interface UserRepository extends CrudRepository<User , Integer> {

    /**
     * 由JPA自動根據方法名生成查詢sql
     * @param id
     * @return
     */
    User findById(int id);

    User findByName(String name);

    void deleteById(int id);

    //自定義sql
    @Modifying
    @Query(value = "select * from user",nativeQuery = true)
    List<User> findAll();
}

再建立service架包,在其下新增inf、impl架包,分別在其下新增介面與實現

public interface IUserService {

    void add(User user);

    void edit(User user);

    void delete(int id);

    User findById(int id);

    User findByName(String name);

    List<User> findAll();
}
@Service
public class UserServiceImpl implements IUserService{

    @Autowired private UserRepository userRepository;

    @Override
    public void add(User user) {
        userRepository.save(user);
    }

    @Override
    public void edit(User user) {
        userRepository.save(user);
    }

    @Override
    public void delete(int id) {
        userRepository.deleteById(id);
    }

    @Override
    public User findById(int id) {
        return userRepository.findById(id);
    }

    @Override
    public User findByName(String name) {
        return userRepository.findByName(name);
    }

    @Override
    public List<User> findAll() {
        return userRepository.findAll();
    }
}

最後,對寫的程式碼進行測試,新建一個測試類,內容如下,右鍵測試方法點選執行一一測試,下面有測試圖片,其中專案結構也在圖片中,把user物件列印成字串,就需要用到fastjson進行序列化

@RunWith(SpringRunner.class)
@SpringBootTest
public class UserTest {

    @Autowired private IUserService userService;

    @Test
    public void add(){
        User user = new User();
        user.setName("zy");
        user.setAge(26);
        userService.add(user);
    }

    @Test
    public void edit(){
        User user = new User();
        user.setId(1);
        user.setName("zy1");
        user.setAge(22);
        userService.edit(user);
    }

    @Test
    public void delete(){
        userService.delete(1);
    }

    @Test
    public void findById(){
        User user = userService.findById(1);
        System.out.println("user content :" + JSON.toJSONString(user));
    }

    @Test
    public void findByName(){
        User user = userService.findByName("zy1");
        System.out.println("user content :" + JSON.toJSONString(user));
    }

    @Test
    public void findAll(){
        List<User> list = userService.findAll();
        System.out.println("user content :" + JSON.toJSONString(list));
    }
}

這裡寫圖片描述
執行add方法後
這裡寫圖片描述
再來一個findById方法,其他的大家自行測試
這裡寫圖片描述