SpringBoot 集成 cassandra 处理InvalidQueryException: unconfigured table，

SpringBoot 集成 cassandra 处理InvalidQueryException: unconfigured table，

在springboot中集成使用cassandra配置如下

 cassandra 主要依赖

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-data-cassandra</artifactId>
	<version>2.0.5.RELEASE</version>
</dependency>

配置方式

@Configuration
public class CassandraConfig extends AbstractCassandraConfiguration {

    @Value("${spring.data.cassandra.keyspace-name}")
    private String keyspaceName;

    @Value("${spring.data.cassandra.entity-base-packages}")
    private String entityBasePackages;

    @Value("${spring.data.cassandra.contact-points}")
    private String contactPoints;

    @Value("${spring.data.cassandra.port}")
    private int port;

    @Value("${spring.data.cassandra.cluster-name}")
    private String clusterName;

    /**
     * Return the name of the keyspace to connect to.
     *
     * @return must not be {@literal null}.
     */
    @Override
    protected String getKeyspaceName() {
        return keyspaceName;
    }

    @Override
    public String getContactPoints() {
        return contactPoints;
    }

    @Override
    public int getPort() {
        return this.port;
    }

    @Override
    public String getClusterName() {
        return clusterName;
    }

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

需要注意的地方：在使用显示Config配置之前使用了springboot中.yml的方式配置，在使用时抛出错误

unconfigured table t_device_message; nested exception is com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table t_device_message

搜索一番后发现是因为没有指定EntityBasePackages，而这个版本中的这个参数在yml配置无效，所以使用这种方式设置后可以正常调用。

操作的实体类

@Data
@Table("t_device_message")
public class DeviceMessageInfo implements Serializable {

    private static final long serialVersionUID = 3531754743416202852L;

    /**
     * 存储主键
     */
    @PrimaryKey
    private String id;

    /**
     * 接收到的报文
     */
    @Column(value = "message")
    private String message;
    /**
     * 接收时间
     */
    @Column(value = "message_time")
    private Date messageTime;
}

表结构

CREATE TABLE t_device_message (
    id text,
    message text,
    message_time timestamp,
    PRIMARY KEY (id)
) WITH
  comment=''
  AND read_repair_chance=0
  AND dclocal_read_repair_chance=0.1
  AND gc_grace_seconds=864000
  AND bloom_filter_fp_chance=0.01;

调用

@Service
public class Test{

    @Autowired
    private CassandraTemplate cassandraTemplate;

    public void test(){
        DeviceMessageInfo messageInfo = new DeviceMessageInfo();
        messageInfo.setId(UUID.randomUUID().toString());
        messageInfo.setMessage("message");
        messageInfo.setMessageTime(new Date());
        cassandraTemplate.insert(messageInfo);        
    }
}