Elasticsearch(Transport Client)常用操作

这里描述操作elasticsearch采用TransportClient这种方式，官方明确表示在ES 7.0版本中将弃用TransportClient客户端，且在8.0版本中完全移除它.
记录一些常用的方法：

官方文档：
TransportClient

/**
* 简单查询es 指定index type id
*/
@Testpublic void search() throws UnknownHostException {//获取clientSettings settings= Settings.builder().put("cluster.name","my-application").build();TransportClient transportClient=new PreBuiltTransportClient(settings);transportClient.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));// 发起请求得到响应GetResponse  response=transportClient.prepareGet("index3","user3","10").get();System.out.println(response.getSource());}/*** 增加文档*/@Testpublic void insert() throws Exception{Settings settings= Settings.builder().put("cluster.name","my-application").build();TransportClient client=new PreBuiltTransportClient(settings);client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));XContentBuilder contentBuilder= XContentFactory.jsonBuilder().startObject().field("catid","22").field("classify",54).field("author","ssve").field("id","1").field("title","菜鸟成长记").endObject();IndexResponse indexResponse = client.prepareIndex("index3", "user3", "10").setSource(contentBuilder).get();System.out.println(indexResponse.status());}/*** 删除文档*/@Testpublic void delete() throws Exception{Settings settings=Settings.builder().put("cluster.name","my-application").build();TransportClient client=new PreBuiltTransportClient(settings);client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));DeleteResponse deleteResponse = client.prepareDelete("index3", "user3", "10").get();System.out.println(deleteResponse.status());}/*** 修改文档*/@Testpublic void update() throws Exception{Settings settings=Settings.builder().put("cluster.name","my-application").build();TransportClient client=new PreBuiltTransportClient(settings);client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));UpdateRequest request=new UpdateRequest();XContentBuilder contentBuilder=XContentFactory.jsonBuilder().startObject().field("id","555").endObject();request.index("index3").type("user3").id("10").doc(contentBuilder);UpdateResponse updateResponse = client.update(request).get();System.out.println(updateResponse.status());}/***upsert使用 如有存在对应文档就修改  不存在就新增  需要指定修改的文档 和新增的文档*/@Testpublic void upsert() throws IOException, ExecutionException, InterruptedException {Settings settings=Settings.builder().put("cluster.name","my-application").build();TransportClient client=new PreBuiltTransportClient(settings);client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));XContentBuilder builder=XContentFactory.jsonBuilder().startObject().field("catid","22").field("classify",54).field("author","zhang").field("id","10").field("title","菜鸟成长记").endObject();UpdateRequest request=new UpdateRequest();IndexRequest indexRequest=new IndexRequest();indexRequest.index("index3").type("user3").id("11").source(builder);request.index("index3").type("user3").id("11").doc(new XContentFactory().jsonBuilder().startObject().field("id","i love you").endObject()).upsert(indexRequest);UpdateResponse updateResponse = client.update(request).get();System.out.println(updateResponse.status());}/*** * 批量查询  multiGet*/@Testpublic  void multiGet() throws Exception{Settings settings=Settings.builder().put("cluster.name","my-application").build();TransportClient client=new PreBuiltTransportClient(settings);client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));MultiGetRequest request=new MultiGetRequest();request.add("index3","user3","11");request.add("index3","user3","10");request.add("index3","user3","13");request.add("index3","user3","14");MultiGetResponse multiGetItemResponses = client.multiGet(request).get();for (MultiGetItemResponse response:multiGetItemResponses) {System.out.println(response.getResponse().getSourceAsString());}}/*** *  bulk实现批量增删改操作。*/@Testpublic void bulk() throws Exception{Settings settings=Settings.builder().put("cluster.name","my-application").build();TransportClient client=new PreBuiltTransportClient(settings);client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));BulkRequestBuilder bulkRequestBuilder = client.prepareBulk();IndexRequest request=new IndexRequest();request.index("index3").type("user3").id("13").source(XContentFactory.jsonBuilder().startObject().field("catid","85").field("classify","85").field("author","宇宙无敌").field("id","漫威").field("title","漫威").endObject());IndexRequest request1=new IndexRequest();request1.index("index3").type("user3").id("14").source(XContentFactory.jsonBuilder().startObject().field("catid","55").field("classify","85").field("author","宇宙无敌").field("id","漫威").field("title","漫威").endObject());bulkRequestBuilder.add(request1);bulkRequestBuilder.add(request);BulkResponse bulkItemResponses = bulkRequestBuilder.get();System.out.println(bulkItemResponses.status());}/*** * 使用query查询  match_all 查询所有*/@Testpublic void query() throws Exception{Settings settings=Settings.builder().put("cluster.name","my-application").build();TransportClient client=new PreBuiltTransportClient(settings);client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));MatchAllQueryBuilder builder= QueryBuilders.matchAllQuery();SearchRequestBuilder index3 = client.prepareSearch("index3").setQuery(builder).setSize(5);SearchResponse searchResponse = index3.get();SearchHits hits =  searchResponse.getHits();for (SearchHit hit:hits) {System.out.println(hit.getSourceAsString());}}/**** 使用query查询  match 查询*/@Testpublic void matchQuery() throws Exception{Settings settings=Settings.builder().put("cluster.name","my-application").build();TransportClient client=new PreBuiltTransportClient(settings);client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("title", "爱");SearchRequestBuilder index = client.prepareSearch("index3").setQuery(matchQueryBuilder).setSize(10);SearchHits hits = index.get().getHits();for (SearchHit hit:hits) {System.out.println(hit.getSourceAsString());}}/**** 使用query查询  mutilMatch 查询*/@Testpublic void mutilMatchQuery() throws Exception{Settings settings=Settings.builder().put("cluster.name","my-application").build();TransportClient client=new PreBuiltTransportClient(settings);client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));MultiMatchQueryBuilder multiMatchQueryBuilder = QueryBuilders.multiMatchQuery("周星驰影帝", "author","title");SearchRequestBuilder index = client.prepareSearch("index3").setQuery(multiMatchQueryBuilder).setSize(10);SearchHits hits = index.get().getHits();for (SearchHit hit:hits) {System.out.println(hit.getSourceAsString());}}/**** 使用query查询 termheterms查询*/@Testpublic void termsMatchQuery() throws Exception{Settings settings=Settings.builder().put("cluster.name","my-application").build();TransportClient client=new PreBuiltTransportClient(settings);client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));TermsQueryBuilder termsQueryBuilder = QueryBuilders.termsQuery("title", "周星驰", "影帝");SearchRequestBuilder index = client.prepareSearch("index3").setQuery(termsQueryBuilder).setSize(10);SearchHits hits = index.get().getHits();for (SearchHit hit:hits) {System.out.println(hit.getSourceAsString());}}/**** 使用query查询  范围  通配符 前缀 模糊查询*/@Testpublic void query1() throws Exception{Settings settings=Settings.builder().put("cluster.name","my-application").build();TransportClient client=new PreBuiltTransportClient(settings);client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));//范围查询//QueryBuilder queryBuilder = QueryBuilders.rangeQuery("classify").from("1").to("40");//通配符查询 * 零个或多个
//        QueryBuilder queryBuilder = QueryBuilders.wildcardQuery("author","周*");//前缀查询
//        QueryBuilder queryBuilder = QueryBuilders.prefixQuery("author","周");//模糊查询 查询类型的
//        QueryBuilder queryBuilder = QueryBuilders.fuzzyQuery("id","aac");//id查询QueryBuilder queryBuilder = QueryBuilders.idsQuery().addIds("1","2","4");SearchRequestBuilder index = client.prepareSearch("index3").setQuery(queryBuilder).setSize(10);SearchHits hits = index.get().getHits();for (SearchHit hit:hits) {System.out.println(hit.getSourceAsString());}}/**** 聚合查询*/@Testpublic void aggregation() throws Exception{Settings settings=Settings.builder().put("cluster.name","my-application").build();TransportClient client=new PreBuiltTransportClient(settings);client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));AggregationBuilder aggregationBuilder= AggregationBuilders.max("max").field("id");SearchResponse index3 = client.prepareSearch("index3").addAggregation(aggregationBuilder).get();Max max = index3.getAggregations().get("max");System.out.println(max.getValue());}/**** queryString */@Testpublic void queryString() throws Exception{Settings settings=Settings.builder().put("cluster.name","my-application").build();TransportClient client=new PreBuiltTransportClient(settings);client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));// + 代表必须有 -代表没有  QueryBuilder queryBuilder=QueryBuilders.queryStringQuery("+周星驰 -sss");SearchRequestBuilder index3 = client.prepareSearch("index3").setQuery(queryBuilder).setSize(10);SearchResponse searchResponse = index3.get();for (SearchHit hit:searchResponse.getHits()) {System.out.println(hit.getSourceAsString());}}/**** 组合查询*/@Testpublic void boolQuery() throws Exception{Settings settings=Settings.builder().put("cluster.name","my-application").build();TransportClient client=new PreBuiltTransportClient(settings);client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));QueryBuilder queryBuilder=QueryBuilders.boolQuery().must(QueryBuilders.matchQuery("author","周星驰")).mustNot(QueryBuilders.matchQuery("title","梁朝伟")).should(QueryBuilders.matchQuery("title","影帝")).filter(QueryBuilders.rangeQuery("id").gte("1"));SearchRequestBuilder index3 = client.prepareSearch("index3").setQuery(queryBuilder).setSize(10);SearchResponse searchResponse = index3.get();for (SearchHit hit:searchResponse.getHits()) {System.out.println(hit.getSourceAsString());}}

Elasticsearch(Transport Client)常用操作相关推荐

Springboot 整合ElasticSearch（Client篇）
目录 1.简介 2.依赖.pom.xml 3.配置类ESConfig 4.yml配置文件 5.实体类,省略不写了,根据自己的业务定义实体类 6.Client的使用 7.有问题留言,谢谢 1.简介相信 ...
Kerberos 入门与常用操作浅析
. 一 .前言二 .Kerberos认证流程三 .Kerberos Principal 四 .Kerberos的优点和不足 4.1. 优点 4.2. 不足五. KDC常用操作六.Client常 ...
聊一聊Elasticsearch和MySQL的常用操作
前言 ElasticSearch,开源的搜索和数据分析引擎,也是名列前茅的 nosql. 很多时候会想拿它和关系型数据库做对比,严格上它们是没有太多可比性的. 不过把有的东西放在一起比较,会帮助我们快 ...
Transport Client 客户端的使用
官方文档:TransportClient 一.基本概念这里描述操作elasticsearch采用TransportClient这种方式,官方明确表示在ES 7.0版本中将弃用TransportCli ...
ElasticSearch Python Client ReadTimeout
ElasticSearch Python Client ReadTimeout ElasticSearch Python Client API,Bulk操作时,当ElasticSearch服务端的性能 ...
elasticsearch Java Client用户指南
这里使用的Java客户端版本是5.1.2,Elasticsearch的版本号也要是5.1.2,否则一些功能可能不支持. 之前介绍过Spring Data Elasticsearch,那里也是使用了本文 ...
phoenix的元数据一般存在哪里_Phoenix常用操作记录-阿里云开发者社区
Apache Phoenix 常用操作基础知识 1****.****Phoenix 主要技术点 a.将SQL转化为HBase Scan,将结果封装为JDBC Result Set. b.表的元数据保 ...
ES transport client批量导入
从bulk.txt文件中按行读取,然后bulk导入.首先通过调用client.prepareBulk()实例化一个BulkRequestBuilder对象,调用BulkRequestBuilder对象 ...
MongoDB使用小结：一些常用操作分享
MongoDB使用小结:一些常用操作分享本文整理了一年多以来我常用的MongoDB操作,涉及mongo-shell.pymongo,既有运维层面也有应用层面,内容有浅有深,这也就是我从零到熟练的历程 ...
ES transport client使用
ES transport client bulk insert 传输(transport)客户端 TransportClient利用transport模块远程连接一个elasticsearch集群.它 ...

Elasticsearch(Transport Client)常用操作

Elasticsearch(Transport Client)常用操作相关推荐

最新文章

热门文章