Apache Ignite中复杂对象序列化与SQL查询的实现

2025-06-11 02:21:07作者：彭桢灵Jeremy

引言

在使用Apache Ignite进行分布式数据存储时，开发者经常会遇到需要存储复杂对象结构的需求。本文将深入探讨如何正确实现复杂对象的序列化，特别是当这些对象需要同时支持键值API和SQL查询时的注意事项。

IBinarizable接口的基本用法

Apache Ignite提供了IBinarizable接口来实现自定义二进制序列化。基本实现方式如下：

public class Employee : IBinarizable
{
    public int Id { get; set; }
    public string Name { get; set; }
    public Address Address { get; set; }
    
    public void WriteBinary(IBinaryWriter writer)
    {
        writer.WriteInt("id", Id);
        writer.WriteString("name", Name);
        writer.WriteObject("address", Address);
    }
    
    public void ReadBinary(IBinaryReader reader)
    {
        Id = reader.ReadInt("id");
        Name = reader.ReadString("name");
        Address = reader.ReadObject<Address>("address");
    }
}

嵌套对象的序列化问题

当处理嵌套对象时，如Employee中包含Address对象，常见的错误是使用GetRawWriter()：

// 错误实现 - 不支持SQL查询
public class Address : IBinarizable
{
    public string City { get; set; }
    
    public void WriteBinary(IBinaryWriter writer)
    {
        var rawWriter = writer.GetRawWriter();
        rawWriter.WriteString(City);
    }
}

这种实现虽然能工作于键值API，但会导致SQL查询无法识别嵌套对象的字段。

正确的嵌套对象序列化

要使嵌套对象支持SQL查询，必须使用带字段名的写入方式：

public class Address : IBinarizable
{
    public string City { get; set; }
    public string Street { get; set; }
    public int StreetNumber { get; set; }
    public int FlatNumber { get; set; }
    
    public void WriteBinary(IBinaryWriter writer)
    {
        writer.WriteString("city", City);
        writer.WriteString("street", Street);
        writer.WriteInt("streetnumber", StreetNumber);
        writer.WriteInt("flatnumber", FlatNumber);
    }
    
    public void ReadBinary(IBinaryReader reader)
    {
        City = reader.ReadString("city");
        Street = reader.ReadString("street");
        StreetNumber = reader.ReadInt("streetnumber");
        FlatNumber = reader.ReadInt("flatnumber");
    }
}

SQL表定义的关键点

在创建SQL表时，必须确保表结构与对象结构匹配。对于嵌套对象，有两种处理方式：

扁平化方式 - 将嵌套对象属性展开为顶级列：

CREATE TABLE employee (
  id INT,
  name VARCHAR,
  city VARCHAR,
  street VARCHAR,
  streetnumber INT,
  flatnumber INT,
  PRIMARY KEY (id)
)

对象列方式 - 保留对象结构，使用OBJECT类型：

CREATE TABLE employee (
  id INT,
  name VARCHAR,
  address OBJECT,
  city VARCHAR,
  street VARCHAR,
  streetnumber INT,
  flatnumber INT,
  PRIMARY KEY (id)
)

第一种方式更适合SQL查询，第二种方式则保留了对象结构但查询灵活性较低。