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);
        }
    
    }
  • 相关阅读:
    Linux下date命令,格式化输出,时间设置
    Linux scp复制文件,不需要输入密码的技巧
    Linux中cp和scp命令的使用方法
    Linux定时任务系统 Cron
    Eclipse启动Tomcat后无法访问项目
    eclipse下tomcat插件配置说明
    RPM方式安装MySQL5.6和windows下安装mysql解压版
    shell script练习
    Eclipse Java注释模板设置详解
    mysql备份还原数据库
  • 原文地址:https://www.cnblogs.com/liubaihui/p/10531073.html
Copyright © 2011-2022 走看看