Apache Ignite连接PostgreSQL时无法找到Users表问题排查

核心结论 #

Apache Ignite完全支持作为现有存量PostgreSQL数据库的缓存层使用，读写穿透对接存量表是Ignite原生提供的标准能力，不存在功能层面的限制。你遇到的Failed to find SQL table for type: Users报错属于配置错误，不存在能力缺失问题。

常见配置缺失/错误点 #

• 未在CacheConfiguration中开启readThrough、writeThrough开关，缓存存储逻辑根本不会触发
• CacheJdbcPojoStoreFactory未指定PostgreSQL对应方言，生成的查询SQL不符合PG语法规则
• 未显式配置JdbcType的schema、表名映射，Ignite默认用Java类名Users作为表名匹配，而PostgreSQL默认未加双引号的标识符会自动转为小写users，直接导致表名匹配失败
• 未配置数据库列和Java实体字段的映射规则，驼峰命名字段和下划线命名的数据库列无法自动对应
• 数据源配置错误，连接到了错误的数据库实例或schema，对应库下确实不存在目标表

可直接运行的正确配置参考 #

Ignite PostgreSQL读写穿透配置类 #

@Configuration
public class IgnitePgConfig {
    @Bean
    public CacheConfiguration<Long, Users> userCacheConfig(DataSource pgDataSource) {
        CacheConfiguration<Long, Users> cacheCfg = new CacheConfiguration<>("userCache");
        // 核心开关，漏配则读写穿透完全不生效
        cacheCfg.setReadThrough(true);
        cacheCfg.setWriteThrough(true);
        cacheCfg.setCacheMode(CacheMode.PARTITIONED);
        cacheCfg.setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL);

        CacheJdbcPojoStoreFactory<Long, Users> storeFactory = new CacheJdbcPojoStoreFactory<>();
        storeFactory.setDataSource(pgDataSource);
        // 必须显式指定PG方言，不要使用默认通用方言
        storeFactory.setDialect(new PostgreSQLDialect());

        // 显式配置表和字段映射，避免大小写、schema匹配问题
        JdbcType userType = new JdbcType();
        userType.setCacheName("userCache");
        userType.setKeyType(Long.class);
        userType.setValueType(Users.class);
        // 按实际库的配置填写schema和表名，PG默认表在public schema下，表名默认小写
        userType.setDatabaseSchema("public");
        userType.setDatabaseTable("users");

        // 主键字段映射
        userType.setKeyFields(new JdbcTypeField(Types.BIGINT, "id", Long.class, "id"));
        // 普通字段映射，严格对应数据库列名、类型和实体字段
        userType.setValueFields(
                new JdbcTypeField(Types.VARCHAR, "username", String.class, "username"),
                new JdbcTypeField(Types.VARCHAR, "password", String.class, "password"),
                new JdbcTypeField(Types.TIMESTAMP, "create_time", Timestamp.class, "createTime")
        );
        storeFactory.setTypes(userType);
        cacheCfg.setCacheStoreFactory(storeFactory);
        return cacheCfg;
    }
}

Users实体类 #

public class Users implements Serializable {
    private static final long serialVersionUID = 1L;
    private Long id;
    private String username;
    private String password;
    private Timestamp createTime;

    // 必须保留无参构造，否则Ignite无法反序列化实体
    public Users() {}

    // 自行补全全参构造、所有字段的getter/setter
}

UserRepository接口 #

@Repository
public interface UserRepository extends JpaRepository<Users, Long> {
    Optional<Users> findByUsername(String username);
}

application.yml配置 #

spring:
  datasource:
    # 连接参数里显式指定schema，避免连错schema
    url: jdbc:postgresql://postgres:5432/test_db?currentSchema=public
    username: postgres
    password: postgres
    driver-class-name: org.postgresql.Driver
  ignite:
    work-dir: ./ignite-data

docker-compose服务编排配置 #

version: '3.8'
services:
  postgres:
    image: postgres:14
    ports:
      - "5432:5432"
    environment:
      POSTGRES_DB: test_db
      POSTGRES_USER: postgres
      POSTGRES_PASSWORD: postgres
    volumes:
      - ./pg_init:/docker-entrypoint-initdb.d
      - ./pg_data:/var/lib/postgresql/data
  app:
    build: .
    ports:
      - "8081:8081"
    depends_on:
      - postgres

报错响应示例 #

500 Internal Server Error

{
  "timestamp": "2024-05-20T12:34:56.789+00:00",
  "status": 500,
  "error": "Internal Server Error",
  "message": "Failed to find SQL table for type: Users",
  "path": "/api/login"
}

快速排查顺序 #

1. 用相同的数据源连接参数直连PostgreSQL，确认对应schema下存在配置里填写的表，连接账号拥有该表的读写权限
2. 检查是否显式配置了PostgreSQLDialect，通用方言生成的SQL会给表名加特殊标识符，和PG的规则不兼容
3. 检查readThrough、writeThrough开关是否都设置为true
4. 核对所有字段的映射关系，数据库列名、JDBC类型和Java实体字段类型、名称完全对应

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