Spring JPA项目中如何根据JSON实例化抽象类子类字段

针对你这个场景，核心是解决JSON反序列化时的子类识别问题，同时还要兼顾JPA的实体继承持久化，下面是几种实用的实现方式：

方法一：用Jackson自带的类型注解（最简便） #

直接在抽象类SourceConfig上添加Jackson的类型识别注解，指定通过source字段来匹配对应的子类：

import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonSubTypes;

@JsonTypeInfo(
    use = JsonTypeInfo.Id.NAME,
    include = JsonTypeInfo.As.PROPERTY,
    property = "source" // 指定用来识别类型的字段
)
@JsonSubTypes({
    @JsonSubTypes.Type(value = KafkaSourceConfig.class, name = "KAFKA"),
    @JsonSubTypes.Type(value = MysqlSourceConfig.class, name = "MYSQL")
})
public abstract class SourceConfig {
    private long id;
    private String name;
    // getter、setter
}

这样当Jackson解析JSON时，看到sourceConfig里的source: "MYSQL"，就会自动实例化MysqlSourceConfig对象，无需额外代码。

配套JPA持久化处理 #

因为是JPA实体，还要给抽象类添加继承映射注解，比如用JOINED策略（每个子类对应单独的表，关联父类主键）：

import jakarta.persistence.*;

@Entity
@Inheritance(strategy = InheritanceType.JOINED)
@JsonTypeInfo(...) // 上面的Jackson注解
@JsonSubTypes(...)
public abstract class SourceConfig {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private long id;
    private String name;
    // ...
}

@Entity
public class MysqlSourceConfig extends SourceConfig {
    private String databaseName;
    private String tableName;
    // getter、setter
}

@Entity
public class KafkaSourceConfig extends SourceConfig {
    private String topic;
    private String messageSchema;
    // getter、setter
}

方法二：自定义Jackson反序列化器（更灵活） #

如果需要更复杂的判断逻辑（比如根据多个字段识别），可以自定义反序列化器：

1. 先写自定义反序列化类：

import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.databind.DeserializationContext;
import com.fasterxml.jackson.databind.JsonDeserializer;
import com.fasterxml.jackson.databind.JsonNode;

import java.io.IOException;

public class SourceConfigDeserializer extends JsonDeserializer<SourceConfig> {
    @Override
    public SourceConfig deserialize(JsonParser p, DeserializationContext ctxt) throws IOException {
        JsonNode node = p.getCodec().readTree(p);
        String sourceType = node.get("source").asText();
        
        switch (sourceType) {
            case "MYSQL":
                return p.getCodec().treeToValue(node, MysqlSourceConfig.class);
            case "KAFKA":
                return p.getCodec().treeToValue(node, KafkaSourceConfig.class);
            default:
                throw new IllegalArgumentException("不支持的数据源类型: " + sourceType);
        }
    }
}

2. 在抽象类SourceConfig上指定这个反序列化器：

import com.fasterxml.jackson.databind.annotation.JsonDeserialize;

@Entity
@Inheritance(strategy = InheritanceType.JOINED)
@JsonDeserialize(using = SourceConfigDeserializer.class)
public abstract class SourceConfig {
    // ... 字段和方法
}

方法三：Controller层手动处理（适合简单场景） #

如果不想修改实体类注解，也可以在Controller接收请求时手动解析：

import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;

@RestController
public class PipelineController {
    private final ObjectMapper objectMapper;

    public PipelineController(ObjectMapper objectMapper) {
        this.objectMapper = objectMapper;
    }

    @PostMapping("/pipelines")
    public Pipeline createPipeline(@RequestBody JsonNode requestNode) throws IOException {
        // 先解析基础的Pipeline字段
        Pipeline pipeline = objectMapper.treeToValue(requestNode, Pipeline.class);
        
        // 解析sourceConfig部分
        JsonNode sourceConfigNode = requestNode.get("sourceConfig");
        String sourceType = sourceConfigNode.get("source").asText();
        SourceConfig sourceConfig;
        
        if ("MYSQL".equals(sourceType)) {
            sourceConfig = objectMapper.treeToValue(sourceConfigNode, MysqlSourceConfig.class);
        } else if ("KAFKA".equals(sourceType)) {
            sourceConfig = objectMapper.treeToValue(sourceConfigNode, KafkaSourceConfig.class);
        } else {
            throw new IllegalArgumentException("不支持的数据源类型");
        }
        
        pipeline.setSourceConfig(sourceConfig);
        // 后续处理sinkConfig同理，然后保存到数据库
        return pipeline;
    }
}

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