Scala环境下Apache Ignite分布式缓存SQL查询异常求助

嘿，我之前踩过一模一样的坑！你put/get都正常，说明缓存本身的分布式部署和数据读写是没问题的，SQL查不到数据大概率是实体类的SQL注解配置不对或者缓存没开启SQL支持，咱们一步步排查：

1. 先检查实体类的SQL注解 #

Ignite要识别字段用于SQL查询，必须给需要参与查询的字段加上@QuerySqlField注解——不管是Key类还是Value类里的字段，只要你要在SQL里用到，就得标。比如你的实体类应该这么写：

import org.apache.ignite.cache.query.annotations.QuerySqlField

// 自定义Key类，要查询deviceId的话必须加注解
case class TelemetryKey(@QuerySqlField val deviceId: String)

// Value类里要查询的字段也得加注解
case class TelemetryValue(
  @QuerySqlField val timestamp: Long,
  @QuerySqlField val sensorValue: Double
)

如果Key类里的字段你不需要在SQL里过滤，那至少要保证Value类的字段都标对，不然SQL根本找不到这些字段。

2. 缓存配置必须开启SQL支持 #

光加注解还不够，你得在CacheConfiguration里明确告诉Ignite要启用SQL，并且指定要索引的键值类型。修改你的setupTelemetryCache方法：

import org.apache.ignite.configuration.CacheConfiguration
import java.util.Collections

def setupTelemetryCache(): CacheConfiguration[TelemetryKey, TelemetryValue] = {
  val dataRegionName = "persistent-region"
  val cacheName = "telemetry-cache"

  val cacheCfg = new CacheConfiguration[TelemetryKey, TelemetryValue](cacheName)
  cacheCfg.setDataRegionName(dataRegionName)

  // 关键：启用SQL，指定键值类型，Ignite会自动生成SQL查询所需的元数据
  cacheCfg.setIndexedTypes(classOf[TelemetryKey], classOf[TelemetryValue])

  // 如果需要自定义索引（比如给timestamp加索引提升查询速度），可以手动配置QueryEntity
  // val queryEntity = new QueryEntity(classOf[TelemetryKey], classOf[TelemetryValue])
  // queryEntity.setIndexes(Collections.singleton(new QueryIndex("timestamp")))
  // cacheCfg.setQueryEntities(Collections.singleton(queryEntity))

  cacheCfg
}

这里的setIndexedTypes是核心——它会让Ignite自动扫描实体类的@QuerySqlField注解，生成对应的SQL表结构和元数据。如果没加这行，就算你实体类加了注解，Ignite也不会把这些字段暴露给SQL。

3. 检查SQL查询语句的正确性 #

别小看这个，很多时候是语句写错了：

• 表名默认就是你的缓存名（也就是telemetry-cache），必须用双引号括起来，因为名字里有横杠，比如：SELECT * FROM "telemetry-cache" WHERE deviceId = ?
• 字段名要和@QuerySqlField标注的字段名完全一致（Ignite默认大小写不敏感，但最好严格匹配）
• 如果是用SqlQuery，第二个参数是查询语句，第一个参数要传Value类的Class（或者Key类，看你查的是什么）

比如正确的查询代码应该是：

val sql = "SELECT * FROM \"telemetry-cache\" WHERE deviceId = ?"
val query = new SqlQuery[TelemetryKey, TelemetryValue](classOf[TelemetryValue], sql)
query.setArgs("device001") // 替换成你的测试Key值

val cursor = cache.query(query)
val results = cursor.getAll()
println(s"查询到${results.size}条数据")

4. 额外排查点 #

如果上面几步都做了还是查不到，试试这两个方向：

• 检查所有Ignite节点是不是都加载了TelemetryKey和TelemetryValue类——分布式环境下，元数据必须在所有节点一致，不然会导致SQL解析异常
• 开启Ignite的DEBUG日志，看SQL执行过程的日志，有没有报错或者元数据加载失败的信息

内容的提问来源于stack exchange，提问作者Alessandro D'Armiento