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();
//            }
//        }
    }

}