mybatis 向数据库存储json格式数据

96 阅读 0 评论 64 点赞

我是靠谱客的博主炙热钢笔，最近开发中收集的这篇文章主要介绍mybatis 向数据库存储json格式数据，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

<insert id="insertForeach" parameterType="java.util.ArrayList">
    insert into edu_student_record
        (   
            gift_to_student,
            gift_to_teacher,
            kid_photo_url
        )
    values
     <foreach collection="list" index="index" item="studentRecord" separator=",">
         (
            #{studentRecord.giftToStudent,typeHandler=com.fable.common.entity.ArrayJsonHandler},
            #{studentRecord.giftToTeacher,typeHandler=com.fable.common.entity.ArrayJsonHandler},
            #{studentRecord.kidPhotoUrl,typeHandler=com.fable.common.entity.ArrayJsonHandler}
        )
    </foreach>
</insert>

package com.fable.common.entity;
 
import com.alibaba.fastjson.JSONArray;
import org.apache.ibatis.type.BaseTypeHandler;
import org.apache.ibatis.type.JdbcType;
import org.apache.ibatis.type.MappedJdbcTypes;
import org.apache.ibatis.type.MappedTypes;
 
import java.sql.CallableStatement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
 
/**
 * Created by lixio on 2019/3/28 20:51
 * @description 用以mysql中json格式的字段，进行转换的自定义转换器，转换为实体类的JSONArray属性
 * MappedTypes注解中的类代表此转换器可以自动转换为的java对象
 * MappedJdbcTypes注解中设置的是对应的jdbctype
 */
@MappedTypes(JSONArray.class)
@MappedJdbcTypes(JdbcType.OTHER)
public class ArrayJsonHandler extends BaseTypeHandler<JSONArray> {
    //设置非空参数
    @Override
    public void setNonNullParameter(PreparedStatement ps, int i, JSONArray parameter, JdbcType jdbcType) throws SQLException {
        ps.setString(i, String.valueOf(parameter.toJSONString()));
    }
    //根据列名，获取可以为空的结果
    @Override
    public JSONArray getNullableResult(ResultSet rs, String columnName) throws SQLException {
        String sqlJson = rs.getString(columnName);
        if (null != sqlJson){
            return JSONArray.parseArray(sqlJson);
        }
        return null;
    }
    //根据列索引，获取可以为空的结果
    @Override
    public JSONArray getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
        String sqlJson = rs.getString(columnIndex);
        if (null != sqlJson){
            return JSONArray.parseArray(sqlJson);
        }
        return null;
    }
 
    @Override
    public JSONArray getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
        String sqlJson = cs.getString(columnIndex);
        if (null != sqlJson){
            return JSONArray.parseArray(sqlJson);
        }
        return null;
    }
 
}

记录以上，以备后日之需。