ElasticSearch API for JAVA 学习笔记

xxxmenger

/**　　
     * es-api的方法学习：
　　
     * 1.prepareIndex方法：索引数据到ElasticSearch
　　
     * 2.prepareGet方法:获取信息
　　
     * 3.prepareDelete方法：删除信息
　　
     * 4.update方法：更新信息
　　
     *   4.1 upsert：在使用update方法时：
　　
     *       a:针对文档不存在的情况时，做出index数据的操作,update无效；
　　
     *        b:如果文档存在，那么index数据操作无效，update有效；
　　
     */
　　
    public static void main(String[] args) throws IOException, InterruptedException, ExecutionException {
　　
        //通过Settings类设置属性参数
　　
        Settings settings = Settings.settingsBuilder().put("cluster.name","myApp").build();
　　

　　
        //启动Client
　　
        Client client = null;
　　
        try {
　　
            client = TransportClient.builder().settings(settings).build().
　　
                    addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("101.200.124.27"),9300));
　　
        } catch (UnknownHostException e) {
　　
            e.printStackTrace();
　　
        }
　　
        //执行操作
　　
        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd");
　　
        XContentBuilder jsonBuilder = XContentFactory.jsonBuilder()
　　
                .startObject()
　　
                .field("user","yuchen")
　　
                .field("interest","reading book")
　　
                .field("insert_time",df.format(new Date()))
　　
                .endObject();
　　
        //1.prepareIndex方法：索引数据到ElasticSearch
　　
        IndexResponse response = client.prepareIndex("index-test","weibo","4")
　　
            .setSource(jsonBuilder)
　　
            .get();
　　

　　
        String _index = response.getIndex();
　　
        String _type = response.getType();
　　
        String _id = response.getId();
　　
        long _version = response.getVersion();
　　
        boolean created = response.isCreated();
　　
        System.out.println(_index+" "+_type+" "+_id+" "+_version+" "+created);
　　

　　
        //2.prepareGet方法:获取信息
　　
        GetResponse getResponse = client.prepareGet("index-test","weibo","1").get();
　　
        System.out.println(getResponse.getSourceAsString());
　　

　　
        //3.prepareDelete方法：删除信息
　　
        DeleteResponse deleteResponse = client.prepareDelete("index-test","weibo","4").get();
　　
        System.out.println(deleteResponse.isFound());
　　

　　
        //4.update方法：更新信息
　　
        UpdateRequest updateRequest = new UpdateRequest();
　　
        updateRequest.index("index-test");
　　
        updateRequest.type("weibo");
　　
        updateRequest.id("1");
　　
        updateRequest.doc(XContentFactory.jsonBuilder().startObject().field("interest","music").endObject());
　　
        UpdateResponse updateResponse = client.update(updateRequest).get();
　　
        System.out.println(updateResponse.isCreated());
　　
        //update方法： 可以为已有的文档添加新的字段
　　
        UpdateResponse updateResponse2 = client.prepareUpdate("index-test", "weibo", "1")
　　
            .setDoc(XContentFactory.jsonBuilder()
　　
                .startObject()
　　
                .field("interest2","reading")
　　
                .endObject()).get();
　　
        System.out.println(updateResponse2.isCreated());
　　
        //4.1 upsert：在使用update方法时，a:针对文档不存在的情况时，做出index数据的操作,update无效；
　　
        //                          b:如果文档存在，那么index数据操作无效，update有效；
　　
        //先构建一个IndexRequest
　　
        IndexRequest indexRequest = new IndexRequest("index-test","weibo","14");
　　
        indexRequest.source(XContentFactory.jsonBuilder()
　　
                .startObject()
　　
                .field("user","yuchen2")
　　
                .field("interest","eating")
　　
                .field("insert_time",df.format(new Date()))
　　
                .endObject());
　　
        //再构建一个UpdateRequest，并用IndexRequest关联
　　
        UpdateRequest updateRequest3 = new UpdateRequest("index-test","weibo","14");
　　
        updateRequest3.doc(XContentFactory.jsonBuilder()
　　
                .startObject()
　　
                .field("interest2","love")
　　
                .endObject()
　　
                ).upsert(indexRequest);
　　
        client.update(updateRequest3).get();
　　

　　
        if(client != null){
　　
            client.close();
　　
        }
　　
    }