SpringBoot專案開發(五):HikariCP資料庫連線池
阿新 • • 發佈:2019-02-19
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方法,其他的大家自行測試