2

使用 Java API 设置 Source 和 Settings 的唯一方法是使用这样的代码（这是一个只有一个 @test 方法的简单测试类）：

   @RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest

@TestPropertySource(value = "classpath:testApplication.properties")
public class ESJavaAPITests {


    @Value("${ES.cluster.name}")
    private String    CLUSTER_NAME;

    @Value("${ES.host}")
    private String    HOSTNAME;

    @Value("${ES.port}")
    private Integer   HOST_PORT;

    private static final String BOOK_INDEX_NAME ="bookshop";
    private static final String BOOK_TYPE_NAME ="book";

    private Client client(){
        Settings settings = Settings.settingsBuilder()
                .put("cluster.name", CLUSTER_NAME)
                .build();

        return new TransportClient.Builder().settings(settings).build()
                .addTransportAddress(
                        new InetSocketTransportAddress(
                                new InetSocketAddress(HOSTNAME, HOST_PORT))
                );

    }

    @Test
    public void shouldSaveDocToPredefinedShard() throws IOException {
        //delete all indexes if any
        client().admin().indices().prepareDelete("_all").get();


        CreateIndexResponse createIndexRequestBuilder = client().admin().indices()
                .prepareCreate(BOOK_INDEX_NAME)
                .setSettings(
                        Settings.settingsBuilder()
                                .put("index.number_of_shards", 2)
                                .put("index.number_of_replicas", 2)
                )
                .execute()
                .actionGet();

        IndexResponse response1 = client().prepareIndex(BOOK_INDEX_NAME, BOOK_TYPE_NAME, "id1")
                .setSource(XContentFactory.jsonBuilder()
                        .startObject()
                            .field("title", "Clean COde")
                            .field("author", "John Smith")
                        .endObject()
                )
                .setRouting("route1")
                .get();

        IndexResponse response2 = client().prepareIndex(BOOK_INDEX_NAME, BOOK_TYPE_NAME, "id2")
                .setSource(XContentFactory.jsonBuilder()
                        .startObject()
                            .field("title", "Learn Scala")
                            .field("author", "John Doe")
                        .endObject()
                )
                .setRouting("route2")
                .get();
    }
}

这在我第一次运行时有效。但是当我第二次运行它时，我得到：

java.lang.IllegalStateException：无法加载 ApplicationContext

invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144) 引起：org .springframework.beans.factory.UnsatisfiedDependencyException：创建名为“bookServiceImpl”的bean时出错：通过方法“setBookRepository”参数表示的不满足依赖项0：创建名为“bookRepository”的bean时出错：调用init方法失败；嵌套异常是 org.springframework.beans.BeanInstantiationException：无法实例化 [org.springframework.data.elasticsearch.repository.support.SimpleElasticsearchRepository]：构造函数抛出异常；嵌套异常是 java.lang.IllegalArgumentException：在 com.intellij.rt.execution.application.AppMain.main(AppMain.java:144) 调用（Method.java:498） 原因：org.springframework.beans.factory.UnsatisfiedDependencyException：创建名为“bookServiceImpl”的 bean 时出错：通过方法'setBookRepository'参数表达的不满足的依赖关系0：创建名为'bookRepository'的bean时出错：调用init方法失败；嵌套异常是 org.springframework.beans.BeanInstantiationException：无法实例化 [org.springframework.data.elasticsearch.repository.support.SimpleElasticsearchRepository]：构造函数抛出异常；嵌套异常是 java.lang.IllegalArgumentException：在 com.intellij.rt.execution.application.AppMain.main(AppMain.java:144) 调用（Method.java:498） 原因：org.springframework.beans.factory.UnsatisfiedDependencyException：创建名为“bookServiceImpl”的 bean 时出错：通过方法'setBookRepository'参数表达的不满足的依赖关系0：创建名为'bookRepository'的bean时出错：调用init方法失败；嵌套异常是 org.springframework.beans.BeanInstantiationException：无法实例化 [org.springframework.data.elasticsearch.repository.support.SimpleElasticsearchRepository]：构造函数抛出异常；嵌套异常是 java.lang.IllegalArgumentException：UnsatisfiedDependencyException：创建名为“bookServiceImpl”的bean时出错：通过方法“setBookRepository”参数表示的不满足依赖项0：创建名为“bookRepository”的bean时出错：调用init方法失败；嵌套异常是 org.springframework.beans.BeanInstantiationException：无法实例化 [org.springframework.data.elasticsearch.repository.support.SimpleElasticsearchRepository]：构造函数抛出异常；嵌套异常是 java.lang.IllegalArgumentException：UnsatisfiedDependencyException：创建名为“bookServiceImpl”的bean时出错：通过方法“setBookRepository”参数表示的不满足依赖项0：创建名为“bookRepository”的bean时出错：调用init方法失败；嵌套异常是 org.springframework.beans.BeanInstantiationException：无法实例化 [org.springframework.data.elasticsearch.repository.support.SimpleElasticsearchRepository]：构造函数抛出异常；嵌套异常是 java.lang.IllegalArgumentException：springframework.beans.BeanInstantiationException：无法实例化 [org.springframework.data.elasticsearch.repository.support.SimpleElasticsearchRepository]：构造函数抛出异常；嵌套异常是 java.lang.IllegalArgumentException：springframework.beans.BeanInstantiationException：无法实例化 [org.springframework.data.elasticsearch.repository.support.SimpleElasticsearchRepository]：构造函数抛出异常；嵌套异常是 java.lang.IllegalArgumentException：[title] 的映射器与其他类型中的现有映射冲突：[mapper [title] 具有不同的 [store] 值]；嵌套异常是 org.springframework.beans.factory.BeanCreationException：创建名为“bookRepository”的 bean 时出错：调用 init 方法失败；嵌套异常是 org.springframework.beans.BeanInstantiationException：无法实例化 [org.springframework.data.elasticsearch.repository.support.SimpleElasticsearchRepository]：构造函数抛出异常；嵌套异常是 java.lang.IllegalArgumentException: Mapper for [title] 与其他类型的现有映射冲突：[mapper [title] has different [store] values] at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredMethodElement.inject

为什么当我第二次运行它时这似乎是一个问题？

如何使用以下方法创建索引并添加两个示例文档：

  1. 分片NR
  2. 副本编号
  3. 索引名称
  4. 索引类型

  5. 新文档 ID。

    使用 Java API？

4

1 回答 1

0

这里没有足够的代码来轻松解释这个问题，但是您在某处有一个名为“bookRepository”的存储库类，它可能设置为自动配置。存储库没有被删除，因此当您第二次（第二次运行）重新创建索引时，它会将“书”类（假设）与现有 ES 索引的架构进行比较 - 您可能会已更改标题字段。

您最好手动清除书籍索引（我假设这并不重要，因为您在上面的代码中有删除）并查看是否连续两次运行应用程序（您的测试用例）仍然失败。

于 2017-01-17T17:21:36.547 回答