Mybatis实现JsonObject对象与JSON之间交互

项目中使用PostGresql数据库进行数据存储，表中某字段为Json类型，用于存储Json格式数据。PG数据库能够直接存储Json算是一大特色，很多特定情境下使用直接存储Json字段数据能够大量节省开发时间，提高后台数据查询和转换效率。

1、基础mysql类型与MyBatis数据进行交互

在这里插入图片描述
如果我们有一个JSONObject属性的字段需要与数据库中Json格式的数据进行交互，此时我们就需要自定义一个转换类，将数据库中json格式的对象映射为Java对象，也可以使用Mybatis对JSONObject对象进行映射，将其在数据库中以json格式保存。

2、Entity

import com.alibaba.fastjson.JSONObject;
import lombok.Data;

@Data
public class UserDO {
    private Long id;
    private JSONObject userInfo;
}

3、导入fastjson包

    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>fastjson</artifactId>
    </dependency>

4、编写JSONTypeHandler类

import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.ibatis.type.BaseTypeHandler;
import org.apache.ibatis.type.JdbcType;

import java.sql.CallableStatement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class JsonTypeHandler<T> extends BaseTypeHandler<T> {
    private static final ObjectMapper mapper = new ObjectMapper();
    private Class<T> clazz;

    public JsonTypeHandler(Class<T> clazz) {
        if (clazz == null) throw new IllegalArgumentException("Type argument cannot be null");
        this.clazz = clazz;
    }

    @Override
    public void setNonNullParameter(PreparedStatement ps, int i, T parameter, JdbcType jdbcType) throws SQLException {
        ps.setString(i, this.toJson(parameter));
    }

    @Override
    public T getNullableResult(ResultSet rs, String columnName) throws SQLException {
        return this.toObject(rs.getString(columnName), clazz);
    }

    @Override
    public T getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
        return this.toObject(rs.getString(columnIndex), clazz);
    }

    @Override
    public T getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
        return this.toObject(cs.getString(columnIndex), clazz);
    }

    private String toJson(T object) {
        try {
            return mapper.writeValueAsString(object);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    private T toObject(String content, Class<?> clazz) {
        if (content != null && !content.isEmpty()) {
            try {
                return (T) mapper.readValue(content, clazz);
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
        } else {
            return null;
        }
    }
}

5、在Mybatis映射中加入调用类并编写insert和select方法

<resultMap id="TestJsonMapper" type="com.huahua.dao.DO.TestJsonDO">
    <id column="id" jdbcType="BIGINT" property="id"/>
    <result column="user_info" property="jsonObject" javaType="com.alibaba.fastjson.JSONObject" typeHandler="com.huahua.dao.jsonHandler.JsonTypeHandler"/>
</resultMap>
    <insert id="insert" parameterType="com.huahua.dao.DO.UserDO">
        insert into `user` (`id`, `user_info`)
        values (#{id,jdbcType=BIGINT}, #{jsonObject,typeHandler=com.huahua.dao.jsonHandler.JsonTypeHandler});
    </insert>
    
 <select id="insert">
        select  `id`, `user_info`
        from user
    </select >