elasticsearch java API ------定义索引字段属性
elasticsearch java API ------定义索引字段属性TransportClient client = null;
public ESClientTest() {
Settings settings = ImmutableSettings.settingsBuilder()
.put("client.transport.sniff", true).build();
client = new TransportClient(settings);
}
public void connect() {
client.addTransportAddress(new InetSocketTransportAddress("localhost", 9300));
}
public void close(){
client.close();
}
public void putMapping(){
try {
//先创建空索引库
client.admin().indices().prepareCreate("productindex").execute().actionGet();
XContentBuilder mapping = XContentFactory.jsonBuilder()
.startObject()
.startObject("productindex")
.startObject("properties")
.startObject("title").field("type", "string").field("store", "yes").endObject()
.startObject("description").field("type", "string").field("index", "not_analyzed").endObject()
.startObject("price").field("type", "double").endObject()
.startObject("onSale").field("type", "boolean").endObject()
.startObject("type").field("type", "integer").endObject()
.startObject("createDate").field("type", "date").endObject()
.endObject()
.endObject()
.endObject();
PutMappingRequest mappingRequest = Requests.putMappingRequest("productindex").type("productindex").source(mapping);
client.admin().indices().putMapping(mappingRequest).actionGet();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static void main(String[] args) {
ESClientTest es = new ESClientTest();
es.putMapping();
es.close();
}
页:
[1]