扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
这篇文章主要介绍Mybatis中怎么样操作MySQL8的Json字段类型，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！
目前成都创新互联公司已为上1000家的企业提供了网站建设、域名、虚拟空间、网站改版维护、企业网站设计、大足网站维护等服务，公司将坚持客户导向、应用为本的策略，正道将秉承"和谐、参与、激情"的文化，与客户和合作伙伴齐心协力一起成长，共同发展。
Json字段是从mysql 5.7起加进来的全新的字段类型，现在我们看看在什么情况下使用该字段类型，以及用mybatis如何操作该字段类型
一般来说，在不知道字段的具体数量的时候，使用该字段是非常合适的，比如说——商品的无限属性。
现在我们来假设这么一个场景，在商品的二级分类中给商品定义足够多的属性，我们先设计属性的类
/** * 商品自定义属性 */@NoArgsConstructor@AllArgsConstructorpublic class OtherProperty implements Serializable {@Getter @Setter private Long id; //属性id @Getter @Setter private FormType formType; //前端使用的表单类型 @Getter @Setter private String name; //属性名称 @Getter @Setter private String unit; //单位 @Getter @Setter private String values; //可选值以@分隔，如配件@车品 @Getter private List valueList = new ArrayList<>(); //对可选值的取值列表 @Getter @Setter private String defaultValue; //可选值中的默认值 @Getter @Setter private boolean search; //是否可搜索 @Getter @Setter private boolean mustWrite; //是否必录 @Getter @Setter private Boolean used = false; //是否已经在商品中使用，已使用该属性则不允许修改 public OtherProperty changeValuesToList() {
String[] split = this.values.split("@"); for (String value : split) {this.valueList.add(value); }this.values = null; return this; }@Override public boolean equals(Object o) {if (this == o) return true; if (o == null || getClass() != o.getClass()) return false; OtherProperty that = (OtherProperty) o; if (!id.equals(that.id)) return false; if (search != that.search) return false; if (mustWrite != that.mustWrite) return false; if (formType != that.formType) return false; if (!name.equals(that.name)) return false; if (unit != null ? !unit.equals(that.unit) : that.unit != null) return false; if (values != null ? !values.equals(that.values) : that.values != null) return false; return defaultValue != null ? defaultValue.equals(that.defaultValue) : that.defaultValue == null; }@Override public int hashCode() {int result = id.hashCode() + formType.hashCode() + name.hashCode(); result = result + (unit != null ? unit.hashCode() : 0); result = result + (values != null ? values.hashCode() : 0); result = result + (defaultValue != null ? defaultValue.hashCode() : 0); result = result + (search ? 1 : 0); result = result + (mustWrite ? 1 : 0); return result; }
} 其中formType为枚举类型
public enum FormType implements Localisable {TYPE1("文本框"), TYPE2("下拉框"), TYPE3("单选框"), TYPE4("复选框"), TYPE5("多行文本框"); private String value; private FormType(String value) {this.value = value; }@Override public String getValue() {return this.value; }
}我们来看一下商品分类的部分代码
@AllArgsConstructor@NoArgsConstructorpublic class ProviderProductLevel implements Provider,Serializable
其中包含一个商品属性对象的列表
@Getter@Setterprivate ListotherProperties;
部分操作源码如下
/** * 通过二级配件分类id查找其包含的所有其他属性 * @param * @return */public ListfindOtherProperties() {if (this.level == 2) { LevelDao levelDao = SpringBootUtil.getBean(LevelDao.class); String ids = levelDao.findIdsByLevel2Id(this.id); return levelDao.findOtherProperties(ids); }return null;}/** * 在二级配件分类中删除其他属性的id * @param paramIds * @return */public boolean deletePropertyIdfromLevel(String paramIds) {if (this.level == 2) { LevelDao levelDao = SpringBootUtil.getBean(LevelDao.class); String ids = levelDao.findIdsByLevel2Id(this.id); String[] idsArray = ids.split(","); List idsList = Arrays.asList(idsArray); List contentIdsList = new ArrayList<>(); contentIdsList.addAll(idsList); String[] paramArray = paramIds.split(","); List paramList = Arrays.asList(paramArray); if (contentIdsList.containsAll(paramList)) { contentIdsList.removeAll(paramList); }if (contentIdsList.size() > 0) { StringBuilder builder = new StringBuilder(); contentIdsList.stream().forEach(eachId -> builder.append(eachId + ",")); String newIds = builder.toString().substring(0, builder.toString().length() - 1); levelDao.addOtherPropertiesToLevel(new ParamOtherPropertiesId(newIds, this.id)); }else { levelDao.addOtherPropertiesToLevel(new ParamOtherPropertiesId("",this.id)); }return true; }return false;}
/** * 展示某二级配件分类的所有其他属性 * @param id * @return */@SuppressWarnings("unchecked")@Transactional@GetMapping("/productprovider-anon/showproperties")public Result> showOtherProperties(@RequestParam("id") Long id) {
Provider level2 = levelDao.findLevel2(id); return Result.success(((ProviderProductLevel)level2).findOtherProperties());}/** * 修改某二级配件分类的其他属性 * @param id * @param otherProperties * @return */@SuppressWarnings("unchecked")@Transactional@PostMapping("/productprovider-anon/changeother")public Result changeOtherProperties(@RequestParam("id") Long id,@RequestBody List otherProperties) {//获取配件二级分类对象 Provider level2 = levelDao.findLevel2(id); //获取未使用的配件二级分类的其他属性(没有任何商品使用过该属性) List unUsedList = Optional.ofNullable(((ProviderProductLevel) level2).getOtherProperties()).map(otherProperties1 -> otherProperties1.stream())
.orElse(new ArrayList().stream())
.filter(otherProperty -> !otherProperty.getUsed())
.collect(Collectors.toList()); //获取已使用的配件二级分类的其他属性 List usedIdList = Optional.ofNullable(((ProviderProductLevel) level2).getOtherProperties()).map(otherProperties1 -> otherProperties1.stream())
.orElse(new ArrayList().stream())
.filter(otherProperty -> otherProperty.getUsed())
.map(OtherProperty::getId)
.collect(Collectors.toList()); //在传递回来的配件二级分类其他属性中校对没有修改过的，没有使用过的其他属性，只对修改过的，没有使用过的其他属性进行 //存储，否则不处理 List changeList = otherProperties.stream().filter(otherProperty -> Optional.ofNullable(otherProperty.getId()).isPresent())
.filter(otherProperty -> !unUsedList.contains(otherProperty))
.filter(otherProperty -> !usedIdList.contains(otherProperty.getId()))
.peek(otherProperty -> otherPropertyDao.deleteOtherPropertiesById(otherProperty.getId()))
.collect(Collectors.toList()); if (changeList.size() > 0) {
StringBuilder builder = new StringBuilder(); changeList.stream().map(OtherProperty::getId).forEach(eachId -> builder.append(eachId + ",")); String newIds = builder.toString().substring(0, builder.toString().length() - 1); ((ProviderProductLevel) level2).deletePropertyIdfromLevel(newIds); ((ProviderProductLevel) level2).addOtherProperties(changeList); }//获取新增的其他属性进行追加到配件二级分类的其他属性中 List newList = otherProperties.stream().filter(otherProperty -> !Optional.ofNullable(otherProperty.getId()).isPresent())
.peek(otherProperty -> otherProperty.setId(idService.genId()))
.collect(Collectors.toList()); ((ProviderProductLevel) level2).addOtherProperties(newList); return Result.success("修改成功");} 在进行一番增删改查后，数据库中的数据大致如下
我们查高级项链的所有属性的结果如下
现在我们要在属于该商品分类中添加商品，商品类定义大致如下
@Data@NoArgsConstructorpublic class ProviderProduct implements Provider { private Product product; //配件元信息对象
private String code; //配件编码
private Brand brand; //品牌
private String details; //配件图文说明
private String levelName; //二级配件分类名称
private DefaultProvider provider; //配件商
private ExtBeanWrapper otherValues; //其他属性集合
}其中对应于属性列表的字段为otherValues，这个值正是我们要存入数据库的Json字段类型映射。
商品的数据库表结构如下
要使用mybatis的数据对Json字段类型的转换，可以先引用一个网上写好的转换器，当然也可以自己写
pom
com.github.jeffreyning extcol 0.0.1-RELEASE
配置文件中添加 type-handlers-package:com.nh.micro.ext.th
mybatis: type-aliases-package: com.cloud.model.productprovider type-handlers-package: com.nh.micro.ext.th mapper-locations: classpath:/mybatis-mappers/* configuration: mapUnderscoreToCamelCase: true
在mapper文件中写入一段插入语句