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

好程序员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();

}