在我的 build.gradle
我的电脑里有个转换器 forcedTypes
. 这在我需要的地方很管用。
forcedType {
userType = 'java.util.List<stormsensor.thor.dto.telemetry.FlowEventType>'
converter = 'stormsensor.thor.config.jooq.StringToFlowEventTypeListConverter'
includeExpression = '.*\\.FLOW_EVENTS'
includeTypes = '.*'
}
但是,我正在尝试将逗号分隔的字符串转换为特定用例的枚举列表:
DataType<List<FlowEventType>> LIST_TYPE = SQLDataType.VARCHAR.asConvertedDataType(new StringToFlowEventTypeListConverter());
ctx.select(
groupConcatDistinct(NOTIFICATION_RULE.FLOW_EVENT_TYPE).as(field(name("notifications"), LIST_TYPE))
)
.from(NOTIFICATION_RULE)
.groupBy(MONITORING_POINT_ID)
.fetchInto(BatchNotificationRuleModel.class);
这会引发异常
org.jooq.exception.MappingException: An error ocurred when mapping record to class stormsensor.thor.dto.notification.batch.BatchNotificationRuleModel
at org.jooq.impl.DefaultRecordMapper$MutablePOJOMapper.map(DefaultRecordMapper.java:802)
at org.jooq.impl.DefaultRecordMapper.map(DefaultRecordMapper.java:500)
at org.jooq.impl.ResultImpl.into(ResultImpl.java:1284)
at org.jooq.impl.AbstractResultQuery.fetchInto(AbstractResultQuery.java:1550)
at org.jooq.impl.SelectImpl.fetchInto(SelectImpl.java:3746)
at stormsensor.thor.repository.notification.BatchNotificationRuleRepositoryJdbcImpl.save(BatchNotificationRuleRepositoryJdbcImpl.java:98)
Caused by: org.jooq.exception.DataTypeException: Cannot convert from CRITICAL_DEPTH,NON_TIDAL_CSO (class java.lang.String) to interface java.util.List
at org.jooq.tools.Convert$ConvertAll.fail(Convert.java:1194)
at org.jooq.tools.Convert$ConvertAll.from(Convert.java:1083)
at org.jooq.tools.Convert.convert0(Convert.java:324)
at org.jooq.tools.Convert.convert(Convert.java:316)
at org.jooq.tools.Convert.convert(Convert.java:387)
at org.jooq.impl.AbstractRecord.get(AbstractRecord.java:275)
at org.jooq.impl.DefaultRecordMapper$MutablePOJOMapper.map(DefaultRecordMapper.java:830)
at org.jooq.impl.DefaultRecordMapper$MutablePOJOMapper.map(DefaultRecordMapper.java:762)
... 72 more
这就是我要介绍的模型:
@Data
@NoArgsConstructor
public class BatchNotificationRuleModel implements Serializable {
private static final long serialVersionUID = 1L;
private List<FlowEventType> notifications;
private List<MessageProtocolType> protocols;
}
我错过什么了吗?
更新:
我能够转换内联使用
//...
.groupBy(MONITORING_POINT_ID)
.fetchStream().map(e -> {
Converter<String, List<FlowEventType>> converter = new StringToFlowEventTypeListConverter();
List<FlowEventType> notifications = e.get(field(name("notifications"), String.class), converter);
return BatchNotificationRuleModel.builder().notifications(notifications).build();
}).collect(toList());
我应用的初始转换器与后期map转换之间有什么区别?
1条答案
按热度按时间klsxnrf11#
虽然我们有理由期待
Field.as(Field)
将使用参数字段的名称和类型进行类型强制,情况并非如此。根据javadoc:基于其他字段的名称为此字段创建别名。
为了将表达式强制为所需的数据类型,必须手动执行以下操作:
看到了吗
Field.coerce(DataType)