复合卡桑德拉主要在春季启动应用

Question

我有一个卡桑德拉集群使用创建以下：

CREATE KEYSPACE IF NOT EXISTS activitylogs WITH replication = {'class': 'SimpleStrategy', 'replication_factor': '1'} AND durable_writes = true; 

CREATE TABLE IF NOT EXISTS activitylogs.activities (
     activity_id timeuuid, 
     actor_id text, 
     app_id text, 
     item_id text, 
     viewer_id text, 
     activity_type int, 
     ts timestamp, 
     PRIMARY KEY (actor_id, activity_id, app_id) 
    ) WITH CLUSTERING ORDER BY (activity_id DESC, app_id ASC); 

INSERT INTO activities (activity_id,actor_id, app_id, item_id, viewer_id, activity_type) VALUES (now(), 'fsdgs346-sdsd5-4242','blossom','ff235-fsd54-fadsfdfs45','hj923hjn-2jnkl23-323yfh',0); 

我使用Eclipse具有以下的build.gradle：

group 'com.abc' 
version '1.0-SNAPSHOT' 

apply plugin: 'java' 
apply plugin: 'eclipse' 
apply plugin: 'idea' 
apply plugin: 'spring-boot' 

buildscript { 
    repositories { 
     mavenCentral() 
    } 
    dependencies { 
     classpath("org.springframework.boot:spring-boot-gradle-plugin:1.2.5.RELEASE") 
    } 
} 

jar { 
    baseName = 'gs-serving-web-content' 
    version = '0.1.0' 
} 

repositories { 
    mavenCentral() 
} 


sourceCompatibility = 1.8 

repositories { 
    mavenCentral() 
} 


dependencies { 
    compile "org.springframework.boot:spring-boot-starter-web" 
    compile "org.springframework.data:spring-data-cassandra:1.4.6.RELEASE" 
    compile 'org.slf4j:slf4j-api:1.6.6' 
    compile 'ch.qos.logback:logback-classic:1.0.13' 
    testCompile "junit:junit" 
} 

task wrapper(type: Wrapper) { 
    gradleVersion = '2.3' 
} 

现在，我写的以下实体：

package com.abc.activitystream.entity; 

import org.springframework.data.cassandra.mapping.Column; 
import org.springframework.data.cassandra.mapping.PrimaryKey; 
import org.springframework.data.cassandra.mapping.Table; 

import java.security.Timestamp; 

@Table(value = "activities") 
public class Activity 
{ 

    /*CREATE TABLE IF NOT EXISTS activitylogs.activities (
    activity_id timeuuid, 
    actor_id text, 
    app_id text,   
    item_id text, 
    viewer_id text, 
    activity_type int, 
    ts timestamp, 
    PRIMARY KEY (actor_id, activity_id, app_id)) WITH CLUSTERING ORDER BY (activity_id DESC);*/ 

    @PrimaryKey 
    private ActivityKey ak; 

    @Column(value = "item_id") 
    private String item_id; 

    @Column(value = "viewer_id") 
    private String viewer_id; 

    @Column(value = "activity_type") 
    private int activity_type; 

    @Column(value = "ts") 
    private Timestamp ts; 

    public String getItem_id() { 
     return item_id; 
    } 

    public void setItem_id(String item_id) { 
     this.item_id = item_id; 
    } 

    public String getViewer_id() { 
     return viewer_id; 
    } 

    public void setViewer_id(String viewer_id) { 
     this.viewer_id = viewer_id; 
    } 

    public int getActivity_type() { 
     return activity_type; 
    } 

    public void setActivity_type(int activity_type) { 
     this.activity_type = activity_type; 
    } 

    public Timestamp getTs() { 
     return ts; 
    } 

    public void setTs(Timestamp ts) { 
     this.ts = ts; 
    } 

    public ActivityKey getAk() { 
     return ak; 
    } 

    public void setAk(ActivityKey ak) { 
     this.ak = ak; 
    } 
} 

由于该表使用复合主键，所以必须使用以下s tructure这里提到：http://docs.spring.io/spring-data/cassandra/docs/1.0.2.RELEASE/reference/html/cassandra.core.html

所以我ActivityKey类是这样的：

@PrimaryKeyClass 
public class ActivityKey implements Serializable { 

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

    @PrimaryKeyColumn(name="activity_id",ordinal = 1,type = PrimaryKeyType.CLUSTERED, ordering = Ordering.DESCENDING) 
    private UUID activity_id = UUIDs.timeBased(); 

    @PrimaryKeyColumn(name="app_id", ordinal = 2, type = PrimaryKeyType.CLUSTERED, ordering = Ordering.ASCENDING) 
    private String app_id; 

    public String getActor_id() { 
     return actor_id; 
    } 

    public void setActor_id(String actor_id) { 
     this.actor_id = actor_id; 
    } 

    public UUID getActivity_id() { 
     return activity_id; 
    } 

    public void setActivity_id(UUID activity_id) { 
     this.activity_id = activity_id; 
    } 

    public String getApp_id() { 
     return app_id; 
    } 

    public void setApp_id(String app_id) { 
     this.app_id = app_id; 
    } 

    @Override 
     public int hashCode() { 
     final int prime = 31; 
     int result = 1; 
     result = prime * result + ((actor_id == null) ? 0 : actor_id.hashCode()); 
     result = prime * result + ((app_id == null) ? 0 : app_id.hashCode()); 
     return result; 
     } 

     @Override 
     public boolean equals(Object obj) { 
     if (this == obj) 
      return true; 
     if (obj == null) 
      return false; 
     if (getClass() != obj.getClass()) 
      return false; 
     ActivityKey other = (ActivityKey) obj; 
     if (actor_id == null) { 
      if (other.actor_id != null) 
      return false; 
     } else if (!actor_id.equals(other.actor_id)) 
      return false; 
     if (app_id == null) { 
      if (other.app_id != null) 
      return false; 
     } else if (!app_id.equals(other.app_id)) 
      return false; 
     return true; 
     } 

} 

我的控制器是这样的：

@RestController 
public class ActivityController { 

    @Autowired 
    private ActivityRepository activityRepository; 

    @RequestMapping(value = "/activity",method = RequestMethod.GET) 
    @ResponseBody 
    public List<Activity> activity() { 
     List<Activity> activities = new ArrayList<>(); 
     activityRepository.findAll().forEach(e->activities.add(e)); 
     return activities; 
    } 

}

最后库是这样的：

public interface ActivityRepository extends CassandraRepository<Activity> { 

    @Query("SELECT*FROM activities WHERE actor_id=?0 LIMIT ?1") 
    Iterable<Activity> findByActor_Id(String actor_id,Integer limit); 

} 

奇怪的是，应用程序不运行并退出时出现以下错误：

创建名为'greetingController'的bean时出错：注入自动装配依赖项失败;嵌套异常是org.springframework.beans.factory.BeanCreationException：无法自动装入字段：private com.rg.cassandraspring.repository.ActivityRepository com.rg.cassandraspring.controller.GreetingController.activityRepository;嵌套异常是org.springframework.beans.factory.BeanCreationException：创建名为'activityRepository'的bean时出错：init方法的调用失败;嵌套的例外是org.springframework.data.cassandra.mapping.VerifierMappingExceptions：java.security.cert.CertPath中： 卡桑德拉实体必须有@Table，@Persistent或@PrimaryKeyClass注释

最后，这是我CassandraConfig：

@Configuration 
//@PropertySource(value = {"classpath:META-INF/cassandra.properties"}) 
@EnableCassandraRepositories(basePackages = {"com.abc"}) 
public class CassandraConfig { 

    @Autowired 
    private Environment environment; 

    private static final Logger LOGGER = LoggerFactory.getLogger(CassandraConfig.class); 

    @Bean 
    public CassandraClusterFactoryBean cluster() { 

     CassandraClusterFactoryBean cluster = new CassandraClusterFactoryBean(); 
     cluster.setContactPoints("localhost"); 
     cluster.setPort(Integer.parseInt("9042")); 
     return cluster; 
    } 

    @Bean 
    public CassandraMappingContext mappingContext() { 
     return new BasicCassandraMappingContext(); 
    } 

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

    @Bean 
    public CassandraSessionFactoryBean session() throws Exception { 

     CassandraSessionFactoryBean session = new CassandraSessionFactoryBean(); 
     session.setCluster(cluster().getObject()); 
     session.setKeyspaceName("activitylogs"); 
     session.setConverter(converter()); 
     session.setSchemaAction(SchemaAction.NONE); 

     return session; 
    } 

    @Bean 
    public CassandraOperations cassandraTemplate() throws Exception { 
     return new CassandraTemplate(session().getObject()); 
    } 

} 

任何人都可以帮助我吗？我似乎无法指出问题所在。

Answer 1

该问题似乎是'Timestamp'类型来表示表'activities'的'ts'列。我将其更改为java.util中的Date，并且一切似乎都运行良好。

我还没有时间查看原因。