ORM Framework for Elasticsearch
No Data
ebatis是一个声明式
Elasticsearch ORM框架。只需要定义接口,便可轻松访问
Elasticsearch。
ebatis优雅地帮你隔离业务对
Elasticserach底层驱动接口的直接调用,你不再需要自己手动去构建繁琐
DSL语句。同时,当升级
Elastisearch版本的时候,业务可以完全不用关心底层接口的变动,平滑升级。
Elastisearch
6.5.1与
7.5.1版本。
ebatis已经在满帮业务系统上稳定运行近一年,承载着每日近十亿次搜索服务。
POM依赖(目前也支持
6.5.1.2.RELEASE)
xml io.manbang ebatis-core 7.5.1.4.RELEASE创建集群连接如下: ```java @AutoService(ClusterRouterProvider.class) public class SampleClusterRouterProvider implements ClusterRouterProvider { public static final String SAMPLECLUSTERNAME = "sampleCluster";
@Override public ClusterRouter getClusterRouter(String name) { if (SAMPLE_CLUSTER_NAME.equalsIgnoreCase(name)) { Cluster cluster = Cluster.simple("127.0.0.1", 9200, Credentials.basic("admin", "123456")); return ClusterRouter.single(cluster); } else { return null; } }
}
定义`POJO`对象如下:java @Data public class RecentOrder { private Long cargoId; private String driverUserName; private String loadAddress; private Boolean searchable; private Integer companyId; }
@Data public class RecentOrderCondition { private Boolean searchable;
private String driverUserName;
}
定义`Mapper`接口java @Mapper(indices = "recentorderindex") public interface RecentOrderRepository { @Search List search(RecentOrderCondition condition); }
测试接口如下:java @Slf4j public class OrderRepositoryTest {
@Test public void search() { // 组装查询条件 RecentOrderCondition condition = new RecentOrderCondition(); condition.setSearchable(Boolean.TRUE); condition.setDriverUserName("张三");// 映射接口 RecentOrderRepository repository = MapperProxyFactory.getMapperProxy(RecentOrderRepository.class, SampleClusterRouterProvider.SAMPLE_CLUSTER_NAME); // 搜索货源 List<recentorder> orders = repository.search(condition); // 断言 Assert.assertEquals(3, orders.size()); // 打印输出 orders.forEach(order -> log.info("{}", order));
}
}
搜索得`DSL`语句如下:json { "query" : { "bool" : { "must" : [ { "term" : { "searchable" : { "value" : true, "boost" : 1.0 } } }, { "term" : { "driverUserName" : { "value" : "张三", "boost" : 1.0 } } } ], "adjustpurenegative" : true, "boost" : 1.0 } }, "_source" : { "includes" : [ "cargoId", "driverUserName", "loadAddress", "searchable", "companyId" ], "excludes" : [ ] } } ``ebatis
版本使用xx.xx.xx.xx.RELEASE
表示,前三位代表Elasticsearch
适配集群的驱动版本,后一位代表ebatis
在此版本上的迭代。例如7.5.1.3.RELEASE
表示ebatis
在Elasticsearch 7.5.1`版本上迭代的第三次版本。
使用手册:https://github.com/ymm-tech/ebatis/wiki
相关文章:https://www.infoq.cn/article/u4Xhw5Q3jfLE1brGhtbR
相关文章:https://mp.weixin.qq.com/s/GFRiiQEk-JLpPnCi_WrRqw
钉钉
开源项目需要的是持续地坚持,而我们坚持的动力当然也来自于你们的支持,希望你 :pointright:
来都来了,加个关注再走吧:pointleft: