走进大数据丨ElasticSearch6.X的JavaAPI使用一

清疚 2023-06-27 08:55 14阅读 0赞

![format_png][]

通过Java操作Elastic Search6，环境请看：[走进大数据丨 ElasticSearch6.X的JavaAPI环境部署][ElasticSearch6.X_JavaAPI]

import org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest;
    import org.elasticsearch.action.get.GetResponse;
    import org.elasticsearch.action.get.MultiGetItemResponse;
    import org.elasticsearch.action.get.MultiGetResponse;
    import org.elasticsearch.action.index.IndexRequest;
    import org.elasticsearch.action.index.IndexResponse;
    import org.elasticsearch.action.search.SearchResponse;
    import org.elasticsearch.action.update.UpdateRequest;
    import org.elasticsearch.action.update.UpdateResponse;
    import org.elasticsearch.client.Requests;
    import org.elasticsearch.client.transport.TransportClient;
    import org.elasticsearch.common.settings.Settings;
    import org.elasticsearch.common.transport.TransportAddress;
    import org.elasticsearch.common.xcontent.XContentBuilder;
    import org.elasticsearch.common.xcontent.XContentFactory;
    import org.elasticsearch.common.xcontent.XContentType;
    import org.elasticsearch.index.query.QueryBuilders;
    import org.elasticsearch.search.SearchHit;
    import org.elasticsearch.search.SearchHits;
    import org.elasticsearch.transport.client.PreBuiltTransportClient;
    
    
    import java.net.InetAddress;
    import java.util.HashMap;
    import java.util.Map;

![format_png][]

初始化获取Elastic Search链接

public final static String HOST = "192.168.1.111";
        // http请求的端口是9200，客户端是9300
        public final static int PORT = 9300;
    
    
        /**
         * getConnection:(获取es连接).
         * @author xbq Date:2018年3月21日上午11:52:02
         * @return
         * @throws Exception
         */
        @SuppressWarnings({"resource", "unchecked"})
        public static TransportClient getConnection() throws Exception {
            // 设置集群名称
            Settings settings = Settings.builder().put("cluster.name", "plus").build();
            // 创建client
            TransportClient client = new PreBuiltTransportClient(settings)
                    .addTransportAddresses(new TransportAddress(InetAddress.getByName(HOST), PORT));
    
    
            //client.close();
            return client;
        }

![format_png][]

创建索引

public static void createIndex() throws Exception {
            TransportClient client = getConnection();
            client.admin().indices().prepareCreate("blog12").get();
            client.close();
        }

![format_png][]

删除索引

public static void deleteIndex() throws Exception {
            TransportClient client = getConnection();
            client.admin().indices().prepareDelete("blog1").get();
            client.close();
        }

![format_png][]

使用Json文件，创建document

**注意：****在ES6.x版本之前可以直接使用jaon传，之后更新需要添加参数XContentType.JSON**

public static void createDocument() throws Exception {
            //构建一个json文件
            String json = "{" + "\"id\":\"1\"," + "\"title\":\"基于Lucene的搜索服务器\","
                    + "\"content\":\"它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口\"" + "}";
            //创建文档,
            IndexResponse indexResponse = getConnection().prepareIndex("blog", "article", "2").setSource(json, XContentType.JSON).execute().actionGet();
            //打印返回结果
            System.out.println("index"+indexResponse.getIndex());
            System.out.println("Type"+indexResponse.getType());
            System.out.println("ID"+indexResponse.getId());
            System.out.println("version"+indexResponse.getVersion());
            System.out.println("Result"+indexResponse.getResult());
            getConnection().close();
        }

![format_png][]

使用map集合创建document

public static void createDocumentmap() throws Exception {
            //构建一个map
            Map<String,String> json = new HashMap<String, String>();
            json.put("id","1");
            json.put("title","基于Lucene的搜索服务器");
            json.put("content","它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口");
    
    
    
    
            //创建文档,
            IndexResponse indexResponse = getConnection().prepareIndex("blog", "article", "1").setSource(json).execute().actionGet();
            //打印返回结果
            System.out.println("index: "+indexResponse.getIndex());
            System.out.println("Type: "+indexResponse.getType());
            System.out.println("ID: "+indexResponse.getId());
            System.out.println("version: "+indexResponse.getVersion());
            System.out.println("Result: "+indexResponse.getResult());
            getConnection().close();
        }

![format_png][]

使用es提供的建议使用的方式

public static void createDocumentXcontent() throws Exception {
            //构建一个Xcontebt
            XContentBuilder field = XContentFactory.jsonBuilder()
                    .startObject()
                    .field("id", "4")
                    .field("title", "基于Lucene的搜索服务器")
                    .field("content", "它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口")
                    .endObject();
    
    
    
    
            //创建文档,
            IndexResponse indexResponse = getConnection().prepareIndex("blog", "article").setSource(field).execute().actionGet();
            //打印返回结果
            System.out.println("index: "+indexResponse.getIndex());
            System.out.println("Type: "+indexResponse.getType());
            System.out.println("ID: "+indexResponse.getId());
            System.out.println("version: "+indexResponse.getVersion());
            System.out.println("Result: "+indexResponse.getResult());
            getConnection().close();
        }

![format_png][]

![format_png 1][]

[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X2dpZi9ZSGwxU2ljSk5NdUxuSTZjTWljMUpUaWJyUkJVZm5LWUhXaEw3VmQyallpYTVYU3NOaWJwc1FBN3NBQVZiaEViNXlxTlB5TkZ2bXU2YnhNYXV6bzNqNWQzbm1BLzY0MA?x-oss-process=image/format,png
[ElasticSearch6.X_JavaAPI]: http://mp.weixin.qq.com/s?__biz=MzU2MjE1MTgyOQ%3D%3D&chksm=fc6cb081cb1b39972ebcd29a441be0de2c7faa72664ef66a7e44348d1769cf8b23ec0c70d0eb&idx=1&mid=2247489659&scene=21&sn=0c6427ee1105fd4cce3ff023d2a38b48#wechat_redirect
[format_png 1]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X2pwZy9sR2x2b0tIblJVSjA2Qk1oaEIyRG05REptTG5JZmdtU2RMYmttTmw3M0FoSVgwajlxMURORVlFSFJ0MW54TFZma0F5RkxVSUdwcTY3ajV3aHJiNjBidy82NDA?x-oss-process=image/format,png