春季启动应用程序中的复合Cassandra键

Question

我有一个使用以下内容创建的cassandra群集：

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.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;
    }
}

由于表使用了复合主键，因此我必须使用以下以下结构，如下所述：http：//docs.spring.io/spring-data/cassandra/cassandra/docs/1.2.2.2.release/reeperion/referene/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);
}

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

错误创建用名称为" engringController"的BEAN：自动依赖性注入失败；嵌套的异常是org.springframework.beans.factory.factory.beancreationexception：无法自动化场：private com.rg.cassandraspring.repository.repository.activity.activityrepositoryposority com.rg.cassandrassandrassandraspring.controller.greetertingcontrollerer.controllerer.activitivitivitivitivitivitivitivitivitivitivitiveReposoritory;嵌套异常是org.springframework.beans.factory.beancreationexception：错误创建使用名称'activityRopository'的bean：Init方法的调用失败；嵌套的异常是org.springframework.data.cassandra.mapping.verifiermpappingexceptions：java.security.cert.cert.cert.cert.certpath：Cassandra实体必须具有@Table， @persistent或@primarykeyklass注释

最后，这是我的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

与您的问题没有完全相关，Spring Docs说，当您想将时间对象存储在实体中时，应使用：

• Joda Time：DateTime
• 传统Java日期和日历
• JDK8日期和时间类型
• 长或长

更多信息在这里：https：//docs.spring.io/spring-data/cassandra/docs/current/referent/referent/html/#auditing.annotations

Answer 2

该问题似乎是'时间戳'类型，以表示表'活动的'ts'列。我从java.util将其更改为"日期"，一切似乎都很好。

我还没有时间研究原因。