从Java获取Cassandra聚合行数据遇sum函数报错，求解决方案

我来帮你搞定这个Cassandra聚合的问题～首先咱们拆解下你遇到的情况：你有一张包含item、price、quantity的表，想查询price > 10的所有quantity总和，但用sum()函数时触发了InvalidQueryException: Unknown function 'sum'，接下来咱们一步步解决：

一、先理清报错原因 #

这个错误大概率是下面两个原因之一：

1. Cassandra版本过低：Cassandra从2.2版本开始才正式支持SUM()、COUNT()这类内置聚合函数，如果你的版本低于2.2，肯定会报这个错。
2. 查询写法或表结构问题：即使版本达标，如果price不是分区键/聚类列且没有创建索引，或者CQL语句写法有误，也会触发异常。

二、分步解决办法 #

1. 确认Cassandra版本

先在CQL Shell里执行SELECT release_version FROM system.local;，如果版本低于2.2，建议升级到3.x或4.x的稳定版本（现在大部分生产环境都用这个版本区间）。

2. 调整表结构（如果需要）

假设你的表创建语句是这样的：

CREATE TABLE your_table_name (
    item text PRIMARY KEY,
    price int,
    quantity int
);

这里item是唯一的分区键，直接用WHERE price > 10会触发全表扫描，不仅效率极低，还可能导致聚合查询异常。所以需要给price列创建索引：

CREATE INDEX idx_your_table_price ON your_table_name(price);

3. 正确的聚合查询语句

现在可以使用SUM()函数编写查询了，正确的CQL语句应该是：

SELECT SUM(quantity) AS total_quantity FROM your_table_name WHERE price > 10;

这条语句会直接返回所有符合条件的quantity的总和（也就是你要的900），不需要自己在Java里手动累加。

4. Java代码执行查询示例

用Datastax Java Driver执行这个查询的代码参考：

// 假设你已经初始化了Cluster和Session
try (Session session = cluster.connect("your_keyspace_name")) {
    String aggregateQuery = "SELECT SUM(quantity) AS total FROM your_table_name WHERE price > 10";
    ResultSet resultSet = session.execute(aggregateQuery);
    Row row = resultSet.one();
    
    if (row != null) {
        // sum返回的是bigint类型，用getLong接收
        long totalQuantity = row.getLong("total");
        System.out.println("聚合后的总数量：" + totalQuantity); // 输出900
    } else {
        System.out.println("没有符合条件的数据");
    }
}

三、额外性能提醒 #

Cassandra本身是为高写入、分布式查询设计的，大范围的聚合查询（比如全表扫描聚合）性能并不理想。如果你的数据量很大，建议提前做预聚合：比如按照price的范围（比如0-10、11-20等）作为分区键，提前把每个区间的quantity总和计算好存储，这样查询时直接取预聚合的值即可，性能会提升很多。

内容的提问来源于stack exchange，提问作者Soumyajit Chatterjee