源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：org.codelibs.elasticsearch.runner.net.Curl

示例1
private void test_wait_for_completion(Node node, String index) {
    String newIndex0 = "dataset0", newIndex1 = "dataset1";

    CurlResponse response0 = Curl.post(node, "/" + index + "/_reindex/" + newIndex0)
            .param("wait_for_completion", "true").execute();
    CurlResponse response1 = Curl.post(node, "/" + index + "/_reindex/" + newIndex1)
            .execute();
    Map<String, Object> map0 = response0.getContentAsMap();
    Map<String, Object> map1 = response1.getContentAsMap();
    assertEquals(map0.size(), 1);
    assertTrue(map0.containsKey("acknowledged"));
    assertEquals(map1.size(), 2);
    assertTrue(map1.containsKey("acknowledged"));
    assertTrue(map1.containsKey("name"));

    runner.flush();
    runner.deleteIndex(newIndex0);
    runner.deleteIndex(newIndex1);
}
示例2
private void test_index_to_newIndex(Node node, String index) throws IOException {
    String newIndex = "dataset2";

    try (CurlResponse curlResponse = Curl
            .post(node, "/" + index + "/_reindex/" + newIndex)
            .param("wait_for_completion", "true")
            .execute()) {
        Map<String, Object> map = curlResponse.getContentAsMap();
        assertTrue(map.containsKey("acknowledged"));
        assertNull(map.get("name"));
    }

    // causes a lucene commit, more expensive than refresh
    runner.flush();

    assertTrue(runner.indexExists(index));
    assertTrue(runner.indexExists(newIndex));

    // search documents
    {
        final SearchResponse searchResponse = runner.search(newIndex,
                // BuilderCallback对象用于加工SearchRequestBuilder对象
                new BuilderCallback<SearchRequestBuilder>() {
                    @Override
                    public SearchRequestBuilder apply(SearchRequestBuilder builder) {
                        return builder;
                    }
                });
        assertEquals(docNumber, searchResponse.getHits().getTotalHits());
    }

    runner.deleteIndex(newIndex);
}
示例3
private void test_index_to_newIndex_withSource(Node node, String index) throws IOException {
    String newIndex = "dataset2";

    try (CurlResponse curlResponse = Curl
            .post(node, "/" + index + "/_reindex/" + newIndex)
            .param("wait_for_completion", "true")
            .body("{\"query\":{\"term\":{\"msg\":{\"value\":\"1\"}}}}")
            .execute()) {
        Map<String, Object> map = curlResponse.getContentAsMap();
        assertTrue(map.containsKey("acknowledged"));
        assertNull(map.get("name"));
    }

    runner.flush();

    assertTrue(runner.indexExists(index));
    assertTrue(runner.indexExists(newIndex));

    // search newly created index
    {
        final SearchResponse searchResponse = runner.search(newIndex,
                new BuilderCallback<SearchRequestBuilder>() {
                    @Override
                    public SearchRequestBuilder apply(SearchRequestBuilder builder) {
                        return builder;
                    }
                });
        assertEquals(1, searchResponse.getHits().getTotalHits());
    }

    runner.deleteIndex(newIndex);
}
示例4
private void test_index_type_to_newIndex(Node node, String index, String type) throws IOException {
    String newIndex = "dataset2";
    String newType = type;

    try (CurlResponse curlResponse = Curl
            .post(node, "/" + index + "/" + type + "/_reindex/" + newIndex)
            .param("wait_for_completion", "true")
            .execute()) {
        Map<String, Object> map = curlResponse.getContentAsMap();
        assertTrue(map.containsKey("acknowledged"));
        assertNull(map.get("name"));
    }

    runner.flush();

    assertTrue(runner.indexExists(index));
    assertTrue(runner.indexExists(newIndex));

    // search documents
    {
        final SearchResponse searchResponse = runner.search(newIndex,
                newType, null, null, 0, 10);
        assertEquals(docNumber, searchResponse.getHits().getTotalHits());
    }

    runner.deleteIndex(newIndex);
}
示例5
private void test_index_type_to_newIndex_newType(Node node, String index, String type) throws IOException {
    String newIndex = "dataset2";
    String newType = "item2";

    try (CurlResponse curlResponse = Curl
            .post(node,
                    "/" + index + "/" + type + "/_reindex/" + newIndex
                            + "/" + newType)
            .param("wait_for_completion", "true").execute()) {
        Map<String, Object> map = curlResponse.getContentAsMap();
        assertTrue(map.containsKey("acknowledged"));
        assertNull(map.get("name"));
    }

    runner.flush();

    assertTrue(runner.indexExists(index));
    assertTrue(runner.indexExists(newIndex));

    // search documents
    {
        final SearchResponse searchResponse = runner.search(newIndex,
                newType, null, null, 0, 10);
        assertEquals(docNumber, searchResponse.getHits().getTotalHits());
    }

    runner.deleteIndex(newIndex);
}
示例6
private void test_index_to_remote_newIndex(Node node, String index) throws IOException {
    String newIndex = "dataset2";

    try (CurlResponse curlResponse = Curl
            .post(node, "/" + index + "/_reindex/" + newIndex)
            .param("wait_for_completion", "true")
            .param("url", "http://localhost:" + node.settings().get("http.port"))
            .execute()) {
        Map<String, Object> map = curlResponse.getContentAsMap();
        assertTrue(map.containsKey("acknowledged"));
        assertNull(map.get("name"));
    }

    runner.flush();

    assertTrue(runner.indexExists(index));
    assertTrue(runner.indexExists(newIndex));

    // search documents
    {
        final SearchResponse searchResponse = runner.search(newIndex,
                new BuilderCallback<SearchRequestBuilder>() {
                    @Override
                    public SearchRequestBuilder apply(SearchRequestBuilder builder) {
                        return builder;
                    }
                });
        assertEquals(docNumber, searchResponse.getHits().getTotalHits());
    }

    runner.deleteIndex(newIndex);
}
示例7
private void test_index_to_remote_newIndex_withSource(Node node, String index) throws IOException {
    String newIndex = "dataset2";

    try (CurlResponse curlResponse = Curl
            .post(node, "/" + index + "/_reindex/" + newIndex)
            .param("wait_for_completion", "true")
            .param("url",
                    "http://localhost:" + node.settings().get("http.port"))
            .body("{\"query\":{\"term\":{\"msg\":{\"value\":\"1\"}}}}")
            .execute()) {
        Map<String, Object> map = curlResponse.getContentAsMap();
        assertTrue(map.containsKey("acknowledged"));
        assertNull(map.get("name"));
    }

    runner.flush();

    assertTrue(runner.indexExists(index));
    assertTrue(runner.indexExists(newIndex));

    // search documents
    {
        final SearchResponse searchResponse = runner.search(newIndex,
                new BuilderCallback<SearchRequestBuilder>() {
                    @Override
                    public SearchRequestBuilder apply(SearchRequestBuilder builder) {
                        return builder;
                    }
                });
        assertEquals(1, searchResponse.getHits().getTotalHits());
    }

    runner.deleteIndex(newIndex);
}
示例8
private void test_index_type_to_remote_newIndex(Node node, String index, String type) throws IOException {
    String newIndex = "dataset2";
    String newType = type;

    try (CurlResponse curlResponse = Curl
            .post(node, "/" + index + "/" + type + "/_reindex/" + newIndex)
            .param("wait_for_completion", "true")
            .param("url",
                    "http://localhost:" + node.settings().get("http.port"))
            .execute()) {
        Map<String, Object> map = curlResponse.getContentAsMap();
        assertTrue(map.containsKey("acknowledged"));
        assertNull(map.get("name"));
    }

    runner.flush();

    assertTrue(runner.indexExists(index));
    assertTrue(runner.indexExists(newIndex));

    // search documents
    {
        final SearchResponse searchResponse = runner.search(newIndex,
                newType, null, null, 0, 10);
        assertEquals(docNumber, searchResponse.getHits().getTotalHits());
    }

    runner.deleteIndex(newIndex);
}
示例9
private void test_index_type_to_remote_newIndex_newType(Node node, String index, String type) throws IOException {
    String newIndex = "dataset2";
    String newType = "item2";

    try (CurlResponse curlResponse = Curl
            .post(node,
                    "/" + index + "/" + type + "/_reindex/" + newIndex
                            + "/" + newType)
            .param("wait_for_completion", "true")
            .param("url",
                    "http://localhost:" + node.settings().get("http.port"))
            .execute()) {
        Map<String, Object> map = curlResponse.getContentAsMap();
        assertTrue(map.containsKey("acknowledged"));
        assertNull(map.get("name"));
    }

    runner.flush();

    assertTrue(runner.indexExists(index));
    assertTrue(runner.indexExists(newIndex));

    // search documents
    {
        final SearchResponse searchResponse = runner.search(newIndex,
                newType, null, null, 0, 10);
        assertEquals(docNumber, searchResponse.getHits().getTotalHits());
    }

    runner.deleteIndex(newIndex);
}