clickhouse表一般都会做分区，而删除数据最快的方式就通过删除分区进行，在维护数据生命周期中，一般我们都会定时删除分区来达到目的，这里就会涉及批量删除分区的动作。
那么我们怎么进行批量删除分区呢？
我们知道用如下语句删除分区：
alter table 表名 drop partition 分区名

分区名可以通过以下语句查询出来：
select * from system.parts p where table = '表名'
![](http://img.classinstance.cn/20211209/1638982921708.jpg)
如上图所示我们上面语句查询出来的分区名，是Java中的yyyyMMdd日期格式，按日期分区这样可以定时删除数据，在海量数据场景中，可以保证我们表中数据维持在一定量中。

说那么多，具体代码不展示？OK,go
#### 一言不合，就上代码
下面以我们库中的表为例，上代码！！
建表语句中分区函数toYYYYMMDD(snapshot_time) ，是用时间字段创建的，语句如下：
```sql
CREATE TABLE base_db.event_local (
`snapshot_time` DateTime, 
`create_time` DateTime, 
`event_id` String, 
`plate_number` String,
`source_id` String
)ENGINE = MergeTree 
PARTITION BY toYYYYMMDD(snapshot_time) 
ORDER BY (source_id, plate_number, snapshot_time) SETTINGS index_granularity = 8192
```
#### Java中批量删除分区
java代码，代码中把库名与表名抽到参数中，可以使用同一个语句删除不同表的分区：
```java
			//传入要删除的日期，并删除这个日期和之前的分区
			Date date = null;
            String ymd = new SimpleDateFormat("yyyyMMdd").format(date);
			//查询表中所有分区名
            List<String> partitions = clickHousePartitionMapper.selectPartitions("base_db", "event_local");
			//小于日期之前的分区过滤出来
            List<String> deletePartitions = partitions.stream().filter(item -> item.compareTo(ymd) <= 0).collect(Collectors.toList());
			//批量删除分区
            deletePartitions.forEach(partitionName -> {
                clickHousePartitionMapper.deletePartition("event_local", partitionName);
            });
```
#### Mybatis Mapper
ClickHousePartitionMapper代码：
```java
@Mapper
public interface ClickHousePartitionMapper {

/**
     * 获取表分区列表
     *
     * @param dbname    库名
     * @param tableName 表名
     * @return 分区列表
     */
    List<String> selectPartitions(@Param("dbname") String dbname, @Param("tableName") String tableName);

/**
     * 删除分区
     *
     * @param tableName     表名
     * @param partitionName 分区名
     */
    void deletePartition(@Param("tableName") String tableName, @Param("partitionName") String partitionName);

}
```
ClickHousePartitionMapper.xml
```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="cn.com.clickhouse.ClickHousePartitionMapper">
    <select id="selectPartitions" resultType="String">
        SELECT
            partition
        FROM
            system.parts
        WHERE
            database = #{dbname}
            and table = #{tableName}
    </select>

<update id="deletePartition">
        alter table ${dbname}.${tableName} on cluster ${clusterName} drop partition #{partitionName}
    </update>
</mapper>
```
OK，代码分享完毕，学废了没？
更多clickhouse删除数据的方式，可以查询我另一篇文章：[《clickhouse如何删除数据》](http://www.classinstance.cn/detail/117.html "《clickhouse如何删除数据》")
了解更多clickhouse文章可以点这：[Clickhouse](http://www.classinstance.cn/list/p2/t24/ "Clickhouse")

ClassInstance

Clickhouse批量删除分区

相关文章

推荐文章

热门文章

标签列表