ELASTICSEARCH如何实现JAVA的增删改查

37次阅读
没有评论

共计 7241 个字符，预计需要花费 19 分钟才能阅读完成。

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

操作 ES 的对象：TransportClient

!--elasticsear 使用的 jar -- 
  dependency 
  groupId org.elasticsearch.client /groupId 
  artifactId transport /artifactId 
  version ${elasticsearch.client.version} /version 
  /dependency 
  !--elasticsear 使用的 jar --

我的版本是 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 Family  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 String  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 Related4MyZuValue  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 的增删改查”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注丸趣 TV 行业资讯频道！

正文完
client elasticsearch es settings transportclient
发表至： 计算机运维
2023-08-16
 
丸趣
版权声明：本站原创文章，由 丸趣 2023-08-16发表，共计7241字。
转载说明：除特殊说明外本站除技术相关以外文章皆由网络搜集发布，转载请注明出处。
linux中.gz解压不了怎么解决
Ubuntu下怎么编译、安装和卸载软件
怎么使用大白菜u盘重装win10系统
XP怎么升级Win10系统
评论（没有评论）