Spring Boot+Impala场景下Apache Ignite save方法仅执行UPDATE而非INSERT问题

1. Ignite Spring Data的save逻辑特性：Ignite Spring Data的save方法默认是UPSERT语义（存在则更新，不存在则插入），即使你实现了Persistable并返回isNew()=true，它仍会先检查缓存/底层存储中是否存在对应主键的记录，若存在则执行UPDATE。
2. 缓存预加载或历史数据残留：如果你的Ignite缓存中已经加载了对应ID的实体，或者底层Impala表中已有该主键的记录，即使isNew()返回true，Ignite也会判定为“已存在”并执行UPDATE。
3. CacheStore的默认行为：如果使用了自定义的Impala CacheStore，其默认的write方法可能采用了UPSERT逻辑，而非纯INSERT。

1. 强制使用INSERT语义替代UPSERT #

直接使用Ignite原生API的putIfAbsent方法替代Spring Data的save，该方法仅在主键不存在时插入数据，不会触发UPDATE：

@Repository
public interface YourEntityRepository extends IgniteRepository<YourEntity, Long> {
    @Autowired
    Ignite ignite;

    default YourEntity forceInsert(YourEntity entity) {
        // 替换为你的缓存名称
        IgniteCache<Long, YourEntity> cache = ignite.cache("your_entity_cache");
        // 仅当主键不存在时插入，返回null表示插入成功，返回旧值表示主键已存在
        return cache.putIfAbsent(entity.getId(), entity);
    }
}

2. 修正isNew()的判断逻辑（配合save方法） #

如果坚持使用Spring Data的save，需要确保isNew()的判断逻辑能准确识别“真正的新实体”，同时在save前主动清理缓存中可能存在的旧数据：

@Entity
public class YourEntity implements Persistable<Long> {
    @Id
    private Long id;
    // 其他字段

    @Override
    public Long getId() {
        return id;
    }

    @Override
    public boolean isNew() {
        // 比如通过新增标记字段判断，或主键为null/未赋值时判定为新实体
        return id == null || id == 0;
    }
}

在调用save前，先移除缓存中可能存在的旧记录：

yourEntityRepository.deleteById(entity.getId());
yourEntityRepository.save(entity);

3. 自定义CacheStore强制执行INSERT #

如果使用了CacheStore对接Impala，重写write方法，直接执行INSERT语句而非UPSERT：

public class ImpalaEntityCacheStore extends CacheStoreAdapter<Long, YourEntity> {
    @Autowired
    private JdbcTemplate jdbcTemplate;

    @Override
    public void write(Cache.Entry<? extends Long, ? extends YourEntity> entry) throws CacheWriterException {
        YourEntity entity = entry.getValue();
        // 直接执行INSERT，避免使用UPSERT语法
        String insertSql = "INSERT INTO your_entity_table (id, col1, col2) VALUES (?, ?, ?)";
        jdbcTemplate.update(insertSql, entity.getId(), entity.getCol1(), entity.getCol2());
    }
}

然后在Ignite缓存配置中指定该CacheStore：

@Bean
public Ignite igniteInstance() {
    IgniteConfiguration cfg = new IgniteConfiguration();
    CacheConfiguration<Long, YourEntity> cacheCfg = new CacheConfiguration<>("your_entity_cache");
    // 绑定自定义CacheStore
    cacheCfg.setCacheStoreFactory(FactoryBuilder.factoryOf(ImpalaEntityCacheStore.class));
    cacheCfg.setWriteThrough(true);
    cfg.setCacheConfiguration(cacheCfg);
    return Ignition.start(cfg);
}

4. 禁用Ignite的自动UPDATE判定 #

在Ignite缓存配置中，设置atomicityMode为ATOMIC，并禁用缓存的读-through（避免从Impala加载旧数据到缓存）：

cacheCfg.setAtomicityMode(CacheAtomicityMode.ATOMIC);
cacheCfg.setReadThrough(false);

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