easyfk-db-clickhouse ClickHouse

<dependency>
    <groupId>com.mcst</groupId>
    <artifactId>db-clickhouse</artifactId>
</dependency>

dependencies {
    implementation 'com.mcst:db-clickhouse'
}

easyfk:
  config:
    db:
      clickhouse:
        url: jdbc:clickhouse://localhost:8123/default
        username: default
        password: your_password
        database: default
        minPoolSize: 5
        maxPoolSize: 20
        connectionTimeout: 30000
        socketTimeout: 300000

@Data
@ClickHouseTable(name = "user_event_log")
public class UserEventLog {

    @ClickHouseColumn(name = "event_id", primaryKey = true)
    private String eventId;

    @ClickHouseColumn(name = "user_id")
    private Long userId;

    @ClickHouseColumn(name = "event_type")
    private String eventType;

    @ClickHouseColumn(name = "event_data")
    private String eventData;

    @ClickHouseColumn(name = "create_time", timestamp = true)
    private LocalDateTime createTime;

    @ClickHouseColumn(ignore = true)
    private String tempField;
}

@Repository
public class UserEventLogRepository extends BaseClickHouseRepositoryImpl<UserEventLog> {

    // 可在此添加自定义查询方法
}

@Service
public class EventService {

    @Resource
    private UserEventLogRepository eventLogRepository;
}

@PostMapping("/search")
public List<UserEventLog> search(@RequestBody SearchRequest<UserEventParam> request) {
    ClickHouseSearchCondition condition =
        ClickHouseSearchConditionUtil.createSearchCondition(request, UserEventLog.class);
    return eventLogRepository.queryList(condition);
}

UserEventLog log = new UserEventLog();
log.setEventId("evt_001");
log.setUserId(10086L);
log.setEventType("LOGIN");
log.setCreateTime(LocalDateTime.now());

eventLogRepository.insert(log);

List<UserEventLog> logs = new ArrayList<>();
for (int i = 0; i < 5000; i++) {
    UserEventLog log = new UserEventLog();
    log.setEventId("evt_" + i);
    log.setUserId((long) (i % 100));
    log.setEventType("PAGE_VIEW");
    log.setCreateTime(LocalDateTime.now());
    logs.add(log);
}

// 默认每批 1000 条
eventLogRepository.insertBatch(logs);

// 自定义批次大小
eventLogRepository.insertBatch(logs, 2000);

ClickHouseSearchCondition condition = new ClickHouseSearchCondition()
    .setEqualsConditions(Map.of("event_type", "LOGIN"))
    .setStart("-7d")
    .setStop("now")
    .setDescFields(new String[]{"create_time"})
    .setTop(100);

List<UserEventLog> logs = eventLogRepository.queryList(condition);

ClickHouseSearchCondition condition = new ClickHouseSearchCondition()
    .setEqualsConditions(Map.of("user_id", 10086L))
    .setPageSearch(new PageSearch(1, 20));

List<UserEventLog> list = eventLogRepository.queryList(condition);
long total = eventLogRepository.count(condition);

ClickHouseSearchCondition condition = new ClickHouseSearchCondition()
    .setAggregationFunctions(new String[]{"event_type", "count(*) as cnt"})
    .setGroupByFields(new String[]{"event_type"})
    .setStart("-30d")
    .setDescFields(new String[]{"cnt"})
    .setTop(10);

List<Map<String, Object>> result = eventLogRepository.aggregate(condition);
// 结果示例：[{event_type=LOGIN, cnt=12345}, {event_type=PAGE_VIEW, cnt=98765}]

ClickHouseSearchCondition condition = new ClickHouseSearchCondition()
    .setBetweenConditions(Map.of("user_id", new Object[]{100L, 200L}));

List<UserEventLog> logs = eventLogRepository.queryList(condition);

ClickHouseSearchCondition condition = new ClickHouseSearchCondition()
    .setInConditions(Map.of("event_type", List.of("LOGIN", "LOGOUT", "REGISTER")));

List<UserEventLog> logs = eventLogRepository.queryList(condition);

// 按时间范围删除
eventLogRepository.deleteByTimeRange("2025-01-01 00:00:00", "2025-06-30 23:59:59");

// 按条件删除
ClickHouseSearchCondition condition = new ClickHouseSearchCondition()
    .setEqualsConditions(Map.of("event_type", "TEST"));
eventLogRepository.delete(condition);

UserEventLog updateEntity = new UserEventLog();
updateEntity.setEventType("UPDATED_TYPE");

ClickHouseSearchCondition condition = new ClickHouseSearchCondition()
    .setEqualsConditions(Map.of("event_id", "evt_001"));

eventLogRepository.update(updateEntity, condition);

ClickHouseSearchCondition condition = new ClickHouseSearchCondition()
    .setUseFinal(true)
    .setEqualsConditions(Map.of("user_id", 10086L));

List<UserEventLog> logs = eventLogRepository.queryList(condition);
// 生成 SQL: SELECT * FROM user_event_log FINAL WHERE user_id = 10086 ORDER BY create_time DESC

// 返回实体列表
List<UserEventLog> logs = eventLogRepository.executeQuery(
    "SELECT * FROM user_event_log WHERE event_type = 'LOGIN' LIMIT 10"
);

// 返回 Map 列表
List<Map<String, Object>> result = eventLogRepository.executeQueryForMap(
    "SELECT event_type, count(*) as cnt FROM user_event_log GROUP BY event_type"
);

// 执行 DDL / DML
eventLogRepository.executeUpdate(
    "ALTER TABLE user_event_log DELETE WHERE create_time < '2025-01-01'"
);

com.mcst.db.clickhouse
├── annotation
│   ├── ClickHouseTable.java              # 表名注解
│   └── ClickHouseColumn.java             # 列名注解
├── config
│   └── ClickHouseConfig.java             # Spring Boot 自动配置类
├── properties
│   └── ClickHouseProperties.java         # 配置属性绑定类
├── repository
│   ├── IBaseClickHouseRepository.java    # 通用仓库接口
│   └── BaseClickHouseRepositoryImpl.java # 通用仓库实现
├── search
│   └── ClickHouseSearchCondition.java    # 查询条件封装类
└── utils
    ├── ClickHouseSearchConditionUtil.java # 查询条件转换工具类
    └── ClickHouseSqlUtil.java            # SQL 构建工具类