Spring Boot 集成Mybatis(druid 數據庫連接池 以及分頁配置）

代碼

MyBatis是一款優秀的持久層框架，它支持定製化 SQL、存儲過程以及高級映射，目前很大一部分互聯網、軟件公司都在使用這套框架

我們主要關注幾個文件

配置文件：generator.properties

主要是數據庫的相關配置，以及文件生成的根路徑

generator.jdbc.driver=com.mysql.jdbc.Driver
generator.jdbc.url=jdbc:mysql://192.168.xxx.xxx:4596/ek?useUnicode=true&characterEncoding=utf8
generator.jdbc.username=root
#\\u6570\\u636e\\u5e93\\u5bc6\\u7801\\uff0c\\u4e0d\\u8981\\u52a0\\u5bc6\\uff01\\uff01\\uff01
generator.jdbc.password=ek2018
#\\u6570\\u636e\\u5e93\\u540d
generator.jdbc.database=ek
#\\u8868\\u7684\\u524d\\u7f00
generator.jdbc.tablePrefix=t_
#\\u751f\\u6210\\u7684package\\u7ed3\\u6784
generator.package.name=com.ek
#\\u751f\\u6210\\u5230\\u7684\\u9879\\u76ee\\u7684\\u6839\\u8def\\u5f84\\uff0c\\u4f8b\\u5982\\uff1a\\u751f\\u6210\\u5230\\u9879\\u76eeexue-authcenter-web\\u4e0b\\u65f6\\uff0c\\u53ef\\u4ee5\\u8fd9\\u4e48\\u914d\\u7f6e\\uff1a
#generator.target.rootPath=E:/MLCS_HQB/workspace/git/exuePlat/exue-authcenter/exue-authcenter-web
generator.target.rootPath=E:/WorkSpace/eke/code-generator

generatorConfig.xml

這裡主要是引用配置文件裡的數據庫配置，標明model、MapperXml、Mapper等文件生成的路徑

  
 connectionURL="${generator.jdbc.url}"
 userId="${generator.jdbc.username}"
 password="exue2018" />
 
 
 
 
 
 
 
 
 

配置文件結束後，執行Generator.java裡的main方法，刷新項目，就ok了

在現在中，我們可能需要對生成的文件內容做一些額外的配置，那就根據具體需求在模板文件裡修改

該要的文件都有了，放到項目中的特定包下

下面看下pom.xml需要加哪些依賴包

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

com.alibaba

druid

1.1.0

mysql

mysql-connector-java

5.1.41

org.mybatis.spring.boot

mybatis-spring-boot-starter

1.3.1

tk.mybatis

mapper-spring-boot-starter

1.2.4

com.github.pagehelper

pagehelper-spring-boot-starter

1.2.3

包括了mysql數據驅動，Mybatis的啟動包，數據庫連接池druid相關依賴

打開Spring Boot啟動類，在類上添加註解@MapperScan("com.example.demo.mapper")，記得要掃描mapper接口

@SpringBootApplication
@MapperScan("com.example.demo.mapper")
public class DemoApplication {
 public static void main(String[] args) {
 SpringApplication.run(DemoApplication.class, args);
 }
}

然後來看下mysql的配置，打開application.properties

#datasource
spring.datasource.url=jdbc:mysql://192.168.128.183:4596/eke?useUnicode=true&characterEncoding=UTF-8&useSSL=false
spring.datasource.username=root
spring.datasource.password=exue2018
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.druid.initial-size=1
spring.datasource.druid.min-idle=5
spring.datasource.druid.max-active=20
spring.datasource.druid.max-wait-millis=60000
#mybatis
mybatis.type-aliases-package=com.example.demo.pojo
mybatis.mapper-locations=classpath:mapper/*.xml
#pagehelper
pagehelper.helperDialect=mysql
pagehelper.reasonable=true
pagehelper.supportMethodsArguments=true
pagehelper.params=count=countSql

第一部分是dataSource的配置，包括了數據庫地址，庫名，用戶名，密碼以及相關數據庫連接池的配置

第二部分是Mybatis的配置,包括自定義pojo的包路徑，不需要加classpath: 以及Mapper xml的路徑

第三部分是分頁的相關配置

在service層定義接口pageUserBase ，最後返回是以分頁的形式展現

PageResult pageUserBase(UserBaseDTO searchCondition, Pagination page) throws Exception;

怎麼去實現這個分頁顯示

@Override
 public PageResult pageUserBase(UserBaseDTO userBaseDTO, Pagination page) throws Exception {
 // TODO Auto-generated method stub
 PageHelper.startPage(page.getPage(),page.getRows());
 UserBaseExample UserBaseExamle = new UserBaseExample();
 UserBaseExamle.setOrderByClause("p_id DESC");
 List listUserBase = userBaseMapper.selectByExample(UserBaseExamle);
 List listUserBaseDTO = new ArrayList();
 for(UserBase ub :listUserBase){
 UserBaseDTO ubd = new UserBaseDTO();
 ubd.setpId(ub.getpId());
 ubd.setsPassword(ub.getsPassword());
 ubd.setsPhone(ub.getsPhone());
 listUserBaseDTO.add(ubd);
 }
 Pagination pagination = new Pagination();
 pagination = SqlUtil.generatePagination(listUserBase);
 return new PageResult<>(listUserBaseDTO, pagination);
 }

PageHelper.startPage(page.getPage(),page.getRows());獲取客戶端傳來的頁碼和一頁顯示記錄數
Pagination pagination = new Pagination();
pagination = SqlUtil.generatePagination(listUserBase); 

根據最後返回的list進行分頁處理
返回到controller層後，進行ResponseMsg的封裝後，返回客戶端

PageResult res = null;
 List list = null;
 UserBaseDTO ubt = new UserBaseDTO();
 try {
 StringBuffer logOut = new StringBuffer();
 logOut.append("\n");
 logOut.append("cjq2測試");
 logOut.append("\n");
 LOGGER.debug(logOut.toString());
 Pagination page = new Pagination();
 page.setPage(1);
 page.setRows(10);;
 res = iUserbaseService.pageUserBase(ubt, page);
 list = res.getList();
 
 } catch (Exception e) {
 // TODO: handle exception
 throw new BaseException("數據錯誤");
 //LOGGER.error(e.getMessage());
 }
 return new ResponseMsg(requestMsg.getRoute(), GeneralConstant.SUCCESS, "查詢成功", res);

啟動SpringBoot項目

閱讀更多 Java開發交流 的文章

關鍵字: 在線教育 連接池 軟件