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;}@Overridepublic void setNonNullParameter(PreparedStatement ps, int i, T parameter, JdbcType jdbcType) throws SQLException {ps.setString(i, this.toJson(parameter));}@Overridepublic T getNullableResult(ResultSet rs, String columnName) throws SQLException {return this.toObject(rs.getString(columnName), clazz);}@Overridepublic T getNullableResult(ResultSet rs, int columnIndex) throws SQLException {return this.toObject(rs.getString(columnIndex), clazz);}@Overridepublic 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 >