Apache Ignite使用Protobuf对象时SQL查询无返回结果问题
问题产生原因
- Apache Ignite的SQL层默认依赖反射扫描对象结构、自动生成SQL元数据、做字段映射的逻辑,仅对符合JavaBean规范的普通POJO生效。你使用的
VdtProto.KnowledgeTime是Protobuf编译生成的类,其内部字段存储结构、getter/setter命名规则都不符合标准JavaBean约定,Ignite无法自动扫描解析出对象的字段结构,不会自动注册对应的SQL表元数据,也不会把插入的Protobuf格式数据纳入SQL索引范围,因此查询返回空结果。 - 普通Java POJO测试能正常返回结果,核心原因是POJO的字段、getter方法可以被Ignite默认的反射逻辑正常识别,自动完成SQL元数据注册和字段映射,不需要额外配置。
- GridGain控制中心界面显示当前
KNOWLEDGETIMEschema下没有自动注册出可查询的表结构,也侧面印证了Protobuf类没有被SQL引擎识别:
GridGain控制中心UI界面
修复方案
- 最简便的实现路径:新增对象转换层,缓存写入前将Protobuf对象转换为标注了
@QuerySqlField注解的标准JavaBean值对象,业务需要Protobuf结构时再做反向转换即可,该方案无需额外自定义复杂组件,兼容性最优。 - 若要求直接存储原生Protobuf对象,需在缓存配置中手动定义
QueryEntity,逐一声明每个SQL列的名称、数据类型,配套自定义属性读写转换器,明确Ignite从Protobuf对象读取字段值、回写字段值的逻辑,完成手动元数据注册后SQL查询才可正常生效。 - 配置完成后需在控制中心核对已注册的SQL表全限定名,再编写查询语句,避免Schema、表名不匹配导致的空结果问题;当前执行的查询语句
SELECT * FROM "test-client_null_cacheName10"."KNOWLEDGETIME"对应的表,在元数据未正确注册的状态下本身不存在于SQL引擎中。
内容的提问来源于stack exchange,提问作者amitwdh
相关产品推荐
相关产品推荐

