Mybatis操做mysql 8的Json字段类型

时间 2019-12-06

标签 mybatis mysql json 字段类型栏目 MyBatis 繁體版

原文原文链接

Json字段是从mysql 5.7起加进来的全新的字段类型，如今咱们看看在什么状况下使用该字段类型，以及用mybatis如何操做该字段类型html

通常来讲，在不知道字段的具体数量的时候，使用该字段是很是合适的，好比说——商品的无限属性。前端

如今咱们来假设这么一个场景，在商品的二级分类中给商品定义足够多的属性，咱们先设计属性的类mysql

/**
 * 商品自定义属性
 */
@NoArgsConstructor
@AllArgsConstructor
public 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<String> 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为枚举类型git

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;
    }
}

咱们来看一下商品分类的部分代码github

@AllArgsConstructor
@NoArgsConstructor
public class ProviderProductLevel implements Provider,Serializable

其中包含一个商品属性对象的列表sql

@Getter
@Setter
private List<OtherProperty> otherProperties;

部分操做源码以下数据库

/**
 * 经过二级配件分类id查找其包含的全部其余属性
 * @param
 * @return
 */
public List<OtherProperty> findOtherProperties() {
    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<String> idsList = Arrays.asList(idsArray);
        List<String> contentIdsList = new ArrayList<>();
        contentIdsList.addAll(idsList);
        String[] paramArray = paramIds.split(",");
        List<String> 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<List<OtherProperty>> 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<String> changeOtherProperties(@RequestParam("id") Long id,@RequestBody List<OtherProperty> otherProperties) {
    //获取配件二级分类对象
    Provider level2 = levelDao.findLevel2(id);
    //获取未使用的配件二级分类的其余属性(没有任何商品使用过该属性)
    List<OtherProperty> unUsedList = Optional.ofNullable(((ProviderProductLevel) level2).getOtherProperties()).map(otherProperties1 -> otherProperties1.stream())
            .orElse(new ArrayList<OtherProperty>().stream())
            .filter(otherProperty -> !otherProperty.getUsed())
            .collect(Collectors.toList());
    //获取已使用的配件二级分类的其余属性
    List<Long> usedIdList = Optional.ofNullable(((ProviderProductLevel) level2).getOtherProperties()).map(otherProperties1 -> otherProperties1.stream())
            .orElse(new ArrayList<OtherProperty>().stream())
            .filter(otherProperty -> otherProperty.getUsed())
            .map(OtherProperty::getId)
            .collect(Collectors.toList());
    //在传递回来的配件二级分类其余属性中校对没有修改过的，没有使用过的其余属性，只对修改过的，没有使用过的其余属性进行
    //存储，不然不处理
    List<OtherProperty> 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<OtherProperty> 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("修改为功");
}

在进行一番增删改查后，数据库中的数据大体以下json

咱们查高级项链的全部属性的结果以下mybatis

如今咱们要在属于该商品分类中添加商品，商品类定义大体以下app

@Data
@NoArgsConstructor
public class ProviderProduct implements Provider {
    private Product product;
    private String code;
    private Brand brand;
    private String details;
    private ExtBeanWrapper otherValues;
}

其中对应于属性列表的字段为otherValues，这个值正是咱们要存入数据库的Json字段类型映射。

商品的数据库表结构以下

要使用mybatis的数据对Json字段类型的转换，能够先引用一个网上写好的转换器，固然也能够本身写

pom

<dependency>
   <groupId>com.github.jeffreyning</groupId>
   <artifactId>extcol</artifactId>
   <version>0.0.1-RELEASE</version>
</dependency>

配置文件中添加 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文件中写入一段插入语句

<insert id="saveProduct" parameterType="com.cloud.productprovider.composite.ProviderProduct">
    insert into product (id,name,code,model,normal_price,price_begin,product_imgs,details,brand_id,other_property_value)
    values (#{product.id},#{product.name},#{code},#{product.model},#{product.price.normalPrice},
    <choose>
        <when test="product.price.begin">
            1
        </when>
        <otherwise>
            0
        </otherwise>
    </choose>,
    #{product.productImgs},
    #{details},
    #{brand.id},
    #{otherValues,jdbcType=VARCHAR}
    )
</insert>

对应商品分类的每个自定义属性，咱们能够先拿到该自定义属性的id,而后以该id，取值为键值对进行插入

{
   "product":{
       "name":"AAAA",
       "model":"AAAAA",
       "price":{
           "normalPrice":199,
           "begin":false
       },
       "productImgs":"http://123.433.567.988"
   },
   "code":"0001",
   "details":"<html><body><a href='sfasffg'><img url='sdfsgwer' /></a></body></html>",
   "brand":{
       "id":1,
       "name":"飞利浦"
   },
   "otherValues":{
       "innerMap":{
           "2459623566996408120":"10",
           "2459623566996409144":"呼和浩特",
           "2459623566996410168":"飞利浦",
           "2459623566996411192":"国际",
           "2459623566996412216":"包邮"
       }
   }
}

执行以后，数据库的数据以下

该插件的数据类和转换器的源码以下，其实也是很简单的

public class ExtBeanWrapper {

   public ExtBeanWrapper() {
   };

   public ExtBeanWrapper(Object entity) {
      this.setObj(entity);
   }

   private Map innerMap = new HashMap();

   public Map getInnerMap() {
      return innerMap;
   }

   public void setInnerMap(Map innerMap) {
      this.innerMap = innerMap;
   }

   public void setObj(Object entity) {
      if (entity == null) {
         innerMap = null;
      }
      JSON jobj = (JSON) JSON.toJSON(entity);
      innerMap = JSON.toJavaObject(jobj, Map.class);
   }

   public Object getObj() {
      if (innerMap == null) {
         return null;
      }
      JSON jobj = (JSON) JSON.toJSON(innerMap);
      Map entity = JSON.toJavaObject(jobj, Map.class);
      return entity;
   }

   public Object getObj(Class targetClass) {
      if (innerMap == null) {
         return null;
      }
      JSON jobj = (JSON) JSON.toJSON(innerMap);
      Object entity = JSON.toJavaObject(jobj, targetClass);
      return entity;
   }

}

MappedTypes(com.nh.micro.ext.ExtBeanWrapper.class)
@MappedJdbcTypes(JdbcType.VARCHAR)
public class TagToJsonTypeHandler extends BaseTypeHandler<ExtBeanWrapper> {
   private Map jsonToMap(String value) {
      if (value == null || "".equals(value)) {
         return Collections.emptyMap();
      } else {
         return JSON.parseObject(value, new TypeReference<Map<String, Object>>() {
         });
      }
   }

   @Override
   public void setNonNullParameter(PreparedStatement ps, int i, ExtBeanWrapper parameter, JdbcType jdbcType)
         throws SQLException {
         ps.setString(i, JSON.toJSONString(parameter.getInnerMap()));
   }

   public boolean isJson(String value){
      if(value==null || "".equals(value)){
         return false;
      }else{
         if(value.startsWith("{")){
            return true;
         }
      }
      return false;
   }

   @Override
   public ExtBeanWrapper getNullableResult(ResultSet rs, String columnName) throws SQLException {
      String value=rs.getString(columnName);
      Map innerMap=jsonToMap(value);
      ExtBeanWrapper extBeanTag=new ExtBeanWrapper();
      extBeanTag.setInnerMap(innerMap);
      return extBeanTag;
   }

   @Override
   public ExtBeanWrapper getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
      String value=rs.getString(columnIndex);
      Map innerMap=jsonToMap(value);
      ExtBeanWrapper extBeanTag=new ExtBeanWrapper();
      extBeanTag.setInnerMap(innerMap);
      return extBeanTag;
   }

   @Override
   public ExtBeanWrapper getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
      String value=cs.getString(columnIndex);
      Map innerMap=jsonToMap(value);
      ExtBeanWrapper extBeanTag=new ExtBeanWrapper();
      extBeanTag.setInnerMap(innerMap);
      return extBeanTag;
}

}

1. mysql 字段操做
2. Mybatis深度整合Mysql的Json字段
3. MySQL字段类型
4. mysql字段类型
5. mysql 字段类型
6. MySQL JSON数据类型操做
7. MySQL JSON 类型数据操做
8. Mysql的字段类型，查询语句，高级操做
9. MySQL的varchar类型字段
10. MyBatis里json型字段到Java类的映射
更多相关文章...
• MyBatis BlobTypeHandler读取Blob字段 - MyBatis教程
• SQL AUTO INCREMENT 字段 - SQL 教程
• Kotlin学习（二）基本类型
• 漫谈MySQL的锁机制