Java存储文件数据到Cassandra时创建物化视图遇语法错误求助

这个错误的根源是你对Cassandra物化视图的语法逻辑理解有误，尤其是WHERE子句和主键定义的部分，咱们一步步拆解问题：

错误原因分析 #

• WHERE子句不能嵌套PRIMARY KEY关键字：你在WHERE里写了PRIMARY KEY (sensor_id)，这完全不符合Cassandra的语法规范。物化视图的WHERE子句需要直接列出基表中要作为筛选条件的列（必须包含基表的全部分区键），并搭配IS NOT NULL约束，而不是用PRIMARY KEY来包裹列名。
• 物化视图的主键定义位置错误：你把主键的定义嵌在了WHERE子句内部，正确的做法是在语句末尾单独用PRIMARY KEY子句来指定物化视图自身的主键（这个主键必须包含基表的分区键，也可以根据需求添加额外列）。

解决办法 #

假设你的基表sensortable的分区键是sensor_id，那么正确的物化视图创建语句应该是这样的：

CREATE MATERIALIZED VIEW IF NOT EXISTS sensorkeyspace.texttable 
AS SELECT * FROM sensorkeyspace.sensortable 
WHERE sensor_id IS NOT NULL 
PRIMARY KEY (sensor_id);

额外注意事项 #

1. 如果基表包含聚类键（比如基表主键是(sensor_id, timestamp)），那么物化视图的WHERE子句必须包含所有分区键（这里是sensor_id），可以选择包含部分聚类键，同时物化视图的主键要符合Cassandra的主键规则，示例如下：

CREATE MATERIALIZED VIEW IF NOT EXISTS sensorkeyspace.texttable 
AS SELECT * FROM sensorkeyspace.sensortable 
WHERE sensor_id IS NOT NULL AND timestamp IS NOT NULL 
PRIMARY KEY (sensor_id, timestamp);

2. 物化视图的主键必须包含基表的全部分区键，这是Cassandra的硬性要求，否则无法保证数据的正确同步和查询逻辑。

内容的提问来源于stack exchange，提问作者Real tiger