ELASTICSEARCH如何实现JAVA的增删改查

小编给大家分享一下ELASTICSEARCH如何实现JAVA的增删改查，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！

创新互联公司长期为1000多家客户提供的网站建设服务，团队从业经验10年，关注不同地域、不同群体，并针对不同对象提供差异化的产品和服务；打造开放共赢平台，与合作伙伴共同营造健康的互联网生态环境。为中卫企业提供专业的成都网站制作、网站建设，中卫网站改版等技术服务。拥有10年丰富建站经验和众多成功案例,为您定制开发。

操作ES的对象：TransportClient


     
         org.elasticsearch.client
         transport
         ${elasticsearch.client.version}

我的版本是5.4.0

创建 TransportClient对象

我是使用spring的bean注入的

@SuppressWarnings("resource")
@Bean(name="transportClient")
@Lazy
public TransportClient getTransportClient(){
   TransportClient client =null;
   try{
      Settings settings= Settings.builder().put("cluster.name", "elasticsearch").build();
      client=new PreBuiltTransportClient(settings).addTransportAddress(
                        new InetSocketTransportAddress(InetAddress.getByName("192.168.0.11"),9300));
      log.info("创建es客户端对象成功");
   }catch(Exception e){
      log.error("创建es客户端对象失败");
      log.error("失败原因:"+e.getMessage());
      System.exit(-1);
   }
   return client;
}

创建对象那个成功后，就可以用来操作es库了，他的作用跟spring-jdbctemplate,spring-jdbctemplate一样，提供了对数据库增删改查的功能，

spring也提供了对es操作的对象叫Spring Data Elasticsearch

参考文档：

http://www.ibm.com/developerworks/cn/opensource/os-cn-spring-jpa

我用的就是es自己提供的对象 TransportClient

添加数据

es的添加数据提供了多种方法，跟hql语言有点相似，都是面向对象的。

es支持批量操作的方法，为了提供效率都是用批量的对象

BulkRequestBuilder builder=transportClient.prepareBulk();

BulkRequestBuilder 对象有一个地方需要注意，因为是批量操作，es忽略了数据的不正确性，就算你的数据不对，builder也不会报错，所以在调试阶段需要先确保数据的准确性再用该对象进行操作。

插入数据，其实只需要把你的对象转成json，然后批量插入即可

@Override
public void batchAddMyZu(List list) {
    BulkRequestBuilder builder=transportClient.prepareBulk();
    for(Family family:list){
        String objstr= JSON.toJSONString(family);
        builder.add(client.prepareIndex("family","myfamily",family.getPrimaryKey()).setSource(objstr, XContentType.JSON));
    }
    builder.execute().actionGet();

System.out.println("此次插入数据的个数是 "+list.size());
}

setSource方法里面可以指定各种插入类型，我一般都是用json格式。

删除操作

es可以通过指定index，type，id删除数据，也支持搜索删除deleteByQuery

通过指定id删除方法

@Override
public void batchUndercarriageFamilies(List publishIds) {
   BulkRequestBuilder builder=transportClient.prepareBulk();
   for(String publishId:publishIds){
      builder.add(transportClient.prepareDelete(FAMILY, FAMILY_MARKETFAMILY, publishId).request());
   }
   builder.get();
}

通过deleteByQuery删除

@Override
public void delMyZu(String guid, String userId) {
   DeleteByQueryAction.INSTANCE.newRequestBuilder(transportClient)
         .source(FAMILY)
         .filter(QueryBuilders.boolQuery().must(QueryBuilders.termQuery("zuGUID", guid)).must(QueryBuilders.termQuery("userId", userId)).must(QueryBuilders.typeQuery(FAMILY_MYFAMILY)))
         .get();
}

QueryBuilder对象可以做任何查询

修改操作

我现在修改是根据指定索引后然后修改指定字段酱样的

@Override
public void updateMyZu_Related4MyZuValue(List list) {
   BulkRequestBuilder builder=transportClient.prepareBulk();
   for(Related4MyZuValue value:list){
      try {
         XContentBuilder source=XContentFactory.jsonBuilder().startObject()
                           .field("related4ZuValue",value.getRelated4ZuValue())
                           .field("zuSalePrice",value.getZuSalePrice())
                           .endObject();
         builder.add(transportClient.prepareUpdate(FAMILY, FAMILY_MYFAMILY, value.getPrimaryKey()).setDoc(source));
      } catch (IOException e) {
         continue;
      }
   }
   builder.get();
}

我这种操作是执行id后修改该数据的related4ZuValue的值和zuSalePrice的值

查询操作

es最主要功能就是查询

QueryBuilder就是设置查询条件的对象，你可以通过他设置各种条件

随便贴几个，自己感受吧。。。。

BoolQueryBuilder boolQueryBuilder=QueryBuilders.boolQuery();
if(keyword!=null&&!keyword.equals("")){
   QueryBuilder nameBuilder=QueryBuilders.matchQuery("zuName", keyword).analyzer("ik_max_word").boost(10);
   QueryBuilder labelBuilder=QueryBuilders.matchQuery("zuLabelName", keyword).analyzer("ik_max_word").boost(10);
   QueryBuilder categoryBuilder=QueryBuilders.matchQuery("categoryName", keyword).analyzer("ik_max_word").boost(10);
   boolQueryBuilder.should(nameBuilder).should(labelBuilder).should(categoryBuilder);
}else{
   boolQueryBuilder.must(QueryBuilders.matchAllQuery());
}
SearchResponse response=transportClient.prepareSearch(FAMILY).setTypes(FAMILY_MARKETFAMILY)
      .setQuery(boolQueryBuilder)
      .setFrom((page-1)*pageSize).setSize(pageSize)
      .setExplain(true)
      .get();

SearchHits hits=response.getHits();

BoolQueryBuilder builders=new BoolQueryBuilder();
//加上条件
builders.must(QueryBuilders.termQuery("userId", userId));
if(relatedValue==RelatedValue.MyBuyerZu.value()){
   builders.must(QueryBuilders.nestedQuery("related4ZuValue",
         QueryBuilders.boolQuery()
                  .must(QueryBuilders.termQuery("related4ZuValue.nameValue", UserReltatedValueUtil.getUserRelatedValue(relatedValue)))
                  //.must(QueryBuilders.rangeQuery("endTime").lte(LongformStringDate(System.currentTimeMillis())))
         ,ScoreMode.None));
}else{
   builders.must(QueryBuilders.nestedQuery("related4ZuValue", QueryBuilders.termQuery("related4ZuValue.nameValue", UserReltatedValueUtil.getUserRelatedValue(relatedValue)), 
         ScoreMode.None));
}
SearchResponse response=transportClient.prepareSearch(FAMILY).setTypes(FAMILY_MYFAMILY)
      .setQuery(builders).setFrom((page-1)*pageSize)
      .setSize(pageSize)
      .get();
SearchHits hits=response.getHits();

@Override
public MarketFamily getMarketFamily(String guid) {
   MarketFamily marketFamily=new MarketFamily();
   SearchResponse response=transportClient.prepareSearch(FAMILY)
         .setTypes(FAMILY_MYFAMILY).setQuery(QueryBuilders.termQuery("zuGUID", guid))
         .setSize(1)
         .get();
   SearchHits hits=response.getHits();
   for(SearchHit hit:hits.getHits()){
      marketFamily=JSON.parseObject(hit.getSourceAsString(),MarketFamily.class);
   }
   return marketFamily;
}

取查询结果总和count

@Override
public long countMyAllZu(String userId, int relatedValue) {
   BoolQueryBuilder builders=new BoolQueryBuilder();
   builders.must(QueryBuilders.termQuery("userId", userId));
   if(relatedValue==RelatedValue.MyBuyerZu.value()){
      builders.must(QueryBuilders.nestedQuery("related4ZuValue",
            QueryBuilders.boolQuery()
                     .must(QueryBuilders.termQuery("related4ZuValue.nameValue", UserReltatedValueUtil.getUserRelatedValue(relatedValue)))
                     .must(QueryBuilders.rangeQuery("endTime").lte(LongformStringDate(System.currentTimeMillis())))
            ,ScoreMode.None));
   }else{
      builders.must(QueryBuilders.nestedQuery("related4ZuValue", QueryBuilders.termQuery("related4ZuValue.nameValue", UserReltatedValueUtil.getUserRelatedValue(relatedValue)), 
            ScoreMode.None));
   }
   SearchResponse response=transportClient.prepareSearch(FAMILY).setTypes(FAMILY_MYFAMILY)
         .setQuery(builders)
         .setSize(1)
         .get();
   SearchHits hits=response.getHits();
   return hits.getTotalHits();
}

聚合求和sum

@Override
public long getPlatformZuOrdersTotalAmount(String keyword,String startTime,String endTime) {
   BoolQueryBuilder boolQueryBuilder=QueryBuilders.boolQuery();
   if(keyword==null||keyword.equals("")){
      QueryBuilder queryBuilder=QueryBuilders.matchAllQuery();
      boolQueryBuilder.must(queryBuilder);
   }else{
      QueryBuilder zuNameBuilder=QueryBuilders.matchQuery("zuName", keyword);
      QueryBuilder buyerNameBuilder=QueryBuilders.matchQuery("buyerName", keyword);
      QueryBuilder sellerNameBuilder=QueryBuilders.matchQuery("sellerName", keyword);
      boolQueryBuilder.should(zuNameBuilder).should(buyerNameBuilder).should(sellerNameBuilder);
      
   }
   if(!startTime.equals("")){
      QueryBuilder addTimeBuilder=QueryBuilders.rangeQuery("addTime").from(startTime).to(endTime);
      boolQueryBuilder.must(addTimeBuilder);
   }
   SearchResponse response=transportClient.prepareSearch(FAMILY).setTypes(FAMILY_FAMILYORDER)
         .setQuery(boolQueryBuilder)
         .addAggregation(AggregationBuilders.sum("price").field("price"))
         .get();
   Sum sum=response.getAggregations().get("price");
   return (long) sum.getValue();
}

以上是“ELASTICSEARCH如何实现JAVA的增删改查”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注创新互联行业资讯频道！

本文标题：ELASTICSEARCH如何实现JAVA的增删改查
文章地址：http://chengdu.cdxwcx.cn/article/psdpjj.html

甜橘子，专注成都网站制作网站设计与营销型网站建设与优化

首页

网站建设

网站制作案例

解决方案

网站设计报价

网站制作动态

关于我们

联系我们

成都网站建设设计将想法与焦点和您一起共享

ELASTICSEARCH如何实现JAVA的增删改查

操作ES的对象：TransportClient

创建 TransportClient对象

添加数据

删除操作

修改操作

查询操作

取查询结果总和count

聚合求和sum

其他资讯

帝国cms语音搜索帝国cms语音搜索不出来

腾讯云服务器48小时腾讯云服务器48小时内免费

怎么远程腾讯云服务器怎么远程连接腾讯云服务器

阿里云服务器退款ecs 阿里云服务器退款不了

php无刷更新数据库 php 刷新

甜橘子，专注成都网站制作网站设计与营销型网站建设与优化

成都网站建设设计 将想法与焦点和您一起共享

ELASTICSEARCH如何实现JAVA的增删改查

操作ES的对象 ：TransportClient

创建 TransportClient对象

添加数据

删除操作

修改操作

查询操作

取查询结果总和count

聚合求和sum

其他资讯

帝国cms语音搜索 帝国cms语音搜索不出来

腾讯云服务器48小时 腾讯云服务器48小时内免费

怎么远程腾讯云服务器 怎么远程连接腾讯云服务器

阿里云服务器退款ecs 阿里云服务器退款不了

php无刷更新数据库 php 刷新

成都网站建设设计将想法与焦点和您一起共享

操作ES的对象：TransportClient

帝国cms语音搜索帝国cms语音搜索不出来

腾讯云服务器48小时腾讯云服务器48小时内免费

怎么远程腾讯云服务器怎么远程连接腾讯云服务器