mybatis-plus clickhouse支持分页

事情不是太复杂，mybatis-plus3.X已经支持ClickHouse数据库，只需正确配置其他用法跟用mysql一样。

废话不多说，直接上代码。

1 相关依赖：

        <dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>2.1.4</version></dependency><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.4.2</version></dependency><!-- alibaba的druid数据库连接池 --><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.2.4</version></dependency><dependency><groupId>ru.yandex.clickhouse</groupId><artifactId>clickhouse-jdbc</artifactId><version>0.1.53</version></dependency>

2 相关配置：

（1）读取yml配置：

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;@Component
@ConfigurationProperties(prefix = "spring.datasource.click")
public class JdbcParamConfig {private String driverClassName ;private String url ;private Integer initialSize ;private Integer maxActive ;private Integer minIdle ;private Integer maxWait ;public String getDriverClassName() {return driverClassName;}public void setDriverClassName(String driverClassName) {this.driverClassName = driverClassName;}public String getUrl() {return url;}public void setUrl(String url) {this.url = url;}public Integer getInitialSize() {return initialSize;}public void setInitialSize(Integer initialSize) {this.initialSize = initialSize;}public Integer getMaxActive() {return maxActive;}public void setMaxActive(Integer maxActive) {this.maxActive = maxActive;}public Integer getMinIdle() {return minIdle;}public void setMinIdle(Integer minIdle) {this.minIdle = minIdle;}public Integer getMaxWait() {return maxWait;}public void setMaxWait(Integer maxWait) {this.maxWait = maxWait;}}

（2）Druid连接池的配置

import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import javax.annotation.Resource;
import javax.sql.DataSource;@Configuration
public class DruidPoolConfig {@Resourceprivate JdbcParamConfig jdbcParamConfig ;@Beanpublic DataSource dataSource() {DruidDataSource datasource = new DruidDataSource();datasource.setUrl(jdbcParamConfig.getUrl());datasource.setDriverClassName(jdbcParamConfig.getDriverClassName());datasource.setInitialSize(jdbcParamConfig.getInitialSize());datasource.setMinIdle(jdbcParamConfig.getMinIdle());datasource.setMaxActive(jdbcParamConfig.getMaxActive());datasource.setMaxWait(jdbcParamConfig.getMaxWait());//datasource.setValidationQuery("select 1");datasource.setTestOnBorrow(true);datasource.setTestOnReturn(true);datasource.setTestWhileIdle(true);datasource.setTimeBetweenEvictionRunsMillis(15000);datasource.setMinEvictableIdleTimeMillis(60000);datasource.setRemoveAbandoned(true);datasource.setRemoveAbandonedTimeout(3600);datasource.setLogAbandoned(true);return datasource;}}

（3）mybatis-plus的配置：

import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class MybatisPlusConfig {/*** 新的分页插件*/@Beanpublic MybatisPlusInterceptor mybatisPlusInterceptor() {MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.CLICK_HOUSE));return interceptor;}
}

3 代码：

（1）映射器mapper：

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.xlkj.clickhouseservice.beans.SafeEventAll;public interface SafeEventAllDao extends BaseMapper<SafeEventAll> {}

（2）service接口：

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.xlkj.clickhouseservice.beans.SafeEventAll;public interface SafeEventAllService extends IService<SafeEventAll> {/*** 分页查询* @param page 第几页* @param pageSize 每页条数* @return Page*/Page<SafeEventAll> list(Integer page, Integer pageSize);
}

（3）serviceImpl实现类：

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.xlkj.clickhouseservice.beans.SafeEventAll;
import com.xlkj.clickhouseservice.dao.SafeEventAllDao;
import com.xlkj.clickhouseservice.service.SafeEventAllService;
import org.springframework.stereotype.Service;@Service
public class SafeEventAllServiceImpl extends ServiceImpl<SafeEventAllDao, SafeEventAll> implements SafeEventAllService {@Overridepublic Page<SafeEventAll> list(Integer page, Integer pageSize) {//TODO 将来在这里处理QueryWrapper<SafeEventAll>对象return this.page(new Page<SafeEventAll>(page,pageSize),new QueryWrapper<SafeEventAll>());}
}

（4）controller前端控制器：

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.xlkj.clickhouseservice.beans.SafeEventAll;
import com.xlkj.clickhouseservice.service.SafeEventAllService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;@RestController
@RequestMapping("/safeallevent")
public class SafeEventAllController {@AutowiredSafeEventAllService safeEventAllService;/*** 分页查询* @return*/@GetMapping("/list")public Object list(@RequestParam(value = "page",defaultValue = "1") Integer page,@RequestParam(value = "page_size",defaultValue = "10") Integer pageSize) {Page<SafeEventAll> pageObj = safeEventAllService.list(page, pageSize);return pageObj;}}

（5）pojo映射对象略、映射文件xml略。

mybatis-plus clickhouse支持分页相关推荐

mysql分页取数每一页生成xml_让MyBatis Generator产生的代码支持分页
本文提供一种方法,让MyBatis Generator产生的代码支持分页, 适用于MySQL. 分析如果要获取分页信息,使用MySQL语句,我们需要怎么做呢? select * from t_us ...
rowbounds分页oracle,Oracle使用MyBatis中RowBounds实现分页查询功能
Oracle中分页查询因为存在伪列rownum,sql语句写起来较为复杂,现在介绍一种通过使用MyBatis中的RowBounds进行分页查询,非常方便. 使用MyBatis中的RowBounds进行 ...
springboot+jpa+mybatis 多数据源支持
springboot+jpa+mybatis 多数据源支持配置dataSource import org.springframework.beans.factory.annotation.Quali ...
Springboot集成mybatis通用Mapper与分页插件PageHelper
Springboot集成mybatis通用Mapper与分页插件PageHelper 插件介绍通用 Mapper 是一个可以实现任意 MyBatis 通用方法的框架,项目提供了常规的增删改查操作以及 ...
MyBatis使用PageHelper排序分页
文章目录 MyBatis使用PageHelper排序分页前言排序分页使用PageHelper排序分页添加PageHelper Spring Boot依赖新增一个列表查询的方法使用PageH ...
大数据druid查询不支持分页_Druid实时大数据分析查询(六)
Druid的数据查询过程以及查询语法 Druid提供了HTTP REST风格的查询接口.用户对数据的查询通过HTTP请求发送到查询节点(Broker Node),然后查询节点转发至历史节点(Histo ...
【Vue】ElementUI el-select 下拉分页加载数据，并支持搜索功能（此处不支持分页）
项目场景: 在公司管理后台需要有一个根据选择客户筛选拥有的服务的功能问题描述: 但是有上千条用户数据,一次性查询加载会导致页面有很长时间(大概4~5s)的空白期,用户体验很不友好. 故需要进行优 ...
spring boot整合mybatis+通用mapper+pagehelper分页插件
spring boot整合mybatis+通用mapper+pagehelper分页插件 pom依赖 <?xml version="1.0" encoding="U ...
【clickhouse】Clickhouse 支持毫秒纳秒数据
文章目录 1.概述 1.概述转载:https://vkingnew.blog.csdn.net/article/details/107294011 在clickhouse winter/Spring ...

mybatis-plus clickhouse支持分页

mybatis-plus clickhouse支持分页相关推荐

最新文章

热门文章