好程序员Java学习路线分享创建Java class

Posted 2022-07-03

好程序员Java学习路线分享创建Java class，首先通过Transport Client获取ES的连接

private Client client;

//通过Transport Client获取ES的连接

@Before

public void getClient() throws Exception

????//ES服务的JavaAPI的port为9300

????//注意:如果请求一个ES集群,可以多添几个节点

????//为了避免在一个节点出现网络问题导致的请求失败问题,可以自动切换另外一个节点

????client = TransportClient.builder().build()

????????????.addTransportAddress(new InetSocketTransportAddress(

????????????????????InetAddress.getByName("localhost"),9300));

????????????//.addTransportAddress(...);

操作命令

----------------------------------------新建文档------------------------------------

1. 使用json来创建文档(插入一条数据),自动创建索引和映射

@Test

public void createDocument1()

????// json格式的数据

????//json "需要转义 -> \

????String source = "" +

????????????"\"id\":\"1\"," +

????????????"\"title\":\"Lucene是一套用于全文检索和搜寻的开源程式库\"," +

????????????"\"content\":\"Lucene提供了一个简单却强大的应用程式接口，能够做全文索引和搜寻\"" +

????????????"";

????//创建文档, 定义索引名称,文档类型,主键唯一标识ID

????//execute().actionGet() == get() ?代表立刻执行

????IndexResponse indexResponse =

????????????client.prepareIndex("blog", "article", "1")

????????????????????.setSource(source).get(); //加载数据并触发

????this.getResponse(indexResponse); ?//对应下面封装信息

????client.close();

将打印信息封装成类,方便this调用

//获取响应信息

private void getResponse(IndexResponse indexResponse)

????System.out.println("索引名称: " + indexResponse.getIndex());

????System.out.println("文档类型: "+indexResponse.getType());

????System.out.println("ID: "+indexResponse.getId());

????System.out.println("版本: "+indexResponse.getVersion());

????System.out.println("是否创建成功: "+indexResponse.isCreated());

2. 使用map创建文档,自动创建索引和映射

@Test

public void createDocument2()

????// map类型的数据

????Map<String,Object> source = new HashMap<>();

????source.put("id","2");

????source.put("title","ElasticSearch");

????source.put("content","是一个分布式的 RESTful 风格的搜索和数据分析引擎");

????//创建文档

????IndexResponse indexResponse = client.prepareIndex("blog", "article", "2")

????????????.setSource(source).get();

????this.getResponse(indexResponse);

????client.close();

使用ES帮助类(执行类),创建文档
@Test

public void createDocument3() throws Exception

????XContentBuilder source = XContentFactory.jsonBuilder()

????????????.startObject() //封装数据

????????????????.field("id","3")

????????????????.field("title","ES的核心")

????????????????.field("content","集中的是巴拉巴拉")

????????????.endObject();

????System.out.println(source.toString());

????//创建文档

????IndexResponse indexResponse = client.prepareIndex("blog", "article", "3")

????????????.setSource(source).get();

????this.getResponse(indexResponse);

????client.close();

----------------------------------------搜索文档------------------------------------

输出格式为json格式

搜索文档数据 -- 单个索引 ?prepareGet

@Test

public void testGetData1()

????GetResponse getResponse = client.prepareGet("blog", "article", "1").get();

????System.out.println(getResponse.getSourceAsString());

????client.close(); ??//输出格式为json格式

搜索文档数据 -- 多个索引 ?prepareMultiGet

@Test

public void testGetData2()

????MultiGetResponse multiGetResponse = client.prepareMultiGet()

????????????.add("blog", "article", "1")

????????????.add("blog", "article", "2", "3")

????????????.get();

????for (MultiGetItemResponse itemResponse : multiGetResponse)

????????GetResponse response = itemResponse.getResponse();

????????if (response.isExists())

????????????System.out.println(response.getSourceAsString());

????????

????

????client.close();

----------------------------------------更新文档------------------------------------

doc更新

创建更新对象

@Test

public void testUpdate1() throws Exception

????UpdateRequest request = new UpdateRequest();

????request.index("blog");

????request.type("article");

????request.id("1");

????request.doc(XContentFactory.jsonBuilder() //doc 更新方法

????.startObject()

????????????.field("id","1")

????????????.field("title","更新:1")

????????????.field("content","更新:1")

????.endObject());

????UpdateResponse updateResponse = client.update(request).get();

????System.out.println("索引名称: " + updateResponse.getIndex());

????System.out.println("文档类型: "+updateResponse.getType());

????System.out.println("ID: "+updateResponse.getId());

????System.out.println("版本: "+updateResponse.getVersion());

????System.out.println("是否创建成功: "+updateResponse.isCreated()); //false

????client.close();

直接调用client.update

@Test

public void testUpdate2() throws Exception

????UpdateResponse updateResponse =

????????????client.update(new UpdateRequest("blog", "article", "2")

????????????????????.doc(XContentFactory.jsonBuilder() //doc 更新方法

????????????????????????.startObject()

????????????????????????????.field("id", "2")

????????????????????????????.field("title", "更新:2")

????????????????????????????.field("content", "更新:2")

????????????????????????.endObject()))

????????????????????.get();

????System.out.println("索引名称: " + updateResponse.getIndex());

????System.out.println("文档类型: "+updateResponse.getType());

????System.out.println("ID: "+updateResponse.getId());

????System.out.println("版本: "+updateResponse.getVersion());

????System.out.println("是否创建成功: "+updateResponse.isCreated()); //false

????client.close();

创建并更新

@Test

public void testUpdate3() throws Exception

????// 设置一个查询的条件,使用ID查询,如果查不到数据,则添加IndexRequest的文档数据

????IndexRequest indexRequest = new IndexRequest("blog1", "article", "4")

????????????.source(XContentFactory.jsonBuilder()

????????????????.startObject()

????????????????????.field("id", "4")

????????????????????.field("title", "李雪静加油")

????????????????????.field("content", "Fighting!")

????????????????.endObject());

????//设置更新的数据,使用ID查询,如果能查到,则更新UpdateRequest的数据

????UpdateRequest updateRequest = new UpdateRequest("blog1", "article", "4")

????????????.doc(XContentFactory.jsonBuilder()

????????????????????.startObject()

????????????????????.field("title", "new fighting~")

????????????????????.endObject())

????????????.upsert(indexRequest);

????UpdateResponse updateResponse = client.update(updateRequest).get();

????System.out.println("索引名称: " + updateResponse.getIndex());

????System.out.println("文档类型: "+updateResponse.getType());

????System.out.println("ID: "+updateResponse.getId());

????System.out.println("版本: "+updateResponse.getVersion());

????System.out.println("是否创建成功: "+updateResponse.isCreated()); //false

????client.close();

----------------------------------------删除文档------------------------------------

prepareDelete

@Test

public void deleteData()

????DeleteResponse deleteResponse = client.prepareDelete("blog", "article", "3").get();

????System.out.println("索引名称: " + deleteResponse.getIndex());

????System.out.println("文档类型: "+deleteResponse.getType());

????System.out.println("ID: "+deleteResponse.getId());

????System.out.println("版本: "+deleteResponse.getVersion());

????System.out.println("是否删除成功: "+deleteResponse.isFound());

????client.close();

----------------------------------------查询文档------------------------------------

安装分词器之前的查询

es提供了queryStringQuery查询

针对多字短的query_string查询

@Test

public void testSearch()

????SearchResponse searchResponse = client.prepareSearch("blog")

????????????.setTypes("article")

//默认分词器只能查找单个字,并没有把中文进行分词,需要我们安装一个分词器,IK分词器

????????????.setQuery(QueryBuilders.queryStringQuery("更新"))

????????????.get();

????//获取数据的结果对象

????SearchHits hits = searchResponse.getHits();

????//获取命中次数

????System.out.println("查询的结果数据有"+hits.getTotalHits()+"条");

????//遍历所有数据

????Iterator<SearchHit> iterator = hits.iterator();

????while (iterator.hasNext())

????????SearchHit hit = iterator.next();

????????//获取整条数据

????????System.out.println(hit.getSourceAsString());

????????//获取单个字段

????????System.out.println("id: "+ hit.getSource().get("id"));

????????System.out.println("title: "+ hit.getSource().get("title"));

????????System.out.println("content: "+ hit.getSource().get("content"));

????

????client.close();