Elastic Search Java Api 创建索引结构，添加索引
发布时间：2020-12-14 23:38:40 所属栏目：Java 来源：网络整理
导读：今天PHP站长网 52php.cn把收集自互联网的代码分享给大家，仅供参考。 创建TCP客户端 Client client = new TransportClient() .addTransportAddress(new InetSocketTransportAddress( "localhost",9300)); 创建索引client.
|
以下代码由PHP站长网 52php.cn收集自互联网 现在PHP站长网小编把它分享给大家，仅供参考
创建TCP客户端
Client client = new TransportClient()
.addTransportAddress(new InetSocketTransportAddress(
"localhost",9300));
创建索引
client.admin().indices().prepareCreate("pages").execute().actionGet();
创建索引结构
XContentBuilder builder=XContentFactory
.jsonBuilder()
.startObject()
????.startObject("sina")
.startObject("properties")
.startObject("article_title")
.field("type","string")
.field("store","yes")
.field("analyzer","ik")
.field("index","analyzed")
.endObject()
.startObject("article_content")
.field("type","no")
.field("analyzer","analyzed")
.endObject()
.startObject("article_url")
.field("type","yes")
.field("index","not_analyzed")
.endObject()
.endObject()
.endObject()
.endObject();
PutMappingRequest mapping = Requests.putMappingRequest("pages").type("sina").source(builder);
client.admin().indices().putMapping(mapping).actionGet();
添加索引数据
IndexResponse response = client.prepareIndex("pages","sina",null)
.setSource(jsonBuilder()
.startObject()
.field("article_title",Bytes.toString(r.getValue("article".getBytes(),"title".getBytes())))
.field("article_content","content".getBytes())))
.field("article_url","url".getBytes())))
.endObject()
)
.execute()
.actionGet();
client.close();
以上内容由PHP站长网【52php.cn】收集整理供大家参考研究 如果以上内容对您有帮助，欢迎收藏、点赞、推荐、分享。 （编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |