package com.basic.security.utils;
|
|
//import org.elasticsearch.action.DocWriteResponse;
|
//import org.elasticsearch.action.index.IndexResponse;
|
//import org.elasticsearch.client.Client;
|
//import org.elasticsearch.common.settings.Settings;
|
//import org.elasticsearch.common.transport.InetSocketTransportAddress;
|
//import org.elasticsearch.common.xcontent.XContentType;
|
//import org.elasticsearch.transport.client.PreBuiltTransportClient;
|
|
public class ElastisearchUtil {
|
public static void test() {
|
// try{
|
// Client client = new PreBuiltTransportClient(
|
// Settings.builder().put("client.transport.sniff", true)
|
// .put("cluster.name","elasticsearch").build())
|
// .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("192.168.1.156"), 9300));
|
//
|
// String jsonObject = "{\"age\":10,\"dateOfBirth\":1471466076564,"
|
// +"\"fullName\":\"John Doe\"}";
|
// IndexResponse response = client.prepareIndex("people", "Doe")
|
// .setSource(jsonObject, XContentType.JSON).get();
|
// String id = response.getId();
|
// String index = response.getIndex();
|
// String type = response.getType();
|
// long version = response.getVersion();
|
//
|
// assertEquals(DocWriteResponse.Result.CREATED, response.getResult());
|
// assertEquals(0, version);
|
// assertEquals("people", index);
|
// assertEquals("Doe", type);
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// }
|
//
|
|
// String id = response.getId();
|
// String index = response.getIndex();
|
// String type = response.getType();
|
// long version = response.getVersion();
|
//
|
// assertEquals(Result.CREATED, response.getResult());
|
// assertEquals(0, version);
|
// assertEquals("people", index);
|
// assertEquals("Doe", type);
|
//
|
//
|
//// ObjectMapper objectMapper = new ObjectMapper();
|
// TransportClient client = null;
|
// User user = new User();
|
// user.setAddress("beijingshi");
|
// user.setAge(28);
|
// user.setName("alvin");
|
// try {
|
// Settings settings = Settings.builder()
|
// .put("cluster.name", "my-application").build();
|
// client = new PreBuiltTransportClient(settings)
|
// .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("192.168.1.156"), 9300));
|
//
|
//// client = new PreBuiltTransportClient(settings);
|
// IndexResponse indexResponse = client.prepareIndex("my_index", "user").setSource(user).get();
|
// } catch (Exception ex) {
|
// ex.printStackTrace();
|
// } finally {
|
// if (client != null) {
|
// client.close();
|
// }
|
// }
|
}
|
|
}
|
