インデックスの作成中に例外が発生する - Spring Data MongoDB

Question

私はSpringデータをSpring Data MongoDBで使用して、@CompoundIndexesアノテーションを使用してエンティティクラスをマップします。ここで、名前とその定義の両方でインデックスを指定しています。本番環境では、実際のデータに基づいてインデックスの属性の一部を変更する必要があると判断しました。これで、アプリケーションが起動するたびに、アノテーションの結果に一致するインデックスを作成できず、その例外が初期化プロセス中にスローされるため、ロードに失敗します（下記参照）。

これらの例外がログに記録されますが、コンテナの開始に失敗しないように、スプリングデータとmongodbを設定する必要はありますか？

Exception while creating index 
! com.mongodb.MongoCommandException: Command failed with error 86: 'Trying to create an index with same name event_source_link_type_at_id_IDX with different key spec **** vs existing spec *****' on server 127.0.0.1:27017. The full response is { "ok" : 0.0, "errmsg" : "Trying to create an index with same name event_source_link_type_at_id_IDX with different key spec **** vs existing spec *****", "code" : 86 } 
! at com.mongodb.connection.ProtocolHelper.getCommandFailureException(ProtocolHelper.java:115) ~[mongodb-driver-core-3.2.2.jar:na] 
! at com.mongodb.connection.CommandProtocol.execute(CommandProtocol.java:114) ~[mongodb-driver-core-3.2.2.jar:na] 
! at com.mongodb.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:159) ~[mongodb-driver-core-3.2.2.jar:na] 
! at com.mongodb.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:286) ~[mongodb-driver-core-3.2.2.jar:na] 
! at com.mongodb.connection.DefaultServerConnection.command(DefaultServerConnection.java:173) ~[mongodb-driver-core-3.2.2.jar:na] 
! at com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocol(CommandOperationHelper.java:215) ~[mongodb-driver-core-3.2.2.jar:na] 
! at com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocol(CommandOperationHelper.java:198) ~[mongodb-driver-core-3.2.2.jar:na] 
! at com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocol(CommandOperationHelper.java:170) ~[mongodb-driver-core-3.2.2.jar:na] 
! at com.mongodb.operation.CreateIndexesOperation$1.call(CreateIndexesOperation.java:116) ~[mongodb-driver-core-3.2.2.jar:na] 
! at com.mongodb.operation.CreateIndexesOperation$1.call(CreateIndexesOperation.java:111) ~[mongodb-driver-core-3.2.2.jar:na] 
! at com.mongodb.operation.OperationHelper.withConnectionSource(OperationHelper.java:230) ~[mongodb-driver-core-3.2.2.jar:na] 
! at com.mongodb.operation.OperationHelper.withConnection(OperationHelper.java:221) ~[mongodb-driver-core-3.2.2.jar:na] 
! at com.mongodb.operation.CreateIndexesOperation.execute(CreateIndexesOperation.java:111) ~[mongodb-driver-core-3.2.2.jar:na] 
! at com.mongodb.operation.CreateIndexesOperation.execute(CreateIndexesOperation.java:66) ~[mongodb-driver-core-3.2.2.jar:na] 
! at com.mongodb.Mongo.execute(Mongo.java:781) ~[mongodb-driver-3.2.2.jar:na] 
! at com.mongodb.Mongo$2.execute(Mongo.java:764) ~[mongodb-driver-3.2.2.jar:na] 
! at com.mongodb.DBCollection.createIndex(DBCollection.java:1541) ~[mongodb-driver-3.2.2.jar:na] 
! at org.springframework.data.mongodb.core.index.MongoPersistentEntityIndexCreator.createIndex(MongoPersistentEntityIndexCreator.java:142) [spring-data-mongodb-1.8.4.RELEASE.jar:na] 

Answer 1

これは私が思ったほど簡単ではありませんが、いくつかの余分なクラスで行うことができます。

最初にインデックスを作成するクラスをオーバーライドし、インデックスを作成するメソッドを上書きし、一致する例外をトラップしてログに記録する必要があります。

残念ながらパッケージ保護されているため、拡張するクラスと同じパッケージにクラスを作成する必要があります。

package org.springframework.data.mongodb.core.index; 

import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 
import org.springframework.data.mongodb.MongoDbFactory; 
import org.springframework.data.mongodb.core.mapping.MongoMappingContext; 

public class ExceptionIgnoringIndexCreator extends MongoPersistentEntityIndexCreator { 

    //assuming SLF4J as your logger otherwise, put your logger here 
    private static final Logger LOG = LoggerFactory.getLogger(ExceptionIgnoringIndexCreator.class); 

    public ExceptionIgnoringIndexCreator(MongoMappingContext mappingContext, MongoDbFactory mongoDbFactory) { 
     super(mappingContext, mongoDbFactory); 
    } 

    @Override 
    void createIndex(MongoPersistentEntityIndexResolver.IndexDefinitionHolder indexDefinition) { 
     try { 
      super.createIndex(indexDefinition); 
     } catch (final RuntimeException exp) { 
      final RuntimeException trans = translate(exp); 
      if (trans != null) { 
       throw trans; 
      } else { 
       LOG.warn("Exception while creating index", exp); 
      } 
     } 
    } 

    protected RuntimeException translate(final RuntimeException exp) { 
     if (exp == null || exp.getMessage().contains("Cannot create index")) { 
      return null; 
     } 
     return exp; 
    } 
} 

インデックスの作成はApplicationEventPublisherInterfaceを使用してMongoMappingContextによって公開イベントによってトリガされます。 インタフェースの2つのメソッドがその呼び出しを委譲するデリゲートとして、別のApplicationEventPublisherを遅延して設定できるクラスが必要です。

public class DelegatingPublisher implements ApplicationEventPublisher { 

     private ApplicationEventPublisher delegate; 

     @Override 
     public void publishEvent(ApplicationEvent event) { 
      delegate.publishEvent(event); 
     } 

     @Override 
     public void publishEvent(Object event) { 
      delegate.publishEvent(event); 
     } 

     public void setDelegate(ApplicationEventPublisher delegate) { 
      this.delegate = delegate; 
     } 

} 

通常はAbstractMongoConfigを拡張し、「モンゴ（）」メソッドをオーバーライドするクラスを使用して春のデータにMongoDBを設定します。

インデックスを初期化するメッセージを発行するコンポーネントは、 "mongoMappingContext（）"から返されたコンポーネントです。そのメソッドをオーバーライドし、デフォルトのMongoMappingContextを拡張してイベントパブリッシャを設定し、新しい代議者パブリッシャー

@Configuration 
@EnableMongoRepositories("com.my.company") 
public class MyMongoConfig extends AbstractMongoConfiguration { 
... 
    @Override 
    @Bean 
    public MongoMappingContext mongoMappingContext() throws ClassNotFoundException { 
     final DelegatingPublisher dep = new DelegatingPublisher(); 
     final MongoMappingContext mappingContext = new MongoMappingContext() { 
      @Override 
      public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) { 
       super.setApplicationEventPublisher(dep); 
      } 
     }; 
     mappingContext.setInitialEntitySet(getInitialEntitySet()); 
     mappingContext.setSimpleTypeHolder(customConversions().getSimpleTypeHolder()); 
     mappingContext.setFieldNamingStrategy(fieldNamingStrategy()); 

     try { 
      final MongoPersistentEntityIndexCreator indexCreator = new ExceptionIgnoringIndexCreator(mappingContext, mongoDbFactory()); 
      dep.setDelegate(new MongoMappingEventPublisher(indexCreator)); 
      return mappingContext; 
     } catch (Exception exp) { 
      throw new RuntimeException(exp); 
     } 
    } 
... 
} 

あなたはXMLベースの構成を使用する場合は、1つの以上のクラスと指定された設定が必要になります

public class EventDelegatingMongoMappingContext extends MongoMappingContext { 

    private ApplicationEventPublisher publisher; 

    public EventDelegatingMongoMappingContext(ApplicationEventPublisher publisher) { 
     this.publisher = publisher;  
    } 

    @Override 
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) { 
     super.setApplicationEventPublisher(publisher); 
    } 
} 

<mongo:db-factory id="mongoDbFactory" 
        host="localhost" 
        port="27017" 
        dbname="database" 
        username="mycompany" 
        password="secret"/> 

<bean id="delegatingPublisher" class="com.my.company.DelegatingPublisher"> 
    <property name="delegate" ref="mappingEventPublisher" /> 
</bean> 

<!-- Must be named 'mongoMappingContext' to be recognized up --> 
<bean id="mongoMappingContext" class="com.my.company.EventDelegatingMongoMappingContext"> 
    <constructor-arg> 
     <bean ref="delegatingPublisher" /> 
    </constructor-arg> 
</bean> 

<bean id="mongoIndexCreator" class="org.springframework.data.mongodb.core.index.ExceptionIgnoringIndexCreator"> 
    <constructor-arg> 
     <bean ref="mongoMappingContext"/> 
    </constructor-arg> 
    <constructor-arg> 
     <bean ref="mongoDbFactory"/> 
    </constructor-arg> 
</bean> 

<bean id="mappingEventPublisher" class="org.springframework.data.mongodb.core.index.MongoMappingEventPublisher"> 
    <constructor-arg> 
     <bean ref="mongoIndexCreator"/> 
    </constructor-arg> 
</bean>