轴突集合识别器型转换器

Question

问题：在聚合状态下，Axon SpringBoot应用程序@AggregateIdentifier类型为UUID，而PostgreSQL数据库列类型为UUID。在持久化时，成功地存储了create-commands-identifier。当发送update-command时，警告将上升，并且命令不会传递给聚合处理程序，因为@targetAggregateIdentifier需要字符串类型，如下Axon所述：

IllegalArgumentException：为类....MyAggregate提供了错误类型的id。需要：类java.util.uuid，得到类java.lang.String

研究：

@Converter
public class UuidJpaConverter implements AttributeConverter<String, UUID> {

  @Override
  public UUID convertToDatabaseColumn(String uuid) {
    return fromString(uuid);
  }

  @Override
  public String convertToEntityAttribute(UUID uuid) {
    return uuid.toString();
  }
}

...

@Aggregate
@Entity
@IdClass(UuidKey.class)
public class MyAggregate implements Serializable {

  @AggregateIdentifier
  @Id
  private String uuid;
  ...
}

public class UuidKey implements Serializable {

  @Column(name = "uuid", nullable = false, updatable = false)
  @Convert(converter = UuidJpaConverter.class)
  private String uuid;
}

o.h.engine.jdbc.spi.sqlExceptionHelper：错误：列“uuid”类型为uuid，但表达式类型为bytea

使用Axon标识符转换器，但它需要为每个聚合定制GenericJpaRepository，并且实际上从不在断点上调用identifierConverter处理程序：

 @Configuration
 public class IdentifierConverter {

   @Bean
   public GenericJpaRepository<MyAggregate> aggregateJpaRepository(
       EntityManagerProvider provider,
       @Qualifier("eventBus") EventBus simpleEventBus) {

     GenericJpaRepository<MyAggregate> repository = GenericJpaRepository
         .builder(MyAggregate.class)
  ->       .identifierConverter(name -> UUID.fromString(name))
         .entityManagerProvider(provider)
         .eventBus(simpleEventBus)
         .build();

     return repository;
   }
 }

并导致：

 final Class<?> aggregateIdentifierType = Stream.of( aggregateType.getDeclaredFields( ) )
 .filter( field -> field.isAnnotationPresent( AggregateIdentifier.class ) )
 .map( field -> field.getType( ) )
 .findFirst( )
 .orElseThrow( ( ) -> new IllegalStateException( "The aggregate '" + aggregate + "' does not have an identifier." ) );

 aggregateConf.configureRepository(
 c -> GenericJpaRepository.builder( aggregateType )
         .identifierConverter( string -> {
             if ( aggregateType == String.class ) {
                 return string;
             } else {
                 try {
                     final ConversionService conversionService = beanFactory.getBean( ConversionService.class );
                     return conversionService.convert( string, aggregateIdentifierType );
                 } catch ( final NoSuchBeanDefinitionException ex ) {
                     throw new IllegalStateException( "Unable to convert String to aggregate identifier of type '" + aggregateIdentifierType.getName( ) + "'. A conversion service is missing." );
                 }
             }
         } )

 ...

 @Named
 final class MyIdConverter implements Converter<String, MyId> {

     ...

     @Override
     public MyId convert( final String source ) {
         return MyId.fromString( source );
     }

 }

Answer 1

老实说，你在这件事上已经说得很深了@Zon。我不确定我是否能给你足够的帮助，但无论如何我都会试一试。

研究要点1显然是目前让事情运转起来的最务实的解决方案。如果您要注意到String与UUID相比的“无效性”，那么我就很难理解了。因此，如果这是一个绝对的不不，调查应该继续进行。否则，它当然可以完成工作。

当谈到研究点2和3时，我相信您在PostgreSQL所使用的方言方面遇到了一个问题，尽管我不是100%确定。特别是PostgreSQL展示了几个“很棒”的类型，但这些类型并不总是在所有场景中自动工作。我在这里的“猜测”是基于强制PostgreSQL使用bytea而不是oid，以防您希望降低Postgres的TOAST功能。如果您选择将Postgres用于事件存储并希望能够实际查看事件的内容，那么这将变得特别方便。例如，这篇博客文章指定了如何处理这个问题。更重要的是，这篇博客文章展示了如何调整所使用的方言。也许这可以在解决方案2和3中为您服务？