ElasticSearch Java api 详解_V1.0

                  1
                import
                 java.io.IOException;

                  2
                  3
                import
                 org.elasticsearch.action.index.IndexResponse;

                  4
                import
                 org.elasticsearch.action.search.SearchResponse;

                  5
                import
                 org.elasticsearch.action.search.SearchType;

                  6
                import
                 org.elasticsearch.client.Client;

                  7
                import
                 org.elasticsearch.client.transport.TransportClient;

                  8
                import
                 org.elasticsearch.common.transport.InetSocketTransportAddress;

                  9
                import
                 org.elasticsearch.common.xcontent.XContentBuilder;

                 10
                import
                 org.elasticsearch.common.xcontent.XContentFactory;

                 11
                import
                 org.elasticsearch.index.query.FilterBuilders;

                 12
                import
                 org.elasticsearch.index.query.QueryBuilder;

                 13
                import
                 org.elasticsearch.index.query.QueryBuilders;

                 14
                import
                 org.elasticsearch.search.SearchHits;

                 15
                 16
                import
                 user.User;

                 17
                 18
                 19
                public
                class
                 First_ES_Test {

                 20
                 21
                private
                 Client client;

                 22
                 23
                public
                void
                 init()

                 24
                    {

                 25
                //
                ip可以在http:
                //
                localhost:9200/_plugin/head/中自行查询
                 26         client = new TransportClient().addTransportAddress(new InetSocketTransportAddress("192.168.1.103", 9300));
 27    }
 28 29publicvoid close()
 30    {
 31        client.close();
 32    }
 33 34/* 35     * create index
 36     **/ 37publicvoid createIndex() {
 38for (int i = 0; i < 1000; i++) {
 39             User user = new User();
 40             user.setId(new Long(i));
 41             user.setName("xxx0624 " + i);
 42             user.setAge(i % 100);
 43             System.out.println("ok:"+i);
 44             client.prepareIndex("users", "user").setSource(generateJson(user))
 45                    .execute().actionGet();
 46        }
 47    }
 48 49/* 50     * 转换成json对象
 51     *
 52     * @param user
 53     * @return json(String)
 54     **/ 55private String generateJson(User user) {
 56         String json = "";
 57try {
 58             XContentBuilder contentBuilder = XContentFactory.jsonBuilder()
 59                    .startObject();
 60             contentBuilder.field("id", user.getId() + "");
 61             contentBuilder.field("name", user.getName());
 62             contentBuilder.field("age", user.getAge() + "");
 63             json = contentBuilder.endObject().string();
 64         } catch (IOException e) {
 65            e.printStackTrace();
 66        }
 67return json;
 68    }
 69 70publicvoid search() {
 71         QueryBuilder qb = QueryBuilders
 72                .boolQuery()
 73                 .must(QueryBuilders.termQuery("age", "0"))
 74                 .should(QueryBuilders.termQuery("id", "0"))
 75//.mustNot(QueryBuilders.termQuery("content", "test2"))
 76//.should(QueryBuilders.termQuery("content", "test3")) 77                ;
 78 79         SearchResponse response = client.prepareSearch("users")
 80                 .setTypes("user")
 81                .setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
 82                 .setQuery(qb) // Query
 83//.setFilter(FilterBuilders.rangeFilter("age").from(0).to(100)) // Filter 84                 .setFrom(0).setSize(100).setExplain(true)
 85                .execute().actionGet();
 86         SearchHits hits = response.getHits();
 87        System.out.println(hits.getTotalHits());
 88for (int i = 0; i < hits.getHits().length; i++) {
 89            System.out.println(hits.getHits()[i].getSourceAsString());
 90        }
 91    }    
 92 93publicstaticvoid main(String[] args) {
 94 95         First_ES_Test client = new First_ES_Test();
 96        client.init();
 97        client.createIndex();
 98        client.search();
 99        client.close();
100101    }
102103publicvoid print(String output)
104    {
105        System.out.print(output);
106    }
107publicvoid println(String output)
108    {
109        System.out.println(output);
110    }
111112 }