CODEWITHSUNDEEP
jsonhibernateannotationsapache-camel
Bart Leemans
Bart Leemans

Reputation: 85

JSON unmarshalling to POJO and inserting

I would like to unmarshal a json string to a pojo class. I am reading it from an existing url: https://builds.apache.org/job/Accumulo-1.5/api/json

I am using apache camel to unmarshal the url

@Component
public class RouteBuilder extends SpringRouteBuilder {

private Logger logger = LoggerFactory.getLogger(RouteBuilder.class);
@Override
public void configure() throws Exception {

    logger.info("Configuring route");

    //Properties die hij niet vindt in de klasse negeren
    ObjectMapper objectMapper = new ObjectMapper();
    objectMapper.configure(DeserializationConfig.Feature.FAIL_ON_UNKNOWN_PROPERTIES, false);


    DataFormat reportFormat = new JacksonDataFormat(objectMapper, HealthReport.class);

                    from("timer://foo?fixedRate=true&delay=0&period=2000&repeatCount=1")
                            .routeId("accumoloToJsonRoute")
                            .setHeader(Exchange.HTTP_METHOD, constant("GET"))
                            .to("https://builds.apache.org:443/job/Accumulo-1.5/api/json")
                            .convertBodyTo(String.class)
                            .unmarshal(reportFormat) //instance van Build
                            .log(LoggingLevel.DEBUG, "be.kdg.teamf", "Project: ${body}")
                            .to("hibernate:be.kdg.teamf.model.HealthReport");


}

}

So far so good. I would like to only insert the 'healthReport' node using hibernate annotations.

@XmlRootElement(name = "healthReport")
@JsonRootName(value = "healthReport")
@Entity(name = "healthreport")
public class HealthReport implements Serializable {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private int Id;

@Column
@JsonProperty("description")
private String description;

@Column
@JsonProperty("iconUrl")
private String iconUrl;

@Column
@JsonProperty("score")
private int score;

public HealthReport() {
}

public HealthReport(int score, String iconUrl, String description) {
    this.score = score;
    this.iconUrl = iconUrl;
    this.description = description;
}

public String getDescription() {
    return description;
}

public String getIconUrl() {
    return iconUrl;
}

public int getId() {
    return Id;
}

public int getScore() {
    return score;
}

public void setDescription(String description) {
    this.description = description;
}

public void setIconUrl(String iconUrl) {
    this.iconUrl = iconUrl;
}

public void setId(int id) {
    Id = id;
}

public void setScore(int score) {
    this.score = score;
}
}

This is where the problem is. It does not recognize the annotations and only null values are inserted in my database 

@XmlRootElement(name = "healthReport")
@JsonRootName(value = "healthReport")

Does anybody know how to fix this?

Thanks

Upvotes: 1

Views: 1270

Answers (2)

Procedurally Generated
Procedurally Generated

Reputation: 301

Can you try this,

 from("timer://foo?fixedRate=true&delay=0&period=2000&repeatCount=1")
.routeId("accumoloToJsonRoute")
.setHeader(Exchange.HTTP_METHOD,constant("GET"))
.to("https://builds.apache.org:443/job/Accumulo-1.5/apijson")
.unmarshal().json(JsonLibrary.Jackson, HealthReport.class)

And make sure the response params match the POJO fields.

Let me know if it works.

Upvotes: 0

Bart Leemans
Bart Leemans

Reputation: 85

Fixed it using a Processor for my Route

public class HealthReportProcessor implements Processor {
@Autowired
private ConfigurationService configurationService;

@Override
public void process(Exchange exchange) throws Exception {
    ObjectMapper mapper = new ObjectMapper();
    JsonNode root = mapper.readTree(exchange.getIn().getBody().toString());
    ArrayNode report = (ArrayNode) root.get("healthReport");

    int configId = configurationService.findJenkinsConfigurationByName(root.get("displayName").asText()).getId();

    for (JsonNode node : report) {
        JsonObject obj = new JsonObject();
        obj.addProperty("description", node.get("description").asText());
        obj.addProperty("iconUrl", node.get("iconUrl").asText());
        obj.addProperty("score", node.get("score").asInt());
        obj.addProperty("jenkinsConfig", configId);

        exchange.getIn().setBody(obj.toString());
    }
}
}

It is working but I think there is a better solution. If you have a better solution please let me know ;)

Upvotes: 2

Related Questions