【java操作Elasticsearch之mapping和aliases】
?
Elasticsearch之创建mapping--字段类型映射,以及别名
?
?
package estest.cn.com.esdemo;
?
import net.sf.json.JSONObject;
?
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;
?
/**
?
<dependency>
? ? <groupId>org.elasticsearch</groupId>
? ? <artifactId>elasticsearch</artifactId>
? ? <version>2.2.0</version>
</dependency>
? ? <!-- http://mvnrepository.com/artifact/org.apache.httpcomponents/httpclient -->
<dependency>
? ? <groupId>org.apache.httpcomponents</groupId>
? ? <artifactId>httpclient</artifactId>
? ? <version>4.5.2</version>
</dependency>
? ??
? ? <dependency>
? <groupId>net.sf.json-lib</groupId>
? <artifactId>json-lib</artifactId>
? <version>2.4</version>
? <classifier>jdk15</classifier>
</dependency>
?*?
?*/
@SuppressWarnings("deprecation")
public class App {
public static void main(String[] args) throws Exception {
System.out.println("Hello World!");
String url ="http://192.168.1.111:9200/";
?
String json = ?createMapping();
doPost(url+"index_users3", JSONObject.fromObject( json));
//
String alias = ?addAlias("index_users3","ttest");
doPost(url+"_aliases", alias);
}
?
/**
* post请求
*?
* @param url
* @param json
* @return
*/
?
public static JSONObject doPost(String url, JSONObject json) {
DefaultHttpClient client = new DefaultHttpClient();
HttpPost post = new HttpPost(url);
JSONObject response = null;
try {
StringEntity s = new StringEntity(json.toString(),HTTP.UTF_8);
?
s.setContentEncoding("UTF-8");
s.setContentType("application/json;charset=UTF-8");// 发送json数据需要设置contentType
post.setEntity(s);
?
HttpResponse res = client.execute(post);
if (res.getStatusLine().getStatusCode() == 200) {
HttpEntity entity = res.getEntity();
String result = EntityUtils.toString(entity,"UTF-8");// 返回json格式：
System.out.println(result);
}
} catch (Exception e) {
throw new RuntimeException(e);
}
return response;
}
?
public static JSONObject doPost(String url, String str) {
DefaultHttpClient client = new DefaultHttpClient();
HttpPost post = new HttpPost(url);
JSONObject response = null;
try {
StringEntity s = new StringEntity(str,HTTP.UTF_8);
post.addHeader("Content-Type", "application/json; charset=UTF-8");?
post.setEntity(s);
?
HttpResponse res = client.execute(post);
if (res.getStatusLine().getStatusCode() == 200) {
HttpEntity entity = res.getEntity();
String result = EntityUtils.toString(res.getEntity(),"UTF-8");// 返回json格式：
System.out.println(result);
}
} catch (Exception e) {
throw new RuntimeException(e);
}
return response;
}
?
public static String ?createMapping() throws Exception {
XContentBuilder builder = XContentFactory.jsonBuilder()
.startObject()
.startObject("settings")
.startObject("index")
.field("number_of_shards").value(2)
.field("number_of_replicas").value(1)
.endObject()
.endObject()
.startObject("mappings")
? ?.startObject("userinfo")
.startObject("properties")
.startObject("name").field("type", "string").field("store", "yes").endObject()
.startObject("address").field("type", "string").field("index", "not_analyzed").endObject()
.startObject("sal").field("type", "double").endObject()
.startObject("sex").field("type", "boolean").endObject()
.startObject("age").field("type", "integer").endObject()
.startObject("createDate").field("type", "date").endObject()
.endObject()?
.endObject();
System.out.println(builder.string());
return builder.string();
}
?
?
//{"actions":[{"add":{"index":"index_users3","alias":"5"}}]}:
public static String addAlias(String index,String alias) throws Exception {
XContentBuilder builder = XContentFactory.jsonBuilder()
.startObject()
.startArray("actions")
.startObject()
.startObject("add")
.field("alias").value(alias).
?field("index").value(index)
.endObject().endObject()
.endArray().endObject();
?
System.out.println(builder.string());
return builder.string();
}
}
?
?