ClickHouseArray序列化异常

140 阅读 0 评论 93 点赞

我是靠谱客的博主陶醉蜗牛，这篇文章主要介绍ClickHouseArray序列化异常，现在分享给大家，希望可以做个参考。

1.异常

Caused by: com.fasterxml.jackson.databind.JsonMappingException: (was java.sql.SQLFeatureNotSupportedException) (through reference chain: com.****.HttpResult["content"]->java.util.ArrayList[0]->java.util.LinkedHashMap["column_14"]->ru.yandex.clickhouse.ClickHouseArray["resultSet"])

使用jdbc操作clickhouse执行sql的返回结果时报错

2.背景知识

controller层使用@RestController时，使用MappingJackson2HttpMessageConverter对返回的数据进行序列化。所以前端可以显示json，xml等格式的数据。而@Controller注解显示的是视图，如果想展示json，要在方法中加上@ResponseBody

3.解决方案

项目中其他语句都没有报错，只有在返回 ClickHouseArray 这个类的时候序列化异常。没有看到其他解法，就自己写了序列化和反序列的代码。

代码如下：

复制代码

import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.core.TreeNode;
import com.fasterxml.jackson.databind.DeserializationContext;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.JsonDeserializer;
import com.fasterxml.jackson.databind.JsonSerializer;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializationFeature;
import com.fasterxml.jackson.databind.SerializerProvider;
import com.fasterxml.jackson.databind.module.SimpleModule;
import com.fasterxml.jackson.databind.node.ArrayNode;
import com.fasterxml.jackson.databind.node.TextNode;
import lombok.SneakyThrows;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.converter.HttpMessageConverter;
import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
import ru.yandex.clickhouse.ClickHouseArray;
import ru.yandex.clickhouse.domain.ClickHouseDataType;
import java.io.IOException;
import java.util.List;
@Configuration
public class WebMvcConfiguration implements WebMvcConfigurer {
@Override
public void configureMessageConverters(List<HttpMessageConverter<?>> converters) {
converters.add(mappingJackson2HttpMessageConverter());
WebMvcConfigurer.super.configureMessageConverters(converters);
}
@Bean
public MappingJackson2HttpMessageConverter mappingJackson2HttpMessageConverter() {
MappingJackson2HttpMessageConverter jsonConverter = new MappingJackson2HttpMessageConverter();
//设置解析JSON工具类
ObjectMapper objectMapper = new ObjectMapper();
//解决空属性报错
objectMapper.configure(SerializationFeature.FAIL_ON_EMPTY_BEANS, false);
//忽略未知属性 防止解析报错
objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
// 全局clickhouseArray序列化配置
SimpleModule module = new SimpleModule();
//module.addDeserializer(ru.yandex.clickhouse.ClickHouseArray.class,new ClickHouseArrayDeserializer());
module.addSerializer(ru.yandex.clickhouse.ClickHouseArray.class,new ClickHouseArraySerialize());
objectMapper.registerModule(module);
objectMapper.findAndRegisterModules();
jsonConverter.setObjectMapper(objectMapper);
return jsonConverter;
}
public class ClickHouseArraySerialize extends JsonSerializer<ClickHouseArray> {
@SneakyThrows
@Override
public void serialize(ClickHouseArray clickHouseArray, JsonGenerator jsonGenerator, SerializerProvider serializerProvider) throws IOException {
// 对象转为字节流
jsonGenerator.writeStartObject();
jsonGenerator.writeStringField("elementType",clickHouseArray.getBaseTypeName());
jsonGenerator.writeObjectField("array",clickHouseArray.getArray());
jsonGenerator.writeEndObject();
}
}
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.core.TreeNode;
import com.fasterxml.jackson.databind.DeserializationContext;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.JsonDeserializer;
import com.fasterxml.jackson.databind.JsonSerializer;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializationFeature;
import com.fasterxml.jackson.databind.SerializerProvider;
import com.fasterxml.jackson.databind.module.SimpleModule;
import com.fasterxml.jackson.databind.node.ArrayNode;
import com.fasterxml.jackson.databind.node.TextNode;
import lombok.SneakyThrows;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.converter.HttpMessageConverter;
import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
import ru.yandex.clickhouse.ClickHouseArray;
import ru.yandex.clickhouse.domain.ClickHouseDataType;
import java.io.IOException;
import java.util.List;
@Configuration
public class WebMvcConfiguration implements WebMvcConfigurer {
@Override
public void configureMessageConverters(List<HttpMessageConverter<?>> converters) {
converters.add(mappingJackson2HttpMessageConverter());
WebMvcConfigurer.super.configureMessageConverters(converters);
}
@Bean
public MappingJackson2HttpMessageConverter mappingJackson2HttpMessageConverter() {
MappingJackson2HttpMessageConverter jsonConverter = new MappingJackson2HttpMessageConverter();
//设置解析JSON工具类
ObjectMapper objectMapper = new ObjectMapper();
//解决空属性报错
objectMapper.configure(SerializationFeature.FAIL_ON_EMPTY_BEANS, false);
//忽略未知属性 防止解析报错
objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
// 全局clickhouseArray序列化配置
SimpleModule module = new SimpleModule();
//module.addDeserializer(ru.yandex.clickhouse.ClickHouseArray.class,new ClickHouseArrayDeserializer());
module.addSerializer(ru.yandex.clickhouse.ClickHouseArray.class,new ClickHouseArraySerialize());
objectMapper.registerModule(module);
objectMapper.findAndRegisterModules();
jsonConverter.setObjectMapper(objectMapper);
return jsonConverter;
}
public class ClickHouseArraySerialize extends JsonSerializer<ClickHouseArray> {
@SneakyThrows
@Override
public void serialize(ClickHouseArray clickHouseArray, JsonGenerator jsonGenerator, SerializerProvider serializerProvider) throws IOException {
// 对象转为字节流
jsonGenerator.writeStartObject();
jsonGenerator.writeStringField("elementType",clickHouseArray.getBaseTypeName());
jsonGenerator.writeObjectField("array",clickHouseArray.getArray());
jsonGenerator.writeEndObject();
}
}
}