Elasticsearch 5.7 Java API实现MySQL日期差查询求助

没问题！我来帮你把这条MySQL查询转换成Elasticsearch 5.7版本的Java API实现，完全匹配你的业务逻辑。先明确原查询的核心逻辑：

从myTable中筛选出created_by为USERX，且updated_at与created_at的日期差大于5天的所有记录

前置条件 #

首先要确保你的Elasticsearch索引里，created_at和updated_at字段是**date类型**（不能存成字符串），否则无法正确计算日期差。如果还没配置映射，需要先调整索引的字段映射。

代码实现步骤 #

1. 依赖准备（Maven） #

先确保你的项目pom.xml里引入了ES 5.7的客户端依赖：

<dependency>
    <groupId>org.elasticsearch</groupId>
    <artifactId>elasticsearch</artifactId>
    <version>5.7.3</version>
</dependency>
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>transport</artifactId>
    <version>5.7.3</version>
</dependency>

2. 查询代码示例（Java 8） #

ES 5.7推荐使用TransportClient作为Java客户端，下面是完整的查询代码，注释已经写得很清楚：

import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.ScriptQueryBuilder;
import org.elasticsearch.script.Script;
import org.elasticsearch.script.ScriptType;
import org.elasticsearch.transport.client.PreBuiltTransportClient;

import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.HashMap;
import java.util.Map;

public class EsDateDiffQuery {
    public static void main(String[] args) throws UnknownHostException {
        // 初始化ES客户端，替换成你的集群名称和节点地址
        Settings clusterSettings = Settings.builder()
                .put("cluster.name", "your-es-cluster")
                .build();

        // 客户端使用try-with-resources自动关闭
        try (TransportClient client = new PreBuiltTransportClient(clusterSettings)
                .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300))) {

            // 构建布尔查询，组合两个条件
            BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();

            // 第一个条件：created_by等于USERX
            boolQuery.must(QueryBuilders.termQuery("created_by", "USERX"));

            // 第二个条件：updated_at与created_at的日期差大于5天
            // 用Painless脚本计算毫秒差，转换成天数后比较
            Map<String, Object> scriptParams = new HashMap<>();
            scriptParams.put("thresholdDays", 5);
            Script dateDiffScript = new Script(
                    ScriptType.INLINE,
                    "painless",
                    "doc['updated_at'].value.getMillis() - doc['created_at'].value.getMillis() > params.thresholdDays * 24 * 60 * 60 * 1000",
                    scriptParams
            );

            ScriptQueryBuilder dateDiffQuery = QueryBuilders.scriptQuery(dateDiffScript);
            boolQuery.must(dateDiffQuery);

            // 执行查询，替换成你的索引名称和type（5.7需要指定type）
            SearchRequestBuilder searchRequest = client.prepareSearch("my_table_index")
                    .setTypes("my_table_type")
                    .setQuery(boolQuery);

            SearchResponse searchResponse = searchRequest.get();

            // 处理查询结果
            System.out.println("匹配到的文档总数：" + searchResponse.getHits().getTotalHits());
            searchResponse.getHits().forEach(hit -> {
                System.out.printf("文档ID：%s，内容：%s%n", hit.getId(), hit.getSourceAsString());
            });
        }
    }
}

关键细节说明 #

• 脚本逻辑：MySQL的datediff(updated_at, created_at)返回的是结束日期减开始日期的天数，ES中我们通过计算两个日期的毫秒差，再转换成天数来做比较，逻辑完全一致。
• 脚本权限：如果你的ES集群限制了脚本执行，需要在elasticsearch.yml中开启Painless脚本支持：

  script.painless.enabled: true
  

• TransportClient注意事项：确保ES节点的transport.tcp.port配置为9300（默认值），并且集群名称和代码中的配置一致。

结果验证 #

根据你提供的测试数据：

• ID=1：日期差8天>5，且created_by=USERX → 会被匹配
• ID=3：日期差4天<5 → 不会被匹配
• ID=2：created_by不是USERX → 不会被匹配

最终查询结果只会返回ID=1的文档，和MySQL查询的结果完全一致。

内容的提问来源于stack exchange，提问作者Hitesh Kumar