我之前也碰到过几乎一模一样的问题！核心卡点其实是Spring Data Neo4j对@Id注解的默认处理逻辑——它会把标注@Id的字段直接当成Neo4j的内部图ID（也就是节点原生的唯一标识），而这个ID是Neo4j自己维护生成的，根本不允许我们手动赋值。所以你直接把RDBMS的原始ID塞进去时，Neo4j会误以为你要修改一个已经存在的节点（但那个ID对应的节点其实不存在），自然就创建失败了。

下面给你一套具体的解决思路和代码示例：

不要把RDBMS的原始ID当作Neo4j的节点ID，而是把它作为普通业务属性存储，同时给实体类单独配置一个由Neo4j自动生成的内部ID。

1. 重构实体类代码 #

import org.springframework.data.neo4j.core.schema.Id;
import org.springframework.data.neo4j.core.schema.GeneratedValue;
import org.springframework.data.neo4j.core.schema.Node;
import org.springframework.data.neo4j.core.schema.Property;
import org.springframework.data.neo4j.core.schema.Index;

// 给原始ID字段加唯一索引，保证同步时不会重复创建
@Node("User")
@Index(name = "idx_user_original_id", properties = "originalId", unique = true)
public class UserNode {
    // Neo4j内部自动生成的节点ID，完全由Neo4j维护
    @Id
    @GeneratedValue
    private Long neo4jInternalId;

    // RDBMS的原始业务ID，作为普通属性存储
    @Property("original_id") // 可以自定义Neo4j中的属性名
    private Long originalId;

    // 其他业务属性
    private String username;
    private String email;

    // 构造器、getter、setter省略
}

2. 基于原始ID实现节点关联与同步 #

同步时，通过原始ID查找目标节点，再建立关联关系，同时实现“存在则更新，不存在则创建”的逻辑：

@Service
public class RdbmsToNeo4jSyncService {
    private final Neo4jTemplate neo4jTemplate;

    public RdbmsToNeo4jSyncService(Neo4jTemplate neo4jTemplate) {
        this.neo4jTemplate = neo4jTemplate;
    }

    // 同步用户数据示例
    public void syncUserFromRdbms(User rdbmsUser) {
        // 先通过原始ID查询Neo4j中是否已存在该节点
        UserNode existingNode = neo4jTemplate.findOne(
                Query.query("MATCH (u:User) WHERE u.original_id = $originalId RETURN u",
                        Map.of("originalId", rdbmsUser.getId())),
                UserNode.class
        ).orElse(null);

        if (existingNode != null) {
            // 存在则更新属性
            existingNode.setUsername(rdbmsUser.getUsername());
            existingNode.setEmail(rdbmsUser.getEmail());
        } else {
            // 不存在则创建新节点
            existingNode = new UserNode();
            existingNode.setOriginalId(rdbmsUser.getId());
            existingNode.setUsername(rdbmsUser.getUsername());
            existingNode.setEmail(rdbmsUser.getEmail());
        }

        neo4jTemplate.save(existingNode);
    }

    // 同步订单并关联用户的示例
    public void syncOrderWithUserFromRdbms(Order rdbmsOrder) {
        // 通过订单关联的原始用户ID查找对应的Neo4j用户节点
        UserNode userNode = neo4jTemplate.findOne(
                Query.query("MATCH (u:User) WHERE u.original_id = $userId RETURN u",
                        Map.of("userId", rdbmsOrder.getUserId())),
                UserNode.class
        ).orElseThrow(() -> new RuntimeException("用户不存在，原始ID：" + rdbmsOrder.getUserId()));

        // 处理订单节点的创建/更新逻辑
        OrderNode orderNode = neo4jTemplate.findOne(
                Query.query("MATCH (o:Order) WHERE o.original_id = $orderId RETURN o",
                        Map.of("orderId", rdbmsOrder.getId())),
                OrderNode.class
        ).orElse(new OrderNode());

        orderNode.setOriginalId(rdbmsOrder.getId());
        orderNode.setOrderNumber(rdbmsOrder.getOrderNumber());
        orderNode.setUser(userNode); // 建立订单与用户的关联

        neo4jTemplate.save(orderNode);
    }
}

3. 关键注意事项 #

• 一定要给originalId字段创建唯一索引：既可以通过实体类的@Index注解自动生成，也可以手动执行CQL语句CREATE CONSTRAINT unique_user_original_id ON (u:User) ASSERT u.original_id IS UNIQUE;，这样能避免重复导入，同时提升查询效率。
• 永远不要依赖Neo4j的内部ID做业务关联：内部ID可能在数据库迁移、备份恢复时发生变化，只有你的业务原始ID是稳定可靠的关联依据。

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