Spring数据支持使用java实体创建表

Question

我正在使用 Spring data Cassandra，连接 Cassandra 数据库，配置文件扩展 AbstractCassandraConfiguration 和覆盖功能 -

@Override
public SchemaAction getSchemaAction() {
    return SchemaAction.RECREATE_DROP_UNUSED;
}

@Override
public String[] getEntityBasePackages() {
    return new String[] {"com.example"};
}

我的目标是在 Cassandra 中使用 @Table 注释从 com.example 包中提到的实体自动创建表。 例如 -

package com.example;

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

@Table(value="goal")
public class Goal {

    @PrimaryKey
    private int id;

    private String description;

    public Goal(int id, String description) {
        this.id = id;
        this.description = description;
    }

    public Goal() {

    }

    public int getId() {
        return id;
    }

    public String getDescription() {
        return description;
    }


    public void setId(int id) {
        this.id = id;
    }

    public void setDescription(String description) {
        this.description = description;
    }

    @Override
    public String toString() {
        return "Goals [id=" + id + ", description=" + description + "]";
    }

}

对于这个实体，在给定的配置下，应该在 spring 初始化期间创建一个表，但它没有这样做。 不过也不例外，它只是没有在 Cassandra 中创建任何东西。 任何帮助，将不胜感激。谢谢。

Answer 1

我也面临类似的要求和以下工作：-

@Bean
public CassandraClusterFactoryBean cluster() {

    CassandraClusterFactoryBean cluster = new CassandraClusterFactoryBean();
    cluster.setContactPoints("127.0.0.1");
    cluster.setPort(9042);
    return cluster;
}    
public String[] getEntityBasePackages() {
    return new String[] { "com.user.entity" };
}

protected String getKeyspaceName() {
    return "user_db";
}

public SchemaAction getSchemaAction() {
    return SchemaAction.CREATE_IF_NOT_EXISTS;
}

一旦您的上下文启动，您就可以在 cassandra 中检查该表。 假设您的密钥空间已经在 cassandra 中创建。 如果您还想动态创建键空间，请告知。