zoukankan      html  css  js  c++  java
  • elestaticsearch原生写法创建mapping

    public class TestMapping {
        private static String ES_HOST1 = "127.0.0.1";
        //private static String ES_HOST2 = "192.168.10.254";
        private static int ES_PORT = 9300;
    
        public static void main(String[] args) {
            Settings settings = Settings.builder().put("cluster.name", "my-application").build();
            TransportClient client=null;
            try {
               client = new PreBuiltTransportClient(settings)
                        .addTransportAddress(new TransportAddress(InetAddress.getByName(ES_HOST1), ES_PORT));
    
            } catch (UnknownHostException e) {
                e.printStackTrace();
            }
    
            try {
                createMapping(client);
            } catch (IOException e) {
                e.printStackTrace();
            }
    
    
        }
    
    
        public static void createMapping(TransportClient client) throws IOException {
            //创建mapping-需要创建一个空 索引,如果没有索引,创建mapping时会报错
            client.admin().indices().prepareCreate("film9").execute().actionGet();
    
            //创建mapping约束字段
            XContentBuilder mapping = XContentFactory.jsonBuilder()
                    .startObject()
                    .startObject("properties")
                    .startObject("title")
                    .field("type","text")
                    .endObject()
                    .startObject("publishDate")
                    .field("type", "date")
                    .endObject()
                    .startObject("content")
                    .field("type","text")
                    .field("analyzer", "standard")
                    .endObject()
                    .startObject("director")
                    .field("type", "keyword")
                    .endObject()
                    .startObject("price")
                    .field("type", "float")
    
                    .endObject()
                    .endObject()
                    .endObject();
            //添加mapping 绑定到 index
            PutMappingRequest putMappingRequest = Requests.putMappingRequest("film9").type("dongzuo").source(mapping);
            boolean result = client.admin().indices().putMapping(putMappingRequest).actionGet().isAcknowledged();
            client.close();
            System.out.println(result);
        }
    
    }
  • 相关阅读:
    ASP.NET Web API编程——客户端调用
    .Net多线程编程—使用Visual Studio 2012进行调试
    .Net多线程编程—误用点分析
    中国省市区数据mysql脚本
    swift/IOS 多线程使用
    swift 自定义TabBarItem
    swift 动画切换View心地层次顺序
    swift 用协议实现代理传值功能
    Swift简单新闻APP实例
    swift NSMutableArray 排序
  • 原文地址:https://www.cnblogs.com/liubaihui/p/10531073.html
Copyright © 2011-2022 走看看