自定義handler處理器

import java.sql.CallableStatement;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

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 com.alibaba.fastjson.JSONObject;

/**

* mysql中json類型轉換擴展

*

* @author: xiaowei.go

* @date: 2019年11月20日

*

*/

@MappedTypes(JSONObject.class)

@MappedJdbcTypes(JdbcType.VARCHAR)

public class MySqlJsonHandler extends BaseTypeHandler {

/**

* 設置非空參數

*

* @author: xiaowei.go

* @date: 2019年11月20日

* @see org.apache.ibatis.type.BaseTypeHandler#setNonNullParameter(java.sql.PreparedStatement,

* int, java.lang.Object, org.apache.ibatis.type.JdbcType)

*/

@Override

public void setNonNullParameter(PreparedStatement ps, int i, JSONObject parameter,

JdbcType jdbcType) throws SQLException {

ps.setString(i, String.valueOf(parameter.toJSONString()));

}

/**

* 根據列名，獲取可以為空的結果

*

* @author: xiaowei.go

* @date: 2019年11月20日

* @see org.apache.ibatis.type.BaseTypeHandler#getNullableResult(java.sql.ResultSet,

* java.lang.String)

*/

@Override

public JSONObject getNullableResult(ResultSet rs, String columnName) throws SQLException {

String sqlJson = rs.getString(columnName);

if (null != sqlJson) {

return JSONObject.parseObject(sqlJson);

}

return null;

}

/**

* 根據列索引，獲取可以為空的結果

*

* @author: xiaowei.go

* @date: 2019年11月20日

* @see org.apache.ibatis.type.BaseTypeHandler#getNullableResult(java.sql.ResultSet, int)

*/

@Override

public JSONObject getNullableResult(ResultSet rs, int columnIndex) throws SQLException {

String sqlJson = rs.getString(columnIndex);

if (null != sqlJson) {

return JSONObject.parseObject(sqlJson);

}

return null;

}

/**

* 根據列索引，獲取可以為空的結果

*

* @author: xiaowei.go

* @date: 2019年11月20日

* @see org.apache.ibatis.type.BaseTypeHandler#getNullableResult(java.sql.CallableStatement, int)

*/

@Override

public JSONObject getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {

String sqlJson = cs.getString(columnIndex);

if (null != sqlJson) {

return JSONObject.parseObject(sqlJson);

}

return null;

}

}

實體類

代碼段

import com.alibaba.fastjson.JSONObject;

@Data

@EqualsAndHashCode(callSuper = false)

@Accessors(chain = true)

public class BizExportJob implements Serializable {

private JSONObject dataRule;

}

map.xml配置

insert into table (data_rule) values (#{dataRule,jdbcType=OTHER,typeHandler=com.magicpose.handler.MySqlJsonHandler})

注冊Handler

2種方式

在application.yml聲明handler包

mybatis:

config-location: classpath:mybatis-config.xml

mapperLocations: classpath:mappers/*.xml

#配置mybaits自定義類型轉換類所在的包

type-handlers-package: com.magicpose.handler

在mybatis-config.xml中注冊該Handler

附：優化版

既然自定義handler處理字段值，當然可以直接轉化為java bean.

// 注冊器如下定義，其他方法參考返回為JSONObject類型的，轉化為Class

public class MySqlJsonHandler extends BaseTypeHandler{

private Class clazz;

}

使用mybatis-config.xml中注冊該Handler,增加 javaType屬性，指定該處理器轉換的java bean

記得實體類的屬性類型修改為對應的java bean

總結

以上是生活随笔為你收集整理的spring mysql json_SpringBoot+MYSQL 配置支持json数据格式的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。