Elasticsearch中的动态DSL解决方案

目录

问题背景

解决方案

编写es的mapper

动态dsl编写

使用mapper获取动态dsl

远程调用restful api查询

---

问题背景

在大数据量的业务系统中，一般都会引入Elasticsearch来作为搜索引擎，而搜索的条件又是多种多样的。回顾下，如果是mysql等这种关系型数据库来作为存储介质呢？我们是不是可以通过mybatis的动态sql解析功能就能轻轻松松的搞定。

或许你也许会问，es不是提供了java版本的sdk么，通过sdk可以动态的构建dsl语句的，确实如此，不过这样的可读性远远没有将dsl放在xml中，可以看下在java代码中操作es的代码案例

public static void main(String[] args) throws IOException {// 初始化RestHighLevelClientRestClientBuilder builder = RestClient.builder(new HttpHost("localhost", 9200, "http"));RestHighLevelClient client = new RestHighLevelClient(builder);// 创建查询条件SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();searchSourceBuilder.query(QueryBuilders.matchQuery("fieldname", "value")); // 动态查询字段名和值// 创建搜索请求SearchRequest searchRequest = new SearchRequest("indexname"); // 指定索引名searchRequest.source(searchSourceBuilder);// 执行搜索SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);// 处理搜索结果SearchHits hits = searchResponse.getHits();for (SearchHit hit : hits) {System.out.println(hit.getSourceAsString());}// 关闭客户端client.close();}

mybatis的执行流程中，就是通过SqlSessionFactory创建SqlSession，有了SqlSession可以开始执行sql，执行sql的时候，会将动态的sql转成一个MappedStatement，通过这个可以创建BoundSql，我们是不是可以利用mybatis执行mysql的一部分功能，拿到BoundSql，然后通过http的方式直接远程调用es查询？

答案是可行的

解决方案

编写es的mapper

package com.tml.mouseDemo.mapper;import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;@Mapper
public interface ESMapper {String queryOrderById(@Param("name") String name, @Param("id") String id);
}

动态dsl编写

<?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.tml.mouseDemo.mapper.ESMapper"><select id="queryOrderById" resultType="string">{"query":{"bool":["term":{"id":"${id}"}<if test="name!=null">,"term":{"name":"${name}"}</if>]}}</select>
</mapper>

dsl的语法就不多介绍了，在这个xml文件中，可以使用mybatis的<if> <when> <choose> <foreach>等诸多标签，通过这些个标签的组合，你可以编写多条件检索的复杂dsl

使用mapper获取动态dsl

    @Testpublic void testEs() {Map<String, String> map = new HashMap<>();map.put("name", "tml");map.put("id", "hello world");BoundSql bSql = sessionFactory.getConfiguration().getMappedStatement("queryOrderById").getBoundSql(map);log.info("bSql:{}", bSql.getSql());
}

其中，sessionFactory是通过spring的自动注入的

@Autowired
private SqlSessionFactory sessionFactory;

远程调用restful api查询

拿到dsl以后，就可以通过http远程调用restful api拿到结果了，通过httpClient或者是RestTemplate实现都行，这里就不赘述了。