如何配置Ignite缓存对接PostgreSQL复合主键表实现第三方持久化

1. 校验复合主键类编写规则 #

复合主键类必须满足以下要求，否则Ignite无法正确识别唯一键：

• 实现Serializable接口，满足Ignite集群内序列化传输需求
• 提供无参构造函数，供Ignite反射实例化使用
• 重写equals()和hashCode()方法，严格基于l_orderkey和l_linenumber两个字段计算，确保相同键值的对象判定为同一主键

示例代码参考：

public class LineitemKey implements Serializable {
    private Long l_orderkey;
    private Integer l_linenumber;

    // 必须提供无参构造
    public LineitemKey() {}

    public LineitemKey(Long l_orderkey, Integer l_linenumber) {
        this.l_orderkey = l_orderkey;
        this.l_linenumber = l_linenumber;
    }

    // 此处省略getter、setter方法

    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        LineitemKey that = (LineitemKey) o;
        return Objects.equals(l_orderkey, that.l_orderkey) && Objects.equals(l_linenumber, that.l_linenumber);
    }

    @Override
    public int hashCode() {
        return Objects.hash(l_orderkey, l_linenumber);
    }
}

注意：若仅用单列作为主键，同一个l_orderkey对应多个行时会触发主键冲突，后续加载的行直接覆盖之前的行，就会出现仅加载部分数据的问题。

2. 调整Spring XML缓存配置 #

核心要明确指定复合主键类型、映射两个主键字段到JDBC配置中，示例配置如下：

<!-- lineitem缓存配置 -->
<bean id="lineitemCache" class="org.apache.ignite.configuration.CacheConfiguration">
    <property name="name" value="lineitem"/>
    <!-- 指定复合主键类全限定名 -->
    <property name="keyType" value="com.yourpackage.LineitemKey"/>
    <!-- 指定值类全限定名 -->
    <property name="valueType" value="com.yourpackage.Lineitem"/>
    <property name="cacheStoreFactory">
        <bean class="org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStoreFactory">
            <property name="dataSourceBean" value="postgreDataSource"/>
            <property name="dialect">
                <bean class="org.apache.ignite.cache.store.jdbc.dialect.PostgreSQLDialect"/>
            </property>
            <property name="types">
                <list>
                    <bean class="org.apache.ignite.cache.store.jdbc.JdbcType">
                        <property name="cacheName" value="lineitem"/>
                        <property name="keyType" value="com.yourpackage.LineitemKey"/>
                        <property name="valueType" value="com.yourpackage.Lineitem"/>
                        <property name="databaseSchema" value="public"/>
                        <property name="databaseTable" value="lineitem"/>
                        <!-- 配置复合主键字段映射 -->
                        <property name="keyFields">
                            <list>
                                <bean class="org.apache.ignite.cache.store.jdbc.JdbcTypeField">
                                    <constructor-arg value="java.sql.Types.BIGINT"/>
                                    <constructor-arg value="l_orderkey"/>
                                    <constructor-arg value="java.lang.Long"/>
                                    <constructor-arg value="l_orderkey"/>
                                </bean>
                                <bean class="org.apache.ignite.cache.store.jdbc.JdbcTypeField">
                                    <constructor-arg value="java.sql.Types.INTEGER"/>
                                    <constructor-arg value="l_linenumber"/>
                                    <constructor-arg value="java.lang.Integer"/>
                                    <constructor-arg value="l_linenumber"/>
                                </bean>
                            </list>
                        </property>
                        <!-- 配置值类字段映射，依次配置l_partkey、l_suppkey等其余表列即可 -->
                        <property name="valueFields">
                            <list>
                                <bean class="org.apache.ignite.cache.store.jdbc.JdbcTypeField">
                                    <constructor-arg value="java.sql.Types.BIGINT"/>
                                    <constructor-arg value="l_partkey"/>
                                    <constructor-arg value="java.lang.Long"/>
                                    <constructor-arg value="l_partkey"/>
                                </bean>
                                <!-- 其余表列配置以此类推 -->
                            </list>
                        </property>
                    </bean>
                </list>
            </property>
        </bean>
    </property>
    <property name="readThrough" value="true"/>
    <property name="writeThrough" value="true"/>
</bean>

3. 触发全量数据加载 #

仅配置上述内容不会自动触发全表数据加载，需要手动调用loadCache方法触发预加载：

// Ignite实例启动后执行该代码完成全量数据加载
ignite.cache("lineitem").loadCache(null);

常见问题排查 #

• 检查运行日志是否有JDBC连接报错、字段类型/名称不匹配的异常，确保配置的字段和PostgreSQL表的列完全对应
• 确认复合主键类的equals和hashCode方法没有逻辑错误，避免相同键值被识别为不同主键
• 若开启了数据过滤，检查过滤规则是否排除了所有行导致缓存为空

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