怎么将Mybatis连接到ClickHouse

这篇文章主要讲解了“怎么将Mybatis连接到ClickHouse”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“怎么将Mybatis连接到ClickHouse”吧！

场景

最近在做数据分析项目，里面有这样一个业务：把匹配的数据打上标签，放到新的索引中。

数据量：累计亿级的数据

使用场景：可能会单次查询大量的数据，但不会设置复杂的条件，且这些数据不会被再次修改

原来使用的数据库：ElasticSearch

问题：上面也说了我这里打上标记后，这些数据几乎不会再修改了。ES 是一个全文检索引擎，更适用于进行大量文本检索的情况。这里与我上面的使用场景就不太匹配了。

技术选型的考虑：改用战斗民族开发的 ClickHouse，它适用于 OLAP 也就是数据分析的场景，当数据写入后，通过不同维度不断挖掘、分析，发现其中的商业价值。ClickHouse 适用于读远大于写的情况。

此外，相比ES，ClickHouse 占用的硬盘空间更小，也有利于降低运维成本。

下面是我在尝试接入 ClickHouse 时的一些实践，以及关于 ClickHouse数组类型转换问题的解决方案。

关于 ClickHouse 更详细的知识参考：https://zhuanlan.zhihu.com/p/98135840

示例代码已经上传到了 Git，目前更新第 28 节：https://github.com/laolunsi/spring-boot-examples/

Mybatis + ClickHouse

以前一直用 Mybatis 去操作 MySQL，其实 Mybatis 还可以操作 ClickHouse，这里用 Druid 进行连接管理。

maven 配置

<dependency>      <groupId>com.alibaba</groupId>      <artifactId>druid</artifactId>      <version>1.2.5</version>    </dependency>    <dependency>      <groupId>ru.yandex.clickhouse</groupId>      <artifactId>clickhouse-jdbc</artifactId>      <version>0.2.6</version>    </dependency>    <dependency>      <groupId>org.mybatis.spring.boot</groupId>      <artifactId>mybatis-spring-boot-starter</artifactId>      <version>2.1.3</version>    </dependency>

配置文件：

spring: datasource:  type: com.alibaba.druid.pool.DruidDataSource  # 注意这里是自定义的配置，通过 JdbcParamConfig 来加载配置到 Spring 中  # 然后由 DruidConfig 来配置数据源  click:   driverClassName: ru.yandex.clickhouse.ClickHouseDriver   url: jdbc:clickhouse://127.0.0.1:8123/test # ip:port/database   userName: default   password: default # 按照自己连接的 clickhouse 数据库来   initialSize: 10   maxActive: 100   minIdle: 10   maxWait: 6000   validationQuery: SELECT 1

加载配置项的类：

@Component@ConfigurationProperties(prefix = "spring.datasource.click")public class JdbcParamConfig {  private String userName;  private String password;  private String driverClassName ;  private String url ;  private Integer initialSize ;  private Integer maxActive ;  private Integer minIdle ;  private Integer maxWait ;  private String validationQuery;  // ignore getters and setters}

配置 Druid:

@Configuration@MapperScan(basePackages = {    "com.aegis.analysis.clickhousestorage.dao"})public class DruidConfig {  @Resource  private JdbcParamConfig jdbcParamConfig ;  @Bean(name = "clickDataSource")  public DataSource dataSource() throws ClassNotFoundException {    Class classes = Class.forName("com.alibaba.druid.pool.DruidDataSource");    DruidDataSource dataSource = (DruidDataSource) DataSourceBuilder        .create()        .driverClassName(jdbcParamConfig.getDriverClassName())        .type(classes)        .url(jdbcParamConfig.getUrl())        .username(jdbcParamConfig.getUserName())        .password(jdbcParamConfig.getPassword())        .build();    dataSource.setMaxWait(jdbcParamConfig.getMaxWait());    dataSource.setValidationQuery(jdbcParamConfig.getValidationQuery());    return dataSource;  }  @Bean  public SqlSessionFactory clickHouseSqlSessionFactoryBean() throws Exception {    SqlSessionFactoryBean factory = new SqlSessionFactoryBean();    factory.setDataSource(dataSource());    // 实体 model的 路径 比如 com.order.model    factory.setTypeAliasesPackage("com.example.clickhousedemo.model");    //添加XML目录    ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();    factory.setMapperLocations(resolver.getResources("classpath:mapperpublic class ClickArrayToIntHandler extends BaseTypeHandler<Integer[]> {  @Override  public void setNonNullParameter(PreparedStatement preparedStatement, int i, Integer[] integers, JdbcType jdbcType) throws SQLException {    preparedStatement.setObject(i, integers);  }  @Override  public Integer[] getNullableResult(ResultSet resultSet, String s) throws SQLException {    Object obj = resultSet.getObject(s);    return parseClickHouseArrayToInt(obj);  }  @Override  public Integer[] getNullableResult(ResultSet resultSet, int i) throws SQLException {    Object obj = resultSet.getObject(i);    return parseClickHouseArrayToInt(obj);  }  @Override  public Integer[] getNullableResult(CallableStatement callableStatement, int i) throws SQLException {    Object obj = callableStatement.getObject(i);    return parseClickHouseArrayToInt(obj);  }  private Integer[] parseClickHouseArrayToInt(Object obj) {    if (obj instanceof ClickHouseArray) {      int[] res = new int[0];      try {        res = (int[]) ((ClickHouseArray) obj).getArray();      } catch (SQLException ex) {        ex.printStackTrace();      }      if (res != null && res.length > 0) {        Integer[] resI = new Integer[res.length];        for (int i = 0; i < res.length; i++) {          resI[i] = res[i];        }        return resI;      }    }    return new Integer[0];  }}

DAO.xml 也给一个示例：

<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mapper namespace="com.aegis.analysis.clickhousestorage.dao.UserInfoMapper">  <resultMap id="BaseResultMap" type="com.example.clickhousedemo.model.UserInfo">    <id column="id" property="id" />    <result column="name" property="name" />    <result column="name" property="name" />    <result column="score" property="score" />    <result column="score2" property="score2" />    <result column="state" property="state" />    <result column="createTime" property="createTime" />    <!-- <result column="ranks" property="ranks" jdbcType="JAVA_OBJECT" javaType="java.lang.Object" />-->    <result column="ranks" property="ranks" typeHandler="com.example.clickhousedemo.dao.ClickArrayToIntHandler" />  </resultMap>  <sql id="Base_Column_List">    *  </sql>  <insert id="saveData" parameterType="com.aegis.analysis.clickhousestorage.model.UserInfo" >    INSERT INTO user      (id,name, score, score2, state, createTime, ranks)    VALUES    (#{id},#{name}, #{score}, #{score2}, #{state}, #{createTime}, #{ranks, jdbcType=ARRAY,    typeHandler=com.example.clickhousedemo.dao.ClickArrayToIntHandler})  </insert>  <select id="selectById" resultMap="BaseResultMap">    select    <include refid="Base_Column_List" />    from user    where id = #{id}    limit 1  </select>  <select id="selectList" resultMap="BaseResultMap" >    select    <include refid="Base_Column_List" />    from user  </select></mapper>

感谢各位的阅读，以上就是“怎么将Mybatis连接到ClickHouse”的内容了，经过本文的学习后，相信大家对怎么将Mybatis连接到ClickHouse这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是编程网，小编将为大家推送更多相关知识点的文章，欢迎关注！