UserDefinedType не найден Spring-data-cassandra

на основе учебника spring-data-cassandra-tutorial Я экспериментирую с аннотацией UserDefinedType.UserDefinedType не найден Spring-data-cassandra

Я модернизировал проект, чтобы использовать spring-data-cassandra: 1.5.0.BUILD-SNAPSHOT, добавили цену атрибута в книгу, внедрили соответствующий UserDefinedType и добавили setInitialEntitySet и setUserTypeResolver в конфигурацию.

Когда я затем выполнить BookRepositoryIntegrationTest против Cassandra 3.9, я получаю следующее сообщение об ошибке:

org.springframework.data.mapping.model.MappingException: Тип пользователя [цена] не найден

Любая идея, что мне не хватает?

Вот мои изменения ...

Book.java:

package org.baeldung.spring.data.cassandra.model; 

import java.util.HashSet; 
import java.util.Set; 
import java.util.UUID; 

import org.springframework.cassandra.core.Ordering; 
import org.springframework.cassandra.core.PrimaryKeyType; 
import org.springframework.data.cassandra.mapping.Column; 
import org.springframework.data.cassandra.mapping.PrimaryKeyColumn; 
import org.springframework.data.cassandra.mapping.Table; 

@Table 
public class Book { 

    @PrimaryKeyColumn(name = "id", ordinal = 0, type = PrimaryKeyType.CLUSTERED, ordering = Ordering.DESCENDING) 
    private UUID id; 

    @PrimaryKeyColumn(name = "title", ordinal = 1, type = PrimaryKeyType.PARTITIONED) 
    private String title; 

    @PrimaryKeyColumn(name = "publisher", ordinal = 2, type = PrimaryKeyType.PARTITIONED) 
    private String publisher; 

    @Column 
    private Set<String> tags = new HashSet<>(); 

    private Price price; 

    public Book(final UUID id, final String title, final String publisher, final Set<String> tags) { 
     this.id = id; 
     this.title = title; 
     this.publisher = publisher; 
     this.tags.addAll(tags); 
    } 
}

pom.xml:

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 
    <modelVersion>4.0.0</modelVersion> 

    <groupId>com.baeldung</groupId> 
    <artifactId>spring-data-cassandra</artifactId> 
    <version>0.0.1-SNAPSHOT</version> 
    <packaging>jar</packaging> 

    <name>spring-data-cassandra</name> 

    <properties> 
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> 

     <org.springframework.version>4.3.4.RELEASE</org.springframework.version> 

     <org.springframework.data.version>1.5.0.BUILD-SNAPSHOT</org.springframework.data.version> 

     <junit.version>4.12</junit.version> 
     <org.slf4j.version>1.7.12</org.slf4j.version> 
     <logback.version>1.1.3</logback.version> 
     <cassandra-driver-core.version>3.1.2</cassandra-driver-core.version> 
     <cassandra-unit.version>3.0.0.1</cassandra-unit.version> 
     <maven-surefire-plugin.version>2.19.1</maven-surefire-plugin.version>   
    </properties> 

    <dependencies> 
     <dependency> 
      <groupId>org.springframework.data</groupId> 
      <artifactId>spring-data-cassandra</artifactId> 
      <version>${org.springframework.data.version}</version> 
     </dependency> 
     <dependency> 
      <groupId>org.springframework</groupId> 
      <artifactId>spring-core</artifactId> 
      <version>${org.springframework.version}</version> 
     </dependency> 
     <dependency> 
      <groupId>org.springframework</groupId> 
      <artifactId>spring-test</artifactId> 
      <version>${org.springframework.version}</version> 
      <scope>test</scope> 
     </dependency> 
     <dependency> 
      <groupId>org.cassandraunit</groupId> 
      <artifactId>cassandra-unit-spring</artifactId> 
      <version>${cassandra-unit.version}</version> 
      <scope>test</scope> 
      <exclusions> 
       <exclusion> 
        <groupId>org.cassandraunit</groupId> 
        <artifactId>cassandra-unit</artifactId> 
       </exclusion> 
      </exclusions> 
     </dependency> 
     <dependency> 
      <groupId>org.cassandraunit</groupId> 
      <artifactId>cassandra-unit</artifactId> 
      <version>${cassandra-unit.version}</version> 
      <scope>test</scope> 
     </dependency> 
     <dependency> 
      <groupId>com.datastax.cassandra</groupId> 
      <artifactId>cassandra-driver-core</artifactId> 
      <version>${cassandra-driver-core.version}</version> 
      <optional>true</optional> 
     </dependency> 
     <dependency> 
      <groupId>org.slf4j</groupId> 
      <artifactId>slf4j-api</artifactId> 
      <version>${org.slf4j.version}</version> 
     </dependency> 
     <dependency> 
      <groupId>ch.qos.logback</groupId> 
      <artifactId>logback-classic</artifactId> 
      <version>${logback.version}</version> 
     </dependency> 
     <dependency> 
      <groupId>org.slf4j</groupId> 
      <artifactId>jcl-over-slf4j</artifactId> 
      <version>${org.slf4j.version}</version> 
     </dependency> 
     <dependency> 
      <groupId>org.slf4j</groupId> 
      <artifactId>log4j-over-slf4j</artifactId> 
      <version>${org.slf4j.version}</version> 
     </dependency> 
    </dependencies> 
    <build> 
     <plugins> 
      <plugin> 
       <artifactId>maven-compiler-plugin</artifactId> 
       <version>2.3.2</version> 
       <configuration> 
        <source>1.8</source> 
        <target>1.8</target> 
       </configuration> 
      </plugin> 
        <plugin> 
         <groupId>org.apache.maven.plugins</groupId> 
         <artifactId>maven-surefire-plugin</artifactId> 
         <version>${maven-surefire-plugin.version}</version> 
         <configuration> 
          <excludes> 
           <exclude>**/*IntegrationTest.java</exclude> 
           <exclude>**/*LiveTest.java</exclude> 
          </excludes> 
         </configuration> 
        </plugin> 
       </plugins> 
      </build> 

    <profiles> 
     <profile> 
      <id>integration</id> 
      <build> 
       <plugins> 
        <plugin> 
         <groupId>org.apache.maven.plugins</groupId> 
         <artifactId>maven-surefire-plugin</artifactId> 
         <executions> 
          <execution> 
           <phase>integration-test</phase> 
           <goals> 
            <goal>test</goal> 
           </goals> 
           <configuration> 
            <excludes> 
             <exclude>**/*LiveTest.java</exclude> 
            </excludes> 
            <includes> 
             <include>**/*IntegrationTest.java</include> 
            </includes> 
           </configuration> 
          </execution> 
         </executions> 
         <configuration> 
          <systemPropertyVariables> 
           <test.mime>json</test.mime> 
          </systemPropertyVariables> 
         </configuration> 
        </plugin> 
       </plugins> 
      </build> 
     </profile> 
    </profiles> 
</project>

CassandraConfig.java

package org.baeldung.spring.data.cassandra.config; 

import org.apache.commons.logging.Log; 
import org.apache.commons.logging.LogFactory; 
import org.baeldung.spring.data.cassandra.model.Book; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.context.annotation.Bean; 
import org.springframework.context.annotation.Configuration; 
import org.springframework.context.annotation.PropertySource; 
import org.springframework.core.env.Environment; 
import org.springframework.data.cassandra.config.CassandraClusterFactoryBean; 
import org.springframework.data.cassandra.config.CassandraEntityClassScanner; 
import org.springframework.data.cassandra.config.java.AbstractCassandraConfiguration; 
import org.springframework.data.cassandra.mapping.BasicCassandraMappingContext; 
import org.springframework.data.cassandra.mapping.CassandraMappingContext; 
import org.springframework.data.cassandra.mapping.SimpleUserTypeResolver; 
import org.springframework.data.cassandra.repository.config.EnableCassandraRepositories; 

@Configuration 
@PropertySource(value = { "classpath:cassandra.properties" }) 
@EnableCassandraRepositories(basePackages = "org.baeldung.spring.data.cassandra.repository") 
public class CassandraConfig extends AbstractCassandraConfiguration { 
    private static final Log LOGGER = LogFactory.getLog(CassandraConfig.class); 

    @Autowired 
    private Environment environment; 

    @Override 
    protected String getKeyspaceName() { 
     return environment.getProperty("cassandra.keyspace"); 
    } 

    @Override 
    @Bean 
    public CassandraClusterFactoryBean cluster() { 
     final CassandraClusterFactoryBean cluster = new CassandraClusterFactoryBean(); 
     cluster.setContactPoints(environment.getProperty("cassandra.contactpoints")); 
     cluster.setPort(Integer.parseInt(environment.getProperty("cassandra.port"))); 
     LOGGER.info("Cluster created with contact points [" + environment.getProperty("cassandra.contactpoints") + "] " + "& port [" + Integer.parseInt(environment.getProperty("cassandra.port")) + "]."); 
     return cluster; 
    } 

    @Override 
    @Bean 
    public CassandraMappingContext cassandraMapping() throws ClassNotFoundException { 
     BasicCassandraMappingContext ctx = new BasicCassandraMappingContext(); 
     ctx.setInitialEntitySet(CassandraEntityClassScanner.scan(Book.class)); 
     ctx.setUserTypeResolver(new SimpleUserTypeResolver(cluster().getObject(), getKeyspaceName())); 
     return ctx; 
    } 
}

Price.java:

package org.baeldung.spring.data.cassandra.model; 

import org.springframework.data.cassandra.mapping.Column; 
import org.springframework.data.cassandra.mapping.UserDefinedType; 

@UserDefinedType 
public class Price { 

    @Column 
    private Double amount; 

    @Column 
    private String currency; 

    public Price(Double amount, String currency) { 
     this.amount = amount; 
     this.currency = currency; 
    } 

    public Double getAmount() { 
     return amount; 
    } 

    public String getCurrency() { 
     return currency; 
    } 
}

источник

2016-11-29 user1388903

Попробуйте использовать ниже класс CassandraConfig.

@Configuration 
@PropertySource(value = { "classpath:cassandra.properties" }) 
@EnableCassandraRepositories(basePackages = "org.baeldung.spring.data.cassandra.repository") 
public class CassandraConfig extends AbstractCassandraConfiguration { 
private static final Log LOGGER = LogFactory.getLog(CassandraConfig.class); 

@Autowired 
private Environment environment; 

@Override 
protected String getKeyspaceName() { 
    return environment.getProperty("cassandra.keyspace"); 
} 

@Override 
@Bean 
public CassandraClusterFactoryBean cluster() { 
    final CassandraClusterFactoryBean cluster = new CassandraClusterFactoryBean(); 
    cluster.setContactPoints(environment.getProperty("cassandra.contactpoints")); 
    cluster.setPort(Integer.parseInt(environment.getProperty("cassandra.port"))); 
    LOGGER.info("Cluster created with contact points [" + environment.getProperty("cassandra.contactpoints") + "] " + "& port [" + Integer.parseInt(environment.getProperty("cassandra.port")) + "]."); 
    return cluster; 
} 


@Bean 
public CassandraMappingContext mappingContext() throws ClassNotFoundException { 
    BasicCassandraMappingContext mappingContext = new BasicCassandraMappingContext(); 
    mappingContext.setInitialEntitySet(CassandraEntityClassScanner.scan("org.baeldung.spring.data.cassandra.model")); 
    mappingContext.setUserTypeResolver(new SimpleUserTypeResolver(cluster().getObject(),getKeyspaceName())); 
    return mappingContext; 
} 

@Bean 
public CassandraConverter converter() throws ClassNotFoundException { 
    return new MappingCassandraConverter(mappingContext()); 
} 

@Bean 
public CassandraSessionFactoryBean session() throws ClassNotFoundException { 
    CassandraSessionFactoryBean session = new CassandraSessionFactoryBean(); 
    session.setCluster(cluster().getObject()); 
    session.setKeyspaceName(getKeyspaceName()); 
    session.setConverter(converter()); 
    session.setSchemaAction(SchemaAction.RECREATE); 
    return session; 
    } 
}

источник

2016-11-30 07:08:34 abaghel

Эй, работает как очарование! Правильно ли я говорю, что MappingCassandraConverter - это трюк? Кроме того, я должен был добавить конструкторы по умолчанию для своих компонентов, чтобы их можно было загрузить. Спасибо большое :) – user1388903

Рад это услышать. Примите ответ, чтобы он был полезен другим. – abaghel

Аналогичный вопрос здесь (http://stackoverflow.com/questions/38862460/user-defined-type-with-spring-data-cassandra/42036202#42036202). шаги для работы UDT с данными Spring Cassandra – denzal

Ваш код выглядит хорошо, но пропустил создание типа пользователя. Вы также настроили SimpleUserTypeResolver, который необходим для поиска типов пользователей.

Тип пользователя [цена] не найден означает, что тип пользователя не был найден в Cassandra.

У вас есть два варианта, как исправить это:

Вы создать тип, определяемый пользователем самостоятельно.
Использовать SchemaAction.RECREATE при загрузке приложения.

Baeldung's tutorial использует создание таблиц в рамках теста, поэтому создание пользовательского типа вручную до создания таблицы может быть лучшим вариантом.

CreateUserTypeSpecification userTypeSpecification = mappingContext. 
          getCreateUserTypeSpecificationFor(mappingContext.getExistingPersistentEntity(Price.class)) 
          .ifNotExists(ifNotExists); 

cqlTemplate.execute(CreateUserTypeCqlGenerator.toCql(userTypeSpecification));

источник

2016-11-30 10:23:48 mp911de

UserDefinedType не найден Spring-data-cassandra

ответ

Смежные вопросы