@Table("abc_configurations")
data class AbcConfiguration(
val name: String,
val distribution: Map
)
Распределение представляет собой столбец jsonb в таблице PostgreSQL:
CREATE TABLE abc_configurations
(
name VARCHAR(50) PRIMARY KEY,
distribution JSONB NOT NULL
);
Для этого я создал следующий специальный конвертер:
import com.fasterxml.jackson.core.type.TypeReference
import com.fasterxml.jackson.databind.ObjectMapper
import org.postgresql.util.PGobject
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import org.springframework.core.convert.converter.Converter
import org.springframework.data.convert.ReadingConverter
import org.springframework.data.convert.WritingConverter
import org.springframework.data.jdbc.core.convert.JdbcCustomConversions
import org.springframework.data.jdbc.core.convert.JdbcValue
import org.springframework.data.jdbc.repository.config.AbstractJdbcConfiguration
import org.springframework.data.jdbc.repository.config.EnableJdbcRepositories
import java.sql.JDBCType
@Configuration
@EnableJdbcRepositories
class DataConfig : AbstractJdbcConfiguration() {
@Autowired
private lateinit var objectMapper: ObjectMapper;
@Bean
override fun jdbcCustomConversions(): JdbcCustomConversions {
val converters = listOf(
DistributionWritingConverter(objectMapper),
DistributionReadingConverter(objectMapper)
)
return JdbcCustomConversions(converters)
}
@WritingConverter
class DistributionWritingConverter(private val objectMapper: ObjectMapper) : Converter {
override fun convert(source: Map): JdbcValue {
return JdbcValue.of(objectMapper.writeValueAsString(source), JDBCType.VARCHAR)
}
}
@ReadingConverter
class DistributionReadingConverter(private val objectMapper: ObjectMapper) : Converter
> {
override fun convert(source: PGobject): Map {
return objectMapper.readValue(source.value, object : TypeReference() {})
}
}
}
Когда я сохраняю объект, он работает нормально, и карта распределения сохраняется в столбце JSONB, как и ожидалось.
Проблема в том, что когда я читаю объект, я получаю следующую ошибку: не удалось найти PersistentEntity для класса типа java.lang.Integer!
org.springframework.data.mapping.MappingException: Couldn't find PersistentEntity for type class java.lang.Integer!
at org.springframework.data.mapping.context.MappingContext.getRequiredPersistentEntity(MappingContext.java:79) ~[spring-data-commons-2.4.5.jar:2.4.5]
at org.springframework.data.jdbc.core.convert.SqlGeneratorSource.lambda$getSqlGenerator$0(SqlGeneratorSource.java:62) ~[spring-data-jdbc-2.1.5.jar:2.1.5]
at java.base/java.util.concurrent.ConcurrentMap.computeIfAbsent(ConcurrentMap.java:330) ~[na:na]
at org.springframework.data.jdbc.core.convert.SqlGeneratorSource.getSqlGenerator(SqlGeneratorSource.java:61) ~[spring-data-jdbc-2.1.5.jar:2.1.5]
at org.springframework.data.jdbc.core.convert.DefaultDataAccessStrategy.sql(DefaultDataAccessStrategy.java:583) ~[spring-data-jdbc-2.1.5.jar:2.1.5]
at org.springframework.data.jdbc.core.convert.DefaultDataAccessStrategy.findAllByPath(DefaultDataAccessStrategy.java:362) ~[spring-data-jdbc-2.1.5.jar:2.1.5]
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:na]
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:64) ~[na:na]
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:na]
at java.base/java.lang.reflect.Method.invoke(Method.java:564) ~[na:na]
at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:344) ~[spring-aop-5.3.4.jar:5.3.4]
Я попробовал изменить метод @ReadingConverter на следующий, но это не сработало:
- Converter
- Converter
Как я могу указать Spring использовать пользовательский @ReadingConverter
Обновление (01.09.2021):
Как упоминали Джен и Сьюзен, это проблема с библиотекой Spring-data-jdbc. Я приступил к следующему обходному пути.
data class Distribution(val value: Map)
@Table("abc_configurations")
data class AbcConfiguration(
val name: String,
val distribution: Distribution
)